mongoose mpromise onResolve before before before

在我的代码中，onResolve（）函数在第一个函数之后被调用，在任何其他函数之前（当req.body.length> 1时看到它）。任何想法为什么？我想将保存的资产列表添加到数组中，然后在所有findOneAndUpdate执行完成后在响应中发送该数组。mongoose mpromise onResolve before before before

exports.saveAssetLists = function(req, res) { 
    console.log('starting save asset lists'); 
    if (!Common.testIfValidForSave(req.body, true)) { 
    res.status(400).send({error:'Invalid request body: ' + JSON.stringify(req)}); 
    return; 
    } 

    var deferred = null; 
    var savedAssetLists = []; 
    for (var i = 0; i < req.body.length; i++) { 
    var newAssetList = new AssetList(req.body); 
    var d = AssetList.findOneAndUpdate({_id: newAssetList._id }, newAssetList, {upsert:true, new:true}).exec().then(function(obj) { 
     console.log('then - obj: ' + JSON.stringify(obj)); 
     savedAssetLists.push(obj); 
    }); 
    if (!deferred) { 
     deferred = d; 
    } else { 
     deferred.chain(d); 
    } 
    } 
    deferred.onResolve(function(err, result) { 
    console.log('onResolve - err: ' + err + ', result: ' + result + ', savedAssetLists: ' + savedAssetLists); 
    res.send({data: savedAssetLists}); 
    }) 
    .onReject(function(err) { 
    res.status(500).send({error: err}); 
    }); 
    return deferred; 
};

这是日志输出：

starting save asset lists 
then - obj: {"_id":"561eafe95c0df2c0468cb798","name":"Asset List 1","__v":0,"assets":[null]} 
onResolve - err: null, result: undefined, savedAssetLists: { _id: 561eafe95c0df2c0468cb798, 
    name: 'Asset List 1', 
    __v: 0, 
    assets: [ null ] } 
then - obj: {"_id":"561eafe95c0df2c0468cb799","name":"Asset List 2","__v":0,"assets":[null]}

按照从梅耶一个建议，我改变了我的代码以下，但当时的方法不会被调用：

exports.saveAssetLists = function(req, res) { 
    console.log('starting save asset lists'); 
    if (!Common.testIfValidForSave(req.body, true)) { 
    res.status(400).send({error:'Invalid request body: ' + JSON.stringify(req)}); 
    return; 
    } 

    var promises = []; 
    var savedAssetLists = []; 
    for (var i = 0; i < req.body.length; i++) { 
    var newAssetList = new AssetList(req.body[i]); 
    var p = AssetList.findOneAndUpdate({_id: newAssetList._id }, newAssetList, {upsert:true, new:true}).exec(); 
    promises.push(p); 

    } 
    Promise.all(promises).then(function(values) { 
    console.log('onResolve - err: ' + err + ', values: ' + values + ', savedAssetLists: ' + savedAssetLists); 
    res.send({data: values }); 
    }, function(err) { 
    res.status(500).send({error: err}); 
    }); 
};

来源

2015-10-14 user1387717

为什么你需要这样一个复杂的调用，如果你可以使用只是得到一堆承诺，把它们推到'Promise.all'并在里面得到结果呢？ –

很好的问题。根据我的控制台，mongoose.Promise.all（）不存在 – user1387717

它不是'mongoose.Promise.all'，它只是'Promise.all'。我会做出回答 –

你可以做的是在req.body之外创建一系列承诺：

var promises = req.body.map(function(data){ 
    var newAssetList = new AssetList(data); 
    return AssetList.findOneAndUpdate({_id: newAssetList._id }, newAssetList, {upsert:true, new:true}) 
}); 

Promise.all(promises).then(function(results){ 
    return res.send({data: results}); 
}).catch(function(err){ 
    return res.status(500).send({error: err}); 
});

小记：代码中不需要mpromise库。这应该适用于猫鼬4+

来源

2015-10-14 19:55:40

嗨，谢谢你的答案。我做了几乎相同的（几乎），然后函数永远不会被调用（请参阅我上面的编辑） – user1387717

您不需要调用'exec'作为'findOneAndUpdate'返回一个承诺。试试我的代码 –

谢谢！你的代码工作！虽然我不明白为什么我没有删除.exec（）语句之后甚至没有。 – user1387717

mongoose mpromise onResolve before before before

回答

相关问题