Java Mongo DB聚合管道-$sum在使用$unwind时不起作用？

Question

我目前正在我的一个Java脚本中开发mongoDB聚合管道。

输入数据可以简化为不同客户的订单列表。例如：

_id、customerId和orderId是字符串，金额是一个Long类型的数字，装运是名为shipping的自定义类的实体。现在，我想汇总这些数据，并显示每个customerId的总花费和所有发货量。对于第一位客户：

{CusterId：123，发货：[发货1，发货2，发货4]，金额：50.00}

json格式的数据

[
 {
   "_id": 1,
   "customerId": 123,
   "orderId": "a12b4",
   "shipments": ["shipment1","shipment2"],
   "amount": 30
 },
 {
   "_id": 2,
   "customerId": 456,
   "orderId": "a14hf",
   "shipments": ["shipment3"],
   "amount": 40
 },
 {
   "_id": 3,
   "customerId": 123,
   "orderId": "a27jd",
   "shipments": ["shipment4"],
   "amount": 20
 }
]

所以，我这样做了：

Aggregates.unwind("$shipments"),
Aggregates.group("$customerId",
     Accumulators.sum("amount","$amount"),
     Accumulators.addToSet("shipments", "$shipments")),
Aggregates.out("test_output")

这就是我的问题所在：放松和求和的用法是排他性的吗？

只要我保留unwind语句，sum函数就不会返回正确的结果。但只要我用另一个我不需要解开的字段替换发货，它就可以正常工作。

任何提示都将不胜感激。

Answer 1

查询

• 展开将创建许多重复项，但您不需要它

普雷蒙戈

aggregate(
[{"$group": 
   {"_id": "$customerId",
    "shipments": {"$push": "$shipments"},
    "total-amound": {"$sum": "$amount"}}},
 {"$set": 
   {"shipments": 
     {"$setUnion": 
       [{"$reduce": 
           {"input": "$shipments",
            "initialValue": [],
            "in": {"$concatArrays": ["$$value", "$$this"]}}}, []]}}}])