Mongoose中$match能否用动态变量？无结果问题求助

可能的原因 #

1. 数据类型不匹配：数据库中terminalId字段的类型（比如ObjectId）和item的类型（比如字符串）不一致，导致$match无法匹配到数据。
2. 单个item无对应数据：tpes数组中部分item在数据库里没有对应的日志记录，返回空数组，最终logs里会包含多个空数组。
3. 异步循环的潜在问题：虽然Promise.all+map的写法本身没问题，但多次发起聚合查询效率低，且容易忽略类型转换细节。

排查步骤 #

• 单独测试单个item：把$match里的item换成tpes中确定存在的ID值，看是否能返回结果，排除循环逻辑的问题。
• 核对数据类型：用typeof或数据库工具查看terminalId的类型，如果是ObjectId，需要将字符串类型的item转换为ObjectId再匹配。
• 检查tpes数组：确认数组内无空值、格式错误的ID。

优化后的代码 #

直接通过一次聚合查询完成所有终端ID的统计，避免多次查询，同时处理类型转换：

// 假设使用Mongoose，若terminalId是ObjectId类型，先转换item的类型
const validTerminalIds = tpes.map(item => 
  typeof item === 'string' ? mongoose.Types.ObjectId(item) : item
);

const logs = await this.logModel.aggregate([
  // 一次匹配所有目标terminalId
  { $match: { terminalId: { $in: validTerminalIds } } },
  // 按terminalId和outcome分组统计数量
  {
    $group: {
      _id: { terminalId: '$terminalId', outcome: '$outcome' },
      value: { $sum: 1 }
    }
  },
  // 按terminalId聚合对应的outcome统计结果
  {
    $group: {
      _id: '$_id.terminalId',
      outcomes: {
        $push: { name: '$_id.outcome', value: '$value' }
      }
    }
  },
  // 整理输出格式
  {
    $project: {
      terminalId: '$_id',
      outcomes: 1,
      _id: 0
    }
  }
]);

console.log('logs', logs);

原代码的修复方案 #

如果一定要保留循环查询的写法，确保类型匹配：

let logs = await Promise.all(
  tpes.map(async (item) => {
    // 类型转换：如果terminalId是ObjectId，转换item
    const matchId = typeof item === 'string' ? mongoose.Types.ObjectId(item) : item;
    return await this.logModel.aggregate([
      { $match: { terminalId: matchId } },
      {
        $group: {
          _id: '$outcome',
          value: { $sum: 1 },
        },
      },
      {
        $project: {
          name: '$_id',
          value: 1,
          _id: 0,
        },
      },
    ]);
  }),
);
console.log('logs', logs);

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