for循环中的promise问题

Question

我遇到了一个让我有点发疯的情况。

所以情况如下：

module.exports = {
  
  generation: function (req, res) {

    // Let's firstly fetch all the products from the productTmp Table
    function fetchProductsTmp (){
      ProductsTmp.find().then(function (products) {
        return Promise.all(products.map (function (row){
           Service.importProcess(row);
        }));
      });
    }
    fetchProductsTmp();
  }

在这里我只是调用我的模型 ProductsTmp 来获取我的数据并遍历我调用 importProcess 的行。

导入过程：

importProcess: function (product) {

    async.series([
      function (callback) {
        return SousFamille.findOne({name: product.sous_famille}).then(function (sf) {
          console.log('1');
          if (!sf) {
            return SousFamille.create({name: product.sous_famille}).then(function (_sf)             {
              console.log('2');
              callback(null, _sf.sf_id);
            });
          } else {
              callback(null, sf.sf_id);
          }
        });
      },
      function (callback){
        console.log('3');
      },
    ], function(err, results){
      if(err) return res.send({message: "Error"});

    });
      
}

所以我得到了我的控制台日志： 1 1 1 2 3 2 3 2 3

我想要获取的是 1 2 3 1 2 3 1 2 3 以便每个函数在调用下一个函数之前等待 promise 完成。

Answer 1

在第一节的generation函数中，替换

return Promise.all(products.map (function (row){
    Service.importProcess(row);
}));

与

var results = [],
    pushResult = id => results.push(id);
return products.reduce(function(prev, row){//Go through all the products
    //Take the previous promise, and schedule next call to Service.importProcess to be
    //made after the previous promise has been resolved
    return prev.then(function(){
        return Service.importProcess(row).then(pushResult);
    });
}, Promise.resolve())
.then(() => results);

您还需要从importProcess 返回一个promise 才能使其正常工作。扔掉整个async.series 的东西，做类似的事情

return new Promise(function(resolve, reject){
     ...
     resolve(sf.sf_id); //instead of the callback(null, sf.sf_id)
     ...
});

更新：这会强制对 Service.importProcess 的调用是顺序的，而不是并发的，这确实会影响对 generation 的调用的整体性能。但我想你有比顺序 console.logs 更充分的理由这样做。

Answer 2

对不起，在 ES6 中控制不住做它的冲动，基本上事情可以简化为单行，就像 Bergi 说的，异步是多余的（使用 Bluebird Promise 库）：

importProcess: product => 
                  SousFamille.findOne({name: product.sous_famille})
                    .then(sf =>  sf? sf.sf_id : SousFamille.create({name: product.sous_famille}).then(_sf => _sf.sf_id))

// the other module
module.exports = {

  generation: (req, res) => ProductsTmp.find()
                              .then(products => Promise.mapSeries(products, Service.importProcess.bind(Service)) )
                              .then(ids => res.send({ids}))
                              .catch(error => res.send({message: 'Error'}))
  }

也像 noppa 所说，你的问题是 Service.importProcess(row) 中缺少 return，ES5 中的代码相同：

module.exports = {

  generation: function (req, res) {

      ProductsTmp.find()
        .then(function (products) {
          return Promise.mapSeries(products, Service.importProcess.bind(Service)) );
      }).then(function(ids){
        res.send({ids: ids});
      }).catch(function(error){
        res.send({message: 'Error'});
      })
}


importProcess: function (product) {

    return SousFamille.findOne({name: product.sous_famille})
      .then(function (sf) {
          if (sf) return sf.sf_id;
          return SousFamille.create({name: product.sous_famille})
                    .then(function (_sf){ return _sf.sf_id});
    });      
}