MongoDB聚合中如何在$lookup管道内使用$group实现关联文档分组

原自定义pipeline返回空的核心原因 #

1. 直接传入let的$package.groupid是字符串数组结构，若使用普通等值匹配{ groupid: "$$group_id" }，本质是拿关联集合中单个文档的字符串类型groupid和整个数组做严格相等比对，永远无法命中结果
2. $lookup管道内引用$$开头的外部自定义变量时，必须通过$expr表达式引擎执行匹配，普通的字段等值匹配语法无法识别外部传入的自定义变量

修正后的完整聚合代码 #

db.collection('products').aggregate([
    // 匹配目标主产品组
    { $match: { groupid: groupid } },
    // 按主产品groupid聚合，汇总同组下所有尺寸的属性数据
    { $group: {
        _id: "$groupid",
        groupid: { $last: "$groupid" },
        description: { $last: "$description" },
        sizepricesdiscountqty: { 
            $push: { 
                size: "$size", 
                price: "$barcode", 
                discount: "$discount", 
                qty: "$qty", 
                barcode: "$itemcode" 
            } 
        },
        package: { $last: "$package" }
    } },
    // 自定义pipeline实现嵌套关联 + 关联数据内部分组
    { $lookup: {
        from: "products",
        // 传入主文档package下所有的groupid值数组
        let: { refGroupIds: "$package.groupid" },
        pipeline: [
            // 使用表达式匹配：当前关联文档的groupid是否在传入的groupid数组范围内
            { $match: {
                $expr: {
                    $in: [ "$groupid", "$$refGroupIds" ]
                }
            } },
            // 复用外层分组逻辑，按关联产品自身的groupid聚合同组下所有尺寸数据
            { $group: {
                _id: "$groupid",
                groupid: { $last: "$groupid" },
                description: { $last: "$description" },
                sizepricesdiscountqty: { 
                    $push: { 
                        size: "$size", 
                        price: "$barcode", 
                        discount: "$discount", 
                        qty: "$qty", 
                        barcode: "$itemcode" 
                    } 
                }
            } }
        ],
        as: "packageProds"
    } },
    // 可选步骤：让packageProds的顺序与原package数组顺序完全对齐
    { $addFields: {
        packageProds: {
            $map: {
                input: "$package",
                as: "pkgItem",
                in: {
                    $mergeObjects: [
                        "$$pkgItem",
                        { $arrayElemAt: [
                            "$packageProds",
                            { $indexOfArray: ["$packageProds.groupid", "$$pkgItem.groupid"] }
                        ]}
                    ]
                }
            }
        }
    }}
]).toArray()

关键实现说明 #

• 匹配逻辑修正：使用$in配合$expr，让关联集合的文档可以和外部传入的groupid数组做包含判断，解决普通匹配无法引用外部变量的问题
• 管道内分组复用：完全照搬外层的$group逻辑，把同groupid下的所有尺寸、价格、条码等属性汇总到sizepricesdiscountqty数组，保证结构和主产品的聚合逻辑一致
• 顺序对齐处理：$lookup默认返回的关联结果顺序为集合自然排序，通过最后一步的$map+$indexOfArray逻辑，可以让返回的packageProds顺序和原package数组的定义顺序完全对齐，匹配预期的输出结构

内容的提问来源于stack exchange，提问作者Lukas Luke Stateczny