diff --git a/src/config/events.json b/src/config/events.json index d6459f9..cb62d99 100644 --- a/src/config/events.json +++ b/src/config/events.json @@ -3,7 +3,7 @@ "address": "0x8135D4F16A7AAA269cbf61CE9659D3A272BF541f", "event": "Confirmation", "abi": "BEMultiSigWallet", - "fromBlock": 34225225, + "fromBlock": 34353697, "eventProcesser": "ScheduleConfirmEvent" } ] diff --git a/src/models/ScheduleConfirmEvent.ts b/src/models/ScheduleConfirmEvent.ts index c1794e5..ad9a5d6 100644 --- a/src/models/ScheduleConfirmEvent.ts +++ b/src/models/ScheduleConfirmEvent.ts @@ -1,5 +1,6 @@ import { getModelForClass, index, modelOptions, prop } from '@typegoose/typegoose' import { dbconn } from 'decorators/dbconn' +import logger from 'logger/logger' import { TaskSvr } from 'service/task.service' import { BaseModule } from './Base' @@ -31,6 +32,7 @@ export class ScheduleConfirmEventClass extends BaseModule { public version: number public static async saveEvent(event: any) { + logger.info(JSON.stringify(event)) if (!event.success) { return } @@ -48,6 +50,7 @@ export class ScheduleConfirmEventClass extends BaseModule { let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.hash }, data) if (record.version === 1) { + logger.log('receive events: ' + JSON.stringify(event.ids)) for (let id of event.ids) { await new TaskSvr().parseOneSchedule(id) }