Mongoose aggregate返回40323错误及管道语法异常排查

• 触发A pipeline stage specification object must contain exactly one field报错的核心原因：两个$lookup的内部联表管道存在基础语法错误——将$match和$group两个独立的聚合阶段写在了同一个对象中。MongoDB聚合管道要求数组内的每一个阶段对象只能包含一个阶段操作符，即一个对象只能单独写$match、单独写$group，不能在同一个对象里同时定义两个阶段，这是报错的直接诱因。
• 其余语法与逻辑问题：
  • 起始匹配阶段字段错误：从User集合发起聚合时，匹配条件写为{ user: userId }，但User集合的用户主键是_id字段，该条件永远无法匹配到目标用户。
  • 冗余无效的let定义：两个$lookup中声明的let变量既没有在内部管道通过$$前缀引用，字段路径写法也不符合规范，属于无效代码。
  • 统计逻辑存在笛卡尔积bug：直接对两个lookup返回的数组做unwind，当同一天存在visits和brackets数据时，会生成多份重复记录导致工时翻倍统计；投影阶段取date: "$_id"拿到的是User集合的主键ID，并非分组后的日期字段，排序逻辑完全失效。
  • TimeBrackets工时取值路径错误：从let定义看工时字段存储在entries.hours路径下，直接写$sum: "$hours"无法取到正确数值。

调整聚合逻辑，先分别对两个业务集合做独立过滤、按日分组统计，再合并结果做统一聚合，从根源避免笛卡尔积问题，修正后代码如下：

const isStart = new Date(req.body.isStart)
const isEnd = new Date(req.body.isEnd)
const userId = mongoose.Types.ObjectId(req.params.id)

User.aggregate([
  // 匹配目标用户
  { $match: { _id: userId } },
  // 联表统计Visits集合按日工时
  {
    $lookup: {
      from: "visits",
      as: "visitsData",
      pipeline: [
        // 第一阶段：过滤指定时间范围、当前用户的记录
        {
          $match: {
            user: userId,
            visitStart: { $gte: isStart },
            visitEnd: { $lte: isEnd }
          }
        },
        // 第二阶段：按日期分组统计（独立阶段对象）
        {
          $group: {
            _id: { $dateToString: { date: "$visitEnd", format: "%m-%d-%Y" } },
            visitHours: { $sum: "$totalHours" }
          }
        }
      ]
    }
  },
  // 联表统计TimeBrackets集合按日工时
  {
    $lookup: {
      from: "timebrackets",
      as: "bracketsData",
      pipeline: [
        // 第一阶段：过滤指定时间范围、当前用户的记录
        {
          $match: {
            user: userId,
            date: { $gte: isStart },
            date: { $lte: isEnd }
          }
        },
        // 工时存在entries数组下时先展开数组，无嵌套可删除该行
        { $unwind: "$entries" },
        // 第二阶段：按日期分组统计（独立阶段对象）
        {
          $group: {
            _id: { $dateToString: { date: "$date", format: "%m-%d-%Y" } },
            bracketHours: { $sum: "$entries.hours" }
          }
        }
      ]
    }
  },
  // 合并两个集合的统计结果
  {
    $project: {
      allData: { $concatArrays: ["$visitsData", "$bracketsData"] }
    }
  },
  { $unwind: "$allData" },
  // 按日期统一分组，合并两类工时数据
  {
    $group: {
      _id: "$allData._id",
      visitHours: { $sum: { $ifNull: ["$allData.visitHours", 0] } },
      bracketHours: { $sum: { $ifNull: ["$allData.bracketHours", 0] } }
    }
  },
  // 整理输出字段
  {
    $project: {
      _id: 0,
      date: "$_id",
      visitHours: 1,
      bracketHours: 1,
      totalHours: { $add: ["$visitHours", "$bracketHours"] }
    }
  },
  // 按日期升序排序
  { $sort: { date: 1 } }
]).exec((err, result) => {
  if (err) return res.send(err);
  res.json(result);
});

• 如果TimeBrackets集合的工时字段直接存储在文档根层级，不存在entries嵌套，可删除{ $unwind: "$entries" }阶段，将$sum: "$entries.hours"修改为$sum: "$hours"即可。
• 日期输出格式可根据前端渲染需求，调整$dateToString的format参数。

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