将猫鼬查询（承诺）添加到数组并进行并行操作

Question

我正在使用 mongoose 在 MongoDB 中进行一些操作。我想搜索用户创建的所有任务，然后将值 isPerforming 设置为 false 并保存。 文档说猫鼬查询（带有.exec() 函数）是承诺的。有很多任务，所以我认为将它们推送到数组并使用Q.all([...]) 进行并行保存操作。问题是当我尝试做.push() 时。我的代码在第一次 .push() 操作后停止。 还有其他方法吗？

 function stopUserTasks(userid) {

    var deferred = Q.defer();
    var query = Task.find({'_creator': userid}).exec();

    query.then(function(data, err) {
        console.log('found: ');
        console.log(data);
        if (err) {
          deferred.reject(err);
        }
        return data;
      })
      .then(function(data, err) {

        var len = data.length;
        var saveTasksPromises = [];

        for(var i = len; i--; ) {
          console.log(data[i]._id);
          saveTasksPromises.push(Task.save({'_id': data[i]._id, 'isPerforming': false}).exec() );
        }
        return saveTasksPromises;

      })
      .then(function(data, err) {
        console.log(data);

        deferred.resolve();
      });

      return deferred.promise;

  }// #stopUserTasks

Answer 1

Model.save()实际上返回promise，所以不需要写Model.save().exec()，所以你的行需要调整如下：

saveTasksPromises.push(Task.save({'_id': element._id, 'isPerforming': false}))

同样使用Q.all，整个函数如下：

function stopUserTasks(userid) {
  var deferred = Q.defer();
  var promise = Task.find({'_creator': userid}).exec();

  promise
    .then(function(data) {
      var len = data.length;
      var saveTasksPromises = [];

      for(var i = len; i--; ) {
        saveTasksPromises.push(Task.save({'_id': data[i]._id, 'isPerforming': false}));
      }
      return Q.all(saveTasksPromises);
    })
    .then(function(data) {
      deferred.resolve(data);
    });
    .catch(function(err) {
      deferred.reject(err);
    });
    return deferred.promise;
}