From fc6818e0989143c2c7e2ab04f2dadb75c1e9b5e5 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sun, 9 Jul 2023 15:34:13 +0800 Subject: [PATCH] 1 --- .../events/BENftMarket/cancel_order.js | 64 ++++++----------- .../events/BENftMarket/price_update.js | 68 ++++++------------- .../services/events/BENftMarket/sell_order.js | 2 +- 3 files changed, 42 insertions(+), 92 deletions(-) diff --git a/server/web3dbspider/services/events/BENftMarket/cancel_order.js b/server/web3dbspider/services/events/BENftMarket/cancel_order.js index f453061..16c34b0 100644 --- a/server/web3dbspider/services/events/BENftMarket/cancel_order.js +++ b/server/web3dbspider/services/events/BENftMarket/cancel_order.js @@ -1,15 +1,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 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'); +const BaseEventProcess = require('../common/BaseEventProcess'); /* // 操作成功的事件 @@ -20,51 +11,36 @@ event CancelOrder( ); */ -class CancelOrder { +class CancelOrder extends BaseEventProcess { - async start(instance, conn, event) { - this.instance = instance; - this.conn = conn; - this.event = event; - - console.log('CancelOrder', event); - const blockNumber = event['blockNumber']; - const returnValues = event['returnValues']; + async start() { + const returnValues = this.getReturnValues(); const orderId = returnValues['orderId']; const nftToken = returnValues['nftToken']; const tokenId = returnValues['tokenId']; - while (true) { - try { - const {err, data} = await http.get(BASE_URL, - { - 'c': 'Market', - 'a': 'eventCancelOrder', - 'orderId': orderId, - 'nftToken': nftToken, - 'tokenId': tokenId, - }); - console.log(err, data); + const params = { + 'c': 'Market', + 'a': 'eventCancelOrder', + 'orderId': orderId, + 'nftToken': nftToken, + 'tokenId': tokenId, + }; + + await this.callGameApi + (params, + async (data) => { if (!data) { - throw 'data is empty3'; + this.throwError('callGameApi error:' + data); } if (data['errcode'] == 0 || data['errcode'] == 1) { - return; + return true; } - } catch (e) { - log.error(e); - } - await utils.sleep(3000 + utils.randRange(500, 1500)); - } - } - - throwError(err) { - const errMsg = 'processCancelOrderEvent:' + - utils.jsonEncode(this.instance) + - ' err:' + err; - throw errMsg; + return true; + }); + await this.markOk(); } } diff --git a/server/web3dbspider/services/events/BENftMarket/price_update.js b/server/web3dbspider/services/events/BENftMarket/price_update.js index 78b8fb1..16bad79 100644 --- a/server/web3dbspider/services/events/BENftMarket/price_update.js +++ b/server/web3dbspider/services/events/BENftMarket/price_update.js @@ -1,15 +1,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 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'); +const BaseEventProcess = require('../common/BaseEventProcess'); /* // 操作成功的事件 @@ -22,16 +13,10 @@ event PriceUpdate( ); */ -class PriceUpdateOrder { +class PriceUpdate extends BaseEventProcess { - async start(instance, conn, event) { - this.instance = instance; - this.conn = conn; - this.event = event; - - console.log('PriceUpdateOrder', event); - const blockNumber = event['blockNumber']; - const returnValues = event['returnValues']; + async start() { + const returnValues = this.getReturnValues(); const orderId = returnValues['orderId']; const nftToken = returnValues['nftToken']; @@ -39,40 +24,29 @@ class PriceUpdateOrder { const priceOld = returnValues['priceOld']; const price = returnValues['price']; - while (true) { - try { - const {err, data} = await http.get(BASE_URL, - { - 'c': 'Market', - 'a': 'eventPriceUpdateOrder', - 'orderId': orderId, - 'nftToken': nftToken, - 'tokenId': tokenId, - 'priceOld': priceOld, - 'price': price - }); - console.log(err, data); + const params = { + 'c': 'Market', + 'a': 'eventPriceUpdateOrder', + 'orderId': orderId, + 'nftToken': nftToken, + 'tokenId': tokenId, + 'priceOld': priceOld, + 'price': price + }; + await this.callGameApi + (params, + async (data) => { if (!data) { - throw 'data is empty4'; + this.throwError('callGameApi error:' + data); } if (data['errcode'] == 0 || data['errcode'] == 1) { - return; + return true; } - } catch (e) { - log.error(e); - } - await utils.sleep(3000 + utils.randRange(500, 1500)); - } - } - - throwError(err) { - const errMsg = 'processPriceUpdateOrderEvent:' + - utils.jsonEncode(this.instance) + - ' err:' + err; - throw errMsg; + return true; + }); } } -module.exports = PriceUpdateOrder; +module.exports = PriceUpdate; diff --git a/server/web3dbspider/services/events/BENftMarket/sell_order.js b/server/web3dbspider/services/events/BENftMarket/sell_order.js index dce75e0..a2a4c58 100644 --- a/server/web3dbspider/services/events/BENftMarket/sell_order.js +++ b/server/web3dbspider/services/events/BENftMarket/sell_order.js @@ -15,7 +15,7 @@ event SellOrder( ); */ -class SellOrder { +class SellOrder extends BaseEventProcess { async start() { const returnValues = this.getReturnValues();