關於 nodejs sequelize 事務批量拆分

sequelize執行事務的時候因為數據量可能會比較大要拆成100條update一組來執行，弄了半天終於可以了，代碼片段如下

const updateResult = [];//存放事務執行結果
const updateFailed = [];//存放失敗的批次
const batchAmount = 100;//拆分粒度

await sequelize.transaction(transaction => {
  return models.User.findAll(
    //查詢出要更新的數據
  )
}).then(async updateArray => {//得到上一個事務返回的要更新的數據
  //事務拆分循環
  for(let i = 0;i<Math.ceil(updateArray.length / batchAmount);i++){
    await sequelize.transaction(transaction => {
      let updateUserPromises = []
      for (var j = i * batchAmount; j < (i + 1) * batchAmount && j < updateArray.length; j++) {
        updateUserPromises.push(
          models.User.update({
              score: sequelize.literal('score + ' + updateArray[j].score)
            },
            {
              where: {
                id: updateArray[j].userId
              },
              transaction
            }
          )
        )
      }
      return Promise.all(updateUserPromises)
    }).then(function (result) {
      updateResult[i] = true
    }).catch(function (err) {
      console.log(err)
      updateResult[i] = false
    })
  }
  //獲取批量處理失敗的index
  updateResult.forEach((item,index)=> {
    if(!item){
      updateFailed.push(index)
    }
  });
  //檢查是否執行成功
  if(updateResult.length === Math.ceil(updateArray.length / batchAmount) && updateResult.indexOf(false) === -1){
    'success'
  }else{
    'failed'
  }
})

 這里脫褲子放屁了，實際上Promise.all()返回的還是Promise，既然是Promise就可以繼續放到Promise.all()里最后判斷最終的Promise.all([Promise.all(),Promise.all()...])就行了