MongoDB聚合在Mongoplayground正常，Compass与Mongoose中soldTotal为0

问题描述 #

构建统计产品库存总量及累计销量的聚合管道时，出现以下异常：

• 在MongoPlayground中可正常计算totalInStock（库存总量）和soldTotal（总销量）；
• 在MongoDB Compass和Node.js Mongoose后端中，soldTotal始终返回0；
• 将最后一个$project阶段条件中的$_id替换为固定产品ID时，Compass和后端能正常统计，但无法动态获取分组后的产品ID；
• 使用的MongoDB版本：MongoPlayground为6.0.13，本地实例为6.0.14，版本差异无影响。

原因分析 #

问题源于嵌套$reduce的作用域冲突：内层$reduce遍历products数组时，$$this指向当前数组元素，此时对外层文档$_id的引用会丢失上下文，导致$eq条件始终不成立，最终累加结果为0。MongoPlayground的作用域解析逻辑可能存在特殊性，但本地实例和Mongoose遵循严格的聚合作用域规则。

解决方案 #

在进入嵌套$reduce前，通过$let将外层的产品ID（$_id）保存为独立变量，确保内层可以正确引用该变量进行条件判断。

修改后的聚合管道代码 #

[
    {
        "$group": {
            "_id": {
                "productItem": "$productItem._id"
            },
            "stock": { "$push": "$$ROOT" }
        }
    },
    {
        "$project": {
            "_id": "$_id.productItem",
            "stock": "$stock",
            "orders": [], // 订单数据保持原结构
            "total": {
                "$reduce": {
                    "input": "$stock",
                    "initialValue": 0,
                    "in": { "$add": ["$$value", "$$this.amount"] }
                }
            }
        }
    },
    {
        "$project": {
            "_id": "$_id",
            "stock": "$stock",
            "totalInStock": "$total",
            "soldTotal": {
                "$let": {
                    "vars": { "currentProductId": "$_id" },
                    "in": {
                        "$reduce": {
                            "input": "$orders",
                            "initialValue": 0,
                            "in": {
                                "$add": [
                                    "$$value",
                                    {
                                        "$reduce": {
                                            "input": "$$this.products",
                                            "initialValue": 0,
                                            "in": {
                                                "$add": [
                                                    "$$value",
                                                    {
                                                        "$cond": [
                                                            { "$eq": ["$$this.productItem", "$$currentProductId"] },
                                                            "$$this.amount",
                                                            0
                                                        ]
                                                    }
                                                ]
                                            }
                                        }
                                    }
                                ]
                            }
                        }
                    }
                }
            }
        }
    }
]

代码说明 #

通过$let定义currentProductId变量存储当前分组的产品ID，在内层$reduce中使用$$currentProductId进行匹配，避免了内层$$this对文档上下文的覆盖，确保$eq条件能正确匹配目标产品，从而准确累加该产品的总销量。

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