MongoDB聚合$in报错：需数组作为第二个参数，实际为objectId

错误原因 #

控制台报错$in requires an array as a second argument, found: objectId，说明你在$in操作中传入的第二个参数不是数组，而是单个ObjectId。问题出在购物车集合的products字段——代码里用$in: ['$_id', '$$prodList']，但$$prodList对应的$products字段实际是单个ObjectId值，而非数组类型。

修复方案 #

情况1：购物车集合的products字段应该是数组（推荐，适配多商品场景） #

如果业务设计中购物车需要存储多个商品，先检查数据库内已有购物车数据的结构是否符合数组要求。若要兼容现有单个值的数据，可在聚合查询中把products统一转为数组：

修改getCartProducts中的$lookup部分：

getCartProducts: userId => {
    return new Promise(async (resolve, reject) => {
      let CartItems = await db
        .get()
        .collection(Collection.CART_COLLECTIONS)
        .aggregate([
          {
            $match: { user: objectId(userId) },
          },
          {
            $lookup: {
              from: Collection.PRODUCT_COLLECTIONS,
              // 用$cond判断并转换为数组，兼容单个值的情况
              let: { prodList: { $cond: [{ $isArray: '$products' }, '$products', ['$products']] } },
              pipeline: [
                {
                  $match: {
                    $expr: {
                      $in: ['$_id', '$$prodList'],
                    },
                  },
                },
              ],
              as: 'CartItems',
            },
          },
        ])
        .toArray();
      resolve(CartItems);
    });
  },
};

情况2：购物车集合的products字段确实是单个ObjectId #

如果业务逻辑限定购物车仅存一个商品，直接将$in替换为$eq即可：

getCartProducts: userId => {
    return new Promise(async (resolve, reject) => {
      let CartItems = await db
        .get()
        .collection(Collection.CART_COLLECTIONS)
        .aggregate([
          {
            $match: { user: objectId(userId) },
          },
          {
            $lookup: {
              from: Collection.PRODUCT_COLLECTIONS,
              let: { prodId: '$products' },
              pipeline: [
                {
                  $match: {
                    $expr: {
                      $eq: ['$_id', '$$prodId'],
                    },
                  },
                },
              ],
              as: 'CartItems',
            },
          },
        ])
        .toArray();
      resolve(CartItems);
    });
  },
};

额外提示 #

• 优先选择情况1的数组设计，购物车场景几乎都会涉及多商品存储，数组结构扩展性更强。
• 同步检查购物车商品的插入逻辑，确保新增商品时是往products数组中push，而非直接赋值覆盖。

内容的提问来源于stack exchange，提问作者Krishnadev. V