那么 Promise 不起作用

Question

我有这个代码用于通过数据库进行统计报告。

exports.calculate = function(req, res, next) {
    models.Quiz.count()
    .then(function(questions) {
        statistics.questions = questions;
        models.Comment.count().then(function(comments) {
            statistics.comments = comments;
            statistics.average_comments = (statistics.comments / statistics.questions).toFixed(2);
            models.Quiz.findAll({
                include:    [{model: models.Comment}]})
            .then(function(quizes) {
                for (index in quizes) {
                    if (quizes[index].Comment.length) {
                        statistics.commented_questions++;
                    } else {statistics.no_commented++;}
                };
            })
        })
    })
    .catch(function(error) {next(error)})
    .finally(function() {next()});      
};

在 SQL 语句之前它可以正常工作，但从不循环 for，所以我永远无法得到 ​​p>

statistics.commented_questions

或

statistics.no_commented

先谢谢了！

Answer 1

当将 Promise 链接在一起时，他们需要知道前一个 Promise 何时被拒绝或履行。在您当前的代码中，初始承诺永远不会返回值/承诺，而是调用异步函数。代码在 JS 引擎看来基本上是这样的：

exports.calculate = function(req, res, next) {
  models.Quiz.count()
    .then(function(questions) {
      statistics.questions = questions;
      // ASYNC FUNCS THAT ARE NEVER RETURNED
      // ...
      // functions in JS without an explicit return statement return nothing (essentially `undefined`)
    })
    .catch(function(error) {
      next(error)
    })
    .finally(function() {
      next()
    });
};

因此，在引擎等待初始承诺被履行/拒绝后，它会触发另一个用于异步操作的承诺，该操作返回一个承诺，但不会将其返回到原始承诺链。默认情况下，原始承诺链接收undefined，然后将其传递给链中的下一个方法。在这种情况下，它将是 finally 方法。

您可能想知道，如果第二个 promise 没有等待它，为什么它仍在更新信息。这是一个竞争条件，本质上，承诺就是胜利。

要将 Promise 正确地链接在一起，您需要将新的 Promise 返回到旧的 Promise 链，如下所示：

exports.calculate = function(req, res, next) {
  models.Quiz.count().then(function(questions) {
    statistics.questions = questions;

    return models.Comment.count();
  }).then(function(comments) {
    statistics.comments = comments;
    statistics.average_comments = (statistics.comments / statistics.questions).toFixed(2);

    return models.Quiz.findAll({
      include: [{
        model: models.Comment
      }]
    });
  }).then(function(quizes) {
    for (index in quizes) {
      if (quizes[index].Comment.length) {
        statistics.commented_questions++;
      } else {
        statistics.no_commented++;
      }
    }
  }).catch(next).finally(next);
};

如果您使用的 Node/IO 版本支持原生 Promise 对象，您可以利用这一点来发出并发请求，因为它们都不相互依赖。注意：Promise API 没有finally() 方法，但我们可以使用then() 的第二个参数来传递错误。

exports.calculate = function(req, res, next) {
  Promise.all([
    models.Quiz.count(),
    models.Comment.count(),
    models.Quiz.findAll({
      include: [{
        model: models.Comment
      }]
    })
  ]).then(function(results)
    // `results` is an array of [questions, comments, quizes]
    statistics.questions = results[0];
    statistics.comments = results[1];
    statistics.average_comments = (statistics.comments / statistics.questions).toFixed(2);

    for (index in results[2]) {
      if (results[2][index].Comment.length) {
        statistics.commented_questions++;
      } else {
        statistics.no_commented++;
      }
    }
  }).then(next, next);
};