From f02757387e5c9c0e5ed25649b6c8d167e5fde2f2 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Sun, 9 Jul 2023 15:27:32 +0800
Subject: [PATCH] 1

---
 .../services/events/BENftMarket/buy_order.js  |  3 -
 .../services/events/BENftMarket/sell_order.js | 73 ++++++-------------
 2 files changed, 22 insertions(+), 54 deletions(-)

diff --git a/server/web3dbspider/services/events/BENftMarket/buy_order.js b/server/web3dbspider/services/events/BENftMarket/buy_order.js
index 1ebadbe..c60dc5f 100644
--- a/server/web3dbspider/services/events/BENftMarket/buy_order.js
+++ b/server/web3dbspider/services/events/BENftMarket/buy_order.js
@@ -1,8 +1,5 @@
 const log = require('j7/log');
-const app = require('j7/app');
 const utils = require('j7/utils');
-const j7event = require('j7/event');
-const metaFactory = require('../../metadata/factory');
 const BaseEventProcess = require('../common/BaseEventProcess');
 
 /*
diff --git a/server/web3dbspider/services/events/BENftMarket/sell_order.js b/server/web3dbspider/services/events/BENftMarket/sell_order.js
index 4240a53..dce75e0 100644
--- a/server/web3dbspider/services/events/BENftMarket/sell_order.js
+++ b/server/web3dbspider/services/events/BENftMarket/sell_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');
 
 /*
 // 操作成功的事件
@@ -26,14 +17,8 @@ event SellOrder(
 
 class SellOrder {
 
-  async start(instance, conn, event) {
-    this.instance = instance;
-    this.conn = conn;
-    this.event = event;
-
-    console.log('SellOrder', event);
-    const blockNumber = event['blockNumber'];
-    const returnValues = event['returnValues'];
+  async start() {
+    const returnValues = this.getReturnValues();
 
     const tokenId = returnValues['tokenId'];
     const owner = returnValues['owner'];
@@ -43,44 +28,30 @@ class SellOrder {
     const currency = returnValues['currency'];
     const price = returnValues['price'];
 
-    while (true) {
-      try {
-        const {err, data} = await http.get
-        (BASE_URL,
-         {
-           'c': 'Market',
-           'a': 'eventSellOrder',
-           'tokenId': tokenId,
-           'owner': owner,
-           'nftToken': nftToken,
-           'amount': amount,
-           'orderId': orderId,
-           'currency': currency,
-           'price': price
-         });
-        if (err) {
-          throw err;
-        }
-        console.log(err, data);
+    const params = {
+      'c': 'Market',
+      'a': 'eventSellOrder',
+      'tokenId': tokenId,
+      'owner': owner,
+      'nftToken': nftToken,
+      'amount': amount,
+      'orderId': orderId,
+      'currency': currency,
+      'price': price
+    };
+    await this.callGameApi
+    (params,
+     async (data) => {
         if (!data) {
-          throw 'data is empty2';
+          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 = 'processSellOrderEvent:' +
-          utils.jsonEncode(this.instance) +
-          ' err:' + err;
-    throw errMsg;
+       return true;
+     });
+    await this.markOk();
   }
 
 }