node.js - MongoDB 过滤器 $lookup 具有日期范围的文档

Question

我有一个查询，输出如下。

return ChallengeModel.aggregate([
    { $match: { is_processed: false,} },
    { $lookup: {
        from: 'scoreboards',
        let: { 'challengeId': '$_id' },
        pipeline: [{ $match: { $expr: { $eq: [ '$challenge_id', '$$challengeId' ]}} }],
        as: 'scoreboards'
    } }
]);

输出:

{
  "_id": "5b9679db0a3d61258aa3ffc3",
  "voucher_paid_by": "issuer",
  "start_date": "2018-09-03T00:00:00.000Z",
  "end_date": "2018-09-09T23:59:00.000Z",
  "accept_by_date": "2018-09-03T12:00:00.000Z",
  "scoreboards": [
    {
      "_id": "5b9757c68a6f1615d8e704d3",
      "user_id": "5b9667200a3d61258aa3ff9f",
      "date": "2018-09-01T00:00:00.000Z",
      "value": 2
    },
    {
      "_id": "5b9757c68a6f1615d8e704d3",
      "user_id": "5b9667200a3d61258aa3ff9f",
      "date": "2018-09-02T00:00:00.000Z",
      "value": 6
    },
    {
      "_id": "5b9757c68a6f1615d8e704d3",
      "user_id": "5b9667200a3d61258aa3ff9f",
      "date": "2018-09-03T00:00:00.000Z",
      "value": 5
    },
    {
      "_id": "5b9757c68a6f1615d8e704d3",
      "user_id": "5b9667200a3d61258aa3ff9f",
      "date": "2018-09-04T00:00:00.000Z",
      "value": 9
    },
    {
      "_id": "5b9757c68a6f1615d8e704d3",
      "user_id": "5b9667200a3d61258aa3ff9f",
      "date": "2018-09-05T00:00:00.000Z",
      "value": 7
    },

    {
      "_id": "5b9757c68a6f1615d8e704d3",
      "user_id": "5b9667200a3d61258aa3ff9f",
      "date": "2018-09-06T00:00:00.000Z",
      "value": 1
    }
  ]
}

我从输出中删除了 challenge_id，所以输出只是一个例子。

现在我想执行相同的查询，我只需要在 start_date 和 end_date 范围内的记分牌数据。

所以我做了这样的事情。

return ChallengeModel.aggregate([
    { $match: { is_processed: false,} },
    { $lookup: {
        from: 'scoreboards',
        let: { 'challengeId': '$_id', 'startDate': '$start_date', 'endDate': '$end_date' },
        pipeline: [{ $match: { 
            date: { $gte: '$$startDate', $lt: '$$endDate' },
            $expr: { $eq: [ '$challenge_id', '$$challengeId' ]}} 
        }],
        as: 'scoreboards'
    } }
]);

但它返回记分板的空数组。我做对了吗？

Answer 1

您需要使用 $expr与其他领域以及$match文档的相同字段。

ChallengeModel.aggregate([
  { "$match": { "is_processed": false,} },
  { "$lookup": {
    "from": "scoreboards",
    "let": { "challengeId": "$_id", "startDate": "$start_date", "endDate": "$end_date" },
    "pipeline": [
      { "$match": {
        "$expr": {
          "$and": [
            { "$eq": [ "$challenge_id", "$$challengeId" ] },
            { "$gte": [ "$date", "$$startDate" ] },
            { "$lt": [ "$date", "$$endDate" ] }
          ]
        }
      }}
    ],
    "as": "scoreboards"
  }}
])