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-03 18:59:06 +08:00
parent 72c7004f7d
commit 2e2d4c98c2
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/web3bcspider/services/pull_bcevent.js
View File

@ -62,17 +62,19 @@ class PullBcEvent extends BaseService {
return; return;
} }
console.log(events); console.log(events);
for (let i in events) { utils.serial
(events,
async (event) => {
while (true) { while (true) {
try { try {
await this.saveToDb(events[i]); await this.saveToDb(event);
break; return;
} catch (err) { } catch (err) {
log.error(err); log.error(err);
} }
await utils.sleep(8000 + utils.randRange(500, 1500)); await utils.sleep(8000 + utils.randRange(500, 1500));
} }
} });
} }
async getFromBlock() { async getFromBlock() {
@ -123,7 +125,7 @@ class PullBcEvent extends BaseService {
} }
async saveLastBlockNumber(blockNumber) { async saveLastBlockNumber(blockNumber) {
const logHead = 'event_process.saveLastBlockNumber'; const logHead = this.getInstanceName() + ' event_process.saveLastBlockNumber';
while (true) { while (true) {
const {err} = await this.conn.upsert( const {err} = await this.conn.upsert(
't_parameter', 't_parameter',
@ -148,7 +150,7 @@ class PullBcEvent extends BaseService {
} }
async saveToDb(event) { async saveToDb(event) {
const logHead = 'event_process.saveToDb'; const logHead = this.getInstanceName() + ' event_process.saveToDb';
while (true) { while (true) {
const nowTime = utils.getUtcTime(); const nowTime = utils.getUtcTime();
const returnValues = event['returnValues']; const returnValues = event['returnValues'];