Mongoose异步函数在Promise解析前返回问题求助

核心问题 #

你这段代码的关键bug在于**Click.find().populate().exec()用了回调函数版本**，这时候exec()不会返回Promise，外层的await根本等不到回调里的异步逻辑执行完毕。外层函数会直接跳过回调，先执行最后的console.log，自然拿不到正确的matchingClickDocs。另外还有个小问题：fileIdsInCsv没提前声明，会变成全局变量，容易引发意外问题。

修复后的代码 #

mongoCheckFile = async (fileData) => {
  try {
    // 提前声明变量，避免全局污染
    const fileIdsInCsv = [];
    const offerIdsValues = [];

    // 提取CSV中的fileId
    fileData.data.forEach(element => {
      fileIdsInCsv.push(`${element.fileId}`);
    });

    // 提取offerIds
    fileData.fileOffers.forEach(element => {
      offerIdsValues.push(element.id);
    });

    // 改用exec()的Promise版本，不带回调，await才能生效
    const clicks = await Click.find({
      // 这里$and可以简化，两个fileId的$in条件直接合并成一个数组即可
      fileId: { $in: [...fileIdsInCsv, ...offerIdsValues] }
    }).populate('furtherInfo').exec();

    // 用Promise.all处理所有click的异步操作，确保全部完成
    const matchingClickDocs = await Promise.all(clicks.map(async (click) => {
      const furtherDatas = await furtherData.findOne({ fileId: click.fileId });
      if (furtherDatas) {
        click.furtherInfo = furtherDatas;
        await click.save();
        return click; // 直接返回处理后的click，Promise.all会自动收集成数组
      }
      // 没有找到furtherDatas的话返回null，后续可以过滤掉
      return null;
    }));

    // 过滤掉无效的null值，只保留有有效数据的项
    const validClickDocs = matchingClickDocs.filter(doc => doc !== null);

    console.log(validClickDocs.length, '最终有效数据长度');
    return validClickDocs; // 返回正确的结果
  } catch (err) {
    console.error(err);
    throw err; // 抛出错误让调用方处理，不要直接return err
  }
};

关键改动说明 #

1. 移除exec的回调版本：改用无回调的exec()，让await能正确等待查询结果返回，这是解决异步不等待的核心。
2. 简化查询条件：原代码里的$and是重复的fileId条件，直接合并两个数组到同一个$in里，逻辑更清晰高效。
3. 用Promise.all批量处理异步操作：直接通过Promise.all收集所有处理后的click对象，替代原来的外部数组push方式，避免闭包和异步顺序问题。
4. 变量提前声明：修复fileIdsInCsv未声明的问题，避免全局变量污染。
5. 错误处理优化：catch里直接抛出错误，让调用方可以通过try/catch捕获，而不是返回错误对象，符合异步函数的错误处理规范。

额外提示 #

如果后续需要给查询加其他条件，再恢复$and即可，比如：

$and: [
  { fileId: { $in: fileIdsInCsv } },
  { status: 'active' } // 新增的其他条件
]

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