使用Mongo聚合计算值之和

Question

我有发票，每张发票都包含一个项目列表。每个项目都有（除其他外）以下字段：

• 姓名
• 数量
• 总计

每张发票都有（除其他外）字段：

• _id
• 创建
• 项目

发票存在于专门的Mongo集合中，称为发票。

我想获取包含指定项目的所有发票，其中每个发票都需要返回以下信息：

• _id

让我们称之为元组

如果发票列出给定项目两次，则相应的发票将生成两个投影实例。如果发票根本没有列出给定的项目，则结果中不存在此发票。

无论如何，我正在使用以下Mongo聚合管道检索所需的投影：

  pipeline = [
    {$match: {'items.name': req.params.name}},
    {$project: {created: 1, 'items.name': 1, 'items.qty': 1, 'items.total': 1}},
    {$unwind: '$items'},
    {$match: {'items.name': req.params.name}},
    {$project: {created: 1, qty: '$items.qty', total: '$items.total'}}
  ],

管道的工作原理如下：

1. 首先匹配具有给定名称的项目的所有发票。在<代码>项上有一个Mongo索引。名称，所以这个$匹配是有效的
2. 发票是一个大对象，因此请去掉所有字段，只留下以下结构：{code>{u id：？，created：？，items:[{name：？，qty：？，total：？}。。。，{名称：？，数量：？，总数：？}]}
3. 展开items数组，现在我们有了一个{id：？，创建：？，'items.name'：？，'items.qty'：？，'items.total'：？} 对象
4. 删除与给定名称不匹配的所有项目
5. 塑造最终发票投影

然后通过以下代码执行发票预测的最终列表：

function prepareResult(projections) {
  var res = projections.reduce(function (acc, item) {
    acc.itemCount += item.qty;
    acc.total += item.total;
    delete item.total;
    return acc;
  }, {itemCount: 0, total: 0});
  res.items = projections;
  return res;
}

它对所有发票预测中的“数量”和“总计”字段求和，并返回一个包含预测和计算总数的新对象。从每个发票预测中删除“总计”字段，因为它只是需要的最终金额。

我的问题-我可以将prepareResult函数的逻辑移到Mongo聚合管道中吗？




Answer 1

您需要向管道中添加$组步骤。

组的\u id将是求和的依据（在本例中是一个常量，因为您需要一个总计）。由于要保留发票列表，可以通过$push操作符将其累积到数组字段中。总数和数量的总和将用$sum处理。

{$group : { _id : 1,
            Total : { $sum : "$total" },
            ItemCount : { $sum : "$qty" },
            Invoices : { $push : { id : "$_id", created : "$created" }}
} }