From f078aaaa2583ad8a4f07a3747e46455d036883b6 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 11 Jul 2023 17:01:07 +0800
Subject: [PATCH] 1

---
 server/common/bchelper.js                     | 21 +++++
 .../UserMinterFactory/activate721nft.js       | 78 +++++--------------
 2 files changed, 42 insertions(+), 57 deletions(-)

diff --git a/server/common/bchelper.js b/server/common/bchelper.js
index ca1319b..517e7dc 100644
--- a/server/common/bchelper.js
+++ b/server/common/bchelper.js
@@ -41,4 +41,25 @@ function getItemMetaNftType(itemMeta) {
   return bcconst.BC_NFT_NONE;
 }
 
+function getNftTableName(tokenType) {
+  switch (Number(tokenType)) {
+  case bcconst.BC_NFT_HERO:
+    {
+      return 't_hero';
+    }
+    break;
+  case bcconst.BC_NFT_CHIP:
+    {
+       return 't_chip';
+    }
+    break;
+  default:
+    {
+      return '';
+    }
+    break;
+  }
+}
+
 exports.getItemMetaNftType = getItemMetaNftType;
+exports.getNftTableName = getNftTableName;
diff --git a/server/web3dbspider/services/events/UserMinterFactory/activate721nft.js b/server/web3dbspider/services/events/UserMinterFactory/activate721nft.js
index 5572828..93337f2 100644
--- a/server/web3dbspider/services/events/UserMinterFactory/activate721nft.js
+++ b/server/web3dbspider/services/events/UserMinterFactory/activate721nft.js
@@ -5,6 +5,7 @@ const utils = require('j7/utils');
 const j7event = require('j7/event');
 const constant = require('common/constant');
 const bcconst = require('common/bcconst');
+const bchelper = require('common/bchelper');
 const metaFactory = require('../../../metadata/factory');
 const BaseEventProcess = require('../common/BaseEventProcess');
 
@@ -60,7 +61,7 @@ class Activate721Nft extends BaseEventProcess {
       return;
     }
     await this.updateGameDbInfo(transId, itemUniId, itemId, tokenId, tokenType);
-    const {err, row} = await this.bcNftConn(
+    const {err} = await this.bcNftConn(
       'ormSelectOne',
       't_nft',
       [
@@ -94,67 +95,30 @@ class Activate721Nft extends BaseEventProcess {
         log.error('processEvent:' + err);
         throw 'processEvent:' + err;
       }
-      try {
-        j7event.emitEvent(C.CREATE_EXEC_CONFIRM_OWNER_EVENT, tokenId);
-      } catch (err) {
-        log.warning('processEvent:' + err);
-      }
     }
   }
 
   async updateGameDbInfo(transId, itemUniId, itemId, tokenId, tokenType) {
-    const {err, conn} = await app.getDbConn(constant.GAMEDB_NAME);
-    if (err) {
-        this.throwError('gamedb connection err:' + err);
-        return;
+    const tblName = bchelper.getNftTableName(tokenType);
+    if (!tblName) {
+      this.throwError('error token_type:' + tokenType);
+      return;
     }
-    const gameDbConn = conn;
-    try {
-      try {
-        let tblName = '';
-        switch (tokenType) {
-        case bcconst.BC_NFT_HERO:
-          {
-            tblName = 't_hero';
-          }
-          break;
-        case bcconst.BC_NFT_EQUIP:
-          {
-            tblName = 't_gun';
-          }
-          break;
-        case bcconst.BC_NFT_CHIP:
-          {
-            tblName = 't_chip';
-          }
-          break;
-        default:
-          {
-          }
-          break;
-        }
-        if (!tblName) {
-          this.throwError('error token_type:' + tokenType);
-          return;
-        }
-        await gameDbConn.update(
-          tblName,
-          [
-            ['idx',  itemUniId],
-          ],
-          [
-            ['token_id',  tokenId],
-            ['!account_id',  () => {
-              return 'null';
-            }],
-          ]
-        );
-      } finally {
-        gameDbConn.release();
-      }
-    } catch (e) {
-        this.throwError('updateGameDbInfo err:' + e);
-        return;
+    const {err} = await this.gameDbConn(
+      'update',
+      tblName,
+      [
+        ['idx',  itemUniId],
+      ],
+      [
+        ['token_id',  tokenId],
+        ['!account_id',  () => {
+          return 'null';
+        }],
+      ]
+    );
+    if (err) {
+      this.throwError('updateGameDbInfo transId:' + transId);
     }
   }