MongoDB中结合$toInt、$group、$match、$sort、$limit实现分组Top3的方法

• 聚合顺序完全颠倒：刚进入管道就执行按Recipient的分组聚合，直接对全量记录的Credit、Debit做跨记录求和，跳过了「单条记录字段类型转换、计算单条交易净额、单条粒度数据筛选」的前置步骤，最终算出来的NetAmount是单个收件人所有交易的总净额，和需要的单条交易净额逻辑完全不符
• 分组字段缺失：$group阶段的_id仅包含Recipient字段，没有保留单条交易的Sender信息，后续$project阶段读取的$_id.Sender是不存在的字段，无法正确取到寄件人信息
• 取数范围不符合要求：最后使用全局$limit:3，是对全量排序后的结果统一截取前3条，没有实现「每个Recipient分组内单独对组内记录排名、截取前3名」的逻辑
• 计算逻辑错位：将跨记录的聚合求和结果当成单条交易的净额，没有利用Debit字段本身存储负值的特点，直接匹配单条记录的数值关系

db.collection.aggregate([
  // 阶段1：字符串转整数，计算单条交易净额
  {
    $addFields: {
      NetAmount: {
        $add: [
          { $toInt: "$Credit" },
          { $toInt: "$Debit" }
        ]
      }
    }
  },
  // 阶段2：筛选净额为正的非零记录
  {
    $match: {
      NetAmount: { $gt: 0 }
    }
  },
  // 阶段3：按Recipient分组，收集组内所有有效交易
  {
    $group: {
      _id: "$Recipient",
      transactionList: {
        $push: {
          Sender: "$Sender",
          Recipient: "$Recipient",
          NetAmount: "$NetAmount"
        }
      }
    }
  },
  // 阶段4：组内按净额降序排序，截取每组前3条
  {
    $addFields: {
      topTransactions: {
        $slice: [
          {
            $sortArray: {
              input: "$transactionList",
              sortBy: { NetAmount: -1 }
            }
          },
          3
        ]
      }
    }
  },
  // 阶段5：拆解嵌套数组为平铺文档
  {
    $unwind: "$topTransactions"
  },
  // 阶段6：替换根节点，输出目标字段结构
  {
    $replaceRoot: {
      newRoot: "$topTransactions"
    }
  }
])

注：若使用的MongoDB版本低于5.2，不支持$sortArray语法，可将组内排序环节调整为先对分组收集的交易列表做$unwind拆解，按NetAmount降序排序后，再按Recipient重新分组收集列表、截取前3条即可，核心业务逻辑保持不变

结果验证 #

用提供的样例数据执行后，输出结果和预期完全匹配：

• 给Mike的交易里，净额排名前3的是Arun(16)、Ajay(14)、Alis(5)，Arvind的净额仅4，排在第4被排除
• 给Abi的交易里，净额排名前3的是Ajay(11)、Alis(6)、Arun(6)，Arvind的净额为-4，在筛选阶段被排除
• 给Anu的交易里，仅Arvind(31)、Ajay(11)的净额为正，其余两条净额为负被筛除，不足3条就按实际有效数量输出
• 给Mary的所有交易净额均为负，在筛选阶段被全部排除，不进入最终结果

内容的提问来源于stack exchange，提问作者Balaji