Mongoose聚合操作无返回结果问题排查求助

需求：计算用户orders数组的总价格，使用MongoDB聚合操作时，在NoSQL Booster中执行能得到正确的totalPrice，但在应用中调用仅返回空数组[]。

数据示例 #

{
  "userId": 1,
  "username": "john_doe",
  "password": "$2b$12$3fJyHTgM8QgU.q.tlpNVyOf.hJYfhVe7XPGCHm9Wq1RmexUZbUEeu",
  "fullName": {
    "firstName": "John",
    "lastName": "Doe"
  },
  "age": 30,
  "email": "john.doe@example.com",
  "isActive": true,
  "hobbies": ["reading", "traveling"],
  "address": {
    "street": "123 Main St",
    "city": "Anytown",
    "country": "USA"
  },
  "orders": [
    {
      "productName": "Product 1",
      "price": 23.56,
      "quantity": 2
    },
    {
      "productName": "Product 2",
      "price": 23.56,
      "quantity": 5
    }
  ]
}

应用中使用的聚合函数 #

export const GetTotalOrderPriceDB = async (userId: string) => {
 const result = await User.aggregate([
  {
    $match: { userId: userId }, 
  },
  {
    $unwind: "$orders", 
  },
  {
    $group: {
      _id: null, 
      totalPrice: {
        $sum: { $multiply: ["$orders.price", "$orders.quantity"] },
      },
   },
 },
 {
  $project: {
    _id: 0,
    totalPrice: 1,
  },
 },
]);
return result;
};

排查要点及解决方案 #

1. 数据类型不匹配（最可能原因） #

数据库中userId字段是数字类型（示例中为1），但函数接收的userId参数是字符串类型。MongoDB的$match是严格类型匹配的，字符串与数字无法匹配，导致没有符合条件的文档被筛选，最终返回空数组。

解决方法：

• 调整函数参数类型为数字：async (userId: number)，调用时传入数字类型的userId；
• 或者在$match阶段将字符串参数转为数字：

  $match: { userId: parseInt(userId) }
  

  注意：需额外处理userId无法转为有效数字的异常情况。

2. 验证参数传递正确性 #

确认调用GetTotalOrderPriceDB时传入的userId值是否正确，是否存在拼写错误、为空值或传入了不存在的userId。

3. 逐步排查聚合阶段 #

简化聚合管道，先只保留$match阶段，测试是否能返回目标用户文档：

const result = await User.aggregate([{ $match: { userId: 1 } }]);

若此阶段返回空数组，说明是匹配条件的问题；若能返回文档，再逐步添加$unwind、$group阶段排查。

4. 优化聚合管道（可选） #

无需使用$unwind，直接用$reduce计算数组内的总价格，效率更高：

export const GetTotalOrderPriceDB = async (userId: number) => {
 const result = await User.aggregate([
  {
    $match: { userId: userId }, 
  },
  {
    $project: {
      _id: 0,
      totalPrice: {
        $reduce: {
          input: "$orders",
          initialValue: 0,
          in: { $add: ["$$value", { $multiply: ["$$this.price", "$$this.quantity"] }] }
        }
      }
    }
  }
]);
return result;
};

内容的提问来源于stack exchange，提问作者Md Pervej Hossain