猫鼬获得多个集合并进行计算[重复]

Question

这是我的代码

module.exports.comparator = function(req, res){
    Buyer
    .find()
    .exec(function (err, buyer) {
        if (err) {
            console.log("Error finding buyer");
            res
                .status(500)
                .json(err);
        } else {
            console.log("Found buyer", buyer.length);
            res
                .json(buyer);
            buyerData = buyer;
        }
    });

    Seller
        .find()
        .exec(function (err, seller) {
            if (err) {
                console.log("Error finding seller");
                res
                    .status(500)
                    .json(err);
            } else {
                console.log("Found seller", seller.length);
                res
                    .json(seller);
                sellerData = seller;
            }
        });

})

如您所见，我正在尝试获取 2 个集合并将它们存储到一个变量中，因为我想进一步编码为...

buyerData.forEach((buyer) => {
    sellerData.forEach((seller) => {
      console.log(buyer.bidPrice , seller.askPrice)
      if(buyer.bidPrice == seller.askPrice){

但是每当我运行它时，我都会收到这样的错误

Error: Can't set headers after they are sent.
    at validateHeader (_http_outgoing.js:491:11)
    at ServerResponse.setHeader (_http_outgoing.js:498:3)
    at ServerResponse.header (E:\eClass\node_modules\express\lib\response.js:767:10)
    at ServerResponse.send (E:\eClass\node_modules\express\lib\response.js:170:12)

那么我是否可以从这些不同的集合中获取数据并对它们进行其他计算？

Answer 1

你可以promisifymongoose，然后完全控制你的异步操作，即：

getBuyer()
.then( buyer => getSeller(buyer) )
.then( calculateAndResponse )
.catch( handleError );

因此，您关于让卖家、买家和操纵他们的逻辑进入小方法。

如果您的环境允许，您也可以考虑使用asyncawait。那么代码库可能是这样的：

const buyer = await getBuyer();
const seller = await getSeller(buyer);
const response = await calculate(buyer, seller);
//...

这也可以在没有 promise 的情况下通过回调来完成，但它很可能会变成 回调地狱，所以在我看来，使用 promise 更好。