Możesz użyć poniższej agregacji:
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 ] }] } ] }
}
}
}
}
}
}
])
Zasadniczo, aby obliczyć wartość dla n-th
element musisz wiedzieć następujące rzeczy:
- wartość sprzedaży pierwszego elementu (
$first
w$group
) - tablica wszystkich
growths
($push
w$group
) n
co wskazuje, ile mnożeń musisz wykonać
Aby obliczyć indeks należy $push
wszystkie elementy w jedną tablicę, a następnie użyj $unwind
z includeArrayIndex
opcja, która wstawi indeks rozwiniętej tablicy do pola index
.
Ostatni krok oblicza skumulowane mnożenie. Używa $slice
z index
pole do oceny ile growths
powinny zostać przetworzone. Więc będzie jeden element dla 601
, dwa elementy dla 602
i tak dalej.
Następnie nadszedł czas na $reduce
aby przetworzyć tę tablicę i wykonać mnożenia w oparciu o twoją formułę:(1 + (growth/100)
)