我如何确保我的聚合过滤出过期的mongo子文档？

Question

我想计算当前活动的resetPassword（用户架构中的子文档）代码数。要激活代码，其到期日期必须大于当前日期。

这是我的用户模式。如果有人请求重置密码，我们将把一个新的{code:X，expiresAt，createdAt}对象推送到数组中。

id: { type: String, unique: true },
resetPassword: [
  {
    code: String,
    expiresAt: Date,
    createdAt: Date,
  },
],

我在尝试对活动重置代码的总数求和时遇到问题。下面是我正在运行的查询，它返回一个空数组。。。请注意，如果要删除resetPassword。expiresAt:{$gt:nowdateinmillizes（）}match节，它将返回所有代码。我试着将这个匹配语句移出初始$match阶段，然后进行放松

[
  {
    $match: {
      "id": userId,
      'resetPassword.expiresAt': {
        $gt: nowDateInMillisec(),
      },
    },
  },
  {
    $group: {
      _id: '$id',
      totalValidResetCodes: {
        $sum: {
          $size: '$resetPassword',
        },
      },
    },
  },
]

这将返回一个空数组，即使我已将到期日期设置为将来的日期。

我还尝试了以下同样的结果（注意我如何在管道中添加$unwind和另一个$match）

[
  {
    $match: {
      "id": userId,
    },
  },
  {
    $unwind: '$resetPassword',
  },
  {
    $match: {
      'resetPassword.expiresAt': {
        $gt: nowDateInMillisec(),
      },
    }
  },
  {
    $group: {
      _id: '$id',
      totalValidResetCodes: {
        $sum: {
          $size: '$resetPassword',
        },
      },
    },
  },
]

• nowDateInMillisec（）-这只是以毫秒为单位返回当前日期

我做错了什么？

Answer 1

@乔在评论中回答了我的问题。他暗示在匹配过滤器中使用从纪元时间算起的毫秒是行不通的，因为我在Mongoose模式中使用了Date类型。

因此，我没有这样做：$gt:nowDateInMillisec（），我只是使用了一个Date类型，比如：$gt:newdate（），

Answer 2

下面是我的研究，当以mongoDB格式存储的日期格式也应该工作毫秒。下面的测试时间长达一分钟。

> db.users13.find().pretty();
{
        "_id" : ObjectId("5f4e03768379a4e3f957641d"),
        "id" : "johnc",
        "resetPassword" : [
                {
                        "code" : "abc",
                        "expiresAt" : ISODate("2020-09-02T09:11:18.394Z"),
                        "createdAt" : ISODate("2020-09-01T08:11:18.394Z")
                },
                {
                        "code" : "mno",
                        "expiresAt" : ISODate("2020-08-25T09:26:18.394Z"),
                        "createdAt" : ISODate("2020-08-25T08:11:18.394Z")
                }
        ]
}
{
        "_id" : ObjectId("5f4e06938379a4e3f957641f"),
        "id" : "katey",
        "resetPassword" : [
                {
                        "code" : "j2c",
                        "expiresAt" : ISODate("2020-09-02T08:48:18.394Z"),
                        "createdAt" : ISODate("2020-09-01T08:11:18.394Z")
                },
                {
                        "code" : "rml",
                        "expiresAt" : ISODate("2020-09-01T08:26:18.394Z"),
                        "createdAt" : ISODate("2020-09-01T08:11:18.394Z")
                }
        ]
}
> db.users13.aggregate([ 
   {$unwind:"$resetPassword"}, 
   {$match:{"resetPassword.expiresAt":{$gt:ISODate()}}} 
 ]).pretty();
{
        "_id" : ObjectId("5f4e03768379a4e3f957641d"),
        "id" : "johnc",
        "resetPassword" : {
                "code" : "abc",
                "expiresAt" : ISODate("2020-09-02T09:11:18.394Z"),
                "createdAt" : ISODate("2020-09-01T08:11:18.394Z")
        }
}
{
        "_id" : ObjectId("5f4e06938379a4e3f957641f"),
        "id" : "katey",
        "resetPassword" : {
                "code" : "j2c",
                "expiresAt" : ISODate("2020-09-02T08:48:18.394Z"),
                "createdAt" : ISODate("2020-09-01T08:11:18.394Z")
        }
}
> ISODate()
ISODate("2020-09-01T08:31:37.059Z")
>

Answer 3

你可以在$project中尝试$减少，而不是你的所有进程，你需要从这个now返回ISOdate DateInMillisec（），

db.collection.aggregate([
  { $match: { id: 1 } },
  {
    $project: {
      totalValidResetCodes: {
        $reduce: {
          input: "$resetPassword",
          initialValue: 0,
          in: {
            $add: [
              "$$value",
              {
                $cond: [
                  { $gt: ["$$this.expiresAt", nowDateInMillisec()] },
                  // If you really want to pass timestamp then try below line
                  // { $gt: ["$$this.expiresAt", { $toDate: nowDateInMillisec() }] },
                  1,
                  0
                ]
              }
            ]
          }
        }
      }
    }
  }
])

游乐场