MongoDB агрегат заполнить / заменить массив ObjectId

Question

У меня есть следующая структура MongoDB:

campaign:{
  _id: '5e4eee638552043e60e5073b',
  name: 'Test campaign',
  partners: [
    {
      _id: '5e4fa9fbbdeb4a5878ac2a35',
      options: [Object],
      partner: '5e4e9bc2101ecb2e8764190c',
    },
    {
      _id: '5e4ff7c6e54b6d676d97b7a6',
      options: [Object],
      partner: '5e4ff51c23f44266a8add39e',
    }
  ]
}

Используя следующую функцию aggregate, я могу найти ID каждого из партнеров и добавить в новый массив:

{
  $lookup:
  {
    from: 'campaigns',
    let: { campaign: '$campaign' },
    pipeline: [
      { $match: { $expr: { $and: [{ $eq: ['$_id', '$$campaign'] }] } } },
      {
        $lookup:
          {
            from: 'partners',
            let: { partner: '$partner.partner' },
            pipeline: [
              { $match: { $expr: { $in: ['$_id', '$$partner'] } } },
              { $project: { _id: 1, name: 1 } }
            ],
            as: 'partner1'
          }
        },
        {
          $project: {
            _id: 1, shortName: 1, userInterface: 1, options: 1, check: 1, description: 1, partner: 1, partner1: 1 } }
    ],
    as: 'campaign'
  }
}

Это новый вывод:

campaign: {
  _id: '5e4eee638552043e60e5073b',
  name: 'Test campaign',
  partners: [
    ...
  ],
  partner1: [
    { _id: '5e4e9bc2101ecb2e8764190c', name: '123' },
    { _id: '5e4ff51c23f44266a8add39e', name: '456' }
  ]
}

Но я хочу заменить _id каждого элемента в массиве партнеров на полный объект партнера.

Партнер объект:

partner
{ 
  _id: '5e4e9bc2101ecb2e8764190c',
  name: '123',
  etc: ...
},
{
  _id: '5e4ff51c23f44266a8add39e',
  name: '456'
  etc: ...
}

Вот так должен выглядеть конечный объект:

[
  {
    "campaign": [
      {
        "partner": [
          {
            "_id": "5e4eee638552043e60e5073b",
            "options": [
              {}
            ],
            "partner": {
                "_id": "5e4e9bc2101ecb2e8764190c",
                "name": "123"
            }
          }
        ]
      }
    ]
  }
]

Answer 1

Вам нужно добавить 3 дополнительных этапа:

db.collection.aggregate([
  //your $lookup,
  {
    $unwind: "$campaign"
  },
  {
    $project: {
      _id: 1,
      "campaign.partner": {
        $map: {
          input: "$campaign.partner",
          as: "partner",
          in: {
            $let: {
              vars: {
                partner1: {
                  $filter: {
                    input: "$campaign.partner1",
                    cond: {
                      $eq: [
                        "$$partner.partner",
                        "$$this._id"
                      ]
                    }
                  }
                }
              },
              in: {
                // we merge partner[i] with partner1[j]
                $mergeObjects: [
                  "$$partner",
                  {
                    partner: {
                      $arrayElemAt: [
                       "$$partner1",
                        0
                      ]
                    }
                  }
                ]
              }
            }
          }
        }
      }
    }
  },
  {
    $group: {
      _id: "$_id",
      campaign: {
        $push: "$campaign"
      }
    }
  }
])

MongoPlayground