如何使用 Mongodb 聚合框架填充数据？

Question

我有一个来自 previous question 的当前 MongoDB Aggregate 框架管道，但我无法添加填充查询以按 id 获取用户配置文件。

我的代码在下面

Product.aggregate([
      {
        $group: {
          _id: {
            hub: "$hub",
            status: "$productStatus",
          },
          count: { $sum: 1 },
        },
      },
      {
        $group: {
          _id: "$_id.hub",
          counts: {
            $push: {
              k: "$_id.status",
              v: "$count",
            },
          },
        },
      },
      {
        $group: {
          _id: null,
          counts: {
            $push: {
              k: { $toString: "$_id" },
              v: "$counts",
            },
          },
        },
      },

      {
        $addFields: {
          counts: {
            $map: {
              input: "$counts",
              in: {
                $mergeObjects: [
                  "$$this",
                  { v: { $arrayToObject: "$$this.v" } },
                ],
              },
            },
          },
        },
      },
      {
        $replaceRoot: {
          newRoot: { $arrayToObject: "$counts" },
        },
      },
    ]);

得到如下结果

[
  {
    "5fe75679e6f7a62ddaf5b2e9": {
      "in progress": 5,
      "Cancelled": 4,
      "return": 1,
      "on the way": 3,
      "pending": 13,
      "Delivered": 4
    }
  }
]

预期输出

我需要使用 hubId "5fe75679e6f7a62ddaf5b2e9" 从用户集合中获取用户信息，并期望得到下面表格的最终结果

[
    {
        "hub": {
            "photo": "avatar.jpg",
            "_id": "5fe75679e6f7a62ddaf5b2e9",
            "name": "Dhaka Branch",
            "phone": "34534543"
        },
        "statusCounts": {
            "in progress": 5,
            "Cancelled": 4,
            "return": 1,
            "on the way": 3,
            "pending": 13,
            "Delivered": 4
        }
    }
]

第一个 id 是用户 id，在用户集合中可用。

Answer 1

您需要稍微调整一下您的聚合管道，并包括新的管道阶段，如填充 枢纽

Product.aggregate([
    {  "$group": {
            "_id": {
                "hubId": "$hubId",
                "status": "$productStatus"
            },
            "count": { "$sum": 1 }
    } },
    { "$group": {
        "_id": "$_id.hubId",
        "statusCounts": {
            "$push": {
                "k": "$_id.status",
                "v": "$count"
            }
        }
    } },
    { "$lookup": {
        "fron": "users",
        "localField": "_id",
        "foreignField": "_id",
        "as": "user"
    } },
    { "$project": {
        "user": { "$arrayElemAt": ["$user", 0] },
        // "hub": { "$first": "$hub" },
        "statusCounts": { "$arrayToObject": "$statusCounts" }      
    } }
])

---

要仅投影用户配置文件中的某些字段，您可以更新您的 $lookup 管道以具有表单

{ "$lookup": {
    "from": "users",
    "let": { "userId": "$_id" },
    "pipeline": [
        { "$match": {
            "$expr": { "$eq": ["$_id", "$$userId"] }
        } },
        { "$project": { 
            "name": 1,
            "phone": 1, 
            "photo": 1 
        } }
    ],
    "as": "user"
} }