server/game2006web3
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2023-07-14 16:31:15 +08:00
parent ced3b56f2b
commit 1633d169ce
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/web3dbspider/services/pull_dbevent.js
View File

@ -58,7 +58,7 @@ class PullDbEvent extends BaseService {
} }
async pullEvent() { async pullEvent() {
const logHead = this.getInstanceName() + ' pullDbEvent: '; const logHead = this.genLogHead(' pullDbEvent: ');
try { try {
const startIdx = this.getStartIdx(); const startIdx = this.getStartIdx();
const endIdx = this.getEndIdx(); const endIdx = this.getEndIdx();
@ -135,7 +135,7 @@ class PullDbEvent extends BaseService {
} }
async getLastIdx() { async getLastIdx() {
const logHead = this.getInstanceName() + ' getLastIdx: '; const logHead = this.genLogHead(' getLastIdx: ');
while (true) { while (true) {
const {err, row} = await this.conn.ormSelectOne( const {err, row} = await this.conn.ormSelectOne(
't_dbpull_last_idx', 't_dbpull_last_idx',
@ -159,7 +159,7 @@ class PullDbEvent extends BaseService {
} }
async saveLastIdx(lastIdx) { async saveLastIdx(lastIdx) {
const logHead = this.getInstanceName() + ' saveLastIdx: '; const logHead = this.genLogHead(' saveLastIdx: ');
while (true) { while (true) {
const {err} = await this.conn.upsert( const {err} = await this.conn.upsert(
't_dbpull_last_idx', 't_dbpull_last_idx',
@ -191,7 +191,7 @@ class PullDbEvent extends BaseService {
} }
async saveToDb(row) { async saveToDb(row) {
const logHead = this.getInstanceName() + ' saveToDb: '; const logHead = this.genLogHead(' saveToDb: ');
while (true) { while (true) {
const {err} = await this.conn.upsert( const {err} = await this.conn.upsert(
this.getTableName(), this.getTableName(),