我目前正在尝试从通过请求收到的项目列表中推送到数组(Mongo模型中的属性)。从这些项目中,我遍历它们以查看数据库中当前存在哪个项目,如果不是这种情况,那么我创建一个新项目并尝试保存它。我正在使用诺言来完成此任务,但是我无法弄清为什么在所有诺言都实现后数组为空。
var q = require('q');
var items_to_get = ['1', '2', '3']; // example array
var trans = new Transaction({
items : []
});
var promises = [];
for (var i = 0; i < items_to_get.length; i++) {
var ith = i; //save current i, kinda hacky
var deferred = q.defer(); //init promise
//find an existing item
Item.findOne({simcode: items_to_get[ith]}, function(err, item) {
trans.items.push(item); // push item to transaction
deferred.resolve(item); // resolve the promise
});
promises.push(deferred); // add promise to array, can be rejected or fulfilled
};
q.allSettled(promises).then(function(result) {
console.log(trans.items); //is empty
trans.save();
}
编辑解决:以下代码基于http://jsbin.com/bufecilame/1/edit?html,js,output ..点数转到@macqm
var items_to_get = ['1', '2', '3'];
var promises = []; //I made this global
items_to_get.forEach(item) {
upsertItem(item);
}
q.allSettled(promises).then(function(result) {
//loop through array of promises, add items
result.forEach(function(res) {
if (res.state === "fulfilled") {
trans.items.push(res.value);
}
});
trans.save();
promises = []; //empty array, since it's global.
}
//moved main code inside here
function upsertItem(item) {
var deferred = q.defer(); //init promise
//find an existing item
Item.findOne({simcode: item}, function(err, item) {
deferred.resolve(item); // resolve the promise
// don't forget to handle error cases
// use deffered.reject(item) for those
});
promises.push(deferred); // add promise to array
}
代替
promises.push(deferred);
...尝试...
promises.push(deferred.promise);
同样,由于您的诺言正在解决仍保存的项目,因此您可以将结果q.allSettled(...)
用作项目:
q.allSettled(promises).then(function(results) {
trans.items = results;
trans.save();
});
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句