我必须做一个特殊的 mongoDB 查询。

我有一个包含这些文档的集合:

{
    "_id" : ObjectId("53c7fd86d624b06abc76e8f6"),
    "works" : [ 
        {
            "code" : "A001",
            "name" : "Cambiar bombilla",
            "orderId" : "53c7fd86d624b06abc76e8f6",
            "price" : 1400,
            "ID" : 1,
            "lazyLoaded" : true,
            "status" : 0,
            "Date" : ISODate("2014-07-21T10:31:55.063Z"),
            "TechnicianId" : "538efd918163b19307c59e8e",
            "_id" : ObjectId("53ccec1bf2bf4d5952b2f205")
        }, 
        {
            "code" : "A005",
            "name" : "Cambiar bombilla 5",
            "price" : 1050,
            "type" : "Bombillas",
            "TechnicianId" : "5383577a994be8b9a9e3f01e",
            "_id" : ObjectId("53ccfdbdf2bf4d5952b2f206")
        }, 
        {
            "code" : "A004",
            "name" : "Cambiar bombilla 4",
            "price" : 1010,
            "type" : "Bombillas",
            "TechnicianId" : "5383577a994be8b9a9e3f01e",
            "date" : "2014-07-21T11:50:52.702Z",
            "orderId" : "53c7fd86d624b06abc76e8f6",
            "_id" : ObjectId("53ccfe9c109c100000ad688a")
        }, 
        {
            "code" : "A002",
            "name" : "Cambiar bombilla 2",
            "price" : 1030,
            "type" : "Bombillas",
            "TechnicianId" : "5383577a994be8b9a9e3f01e",
            "date" : "2014-07-21T11:57:37.065Z",
            "orderId" : "53c7fd86d624b06abc76e8f6",
            "_id" : ObjectId("53cd0036109c100000ad688b")
        }, 
        {
            "code" : "A003",
            "name" : "Cambiar bombilla 3",
            "price" : 1050,
            "type" : "Bombillas",
            "TechnicianId" : "5383577a994be8b9a9e3f01e",
            "date" : "2014-07-21T11:59:35.586Z",
            "orderId" : "53c7fd86d624b06abc76e8f6",
            "_id" : ObjectId("53cd00a7109c100000ad688c")
        }
    ],
    "Items" : [ 
        {
            "_id" : "534ba71f394835a7e51dd938",
            "total":50
            "qty" : 2
        }, 
        {
            "_id" : "534664b081362062015d1b77",
            "qty" : 2,
            "total":30
        }
    ]}

现在，我想查询 TechnicianId=5383577a994be8b9a9e3f01e 的作品，这些作品的“价格”之和减去项目之和。总计，这些文件的总作品数量减去总和项目总数。

对于这个例子，我想要这样的东西:

{
    "result" : [ 
        {
            "_id" : ObjectId("53c7fd86d624b06abc76e8f6"),
            "works.totalsumfortech" : 1050+1010+1030+1050 - (50+30),//Sum of works of this technicianId deducting the items.total qty
            "works.total":1400+1050+1010+1030+1050-(50+30)//Summ of all works of document deducting the items.total qty
        }
    ],
    "ok" : 1
}

这是我当前的查询，但我没有得到预期的结果..

