Express+Mongoose接口返回数据缺失且不稳定问题求助

核心问题分析 #

1. 全局循环变量污染：代码中for (i = 0; i < pids.length; i++)和内层的for (j = 0; j < package.length; j++)未用let/const声明i和j，这两个变量会成为全局变量。在异步请求并发场景下，多个请求的循环变量会互相覆盖，导致迭代逻辑混乱，出现返回记录数量不稳定的情况。

2. 未处理空查询结果：当某个pid在priceModel中没有匹配记录时，package会是空数组，此时访问package[0]._id、package[0].pid等属性会直接抛出TypeError，中断整个循环执行，后续pid对应的记录无法被添加到返回结果中，这就是"传入4个pid但仅返回2条记录"的直接原因。

修复后的代码 #

exports.getPackages = async function (req, res) {
  try {
    const pids = req.query.p_id;
    // 确保pids始终是数组，兼容单个pid传入的情况
    const pidList = Array.isArray(pids) ? pids : [pids];
    const newObject = [];

    for (let i = 0; i < pidList.length; i++) { // 用let声明i，限制变量作用域
      const pid = pidList[i];
      let cr = [];
      const package = await priceModel
        .find({ pid })
        .select({ pro_config_options: 0 });
      
      // 无匹配记录时跳过当前迭代，避免后续属性访问报错
      if (!package.length) {
        continue;
      }

      const packageFeatures = await featuresModel
        .find({ pid })
        .select({ pid: 0 });

      for (let j = 0; j < package.length; j++) { // 用let声明j，避免全局污染
        const pkgItem = package[j];
        const ccr = {
          currency: pkgItem.currency,
          annually: pkgItem.annually,
          biennially: pkgItem.biennially,
          triennially: pkgItem.triennially,
          monthly: pkgItem.monthly,
          quarterly: pkgItem.quarterly,
          semiannually: pkgItem.semiannually,
          qsetupfee: pkgItem.qsetupfee,
          ssetupfee: pkgItem.ssetupfee,
          asetupfee: pkgItem.asetupfee,
          bsetupfee: pkgItem.bsetupfee,
          tsetupfee: pkgItem.tsetupfee,
        };
        cr.push(ccr);
      }

      const obj = {
        id: package[0]._id,
        pid: package[0].pid,
        name: package[0].name,
        title: package[0].title,
        tid: "",
        fname: package[0].fname,
        currency: cr,
        addons: [],
        freedomain: [],
        packageFeatures,
        addonids: package[0].addonids,
      };
      newObject.push(obj);
    }
    res.json(newObject);
  } catch (err) {
    // 全局捕获异常，避免服务器崩溃，同时输出错误日志便于排查
    console.error("获取套餐数据失败:", err);
    res.status(500).json({ error: "服务器内部错误" });
  }
};

关键修改点说明 #

• 用let声明循环变量i和j，将变量作用域限制在循环内部，彻底解决全局变量污染问题。
• 新增pidList处理逻辑：确保pids始终是数组，避免单个pid传入时pids.length报错。
• 添加空结果判断：当package为空时，用continue跳过当前迭代，保证其他pid的记录能正常处理。
• 新增全局try/catch：捕获整个函数执行过程中的异常，避免接口直接崩溃，同时输出错误日志。
• 优化变量引用：将package[j]赋值给pkgItem，提升代码可读性。

额外性能优化建议 #

当前代码是串行查询每个pid的数据，可改为并行查询提升接口响应速度：

// 用Promise.all并行处理所有pid的查询
const packagePromises = pidList.map(async pid => {
  const package = await priceModel.find({ pid }).select({ pro_config_options: 0 });
  if (!package.length) return null;
  const packageFeatures = await featuresModel.find({ pid }).select({ pid: 0 });
  
  // 用map替代内层循环处理currency数据
  const cr = package.map(pkgItem => ({
    currency: pkgItem.currency,
    annually: pkgItem.annually,
    biennially: pkgItem.biennially,
    triennially: pkgItem.triennially,
    monthly: pkgItem.monthly,
    quarterly: pkgItem.quarterly,
    semiannually: pkgItem.semiannually,
    qsetupfee: pkgItem.qsetupfee,
    ssetupfee: pkgItem.ssetupfee,
    asetupfee: pkgItem.asetupfee,
    bsetupfee: pkgItem.bsetupfee,
    tsetupfee: pkgItem.tsetupfee,
  }));

  return {
    id: package[0]._id,
    pid: package[0].pid,
    name: package[0].name,
    title: package[0].title,
    tid: "",
    fname: package[0].fname,
    currency: cr,
    addons: [],
    freedomain: [],
    packageFeatures,
    addonids: package[0].addonids,
  };
});

const results = await Promise.all(packagePromises);
// 过滤掉无匹配记录的null值
const newObject = results.filter(item => item !== null);

这样可以同时发起所有pid的查询请求，大幅缩短接口响应时间。

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