From 1633d169cedb162d4f9ce7c64ee5b3a232b029c9 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Fri, 14 Jul 2023 16:31:15 +0800 Subject: [PATCH] 1 --- server/web3dbspider/services/pull_dbevent.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/web3dbspider/services/pull_dbevent.js b/server/web3dbspider/services/pull_dbevent.js index 2d59dcc..75fb3c8 100644 --- a/server/web3dbspider/services/pull_dbevent.js +++ b/server/web3dbspider/services/pull_dbevent.js @@ -58,7 +58,7 @@ class PullDbEvent extends BaseService { } async pullEvent() { - const logHead = this.getInstanceName() + ' pullDbEvent: '; + const logHead = this.genLogHead(' pullDbEvent: '); try { const startIdx = this.getStartIdx(); const endIdx = this.getEndIdx(); @@ -135,7 +135,7 @@ class PullDbEvent extends BaseService { } async getLastIdx() { - const logHead = this.getInstanceName() + ' getLastIdx: '; + const logHead = this.genLogHead(' getLastIdx: '); while (true) { const {err, row} = await this.conn.ormSelectOne( 't_dbpull_last_idx', @@ -159,7 +159,7 @@ class PullDbEvent extends BaseService { } async saveLastIdx(lastIdx) { - const logHead = this.getInstanceName() + ' saveLastIdx: '; + const logHead = this.genLogHead(' saveLastIdx: '); while (true) { const {err} = await this.conn.upsert( 't_dbpull_last_idx', @@ -191,7 +191,7 @@ class PullDbEvent extends BaseService { } async saveToDb(row) { - const logHead = this.getInstanceName() + ' saveToDb: '; + const logHead = this.genLogHead(' saveToDb: '); while (true) { const {err} = await this.conn.upsert( this.getTableName(),