如何用Promise.all实现嵌套循环？数据库插入的响应头错误与代码失效问题

咱们先拆解下你遇到的两个核心问题：

第一个版本代码的问题：「Can't set header after they are sent」 #

你这里的问题根源有两个：

1. pool.query未封装成Promise：pool.query是基于回调的异步方法，但你直接把它丢进Promise.all的map里，没返回任何Promise。这导致Promise.all根本不会等待数据库插入操作完成，就直接跳进then回调；再加上循环的存在，很容易多次触发响应操作。
2. then的写法错误：你写的.then(req.flash(...), res.redirect(...))，其实是把res.redirect()的执行结果作为参数传给then，而不是传递一个回调函数。这会让res.redirect在Promise还没完成时就立即执行，加上循环里的多次触发，自然就会重复设置响应头，抛出错误。

第二个版本代码的问题：程序完全无法运行 #

这个版本主要是语法错误和核心逻辑缺失：

• 箭头函数的括号、大括号匹配混乱，比如then(() =>{里的res.redirect('/pengajuan_event'))多了一个闭合括号，catch的语法也有问题；
• 最关键的是，还是没把pool.query封装成Promise，Promise.all依然无法正确等待异步操作完成，程序自然跑不起来。

正确的实现方式 #

要解决问题，咱们分两步走：先把回调式的pool.query转成Promise，再正确嵌套使用Promise.all，最后确保响应只发送一次。

第一步：封装pool.query为Promise

在Node.js里，我们可以用util.promisify快速把回调函数转成Promise风格：

const util = require('util');
// 绑定pool上下文，避免this指向问题，再转成Promise
const queryPromise = util.promisify(pool.query.bind(pool));

第二步：正确编写嵌套的Promise.all

现在用封装好的queryPromise构建Promise链，确保所有插入操作完成后再执行响应：

Promise.all(venue.map(venueItem => {
  // 注意变量名不要和外层数组venue重名，避免作用域混淆
  return Promise.all(concat_all.map(tgl => {
    // 返回每个插入操作的Promise，让Promise.all等待它完成
    return queryPromise(
      "INSERT INTO peminjaman_venue VALUES (?,?,?,?,?,?,?,?,?,?,?)",
      [
        id_event,
        venueItem,
        nama_lengkap_peminjam,
        jabatan_nim_peminjam,
        jumlah_personel,
        id_google_calendar,
        waktu_mulai_rutin,
        waktu_selesai_rutin,
        tgl,
        tgl,
        fasilitas_lain
      ]
    );
  }));
}))
.then(() => {
  // 所有插入操作成功完成后，只执行一次flash和redirect
  req.flash('message_success', 'Berhasil mengajukan event');
  res.redirect('/pengajuan_event');
})
.catch((err) => {
  // 任何一个插入失败都会进入这里，同样只执行一次响应
  console.error('插入数据出错:', err); // 建议打印错误日志，方便排查问题
  req.flash('message_err', 'Gagal mengajukan event');
  res.redirect('/pengajuan_event');
});

关键要点总结 #

• 异步操作必须返回Promise：Promise.all只能等待Promise对象完成，所以一定要把回调式的数据库操作封装成Promise；
• 避免变量名冲突：外层数组是venue，内层循环元素别再用同名变量，改成venueItem这类名字；
• 响应只发送一次：then和catch里的res.redirect只会执行一次，因为Promise.all只有在所有子Promise都完成（或有一个失败）时才会进入对应回调，彻底解决重复设置响应头的问题。

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