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-09 13:50:46 +08:00
parent d356b9c3db
commit 53ba20dfd3
3 changed files with 49 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/common/constant.js Normal file
View File

@ -0,0 +1,5 @@
const EVENTDB_STATE_PENDING = 0;
const EVENTDB_STATE_HANDLED = 1;
exports.EVENTDB_STATE_PENDING = EVENTDB_STATE_PENDING;
exports.EVENTDB_STATE_HANDLED = EVENTDB_STATE_HANDLED;

19
server/web3dbspider/services/dbevent_process.js
View File

@ -2,6 +2,7 @@ const app = require('j7/app');
const utils = require('j7/utils'); const utils = require('j7/utils');
const bcutils = require('j7/bcutils'); const bcutils = require('j7/bcutils');
const log = require('j7/log'); const log = require('j7/log');
const constant = require('common/constant');
const BaseService = require('./baseservice'); const BaseService = require('./baseservice');
const metaFactory = require('../metadata/factory'); const metaFactory = require('../metadata/factory');
const eventsFactory = require('./events/factory'); const eventsFactory = require('./events/factory');
@ -58,7 +59,9 @@ class DbEventProcess extends BaseService {
async start() { async start() {
while (true) { while (true) {
await this.pullEvent(); if (this.eventHandle) {
await this.pullEvent();
}
await utils.sleep(500 + utils.randRange(500, 1500)); await utils.sleep(500 + utils.randRange(500, 1500));
} }
} }
@ -75,7 +78,8 @@ class DbEventProcess extends BaseService {
} }
const {err, rows} = await this.conn.execQuery( const {err, rows} = await this.conn.execQuery(
'SELECT * FROM ${tableName} WHERE `idx` > ? AND `idx` <= ? ' + 'SELECT * FROM ${tableName} WHERE `idx` > ? AND `idx` <= ? ' +
'AND net_id = ? AND event_name = ? AND contract_address = ? ' + 'AND net_id = ? AND event_name = ? AND contract_address = ? AND ' +
'state = ' + constant.EVENTDB_STATE_PENDING + ' ' +
'LIMIT ' + LIMIT_COUNT, 'LIMIT ' + LIMIT_COUNT,
[ [
startIdx.toString(), startIdx.toString(),
@ -91,7 +95,7 @@ class DbEventProcess extends BaseService {
await utils.serial( await utils.serial(
rows, rows,
async (row) => { async (row) => {
await this.saveToDb(row); await this.process(row);
} }
); );
this.progInfo['procEventCount'] += rows.length; this.progInfo['procEventCount'] += rows.length;
@ -206,6 +210,15 @@ class DbEventProcess extends BaseService {
} }
} }
async process(row) {
if (!this.eventHandle) {
return false;
}
const handle = eventsFactory.createHash(this);
await handle.start();
return true;
}
} }
module.exports = DbEventProcess; module.exports = DbEventProcess;

28
server/web3dbspider/services/events/common/BaseEventProcess.js
View File

@ -3,6 +3,7 @@ const app = require('j7/app');
const bcutils = require('j7/bcutils'); const bcutils = require('j7/bcutils');
const utils = require('j7/utils'); const utils = require('j7/utils');
const j7event = require('j7/event'); const j7event = require('j7/event');
const constant = require('common/constant');
const metaFactory = require('../../metadata/factory'); const metaFactory = require('../../metadata/factory');
class BaseEventProcess { class BaseEventProcess {
@ -35,6 +36,33 @@ class BaseEventProcess {
throw errMsg; throw errMsg;
} }
async markOk() {
await this.updateEventDb(
[
['state', constant.EVENTDB_STATE_HANDLED],
['modifytime', utils.getUtcTime()],
]
);
}
async updateEventDb(fields) {
const logHead = this.genLogHead('updateEventDb');
while (true) {
const {err} = await this.conn.update(
this.eventProc.getTableName(),
[
['idx', this.getEventDb['idx']],
],
fields
);
if (!err) {
break;
}
log.error(logHead + err);
await utils.sleep(5000 + utils.randRange(500, 1500));
}
}
} }
module.exports = BaseEventProcess; module.exports = BaseEventProcess;