调整流程
This commit is contained in:
parent
5626ff8527
commit
b291b7052f
@ -28,13 +28,14 @@ export class ConfirmQueue {
|
|||||||
if (task.status === ReqTaskStatus.WAIT_CONFIRM) {
|
if (task.status === ReqTaskStatus.WAIT_CONFIRM) {
|
||||||
task.status = ReqTaskStatus.WAIT_EXEC
|
task.status = ReqTaskStatus.WAIT_EXEC
|
||||||
task.endScheduleTime = Date.now()
|
task.endScheduleTime = Date.now()
|
||||||
|
await task.save()
|
||||||
await ChainTask.checkScheduleStatus(task.chainTaskId)
|
await ChainTask.checkScheduleStatus(task.chainTaskId)
|
||||||
} else if (task.status === ReqTaskStatus.WAIT_EXEC_CONFIRM) {
|
} else if (task.status === ReqTaskStatus.WAIT_EXEC_CONFIRM) {
|
||||||
task.status = ReqTaskStatus.SUCCESS
|
task.status = ReqTaskStatus.SUCCESS
|
||||||
task.endExecTime = Date.now()
|
task.endExecTime = Date.now()
|
||||||
|
await task.save()
|
||||||
await ChainTask.checkStatus(task.chainTaskId)
|
await ChainTask.checkStatus(task.chainTaskId)
|
||||||
}
|
}
|
||||||
await task.save()
|
|
||||||
} else {
|
} else {
|
||||||
if (task.status === ReqTaskStatus.WAIT_CONFIRM) {
|
if (task.status === ReqTaskStatus.WAIT_CONFIRM) {
|
||||||
task.status = ReqTaskStatus.SCHEDULE_REVERT
|
task.status = ReqTaskStatus.SCHEDULE_REVERT
|
||||||
|
Loading…
x
Reference in New Issue
Block a user