This commit is contained in:
Florian Baumann 2022-01-03 14:28:15 +01:00
parent 5984e522da
commit f3dbebd6e2
2 changed files with 6 additions and 4 deletions

View File

@ -34,6 +34,10 @@ Update card Price
{$set:{'serra_updated':ISODate("2021-11-02T09:28:56.504Z")}, {$set:{'serra_updated':ISODate("2021-11-02T09:28:56.504Z")},
$push: {"serra_prices": { date: ISODate("2021-11-02T09:28:56.504Z"), value: 0.1 }}}); $push: {"serra_prices": { date: ISODate("2021-11-02T09:28:56.504Z"), value: 0.1 }}});
Set value
db.cards.aggregate([{ $group: { _id: { set: "$set" }, value: { $sum: { $multiply: ["$prices.eur", "$serra_count"] } }, count: { $sum: 1 } } }])
# MongoDB Operations # MongoDB Operations

View File

@ -75,15 +75,13 @@ func Sets() {
groupStage := bson.D{ groupStage := bson.D{
{"$group", bson.D{ {"$group", bson.D{
{"_id", "$setname"}, {"_id", "$setname"},
{"sum", bson.D{ {"value", bson.D{{"$sum", bson.D{{"$multiply", bson.A{"$prices.eur", "$serra_count"}}}}}},
{"$sum", "$prices.eur"},
}},
}}, }},
} }
sets, _ := coll.storage_aggregate(groupStage) sets, _ := coll.storage_aggregate(groupStage)
for _, set := range sets { for _, set := range sets {
fmt.Printf("* %s (%.2f Eur)\n", set["_id"], set["sum"]) fmt.Printf("* %s (%.2f Eur)\n", set["_id"], set["value"])
} }
storage_disconnect(client) storage_disconnect(client)