From 47752617ddb467c43c2c9d5a09ac3ac90186df1e Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 3 Jul 2023 19:38:58 +0800 Subject: [PATCH] 1 --- server/web3bcspider/services/pull_bcevent.js | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/server/web3bcspider/services/pull_bcevent.js b/server/web3bcspider/services/pull_bcevent.js index cc3644d..b78a4e0 100644 --- a/server/web3bcspider/services/pull_bcevent.js +++ b/server/web3bcspider/services/pull_bcevent.js @@ -25,7 +25,7 @@ class PullBcEvent extends BaseService { } async pullEvent() { - const logHead = this.getInstanceName() + ' pullEvent:'; + const logHead = this.getInstanceName() + ' pullEvent: '; while (true) { await this.bc.lockQuery(); try { @@ -78,7 +78,7 @@ class PullBcEvent extends BaseService { } async getFromBlock() { - const logHead = this.getInstanceName() + ' getFromBlock:'; + const logHead = this.getInstanceName() + ' getFromBlock: '; const firstBlockNumber = this.getInitBlock(); while (this.lastBlockNumber < 1) { try { @@ -92,7 +92,7 @@ class PullBcEvent extends BaseService { ); if (!err) { if (row) { - this.lastBlockNumber = Number(row['value']); + this.lastBlockNumber = Number(row['block_number']); } else { this.lastBlockNumber = firstBlockNumber; } @@ -125,7 +125,7 @@ class PullBcEvent extends BaseService { } async saveLastBlockNumber(blockNumber) { - const logHead = this.getInstanceName() + ' event_process.saveLastBlockNumber'; + const logHead = this.getInstanceName() + ' event_process.saveLastBlockNumber: '; while (true) { const {err} = await this.conn.upsert( 't_last_block', @@ -155,7 +155,7 @@ class PullBcEvent extends BaseService { } async saveToDb(event) { - const logHead = this.getInstanceName() + ' event_process.saveToDb'; + const logHead = this.getInstanceName() + ' event_process.saveToDb: '; while (true) { const nowTime = utils.getUtcTime(); const returnValues = event['returnValues'];