如何在MongoDB中获取唯一用户文档？求Mongoose解决方案

你的代码中，由于order.orders数组里同一用户的订单会被多次遍历，map方法会生成多条重复的用户记录。以下两种方案可以解决这个问题，其中第二种是Mongoose原生的聚合方案，更高效。

方案一：查询后通过JavaScript去重 #

通过Map结构存储唯一用户，将同一用户的所有订单聚合到数组中：

router.post('/getusers', async(req, res) => {
  try {
    const { orderID } = req.body;

    const order = await Order.findById(orderID).populate({
      path: 'orders',
      populate: {
        path: 'user_id',
        model: 'User',
        select: 'name',
      },
    });

    if (!order) {
      return res.status(404).send('order not found');
    }

    // 用Map存储唯一用户，避免重复
    const userMap = new Map();
    order.orders.forEach((orderItem) => {
      const userId = orderItem.user_id._id.toString();
      if (userMap.has(userId)) {
        // 已有该用户，追加订单
        userMap.get(userId).orders.push(orderItem.order);
      } else {
        // 新用户，初始化数据结构
        userMap.set(userId, {
          user_id: userId,
          name: orderItem.user_id.name,
          orders: [orderItem.order]
        });
      }
    });

    // 将Map转为数组作为响应结果
    const response = Array.from(userMap.values());

    console.log(response);
    res.status(200).json(response);
  } catch (error) {
    console.error(error);
    res.status(500).send('服务器错误');
  }
});

方案二：使用Mongoose聚合管道（推荐） #

直接在数据库层面完成关联查询、分组去重，减少后端数据处理压力，适合大数据量场景：

const mongoose = require('mongoose');

router.post('/getusers', async(req, res) => {
  try {
    const { orderID } = req.body;

    const result = await Order.aggregate([
      // 匹配目标订单文档
      { $match: { _id: mongoose.Types.ObjectId(orderID) } },
      // 展开orders数组，便于后续关联和分组
      { $unwind: '$orders' },
      // 关联User集合获取用户信息
      {
        $lookup: {
          from: 'users', // 注意这里是User集合的实际名称（通常是复数）
          localField: 'orders.user_id',
          foreignField: '_id',
          as: 'user_info'
        }
      },
      // 展开用户信息数组（$lookup返回的是数组）
      { $unwind: '$user_info' },
      // 按用户ID分组，聚合订单列表
      {
        $group: {
          _id: '$user_info._id',
          name: { $first: '$user_info.name' },
          orders: { $push: '$orders.order' }
        }
      },
      // 调整输出字段格式，符合需求
      {
        $project: {
          _id: 0,
          user_id: '$_id',
          name: 1,
          orders: 1
        }
      }
    ]);

    if (result.length === 0) {
      return res.status(404).send('order not found');
    }

    res.status(200).json(result);
  } catch (error) {
    console.error(error);
    res.status(500).send('服务器错误');
  }
});

方案对比 #

• 方案一实现简单，适合数据量较小的场景，前端/后端处理逻辑直观。
• 方案二利用MongoDB的聚合能力，把计算压力转移到数据库，减少网络传输的数据量，性能更优，适合数据量大的场景。

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