diff --git a/server/web3dbspider/services/dbevent_process.js b/server/web3dbspider/services/dbevent_process.js index 306d5f8..a3157d0 100644 --- a/server/web3dbspider/services/dbevent_process.js +++ b/server/web3dbspider/services/dbevent_process.js @@ -40,14 +40,15 @@ class DbEventProcess extends BaseService { } async init(net, event) { - const {err, conn} = await app.getDbConn('BcEventDb0'); - this.conn = conn; + console.log(event); this.net = net; this.event = event; this.lastIdx = BigInt(0); this.eventConf = this.event['eventConf']; this.progInfo = this.event['progressInfo']; this.contractAddress = this.net.getContractAddressByName(this.getContractName()); + const {err, conn} = await app.getDbConn('BcEventDb0'); + this.conn = conn; this.lastIdx = await this.getLastIdx(); this.progInfo['proclastIdx'] = this.lastIdx.toString(); await this.start(); diff --git a/server/web3dbspider/tasks/dbspider.js b/server/web3dbspider/tasks/dbspider.js index e0fd616..735e38e 100644 --- a/server/web3dbspider/tasks/dbspider.js +++ b/server/web3dbspider/tasks/dbspider.js @@ -41,6 +41,7 @@ class DbSpider extends BaseTask { this.createPullDbEventService(net, event); this.createDbEventProcessService(net, event); }); + await utils.sleep(1000 * 10); this.outputProgressInfo(net, events); } @@ -52,14 +53,13 @@ class DbSpider extends BaseTask { } createDbEventProcessService(net, event) { - const DbEventProcessService = serviceFactory.create('DbEventProcess'); - event['dbEventProcessService'] = DbEventProcessService; - DbEventProcessService.init(net, event); - return DbEventProcessService; + const dbEventProcessService = serviceFactory.create('DbEventProcess'); + event['dbEventProcessService'] = dbEventProcessService; + dbEventProcessService.init(net, event); + return dbEventProcessService; } async outputProgressInfo(net, events) { - await utils.sleep(1000 * 10); let count = 0; while (true) { log.info('----------------------------------------------------------');