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 15:34:13 +08:00
parent f02757387e
commit fc6818e098
3 changed files with 42 additions and 92 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
server/web3dbspider/services/events/BENftMarket/cancel_order.js
View File

@ -1,15 +1,6 @@
const log = require('j7/log'); const log = require('j7/log');
const app = require('j7/app');
const bcutils = require('j7/bcutils');
const utils = require('j7/utils'); const utils = require('j7/utils');
const j7event = require('j7/event'); const BaseEventProcess = require('../common/BaseEventProcess');
const metaFactory = require('../../metadata/factory');
const C = require('../../C');
const gameapi = require('../gameapi');
const http = require('j7/http');
const config = require('j7/config');
const BASE_URL = config('market_api');
/* /*
// 操作成功的事件 // 操作成功的事件
@ -20,51 +11,36 @@ event CancelOrder(
); );
*/ */
class CancelOrder { class CancelOrder extends BaseEventProcess {
async start(instance, conn, event) { async start() {
this.instance = instance; const returnValues = this.getReturnValues();
this.conn = conn;
this.event = event;
console.log('CancelOrder', event);
const blockNumber = event['blockNumber'];
const returnValues = event['returnValues'];
const orderId = returnValues['orderId']; const orderId = returnValues['orderId'];
const nftToken = returnValues['nftToken']; const nftToken = returnValues['nftToken'];
const tokenId = returnValues['tokenId']; const tokenId = returnValues['tokenId'];
while (true) { const params = {
try { 'c': 'Market',
const {err, data} = await http.get(BASE_URL, 'a': 'eventCancelOrder',
{ 'orderId': orderId,
'c': 'Market', 'nftToken': nftToken,
'a': 'eventCancelOrder', 'tokenId': tokenId,
'orderId': orderId, };
'nftToken': nftToken,
'tokenId': tokenId, await this.callGameApi
}); (params,
console.log(err, data); async (data) => {
if (!data) { if (!data) {
throw 'data is empty3'; this.throwError('callGameApi error:' + data);
} }
if (data['errcode'] == 0 || if (data['errcode'] == 0 ||
data['errcode'] == 1) { data['errcode'] == 1) {
return; return true;
} }
} catch (e) { return true;
log.error(e); });
} await this.markOk();
await utils.sleep(3000 + utils.randRange(500, 1500));
}
}
throwError(err) {
const errMsg = 'processCancelOrderEvent:' +
utils.jsonEncode(this.instance) +
' err:' + err;
throw errMsg;
} }
} }

68
server/web3dbspider/services/events/BENftMarket/price_update.js
View File

@ -1,15 +1,6 @@
const log = require('j7/log'); const log = require('j7/log');
const app = require('j7/app');
const bcutils = require('j7/bcutils');
const utils = require('j7/utils'); const utils = require('j7/utils');
const j7event = require('j7/event'); const BaseEventProcess = require('../common/BaseEventProcess');
const metaFactory = require('../../metadata/factory');
const C = require('../../C');
const gameapi = require('../gameapi');
const http = require('j7/http');
const config = require('j7/config');
const BASE_URL = config('market_api');
/* /*
// 操作成功的事件 // 操作成功的事件
@ -22,16 +13,10 @@ event PriceUpdate(
); );
*/ */
class PriceUpdateOrder { class PriceUpdate extends BaseEventProcess {
async start(instance, conn, event) { async start() {
this.instance = instance; const returnValues = this.getReturnValues();
this.conn = conn;
this.event = event;
console.log('PriceUpdateOrder', event);
const blockNumber = event['blockNumber'];
const returnValues = event['returnValues'];
const orderId = returnValues['orderId']; const orderId = returnValues['orderId'];
const nftToken = returnValues['nftToken']; const nftToken = returnValues['nftToken'];
@ -39,40 +24,29 @@ class PriceUpdateOrder {
const priceOld = returnValues['priceOld']; const priceOld = returnValues['priceOld'];
const price = returnValues['price']; const price = returnValues['price'];
while (true) { const params = {
try { 'c': 'Market',
const {err, data} = await http.get(BASE_URL, 'a': 'eventPriceUpdateOrder',
{ 'orderId': orderId,
'c': 'Market', 'nftToken': nftToken,
'a': 'eventPriceUpdateOrder', 'tokenId': tokenId,
'orderId': orderId, 'priceOld': priceOld,
'nftToken': nftToken, 'price': price
'tokenId': tokenId, };
'priceOld': priceOld, await this.callGameApi
'price': price (params,
}); async (data) => {
console.log(err, data);
if (!data) { if (!data) {
throw 'data is empty4'; this.throwError('callGameApi error:' + data);
} }
if (data['errcode'] == 0 || if (data['errcode'] == 0 ||
data['errcode'] == 1) { data['errcode'] == 1) {
return; return true;
} }
} catch (e) { return true;
log.error(e); });
}
await utils.sleep(3000 + utils.randRange(500, 1500));
}
}
throwError(err) {
const errMsg = 'processPriceUpdateOrderEvent:' +
utils.jsonEncode(this.instance) +
' err:' + err;
throw errMsg;
} }
} }
module.exports = PriceUpdateOrder; module.exports = PriceUpdate;

2
server/web3dbspider/services/events/BENftMarket/sell_order.js
View File

@ -15,7 +15,7 @@ event SellOrder(
); );
*/ */
class SellOrder { class SellOrder extends BaseEventProcess {
async start() { async start() {
const returnValues = this.getReturnValues(); const returnValues = this.getReturnValues();