如何在MongoDB中获取指定用户的购物车数据并计算总价

针对你的ecom数据库结构，我们可以通过MongoDB的聚合查询实现需求，以下分两种常见场景给出解决方案：

场景1：已知用户X的userId #

直接从users_orders集合筛选目标用户，关联商品信息并计算总价：

db.users_orders.aggregate([
  // 筛选用户X的所有购物车记录
  { $match: { userId: ObjectId("用户X的userId") } },
  // 关联products集合，获取商品详情
  {
    $lookup: {
      from: "products",
      localField: "prodId",
      foreignField: "_id",
      as: "product"
    }
  },
  // 展开商品数组，方便后续处理
  { $unwind: "$product" },
  // 计算每个商品的小计（单价*数量）
  {
    $addFields: {
      subtotal: { $multiply: ["$product.price", "$quantity"] }
    }
  },
  // 汇总数据：保留所有商品详情，计算总价
  {
    $group: {
      _id: "$userId",
      cartItems: {
        $push: {
          productId: "$prodId",
          productName: "$product.productname",
          price: "$product.price",
          quantity: "$quantity",
          subtotal: "$subtotal"
        }
      },
      totalPrice: { $sum: "$subtotal" }
    }
  }
])

各阶段说明： #

• $match：精准过滤出用户X的所有购物车记录，减少后续处理的数据量
• $lookup：通过prodId关联products集合，把商品信息嵌入到结果中
• $unwind：将关联得到的数组型商品数据展开为单条文档，便于计算小计
• $addFields：新增subtotal字段，计算单个商品的总花费
• $group：按用户ID分组，把所有商品详情存入cartItems数组，同时用$sum累加所有小计得到总价

场景2：仅知道用户X的name #

需要先从users集合定位用户ID，再关联购物车和商品数据：

db.users.aggregate([
  // 筛选名称为X的用户
  { $match: { name: "用户X的姓名" } },
  // 关联users_orders集合，获取该用户的购物车记录
  {
    $lookup: {
      from: "users_orders",
      localField: "_id",
      foreignField: "userId",
      as: "userOrders"
    }
  },
  // 展开购物车记录数组
  { $unwind: "$userOrders" },
  // 关联products集合，获取商品详情
  {
    $lookup: {
      from: "products",
      localField: "userOrders.prodId",
      foreignField: "_id",
      as: "product"
    }
  },
  // 展开商品信息数组
  { $unwind: "$product" },
  // 计算单商品小计
  {
    $addFields: {
      subtotal: { $multiply: ["$product.price", "$userOrders.quantity"] }
    }
  },
  // 汇总数据
  {
    $group: {
      _id: "$_id",
      userName: { $first: "$name" },
      cartItems: {
        $push: {
          productId: "$userOrders.prodId",
          productName: "$product.productname",
          price: "$product.price",
          quantity: "$userOrders.quantity",
          subtotal: "$subtotal"
        }
      },
      totalPrice: { $sum: "$subtotal" }
    }
  }
])

额外说明： #

• 如果users_orders中的userId或prodId是字符串类型而非ObjectId，请去掉代码中的ObjectId()包裹，直接传入字符串值
• 结果中的cartItems数组会包含用户购物车的所有商品详情，totalPrice即为这些商品的总价

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