Mongoose多集合聚合：查询医生名下患者的最早及最新检测分数

原聚合管道的错误点 #

• 关联Records集合的字段匹配错误：User文档的medicalVisits字段存储的是Record的_id值，原代码错误使用patients.user作为关联字段匹配Records的_id，没有匹配结果是返回空数组的核心原因
• 缺失Tests集合的关联逻辑：没有关联存储检测分数的Tests集合，自然无法提取首次和最新的检测分数
• 分组逻辑错误：按医生_id分组会把所有患者数据合并为1条，无法返回所有患者的独立信息
• 缺少检测数据的排序和极值提取逻辑：没有按检测创建时间排序、取最早/最新分数的处理步骤
• 未处理_id类型匹配：如果传入的docId是字符串格式，需要先转为Mongoose的ObjectId类型才能正确匹配文档_id

最优实现方案 #

推荐使用lookup子管道在关联检测数据时直接处理极值提取，无需拉取全量历史检测数据，性能更优。
首先引入ObjectId处理类型匹配：

const { ObjectId } = require('mongoose').Types;

正确的聚合管道代码如下：

const patients = await Doctor.aggregate([
  // 匹配指定医生，字符串id需转为ObjectId
  { $match: { _id: new ObjectId(docId) } },
  // 关联获取该医生名下所有患者
  {
    $lookup: {
      from: "users",
      localField: "patients",
      foreignField: "_id",
      as: "patients"
    }
  },
  // 拆分患者数组，每个患者单独为一条文档
  { $unwind: "$patients" },
  // 关联患者对应的唯一病历记录
  {
    $lookup: {
      from: "records",
      localField: "patients.medicalVisits",
      foreignField: "_id",
      as: "patientRecord"
    }
  },
  // 拆分病历记录，因每个患者仅1条病历，直接取即可
  { $unwind: "$patientRecord" },
  // 关联检测数据，子管道直接处理极值提取
  {
    $lookup: {
      from: "tests",
      let: { testIds: "$patientRecord.tests" },
      pipeline: [
        // 匹配当前病历关联的所有检测
        { $match: { $expr: { $in: ["$_id", "$$testIds"] } } },
        // 按检测创建时间升序排序
        { $sort: { createdAt: 1 } },
        // 直接分组取首次和最新的检测分数
        {
          $group: {
            _id: null,
            initialTestScore: { $first: "$testScore" },
            recentTestScore: { $last: "$testScore" }
          }
        }
      ],
      as: "testStats"
    }
  },
  // 拆分检测统计结果，无检测数据时保留患者记录
  { $unwind: { path: "$testStats", preserveNullAndEmptyArrays: true } },
  // 映射为期望的输出字段格式
  {
    $project: {
      _id: 0,
      userId: "$patients._id",
      name: "$patients.name",
      email: "$patients.email",
      rating: "$patientRecord.rating",
      initialTestScore: { $ifNull: ["$testStats.initialTestScore", null] },
      recentTestScore: { $ifNull: ["$testStats.recentTestScore", null] }
    }
  }
])

返回的patients是符合要求的所有患者数组，每个元素的结构和你期望的输出完全一致。如果只需要查询单个患者的信息，在匹配医生的步骤后增加对应用户_id的匹配条件即可。

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