获取MongoDB中查询之外的数据

Question

我正在做一个购物车，我必须获得产品的价格才能乘以数量，但我遇到了异步问题，我无法在循环的每次迭代中获得价格。

router.get('/cartlist', function(req, res) {
    var db = req.db;
    var collection = db.get('cart');
    collection.find({},{},function(e,docs){


		var totalPrice = 0;
    	for(var i in docs)
    	{
    		var name = docs[i].productname;
    		var amount = docs[i].amount;

    		var products = db.get('products');



    		var idPrice = 0;
    		getPrice(products, name, function(data)
    		{
    			idPrice = data;
    		});



    		console.log(idPrice);
    	}
        
        totalPrice += idPrice * amount;

		console.log(totalPrice);

        res.render('cartlist', {
            "cartlist" : docs
        });
    });
});

还有回调：

function getPrice(collection, name, callback)
{
	collection.findOne({"productname" : name}, {_id:0, price:1}, function(err, objs)
	{
		if(objs != null)
		 {
		 	callback(objs.price);
		 }
	});
}

当我显示 totalPrice 的值为 0 时。我该怎么做？我需要获取价格才能在循环中执行 totalprice += amount * price。谢谢。

Answer 1

假设您的购物车和产品集合具有以下最基本的架构：

购物车

- productname (reference to product collection on productname field)
- amount

产品

- productname
- price

然后使用聚合框架并运行一个管道，该管道采用 $lookup 运算符对同一数据库中的 products 集合执行左外连接以进行过滤，这将变得更加容易和高效在 "joined" 集合的文档中进行处理，然后使用 $sum 和 $multiply 管道计算总价强> 运算符。

下面的例子展示了你如何去做这个

router.get('/cartlist', function(req, res) {
    var db = req.db;
    var collection = db.get('cart');
    collection.aggregate([
        {
            "$lookup": {
                "from": "products",
                "foreignField": "productname",
                "localField": "productname",
                "as": "productList"
            }
        },
        { "$unwind": "$productList" },
        {
            "$group": {
                "_id": null,
                "totalPrice": {
                    "$sum": {
                        "$multiply": [
                            "$productList.price",
                            "$amount"
                        ]
                    }
                },
                "cartlist": { "$push": "$$ROOT" }
            }
        }

    ], function(err, result){
        console.log(result);
        console.log(result[0]);
        console.log(result[0].totalPrice);
        res.render("cartlist", result);
    });
});