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-13 14:52:36 +08:00
parent 5b30a8880d
commit 875f15dc8d
2 changed files with 31 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
server/common/dbpool.js
View File

@ -42,16 +42,35 @@ async function internalCreateConn(app, name) {
return dbObj.conn; return dbObj.conn;
} }
async function getBcEventConn(app) { async function getBcEventConn(app, method, ...args) {
return await internalCreateConn(app, constant.BCEVENTDB_NAME); try {
const conn = await internalCreateConn(app, constant.BCEVENTDB_NAME);
const ret = await conn[method](...args);
if (ret.err) {
return {
'err': ret.err,
'conn': null,
'row': null,
'rows': null
};
}
} catch (err) {
return {
'err': err,
'conn': null,
'row': null,
'rows': null
};
}
} }
async function getBcNftConn(app) { async function getBcNftConn(app, method, ...args) {
return await internalCreateConn(app, constant.BCNFTDB_NAME); const conn = await internalCreateConn(app, constant.BCNFTDB_NAME);
} }
async function getGameConn(app) { async function getGameConn(app, method, ...args) {
return await internalCreateConn(app, constant.GAMEDB_NAME); const conn = await internalCreateConn(app, constant.GAMEDB_NAME);
} }
exports.getBcEventConn = getBcEventConn; exports.getBcEventConn = getBcEventConn;

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

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