JavaScript：flatMap结合Promise.all时如何正确编写条件语句并获取返回值？

问题根源 #

flatMap是同步迭代方法，回调内使用await不会让flatMap等待异步操作完成，若回调未明确返回Promise，最终Promise.all得到的数组就会全是undefined。你的场景是每个event对应一套异步流程（条件查询、条件插入、必做更新），需要把每个event的逻辑封装成独立的Promise，再用map生成Promise数组，而非直接在flatMap里嵌套await。

具体实现步骤 #

1. 封装单event处理逻辑
   把每个event的异步操作封装成一个异步函数，确保明确返回处理结果：

async function handleSingleEvent(event) {
  // 条件执行查询与插入
  if (event.state.matchPhase === "1H") {
    const originalObj = await simpleQuery(/* 传入你的查询参数 */);
    if (!originalObj.state) {
      await insertRealStartTime(/* 传入你的插入参数 */);
    }
  }

  // 执行必做的更新操作，获取返回值
  const updateRes = await Events.updateMany(
    /* 更新条件 */,
    /* 更新内容 */
  );

  // 返回当前event的处理结果，便于后续判断
  return {
    eventId: event._id,
    updateSuccess: updateRes.modifiedCount > 0, // 根据updateMany返回值判断更新状态
    // 可按需添加其他字段，比如是否执行了insert操作
  };
}

2. 生成Promise数组并等待全部完成
   用map替代flatMap生成Promise数组，再通过Promise.all获取所有结果：

// 假设events是你的事件数组
const taskPromises = events.map(handleSingleEvent);
const allResults = await Promise.all(taskPromises);

// 遍历结果做后续处理
allResults.forEach(result => {
  console.log(`事件${result.eventId}更新${result.updateSuccess ? '成功' : '失败'}`);
});

关键注意事项 #

• 不要用flatMap处理异步逻辑：flatMap的设计目的是同步扁平化数组，不支持异步回调，用map搭配异步函数才是正确姿势。
• 必须明确返回值：异步函数一定要return结果，否则Promise.all的数组里会出现undefined。
• 并行vs串行：上述方案是并行执行所有event的异步操作，若需要串行处理（逐个执行），则改用for...of循环+await，而非Promise.all。

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