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(),