查找和匹配多个集合的问题

Question

在多个阶段存在聚合和查找问题。问题是我无法匹配 userId 在最后一次查找中。如果我省略 { $eq: ['$userId', '$$userId'] } 它可以工作并符合其他标准。但不是userid。

我已经尝试添加池作为 let 并在最后阶段将其用作 { $eq: ['$userId', '$$pools.userId'] }，但这也不起作用。我得到一个空的优惠券数组。

我通过以下查询得到了这个。我想我需要以某种方式使用$unwind？但还没有开始工作。有什么指点吗？

总共要加入三个集合。首先是 userModel，它应该包含池，然后池应该包含用户优惠券。

{
   "userId": "5df344a1372f345308dac12a", // Match this usedId with below userId coming from the coupon

   "pools": [
               {
                "_id": "5e1ebbc6cffd4b042fc081ab",
                "eventId": "id999",
                "eventStartTime": "some date",
                "trackName": "tracky",
                "type": "foo bar",
                "coupon": []
               }
            ]
  },

我需要在优惠券数组中填充正确的数据（如下），其中包含匹配的 userId。

"coupon": [
                {
                    "eventId": "id999",
                    "userId": "5df344a1372f345308dac12a",  // This userId need to match the above one
                    "checked": true,
                    "pool": "a pool",
        }           

池项目：

const poolProject = {
    eventId: 1,
    eventStartTime: 1,
    trackName: 1,
    type: 1,
  };

用户项目：

const userProjection = {
    _id: {
      $toString: '$_id',
    },
    paper: 1,
    correctBetsLastWeek: 1,
    correctBetsTotal: 1,
    totalScore: 1,
    role: 1,
  };

聚合查询

  const result = await userModel.aggregate([
{ $project: userProjection },
{
  $match: {
    $or: [{ role: 'User' },
      { role: 'SuperUser' }],
  },
},
{ $addFields: { userId: { $toString: '$_id' } } },
{
  $lookup: {
    from: 'pools',
    as: 'pools',
    let: { eventId: '$eventId' },
    pipeline: [
      { $project: poolProject },
      {
        $match: {
          $expr: {
            $in: ['$eventId', eventIds],
          },
        },
      },
      {
        $lookup: {
          from: 'coupons',
          as: 'coupon',
          let: { innerUserId: '$$userId' },
          pipeline: [
            {
              $match: {
                $expr: {
                  $eq: ['$userId', '$$innerUserId'],
                },
              },
            },
          ],
        },
      },
    ],
  },
},
]);

感谢您的任何意见！

编辑： 如果我移动第二个查找（优惠券），使它们处于相同的“级别”，它可以工作，但我希望将它放在池中。如果我添加as: 'pools.coupon'，在最后一次查找中它会覆盖查找的池数据。

Answer 1

当您访问带有 $$ 前缀的字段时，这意味着它们被 Mongo 定义为“特殊”系统变量。

我们不知道 Mongo 的魔法究竟是如何发生的，但您用相同的名称命名了两个变量，这似乎会导致冲突。

所以要么从第一次查找中删除userId: '$userId'，因为你甚至没有使用它。

或将userId: '$userId' 重命名或第二个名称，例如innerUserId: '$userId'，以避免在访问时发生冲突。

之后别忘了把{ $eq: ['$userId', '$$userId'] }改成{ $eq: ['$userId', '$$innerUserId'] }。

编辑：

既然已经清楚 pools 集合中没有字段 userId，只需将第二个 lookup 集合中的变量更改为：

let: { innerUserId: '$userId' } //userId does not exist in pools.

收件人：

let: { innerUserId: '$$userId' }