在map中获取带回调函数的返回值——qbo.getBill异步处理困境

兄弟，我太懂这种被老式回调API卡得头疼的感觉了！别担心，咱们只需要把qbo.getBill这个回调风格的函数包装成Promise，然后用async/await配合数组遍历就能完美解决，一步步来：

第一步：把回调函数包装成Promise #

首先给qbo.getBill套个Promise壳子，把回调里的成功/失败逻辑转成Promise的resolve/reject：

// 包装qbo.getBill为Promise版本
const getBillPromise = (billId) => {
  return new Promise((resolve, reject) => {
    qbo.getBill(billId, (err, billData) => {
      if (err) {
        reject(err); // 出错时抛出错误
      } else {
        resolve(billData); // 成功时返回账单数据
      }
    });
  });
};

第二步：用async/await遍历数组处理数据 #

接下来分两种场景处理你的数组：

场景1：并行处理所有账单（效率更高） #

如果你的账单处理不需要按顺序执行，用Promise.all配合map可以并行处理所有请求：

// 假设你的账单ID数组是这个
const billIds = [1001, 1002, 1003];

async function processAllBills() {
  try {
    // 把每个账单ID转成处理Promise，然后等待所有完成
    const processedResults = await Promise.all(
      billIds.map(async (billId) => {
        // 获取原始账单数据
        const rawBillData = await getBillPromise(billId);
        
        // 这里写你的数据处理逻辑，比如提取需要的字段、转换格式
        const processedData = {
          billId: rawBillData.Id,
          totalAmount: rawBillData.TotalAmt,
          vendorName: rawBillData.VendorRef?.Name || '未知供应商'
        };

        // 把处理后的数据传入另一个函数（如果这个函数也是回调风格，同样要包装成Promise）
        await passToAnotherFunction(processedData);

        return processedData;
      })
    );

    console.log('所有账单处理完成！结果:', processedResults);
  } catch (error) {
    console.error('处理过程中出错:', error);
    // 这里可以加错误重试、日志记录等逻辑
  }
}

// 启动处理
processAllBills();

场景2：串行处理账单（按顺序执行） #

如果必须按数组顺序处理每个账单（比如后一个依赖前一个的结果），用for...of循环更稳妥：

async function processBillsInOrder() {
  try {
    const processedResults = [];
    for (const billId of billIds) {
      const rawBillData = await getBillPromise(billId);
      const processedData = { /* 同样的处理逻辑 */ };
      await passToAnotherFunction(processedData);
      processedResults.push(processedData);
    }
    console.log('串行处理完成！结果:', processedResults);
  } catch (error) {
    console.error('串行处理出错:', error);
  }
}

补充：如果另一个函数也是回调风格 #

如果你的"另一个函数"也是回调模式，同样用Promise包装它：

const passToAnotherFunction = (processedData) => {
  return new Promise((resolve, reject) => {
    // 假设原函数是：anotherFunction(data, (err, res) => { ... })
    anotherFunction(processedData, (err, result) => {
      if (err) reject(err);
      else resolve(result);
    });
  });
};

为什么你之前尝试失败？ #

大概率是这两个原因：

• 直接在array.map里用await但没配合Promise.all，导致拿到的是一堆pending状态的Promise，而不是处理后的数据
• 包装Promise时没正确处理错误（比如漏掉了reject(err)），导致错误被吃掉，无法排查问题

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