MongoDb $addFields inside arrays $multiply 数组中的两个值

Question

MongoDb 版本 3.4.4

如何为数组快照中的每个对象聚合一个新键“total”，其值是“course”和“quantity”的乘积。

示例文档:

{
    cur: "EUR",
    snapshot: [
        {
            id: "24352345",
            course: 58.12,
            quantity: 13
        },    
        {
            id: "34552345",
            course: 18.12,
            quantity: 63
        }
    ]
}

期望的结果:

{
    cur: "EUR",
    snapshot: [
        {
            id: "24352345",
            course: 58.12,
            quantity: 13,
            total: 755.56
        },    
        {
            id: "34552345",
            course: 18.12,
            quantity: 63,
            total: 1141.56
        }
    ]
}

第一次尝试:

db.mycoll.aggregate([{
    $addFields: {
        "snapshot.total": {
            $multiply:["$snapshot.quantity", "$snapshot.course"]
        }
    }
}])

"errmsg": "$multiply 只支持数值类型，不支持数组"

第二次尝试:

db.mycoll.aggregate( [ 
    { "$addFields": { 
        "snapshot.total": {
            "$map": { 
                "input": "$snapshot", 
                "as": "row", 
                "in": { "$multiply": [ 
                    { "$ifNull": [ "$$row.quantity", 0 ] }, 
                    { "$ifNull": [ "$$row.course", 0 ] } 
                ]} 
            }
        } 
    }} 
])

'total' 的不需要的值是一个包含所有对象总和的数组:

{
    cur: "EUR",
    snapshot: [
        {
            id: "24352345",
            course: 58.12,
            quantity: 13,
            total: [
                755.56,
                1141.56
            ]
        },    
        {
            id: "34552345",
            course: 18.12,
            quantity: 63,
            total: [
                755.56,
                1141.56
            ]
        }
    ]
}

Answer 1

使用 $map operator 修改您的第二次尝试将整个快照嵌入文档与其字段映射为

db.mycoll.aggregate([
    {
        "$addFields": {
            "snapshot": {
                "$map": {
                    "input": "$snapshot",
                    "as": "row",
                    "in": {
                        "id": "$$row.id",
                        "course": "$$row.course",
                        "quantity": "$$row.quantity",
                        "total": { "$multiply": [ 
                            { "$ifNull": [ "$$row.quantity", 0 ] }, 
                            { "$ifNull": [ "$$row.course", 0 ] } 
                        ]} 
                    }
                }
            }
        }
    }
])