Mongodb计算查询--累加乘法

我最近开始在 Mongodb 中从事 POC 工作。我下面有一个 json 集合

db.ccpsample.insertMany([
  {
    "ccp_id":1,
    "period":601,
    "sales":100.00
  },
  {
    "ccp_id":1,
    "period":602,
    "growth":2.0,
    "sales":"NULL"    ##sales=100.00*(1+(2.0/100)) -- 100.00 comes from(ccp_id:1 and period=601) 
  },
  {
    "ccp_id":1,
    "period":603,
    "growth":3.0,
    "sales":"NULL"   ##sales=100.00*(1+(2.0/100))**(1+(3.0/100))-- 100.00 comes from(ccp_id:1 and period=601) 2.0 comes from (ccp_id:2 and period=602)  
  },
  {
    "ccp_id":2,
    "period":601,
    "sales":200.00
  },
  {
    "ccp_id":2,
    "period":602,
    "growth":2.0,
    "sales":"NULL"   ##sales=200.00*(1+(2.0/100))
  },
  {
    "ccp_id":2,
    "period":603,
    "growth":3.0,
    "sales":"NULL"   ##same like above
  }
])

我需要使用上面的文档来计算具有 NULL 的销售字段，ccp_id 的匹配条件应该相同，期间字段应该等于 601。我添加了一行来演示上面集合本身中销售字段的计算。我尝试使用 $graphlookup 但没有运气。你们能帮忙或建议一些方法吗？

您可以使用以下聚合：

db.ccpsample.aggregate([
  { $sort: { ccp_id: 1, period: 1 } },
  { 
    $group: {
      _id: "$ccp_id",
      items: { $push: "$$ROOT" },
      baseSale: { $first: "$sales" },
      growths: { $push: "$growth" }
    }
  },
  {
    $unwind: {
      path: "$items",
      includeArrayIndex: "index"
    }
  },
  {
    $project: {
      cpp_id: "$items.cpp_id",
      period: "$items.period",
      growth: "$items.growth",
      sales: {
        $cond: {
          if: { $ne: [ "$items.sales", "NULL" ] },
          then: "$items.sales",
          else: {
            $reduce: {
              input: { $slice: [ "$growths", "$index" ] },
              initialValue: "$baseSale",
              in: { $multiply: [ "$$value", { $add: [1, { $divide: [ "$$this", 100 ] }] } ] }
            }
          }
        }
      }
    }
  }
])

基本上是为了计算值n-th您必须了解以下内容：

• 第一个元素的销售价值 ($first in $group)
• 全部的数组growths ($push in $group)
• the n这表明你必须执行多少次乘法

要计算该指数，您应该$push将所有元素放入一个数组中，然后使用$unwind https://docs.mongodb.com/manual/reference/operator/aggregation/unwind/index.html with includeArrayIndex选项将展开数组的索引插入到字段中index.

最后一步计算累积乘法。它用$slice https://docs.mongodb.com/manual/reference/operator/aggregation/slice/index.html with index字段来评估多少growths应进行处理。所以会有一个元素601, 两个元素602等等。

那么是时候了$reduce https://docs.mongodb.com/manual/reference/operator/aggregation/reduce/index.html处理该数组并根据您的公式执行乘法：（1 + (growth/100))