db.orders.aggregate([
        { "$match": {
            "$and": [
                {"OrderState": {$in:['Review','Archived']}},
                {'works.TechnicianId':'5383577a994be8b9a9e3f01e'}
            ]
        }},
        {$group: {
         _id: "$_id",
         'total': {$subtract:[{$sum: { $cond: [ { $eq: [ "$works.TechnicianId", "5383577a994be8b9a9e3f01e" ] } , 2, 1 ]},{$sum: '$Items.total'}]
         'total': {$subtract:[{$sum: '$works.price'},{$sum: '$Items.total'}]
         }
         }]);

最佳答案

现代

对于现代版本的 MongoDB，这实际上要容易得多。在特定情况下，没有跨文档的实际“聚合”，尽管返回的数据和要应用的“文档内聚合”显着减少。

现代对此的看法允许从数组中的数据中进行这种 reshape 和选择，而无需诉诸 $unwind和 $group为了处理:

db.getCollection('orders').aggregate([
  { "$match": {
    //"OrderState": { "$in":["Review","Archived"]},
    "works.TechnicianId":"5383577a994be8b9a9e3f01e"
  }},
  { "$project": {
    "works": {
      "$let": {
        "vars": {
          "techTotal": {
            "$sum": {
              "$map": {
                "input": { 
                  "$filter": {
                    "input": "$works",
                    "cond": {
                      "$eq": [
                        "$$this.TechnicianId",
                        "5383577a994be8b9a9e3f01e"
                      ]
                    }
                  }
                },
                "in": "$$this.price"
              }    
            }
          },
          "items_total": { "$sum": "$Items.total" },
          "worksTotal": { "$sum": "$works.price" }
        },
        "in": {
          "totalSumForTech": {
            "$subtract": [ "$$techTotal", "$$items_total" ]
          },
          "total": {
            "$subtract": [ "$$worksTotal", "$$items_total" ]
          }
        }
      }
    }
  }}
])

自最初询问以来的变化是 $sum在 $project 中使用时接受“数组”作为输入或类似的舞台环境，除了作为蓄能器的传统角色。因此，与其“展开”数组，不如执行 { "$sum": "$Items.total"} 之类的操作，它通过内部符号从指定属性重新调整值数组，然后通过 $sum “减少”这些值.这本身就是一个很大的改进。

其他改进是 $map和 $filter .应用后者是为了仅将数组的匹配条目返回到给定条件，而对于前者，则允许“ reshape ”数组内容。两者都是其他编程语言中处理数组的常用方法，在这里功能基本相同。

这意味着您可以根据需要从 "works" 数组中提取与技术人员匹配的 "price" 值，然后使用 $sum 合计这些值以与前面所述相同的方式作为“值数组”。

另外一个是$let ，它允许使用“变量”声明 block 以供在该 block 内使用。在这种情况下，我们可以从数组中计算出这些“总数”，然后应用 $subtract计算值以得出最终结果。

与早期版本相比的优势在于您可以在不分离聚合管道阶段的情况下执行此操作。当然，这里可以使用 $$items_total 来代替重复完整的语句来计算。此外，计算的一般分离使最终输出 block 更容易阅读。所以它实际上只是“使用变量”，就像您在常规编程中所做的一样。

这里的最大收获是这变得简单 $match和 $project ，而不是为了从每个文档获得最终计算结果的整个流水线阶段链。

原创

如前所述，您需要使用$unwind在 MongoDB 聚合中使用数组时。除非您这样做，否则聚合操作不适用于每个数组元素。

这里的其他问题是在 $group 内流水线阶段的所有“顶层”操作都需要 group aggregation operators .不像$subtract的东西不允许，因此您需要在 $sum 之类的范围内执行这些操作在可能的情况下或在另一个管道阶段:

db.orders.aggregate([

    // Match documents "and" is implied in MongoDB. Not required unless
    // against the same field
    { "$match": {
        "OrderState": { "$in":["Review","Archived"]},
        "works.TechnicianId":"5383577a994be8b9a9e3f01e"
    }},

    // Unwind Items first
    { "$unwind": "$Items" },

    // Group to get that total
    { "$group": {
        "_id": "$_id",
        "works": { "$first": "$works" },
        "items_total": { "$sum": "$Items.total" }
    }},

    // Unwind works to "de-normalize"
    { "$unwind": "$works" },

    // Group conditionally on "TechnicianId" and the full total
    { "$group": {
        "_id": "$_id",
        "techTotal": {
            "$sum": {
                "$cond": [ 
                    { "$eq": [ 
                        "$works.TechnicianId", 
                        "5383577a994be8b9a9e3f01e"
                    ]},
                    "$works.price",
                    0 
                ]
            }
        },
        "worksTotal": { "$sum": "$works.price" },
        "items_total": { "$first": "$items_total" }
    }},

    // Project to do math and other re-shaping
    { "$project": {
        "works": {
            "totalSumForTech": {
                "$subtract": [ "$techTotal", "$items_total" ]
            },
            "total": {
                "$subtract": [ "$worksTotal", "$items_total" ]
            }
        }
    }}
])

在示例文档中(虽然我需要删除 $match 因为该数据不存在于您的示例中)结果是:

{
    "_id" : ObjectId("53c7fd86d624b06abc76e8f6"),
    "works" : {
            "totalSumForTech" : 4060,
            "total" : 5460
    }
}

关于具有条件总和的 MongoDB 聚合，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24907631/