This commit is contained in:
aozhiwei 2023-07-13 15:07:18 +08:00
parent 473d1488d4
commit 4bf1275386

View File

@ -86,7 +86,8 @@ class PullBcEvent extends BaseService {
const firstBlockNumber = this.getInitBlock();
while (this.lastBlockNumber < 1) {
try {
const {err, row} = await dbpool.getBcEventConn(app)(
const {err, row} = await dbpool.getBcEventConn(
app,
'ormSelectOne',
't_last_block',
[
@ -133,7 +134,8 @@ class PullBcEvent extends BaseService {
async saveLastBlockNumber(blockNumber) {
const logHead = this.genLogHead(' event_process.saveLastBlockNumber: ');
while (true) {
const {err} = await dbpool.getBcEventConn(app)(
const {err} = await dbpool.getBcEventConn(
app,
'upsert',
't_last_block',
[
@ -170,7 +172,8 @@ class PullBcEvent extends BaseService {
const nowTime = utils.getUtcTime();
const returnValues = event['returnValues'];
const hashCode = '';
const {err} = await dbpool.getBcEventConn(app)(
const {err} = await dbpool.getBcEventConn(
app,
'upsert',
't_blockchain_event',
[