fix some bug
This commit is contained in:
parent
595562dc86
commit
6fd22e3984
@ -50,7 +50,7 @@ export class ScheduleConfirmEventClass extends BaseModule {
|
|||||||
|
|
||||||
let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.transactionHash }, data)
|
let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.transactionHash }, data)
|
||||||
if (record.version === 1) {
|
if (record.version === 1) {
|
||||||
logger.log('receive events: ' + JSON.stringify(event.ids))
|
logger.log('receive events: ' + JSON.stringify(record.scheduleIds))
|
||||||
for (let id of record.scheduleIds) {
|
for (let id of record.scheduleIds) {
|
||||||
await new TaskSvr().parseOneSchedule(id)
|
await new TaskSvr().parseOneSchedule(id)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user