node.js - 异步方法，迭代器应该在更新发生时发生

Question

我有一个正在使用 Asynch.forEachSeries 迭代的数组。在迭代器中，我找到了模型并进行了更新。更新发生后，我需要迭代第二个项目。找到下面的代码。

async.eachOfSeries(stockUpdate, function (valueSU, keySU, callbackSU) {

    ProductVariations.findOne({id:valueSU.id}).exec(function (ePV,dPV){
       dPV.available_stock = parseInt(dPV.available_stock) - Qty; 
       dPV.save(function (errDPV) {   
             callbackSU(); // HERE ONCE, NEXT ITERATOR SHOULD BE CALLED
       });
    });

}, function (err) {
 if (err) callback(err.message);                     

});

Answer 1

我认为您应该将“ProductVariations...”包装在 promise 中。等待，直到它解决。然后调用下一个迭代器。

这段代码必须解决你的任务

let promiseProductVariations = function (valueSU, keySU) {
return new Promise(function (resolve, reject) {
    ProductVariations.findOne({id:valueSU.id}).exec(function (ePV,dPV){
        dPV.available_stock = parseInt(dPV.available_stock) - Qty;
        dPV.save(function (errDPV) {
            if(errDPV){
                reject(errDPV);
            }else{
                resolve(); // HERE ONCE, NEXT ITERATOR SHOULD BE CALLED
            }
        });
    });
})};

async.eachOfSeries(stockUpdate, function (valueSU, keySU, callbackSU) {
    promiseProductVariations(valueSU, keySU)
    .then(function () {
        callbackSU();
    })
    .catch(function (error) {
        if(error)
            console.log(error);
        //do thomething with error
    });
}, function (err) {
    if (err) callback(err.message);
});