diff --git a/src/controllers/workflow.controller.ts b/src/controllers/workflow.controller.ts index 06dde70..2c2594f 100644 --- a/src/controllers/workflow.controller.ts +++ b/src/controllers/workflow.controller.ts @@ -108,16 +108,16 @@ class WorkFlowController extends BaseController { // let fileId = 'WWME_g-oYEAAAzSUkPNpznkoGbgD2f1bDCA.xlsx' // await new WechatWorkService().fetchFile(fileId) // console.log('11') - let spNo = '202304070010' - // new TaskQueue().addTaskToQueue(spNo) - let task = await ChainTask.findById('642fe42611845ce0e1def316') - for (let tid of task.tasks) { - let subTask = await RequestTask.findById(tid) - let { scheduleId } = new BlockChain().walletReactor.genOperation(subTask) - subTask.scheduleId = scheduleId - await subTask.save() - new ChainQueue().addTaskToQueue(subTask) - } + let spNo = '202304140001' + new TaskQueue().addTaskToQueue(spNo) + // let task = await ChainTask.findById('642fe42611845ce0e1def316') + // for (let tid of task.tasks) { + // let subTask = await RequestTask.findById(tid) + // let { scheduleId } = new BlockChain().walletReactor.genOperation(subTask) + // subTask.scheduleId = scheduleId + // await subTask.save() + // new ChainQueue().addTaskToQueue(subTask) + // } // let { id } = req.params // let record = await RequestTask.findById(id) // if (record) {