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-11 18:03:04 +08:00
parent b0a256e418
commit bfee2f5bcf
1 changed files with 13 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -158,38 +158,23 @@ class BaseEventProcess {
} }
async bcEventDbConn(method, ...args) { async bcEventDbConn(method, ...args) {
if (!this.bcEventConn) { const conn = await this.recreateConn('bcEventConn', constant.BCEVENTDB_NAME);
const {err, conn} = await app.getDbConn(constant.BCEVENTDB_NAME); return await this.internalDbConn(conn, method, ...args);
if (err) {
return {
'err': err,
'row': null,
'rows': null
};
}
this.bcEventConn = conn;
}
return await this.internalDbConn(this.bcEventConn, method, ...args);
} }
async bcNftDbConn(method, ...args) { async bcNftDbConn(method, ...args) {
if (!this.bcNftConn) { const conn = await this.recreateConn('bcNftConn', constant.BCNFTDB_NAME);
const {err, conn} = await app.getDbConn(constant.BCNFTDB_NAME); return await this.internalDbConn(conn, method, ...args);
if (err) {
return {
'err': err,
'row': null,
'rows': null
};
}
this.bcNftConn = conn;
}
return await this.internalDbConn(this.bcNftConn, method, ...args);
} }
async gameDbConn(method, ...args) { async gameDbConn(method, ...args) {
if (!this.gameConn) { const conn = await this.recreateConn('gameConn', constant.GAMEDB_NAME);
const {err, conn} = await app.getDbConn(constant.GAMEDB_NAME); return await this.internalDbConn(conn, method, ...args);
}
async recreateConn(connName, dbName) {
if (!this[connName]) {
const {err, conn} = await app.getDbConn(dbName);
if (err) { if (err) {
return { return {
'err': err, 'err': err,
@ -197,9 +182,9 @@ class BaseEventProcess {
'rows': null 'rows': null
}; };
} }
this.gameConn = conn; this[connName] = conn;
} }
return await this.internalDbConn(this.gameConn, method, ...args); return this[connName];
} }
async internalDbConn(conn, method, ...args) { async internalDbConn(conn, method, ...args) {