如何在MongoDB集合中分别对几个月的数据求和

Question

我试图在集合的子数组中对字段进行计数，我希望每个月都这样做。我曾在Mongo 2.6中使用过此功能，但最近升级到3.0.12导致查询中出现一些错误结果。这几个查询的总和似乎没有重置。

因此，目前我正在异步执行12个查询，并等待它们全部完成。这同样适用于2.6。我的表格结构如下：

{
"_id" : ObjectId("<id>"),
"userId" : ObjectId("<id>"),
"accountId" : "1234567890",
"transactionId" : "22222222333",
"date" : ISODate("2016-09-08T04:00:00.000Z"),
"description" : "SUPERCOOL STORE",
"amount" : -123.45,
"allocations" : [ 
    {
        "jarId" : ObjectId("566faf1937af9ae11ef84bc4"),
        "amount" : -100
    }, 
    {
        "jarId" : ObjectId("566faf1937af9ae11ef84bc1"),
        "amount" : -23.45
    }
],
"reconciled" : true,
"tally" : true,
"split" : true
}

这是我的代码：

var getTransactionAggregate = function (userId, month) {
  var deferred = q.defer();
  var nextMonth = moment(month).add(1, 'M');

  Transactions.aggregate([
    {$match: {
      userId: userId,
      tally: true,
      date: {
        $gte: month.toDate(),
        $lt: nextMonth.toDate()
      }
    }},
    {$project: { _id: 0, allocations: 1 } },
    {$unwind: '$allocations'},
    {$group: {_id: '$allocations.jarId', total: {$sum: '$allocations.amount'}}}
  ]).then(function(data) {
    deferred.resolve(data);
  })
  .catch(function (err) {
    logger.error(err);
    deferred.reject(err);
  });

  return deferred.promise;
};

summaryReport = function (req, res) {
  Jars.aggregate([
    { $match: {userId: new ObjectID(req.user._id)} },
    { $sort: {name: 1} }
  ])
  .then(function (jars) {
    var month = moment(moment().format('YYYY-MM') + '-01T00:00:00.000');
    var i, j;
    var promises = [];

    for (i = 0; i < 12; i++) {
      promises.push(getTransactionAggregate(new ObjectID(req.user._id), month));
      month.add(-1, 'M');
    }

    q.allSettled(promises).then(function (data) {
      for (i = 0; i < data.length; i++) {
        // data[i].value here is returned incorrectly from the queries

        ........
    });
  });
};

因此，从本质上讲，第一个月包含的数据是正确的，但总和似乎继续包含前几个月的数据。如果我分解查询，则会在日期范围内返回正确的事务，并且展开也会起作用。就在groupBy step似乎是罪魁祸首的时候。在我将Mongo升级到3.0.12之前，同样的逻辑运行良好。

是否有更好的方法一次性执行此查询，或者执行12个查询是最好的方法？

Answer 1

它最终与比赛有关，尽管不是因为上述答案中提到的美元和案例。这与日期匹配有关，我猜是时刻对象。toDate（）返回的日期对象与使用new date（）时返回的日期对象不同，尽管我认为它们是相同的。

无论如何，工作逻辑如下所示：

Transactions.aggregate([
  {$match: {
    userId: userId,
    tally: true,
    $and: [
      { date: { $gt : new Date(month.toISOString()) } },
      { date: { $lt: new Date(nextMonth.toISOString()) } }
    ]
  }},
  {$unwind: '$allocations'},
  {$group: {_id: '$allocations.jarId', total: {$sum: '$allocations.amount'}}}
])

信用到日期查询与ISODate在mongoDB似乎不工作和@Leif为我指明了正确的方向。

Answer 2

这似乎是$匹配阶段的问题。您的date字段有两个表达式，在这种情况下您需要使用$和运算符，如文档中指定的：

MongoDB在指定逗号分隔的表达式列表时提供隐式AND操作。当必须在多个表达式中指定相同的字段或运算符时，必须使用带有$和运算符的显式AND。

因此它变成：

{$match: {
    userId: userId,
    tally: true,
    $and: [
        { date: { $gte : month.toDate() } },
        { date: { $lt: nextMonth.toDate() } }
    ]
}}