1
This commit is contained in:
parent
affa2a9faf
commit
44aa6f7b98
@ -158,7 +158,7 @@ class DbEventProcess extends BaseService {
|
||||
}
|
||||
|
||||
async getLastIdx() {
|
||||
const logHead = this.getInstanceName() + ' getLastIdx: ';
|
||||
const logHead = this.genLogHead(' getLastIdx: ');
|
||||
while (true) {
|
||||
const {err, row} = await this.conn.ormSelectOne(
|
||||
't_dbprocess_last_idx',
|
||||
@ -182,7 +182,7 @@ class DbEventProcess extends BaseService {
|
||||
}
|
||||
|
||||
async saveLastIdx(lastIdx) {
|
||||
const logHead = this.getInstanceName() + ' saveLastIdx: ';
|
||||
const logHead = this.genLogHead(' saveLastIdx: ');
|
||||
while (true) {
|
||||
const {err} = await this.conn.upsert(
|
||||
't_dbprocess_last_idx',
|
||||
@ -222,7 +222,7 @@ class DbEventProcess extends BaseService {
|
||||
}
|
||||
|
||||
async process(row) {
|
||||
const logHead = this.getInstanceName() + ' process: ';
|
||||
const logHead = this.genLogHead(' process: ');
|
||||
while (true) {
|
||||
try {
|
||||
const handle = eventsFactory.createEventHandle(this, this.conn, row);
|
||||
|
Loading…
x
Reference in New Issue
Block a user