diff --git a/server/web3dbspider/services/events/common/BaseEventProcess.js b/server/web3dbspider/services/events/common/BaseEventProcess.js index 7d2b707..b6c9efb 100644 --- a/server/web3dbspider/services/events/common/BaseEventProcess.js +++ b/server/web3dbspider/services/events/common/BaseEventProcess.js @@ -2,7 +2,6 @@ const log = require('j7/log'); const app = require('j7/app'); const bcutils = require('j7/bcutils'); const utils = require('j7/utils'); -const j7event = require('j7/event'); const http = require('j7/http'); const constant = require('common/constant'); const metaFactory = require('../../../metadata/factory'); @@ -78,8 +77,8 @@ class BaseEventProcess { async markOk() { await this.updateEventDb( [ - ['state', constant.EVENTDB_STATE_HANDLED], - ['modifytime', utils.getUtcTime()], + ['state', constant.EVENTDB_STATE_HANDLED], + ['modifytime', utils.getUtcTime()], ] ); } @@ -206,7 +205,42 @@ class BaseEventProcess { } async confirmTransactionDb(transId) { - this.throwError('not impl'); + { + const nowTime = utils.getUtcTime(); + const {err} = await this.gameDbConn + ( + 'update', + 't_transaction_prefee', + [ + ['trans_id', transId], + ], + [ + ['done', 1], + ['modifytime', nowTime], + ] + ); + if (err) { + this.throwError('confirmTransactionDb t_transaction_prefee error transId:' + transId); + } + } + { + const nowTime = utils.getUtcTime(); + const {err} = await this.gameDbConn + ( + 'update', + 't_transaction', + [ + ['trans_id', transId], + ], + [ + ['status', 3], + ['modifytime', nowTime], + ] + ); + if (err) { + this.throwError('confirmTransactionDb t_transaction_prefee error transId:' + transId); + } + } } }