From 4bf1275386c2e4fe811fcba757f313435f16b24b Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Thu, 13 Jul 2023 15:07:18 +0800 Subject: [PATCH] 1 --- server/web3bcspider/services/pull_bcevent.js | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server/web3bcspider/services/pull_bcevent.js b/server/web3bcspider/services/pull_bcevent.js index 2003694..fa7d878 100644 --- a/server/web3bcspider/services/pull_bcevent.js +++ b/server/web3bcspider/services/pull_bcevent.js @@ -86,7 +86,8 @@ class PullBcEvent extends BaseService { const firstBlockNumber = this.getInitBlock(); while (this.lastBlockNumber < 1) { try { - const {err, row} = await dbpool.getBcEventConn(app)( + const {err, row} = await dbpool.getBcEventConn( + app, 'ormSelectOne', 't_last_block', [ @@ -133,7 +134,8 @@ class PullBcEvent extends BaseService { async saveLastBlockNumber(blockNumber) { const logHead = this.genLogHead(' event_process.saveLastBlockNumber: '); while (true) { - const {err} = await dbpool.getBcEventConn(app)( + const {err} = await dbpool.getBcEventConn( + app, 'upsert', 't_last_block', [ @@ -170,7 +172,8 @@ class PullBcEvent extends BaseService { const nowTime = utils.getUtcTime(); const returnValues = event['returnValues']; const hashCode = ''; - const {err} = await dbpool.getBcEventConn(app)( + const {err} = await dbpool.getBcEventConn( + app, 'upsert', 't_blockchain_event', [