MongoDB如何按hubId分组统计各产品状态数量并关联Hub信息

你现有聚合语句的核心问题 #

• 单维度按hubId分组时，$sum:1只会统计该hub下所有产品的总数量，无法拆分不同产品状态的计数
• $addToSet收集产品状态的操作只会去重存入状态值本身，不会携带任何计数信息，完全达不到分状态统计的目标

正确的聚合管道实现步骤 #

按照需求，需要3个核心阶段完成统计，再叠加关联Hub信息的逻辑，完整代码如下：

// 引入关联的Hub集合名称，匹配Mongoose模型的实际集合
const HubCollection = mongoose.model('Hub').collection.name;

const productStats = await Product.aggregate([
  // 1. 双维度分组：先按hubId + ProductStatus 拆分所有组合，拿到每个组合的准确计数
  {
    $group: {
      _id: {
        hubId: "$hubId",
        status: "$ProductStatus"
      },
      count: { $sum: 1 }
    }
  },
  // 2. 二次归组：把同个hub下的所有状态计数整理为可转换的键值对数组
  {
    $group: {
      _id: "$_id.hubId",
      statusList: {
        $push: {
          k: "$_id.status",
          v: "$count"
        }
      },
      hubId: { $first: "$_id.hubId" }
    }
  },
  // 3. 将状态数组转换为目标格式的状态统计对象
  {
    $set: {
      statusStats: { $arrayToObject: "$statusList" }
    }
  },
  // 4. 关联Hub集合，实现populate等价的关联信息查询
  {
    $lookup: {
      from: HubCollection,
      localField: "hubId",
      foreignField: "_id",
      as: "hubInfo"
    }
  },
  // 5. 解包关联结果（单hub关联只会匹配1条Hub记录，无需保留数组结构）
  {
    $set: {
      hubInfo: { $arrayElemAt: ["$hubInfo", 0] }
    }
  },
  // 6. 转换为目标格式：最外层以hubId字符串为键，值为对应统计+关联信息
  {
    $group: {
      _id: null,
      resultMap: {
        $push: {
          k: { $toString: "$hubId" },
          v: {
            ..."$statusStats",
            hubInfo: "$hubInfo"
          }
        }
      }
    }
  },
  {
    $replaceRoot: {
      newRoot: { $arrayToObject: "$resultMap" }
    }
  }
]);

关键注意点 #

• 聚合管道内无法直接使用Mongoose的populate方法，必须通过$lookup阶段实现跨集合关联，效果和populate完全等价
• 代码中的字段名请和你实际Product集合的字段做匹配：题目里关联Hub的字段是hubId，如果你实际代码中关联字段叫hub，对应替换所有引用$hubId的位置即可
• hubId是ObjectId类型，作为JSON对象的键时需要先通过$toString转为字符串，否则序列化结果不符合示例中纯字符串键的格式
• 按照你给出的示例数据运行，结果会完全匹配目标格式：比如mlm节点会自动统计出2条Delivered、1条On the Way的计数，xyz节点统计为1条Delivered、1条On the Way，和预期一致

内容的提问来源于stack exchange，提问作者Md Rezaul Karim