node.js - 用于算术运算的MongoDB聚合-子文档字段

我们有一个汇总查询，投影了很少的子文档。我们想对这些预计值应用一些算术运算，例如Sum和Product。

汇总查询-

Item.aggregate([
        { $unwind: '$dummy'},
        { $match: {'dummy.storage': {$gt: 0}} },
        { $group: {_id: '$_id',
                    dummy: {$push: '$dummy'},
                    original_y: { $first: "$original_y" },
                    new_y: { $first: "$new_y" },

        }},
        {$project:{
                  original_y: 1, new_y: 1,
                  tallyAmount: {$sum: ["$new_y","$original_y"] }
                }
        },
     ]
    )
    .exec(function(err, results){
        if(err)
        {
            console.log("Error : " + err);
            return res.json ({error: "Error"});

        }
        else if(!(results) || results == null || results.length == 0)
        {
            console.log("No Results Found");
            return res.json ({error: "No Results Today"});

        }else{

            res.send(results);
        }
    });

这给出了一个错误说明invalid operator '$sum'
我们应该怎么做才能在original_y中获得new_y和$project的总和？

编辑

文件:

{
 id:1,
 original_y: 200,
 new_y: 140,
 dummy: [
  {id:1, storage:2, cost: 10},
  {id:2, storage:0, cost: 20},
  {id:3, storage:5, cost: 30},
  ]
}

预期输出:

 {
     id:1,
     original_y: 200,
     new_y: 140,
     dummy: [
      {id:1, storage:2, cost: 10, tallyAmount: 34},
      {id:3, storage:5, cost: 30, tallyAmount: 11.33},
      ]
    }

在哪里，
tallyAmount = (original_y + new_y) / cost
错误:无法为虚拟子字段添加表达式，因为已经有一个表达式适用于整个字段

最佳答案

如果没有太多文档架构细节和预期的聚合结果，我建议您尝试以下聚合，因为我认为您需要 $add 运算符而不是 $sum 运算符。请注意， $sum 运算符仅适用于 $group 运算符。使用 $add 运算符，它将两个数字/字段加在一起，结果通过 $project 运算符存储在新字段中:

Item.aggregate([
    { "$match": { "dummy.storage": { "$gt": 0 } } },
    { "$unwind": "$dummy" },
    { "$group": {
        "_id": "$_id",
        "original_y": { "$first": "$original_y" },
        "new_y": { "$first": "$new_y" }
    } },
    { "$project": {
        "original_y": 1,
        "new_y": 1,
        "tallyAmount": { "$add": [ "$new_y", "$original_y" ] }
    } }
]).exec(callback);

-更新-

为了满足tallyAmount = (original_y + new_y) / cost条件，您应该在$ project运算符管道阶段使用 $add 和 $divide 算术运算符，这样最终的聚合管道将如下所示:

Item.aggregate([
    { "$match": { "dummy.storage": { "$gt": 0 } } },
    { "$unwind": "$dummy" },
    {
        "$project": {
            "original_y": 1,
            "new_y": 1,
            "dummy.id": "$dummy.id",
            "dummy.storage": "$dummy.storage",
            "dummy.cost": "$dummy.cost",
            "dummy.tallyAmount": {
                "$divide": [
                    { "$add": ["$new_y","$original_y"] },
                    "$dummy.cost"
                ]
            }
        }
    },
    {
        "$group": {
            "_id": "_$id",
            "original_y": { "$first": "$original_y" },
            "new_y": { "$first": "$new_y" },
            "dummy": {
                "$addToSet": "$dummy"
            }
        }
    }
 ]).exec(callback);