Mongoose多表关联聚合嵌套分组结果结构调整求助

我来帮你搞定这个嵌套关联的问题，核心问题在于你之前的写法里，直接在$lookup的as参数里指定嵌套路径是无效的，而且分组逻辑没有正确还原层级结构。下面是修正后的完整聚合代码，以及逐步骤的解释：

正确的聚合管道代码 #

let order = await Order.aggregate([
  // 1. 关联Order与Order_Batches
  {
    $lookup: {
      from: 'orderbatches',
      localField: '_id',
      foreignField: 'order',
      as: 'order_batches'
    }
  },
  // 2. 展开order_batches数组，保留空数组/空值的情况
  {
    $unwind: { path: '$order_batches', preserveNullAndEmptyArrays: true }
  },
  // 3. 关联当前Order_Batch对应的Batch，结果存入order_batches.batches数组
  {
    $lookup: {
      from: 'batches',
      localField: 'order_batches._id',
      foreignField: 'orderBatches',
      as: 'order_batches.batches'
    }
  },
  // 4. 展开order_batches下的batches数组，方便后续关联Event
  {
    $unwind: { path: '$order_batches.batches', preserveNullAndEmptyArrays: true }
  },
  // 5. 关联当前Batch对应的Event，先存入临时字段temp_events
  {
    $lookup: {
      from: 'events',
      localField: 'order_batches.batches._id',
      foreignField: 'batch',
      as: 'temp_events'
    }
  },
  // 6. 将temp_events嵌入到对应的Batch对象内部
  {
    $addFields: {
      'order_batches.batches.events': '$temp_events'
    }
  },
  // 7. 清理临时字段
  {
    $project: { temp_events: 0 }
  },
  // 8. 第一次分组：还原Order_Batch层级，将同一Order_Batch下的Batch重新组成数组
  {
    $group: {
      _id: { order_id: '$_id', order_batch_id: '$order_batches._id' },
      code: { $first: '$code' },
      order_batch_base: { 
        $first: { 
          _id: '$order_batches._id',
          // 这里可以添加Order_Batches的其他字段，比如创建时间、状态等
        } 
      },
      batches: { $push: '$order_batches.batches' }
    }
  },
  // 9. 将batches数组合并回Order_Batch对象
  {
    $addFields: {
      'order_batch_base.batches': '$batches'
    }
  },
  // 10. 第二次分组：还原Order层级，将同一Order下的Order_Batch重新组成数组
  {
    $group: {
      _id: '$_id.order_id',
      code: { $first: '$code' },
      order_batches: { $push: '$order_batch_base' }
    }
  }
]);

关键修正点说明 #

1. 不能直接在$lookup的as里写嵌套路径：
   Mongoose的$lookup不支持直接将结果写入嵌套对象的属性（比如order_batches.batches.events），必须先将关联结果存入临时字段，再通过$addFields将其合并到目标嵌套位置。

2. 分组逻辑要逐层还原：
   每一次$unwind展开数组后，都需要通过$group重新聚合回原数组结构，而且分组时要同时保留上层层级的ID（比如第一次分组要同时保留order_id和order_batch_id），否则会丢失关联关系，无法还原最终的嵌套结构。

预期输出结构 #

最终返回的Order对象结构会符合你的需求：

{
  _id: ObjectId("..."),
  code: "你的订单编号",
  order_batches: [
    {
      _id: ObjectId("..."),
      // Order_Batches的其他字段
      batches: [
        {
          _id: ObjectId("..."),
          // Batch的其他字段
          events: [
            { /* 单个Event对象 */ },
            { /* 单个Event对象 */ }
          ]
        }
      ]
    }
  ]
}

内容的提问来源于stack exchange，提问作者JenuRudan