javascript - 对 Collection.find() 的每个元素求和

Question

我尝试总结适合特定查询的 DataPoints 集合的特定列。

getClicksTotalCampaign: function () {
    var docs = DataPoints.find({campaign: this._id, influencer: Meteor.userId()});
            var clicks = 0;
            for(var i = 0; i< docs.length; i++) {
                clicks += parseInt(docs[i].clicks);
            }
            return clicks;
    },

我对 DataPoints.find 对象数组的返回有误？它的长度始终为空，当我在 mongo 上进行查询时，我会返回条目。@edit 这里的数据模式:

Schemas.DataPoints = new SimpleSchema({

    influencer: {
        type: String,
        label: "Influencer ID"
    },
    advertiser: {
        type: String,
        label: "Advertiser ID"
    },
    campaign: {
        type: String,
        label: "Campaign ID"
    },
    amount: {
        type: Number,
        label: "Amount"
    }    
});

Answer 1

使用 aggregation framework 您可以在其中使用 $match 管道运营商过滤事件和影响者的集合。 <强> $group 管道步骤然后将来自过滤器的所有输入文档分组并应用累加器表达式 $sum 到该组以获取文档总数。

您的管道将如下所示:

var DataPoints = new Mongo.Collection('datapoints');
var pipeline = [
    {
        "$match": {
            "campaign": this._id, 
            "influencer": Meteor.userId()
        }
    },
    {
        "$group": {
            "_id": null,
            "count": {"$sum": "$amount"}
        }
    }
];
var result = DataPoints.aggregate(pipeline).fetch();
var count = result[0].count;

您可以添加 meteorhacks:aggregate package 在 Meteor 中实现聚合:

添加到您的应用中

meteor add meteorhacks:aggregate

由于此包在 Mongo.Collection 实例上公开了 .aggregate 方法，因此您可以调用该方法以获取具有 count 字段的文档的结果数组。例如

if (Meteor.isServer) {
    var DataPoints = new Mongo.Collection('datapoints');
    Meteor.methods({
        getClicksTotalCampaign: function () {
            var pipeline = [
                {
                    "$match": {
                        "campaign": this._id, 
                        "influencer": Meteor.userId()
                    }
                },                  
                {
                    "$group": {
                        "_id": null,
                        "count": {"$sum": "$amount"}
                    }
                }
            ];
            var result = DataPoints.aggregate(pipeline);
            return result[0].count;
        }
    }); 
}

if (Meteor.isClient) {
    setInterval(function () {
        Meteor.call('getClicksTotalCampaign', updateCounter);
    }, 1000 * 10);

    function updateCounter(err, count) {
        console.log("this is the new count: ", count)
    }
}