From 89fc7388a59d20c6e73d30a2483a8c9022d7615a Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 11 Jul 2023 19:16:44 +0800 Subject: [PATCH] 1 --- server/web3dbspider/services/dbevent_process.js | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/web3dbspider/services/dbevent_process.js b/server/web3dbspider/services/dbevent_process.js index 980452c..1afd2df 100644 --- a/server/web3dbspider/services/dbevent_process.js +++ b/server/web3dbspider/services/dbevent_process.js @@ -219,9 +219,6 @@ class DbEventProcess extends BaseService { async process(row) { const logHead = this.getInstanceName() + ' process: '; - if (!this.eventHandle) { - return false; - } while (true) { try { const handle = eventsFactory.createEventHandle(this, this.conn, row); @@ -237,6 +234,10 @@ class DbEventProcess extends BaseService { await utils.sleep(5000 + utils.randRange(500, 1500)); } } + const idx = BigInt(row['idx']); + if (idx > this.lastIdx) { + this.lastIdx = idx; + } return true; }