diff --git a/server/web3dbspider/services/events/common/BaseEventProcess.js b/server/web3dbspider/services/events/common/BaseEventProcess.js index 7217496..7905b3e 100644 --- a/server/web3dbspider/services/events/common/BaseEventProcess.js +++ b/server/web3dbspider/services/events/common/BaseEventProcess.js @@ -5,6 +5,7 @@ const utils = require('j7/utils'); const http = require('j7/http'); const config = require('j7/config'); const constant = require('common/constant'); +const dbpool = require('common/dbpool'); const metaFactory = require('../../../metadata/factory'); class BaseEventProcess { @@ -102,16 +103,45 @@ class BaseEventProcess { } } + genCbUuid() { + + } + async callGameApi(params, checkCb) { while (true) { try { const nowTime = utils.getUtcTime(); - params['_timestamp'] = nowTime; - delete params['_sign']; - params['_sign'] = utils.normalMd5UrlSign(params, config('cb_secret_key')); + const cbUuid = this.genCbUuid(); + const secretKey = ''; + { + params['_cb_uuid'] = cbUuid; + params['_timestamp'] = nowTime; + delete params['_sign']; + } + const sign = utils.normalMd5UrlSign(params, secretKey); + params['_sign'] = sign; + { + const {err} = await dbpool.execBcNftConn + ( + app, + 'insert', + [ + ['cb_uuid', cbUuid], + ['params', utils.jsonEncode(params)], + ['signature', sign], + ['secret_key', secretKey], + ['createtime', nowTime], + ['modifytime', nowTime] + ] + ); + if (err) { + await utils.sleep(5000 + utils.randRange(500, 1500)); + continue; + } + } const {err, data} = await http.get(config('gameapi_url'), params); if (err) { - await utils.sleep(3000 + utils.randRange(500, 1500)); + await utils.sleep(5000 + utils.randRange(500, 1500)); continue; } const ret = await checkCb(data); @@ -122,7 +152,7 @@ class BaseEventProcess { utils.safeDumpErrStack(e); log.error(e); } - await utils.sleep(3000 + utils.randRange(500, 1500)); + await utils.sleep(5000 + utils.randRange(500, 1500)); } }