ノードjs foreach done関数

Question

setTimeoutを使用するように指示されていますが、foreachの完了後にはどうすればよいですか？

app.post('/grid', function(req, res){ 
    getResults(req.body.idarray, function(callback){ 
     res.send(callback); 
    }); 
}); 
function getResults(userIds, callback) { 
    var totalresult = []; 
    userIds.forEach(function (user) { 
     sequence 
      .then(function (next) { 
       db.query('SELECT given FROM books WHERE user_id = ?', [user.userId], function (err2, result) { 
        if (err2) throw err2; 
        next(err, result); 
       }); 
      }) 
      .then(function (next, err, books) { 
       db.query('SELECT received FROM encycs WHERE user_id = ?', [user.userId], function (err3, result2) { 
        if (err3) throw err3; 
        next(err, result2, books); 
       }); 
      }) 
      .then(function (next, err, books, encycs) { 
       Calculation(books, encycs, function (cb) { 
        totalresult.push(cb); 
       }); 
       next(); 
      }); 
    }); 
    setTimeout(function() { 
     console.log(totalresult); // output ok. 
     return callback(totalresult); // returning as expected 
    }, 2000); 
} 

私はtotalresult.lengthとは何か分かりません。だから私は長さを確認することはできません。

Answer 1

あなたのユースケースによれば、何らかの理由でコールバックをコールしてtotalresultを渡す必要があります。なぜなら、ルート内のコードが外部コードであるためです。 これを行うには、3番目の.thenステートメントのnextを呼び出す前にコールバックを呼び出すことができます。それで

 ... 
     .then(function (next, err, books, encycs) { 
      Calculation(books, encycs, function (cb) { 
       totalresult.push(cb); 
      }); 
      callback(totalresult); 
      next(); 
      //console.log(totalresult); //output OK. 
     }); 

これは機能する場合があります。

アップデート1

あなたのコードに従うことは困難です。それの論理に追いつくことはできません。私はあなたに約束のアプローチを提案します。私はその解決法を用意しました。それはほとんどエラーを含んでいないかもしれませんが、あなたが達成しようとしていることの主なアイデアと、それがどのようにできるかを表しています。

app.post("/grid", (req, res) => { 
    getResults(req.body.idarray) 
     .then(data => { 
      res.status(200).json(data); 
     }) 
     .catch(err => { 
      console.error("Error occured", err); 
      res.status(500).json(err); 
     }); 
}); 

function getResults(userIds) { 
    let promises = userIds.map(loadCalculation); 
    //this will wait until all loadings are done 
    return Promise.all(promises); 
} 

function loadCalculation(user) { 
    //parallel loading of the books and encycs 
    return Promise.all([loadBooks(user), loadEncycs(user)]) 
     .then(results => { 
      let books = results[0]; 
      let encycs = results[1]; 

      let totalresult = []; 

      Calculation(books, encycs, function (cb) { 
       totalresult.push(cb); 
      }); 

      return totalresult; 
     }); 
} 

function loadBooks(user) { 
    return makeQuery('SELECT given FROM books WHERE user_id = ?', user); 
} 

function loadEncycs(user) { 
    return makeQuery('SELECT received FROM encycs WHERE user_id = ?', user); 
} 

function makeQuery(query, user) { 
    return Promise((resolve, reject) => { 
     db.query(query, [user.userId], function (err, result) { 
      if(err) { 
       reject(err); 
      } else { 
       resolve(result); 
      } 
     });   
    }); 
} 

してください、ので、少なくとも、私は単一のクエリですべての書籍やencycsをロードする可能性は、あなたがそこにあることを確信している、これは実際にデータベースからデータをロードするパフォーマンスの方法ではありませんのでご注意あなたはSQLを使用しており、それは本当に柔軟な言語です。