正從async.forEachOf的值傳遞到async.waterfall

Question

我有一個問題想從一個查詢的值的下一個步驟內async.forEachOf，取決於if語句的運行，所以我可以傳遞到價值的async.waterfall

這裏的下一步是代碼：

async.waterfall([ 
    function(callback) { 
     db.query('select id from topics where description = ?', 
      [topic], function(err, rows){ 
       callback(err, rows); 
      }); 
    }, 
    function(rows, callback) { 
     var query = rows[0].id 
     db.query('select id, background, viewOrder, description from topics where parent = ? order by viewOrder', 
      [query], function(err, rows){ 
       callback(err, rows); 
      }); 
    }, 
    function(rows, callback){ 
     var callbackRows = rows; 
     async.forEachOf(callbackRows, function(row, key, callback){ 
      var topics 
      console.log('rows[key].id: ', callbackRows[key].id); 
      if (callbackRows[key].background == 0){ 
       var query = callbackRows[key].id 
       db.query('select id, background, viewOrder, description from topics where parent = ? order by viewOrder', 
        [query], function(err, rows){ 
         callbackRows[key].subTopics = rows; 
         topics = callBackRows; 
         console.log('rows from async.forEach db query: ', rows); 
         console.log("from inside asnyc.foreach", callbackRows); 
         }); 
      } 
      callback(); 
     }, function(){ 
      callback(null, topics); 
      console.log('forEachOf callback called'); 
     }); 
     // console.log(topics); 
    } 
], function(err, topics){ 
    console.log("from end of waterfall: ", topics); 
}); 

我試圖做這多種方式，目前我得到的錯誤是主題沒有在該行定義callback(null, topics)在async.forEachOf部

現在寫得比較累，我要去睡覺了。如果這需要改善，我會看到它。與此同時，我試圖做的是將async.forEachOf結尾的查詢結果附加到前面查詢返回值的數組中的元素。從那裏，我想發送這個在響應對象中的快遞，在async.waterfall的最後回調。

Answer 1

在第三部分中，回調需要在數據查詢完成後調用，但也在if語句的else部分中確保總是隻調用一次。

if (callbackRows[key].background == 0){ 
    var query = callbackRows[key].id 
    db.query('select id, background, viewOrder, description from topics where parent = ? order by viewOrder', 
     [query], function(err, rows){ 
      callbackRows[key].subTopics = rows; 
      topics = callBackRows; 
      console.log('rows from async.forEach db query: ', rows); 
      console.log("from inside asnyc.foreach", callbackRows); 
      callback(); 
      }); 
} else callback(); 

Answer 2

主題是不確定的，因爲它不是在要麼是函數的範圍，或父函數的範圍限定。在你的代碼中，topics是在forEachOf的迭代器函數中定義的。解決方案是簡單地在父功能中定義主題，例如

function(rows, callback){ 
     var callbackRows = rows; 
     var topics; // move the definition to here 
     async.forEachOf(callbackRows, function(row, key, callback){ 

Answer 3

您不需要topics。只需將rows傳入回調。即callback(null, rows);