异步函数问题求助：如何获取数据库中各店铺用户数量

阿华AIGC实验室

2026-5-25

解决店铺用户数返回为空的问题

嘿，我来帮你排查这个nbr_users返回空的问题！先从几个常见的原因和修复方案说起：

1. 最可能的问题：异步Promise没有正确处理

你的nbr_users返回的是Promise，但如果在主函数里调用它时，没有用await或者.then()等待结果，直接取值的话，拿到的会是一个未resolved的Promise对象，看起来就像“空值”。

比如如果你的主函数原来写的是这样：

db.Account.find({}, (err, shops) => {
  if (err) return res.status(500).send(err);
  const shopData = shops.map(shop => ({
    ...shop.toObject(),
    nbr_users: nbr_users(shop._id) // 这里直接返回Promise，不是实际数字
  }));
  res.send(shopData);
});

这时候前端拿到的nbr_users就是Promise对象，而不是你想要的数字。

修复方案：用`async/await` + `Promise.all`处理异步调用

把主函数改成异步函数，并用Promise.all等待所有用户数查询完成：

// 先优化nbr_users：用countDocuments更高效，避免查询所有用户再取长度
function nbr_users(key) {
  return db.User.countDocuments({ shop: key })
    .catch(err => {
      console.error('统计用户数出错:', err);
      throw err; // 抛出错误让上层捕获
    });
}

module.exports = async (req, res) => {
  try {
    // 用lean()返回普通JS对象，提升处理速度
    const shops = await db.Account.find({}).lean();
    
    // 遍历店铺，并行查询每个店铺的用户数
    const shopsWithUserCount = await Promise.all(shops.map(async shop => {
      const userCount = await nbr_users(shop._id);
      return {
        ...shop,
        nbr_users: userCount
      };
    }));
    
    res.send(shopsWithUserCount);
  } catch (err) {
    console.error('获取数据出错:', err);
    res.status(500).send('获取店铺数据失败');
  }
};

2. 类型不匹配导致查询不到用户

如果你的Account集合的_id是MongoDB的ObjectId类型，但User集合里的shop字段存的是字符串，那查询条件{ shop: key }会匹配不到任何数据，返回0或者空数组。

修复方案：统一字段类型

如果User.shop是字符串：把传入的key转成字符串

function nbr_users(key) {
  return db.User.countDocuments({ shop: key.toString() });
}

如果User.shop是ObjectId：确保传入的key是ObjectId类型（比如如果key是字符串，用mongoose.Types.ObjectId(key)转换）

3. 更高效的方案：用MongoDB聚合一次查询搞定

其实你不需要分两次调用数据库，用MongoDB的$lookup聚合可以直接关联店铺和用户，一次查询得到所有店铺的用户数，避免N+1查询的性能问题：

module.exports = async (req, res) => {
  try {
    const shopsWithUserCount = await db.Account.aggregate([
      // 关联User集合，匹配shop字段
      {
        $lookup: {
          from: 'users', // 注意这里是User集合的实际名称（通常是复数）
          localField: '_id',
          foreignField: 'shop',
          as: 'matchedUsers'
        }
      },
      // 添加用户数字段，统计matchedUsers数组的长度
      {
        $addFields: {
          nbr_users: { $size: '$matchedUsers' }
        }
      },
      // 不需要返回用户列表，移除该字段
      {
        $project: {
          matchedUsers: 0
        }
      }
    ]);
    
    res.send(shopsWithUserCount);
  } catch (err) {
    console.error('聚合查询出错:', err);
    res.status(500).send('获取店铺数据失败');
  }
};