diff --git a/server/web3dbspider/services/events/CFHero/transfer.js b/server/web3dbspider/services/events/CFHero/transfer.js
index 1080e73..693a90f 100644
--- a/server/web3dbspider/services/events/CFHero/transfer.js
+++ b/server/web3dbspider/services/events/CFHero/transfer.js
@@ -13,6 +13,7 @@ class Transfer extends BaseEventProcess {
     const to = returnValues['to'];
     const tokenId = returnValues['tokenId'];
 
+    await this.mustBeMint(to, tokenId, bcconst.BC_NFT_HERO);
     if (bcutils.isSysAddress(from)) {
       const airDropMeta = metaFactory.getAirDrop(
         tokenId,
@@ -20,28 +21,19 @@ class Transfer extends BaseEventProcess {
         bcconst.BC_NFT_HERO,
         this.getContractAddress());
       if (airDropMeta) {
-        const exists = await this.exists721Nft(tokenId, this.getContractAddress());
-        if (!exists) {
-          await this.mint721Nft(
-            to,
-            tokenId,
-            airDropMeta['item_id'],
-            bcconst.BC_NFT_HERO,
-            this.getContractAddress(),
-            this.getBlockNumber()
-          );
-        }
         await this.apiMint(to, tokenId, airDropMeta);
+      } else {
+        await this.ingameActivate(tokenId, bcconst.BC_NFT_HERO);
       }
+    } else {
+      await this.add721NftRefresh
+      (
+        this.getNetId(),
+        this.getContractAddress(),
+        this.getContractName(),
+        tokenId
+      );
     }
-
-    await this.add721NftRefresh
-    (
-      this.getNetId(),
-      this.getContractAddress(),
-      this.getContractName(),
-      tokenId
-    );
     await this.update721NftOwner(tokenId, this.getContractAddress(), to);
     await this.markOk();
   }
diff --git a/server/web3dbspider/services/events/common/BaseEventProcess.js b/server/web3dbspider/services/events/common/BaseEventProcess.js
index 2b04547..c44d256 100644
--- a/server/web3dbspider/services/events/common/BaseEventProcess.js
+++ b/server/web3dbspider/services/events/common/BaseEventProcess.js
@@ -7,6 +7,8 @@ const config = require('j7/config');
 const constant = require('common/constant');
 const dbpool = require('common/dbpool');
 const metaFactory = require('../../../metadata/factory');
+const bchelper = require('common/bchelper');
+const bcconst = require('common/bcconst');
 
 let gSeqId = 1;
 function genSeqId() {
@@ -379,6 +381,90 @@ class BaseEventProcess {
     }
   }
 
+  async mustBeMint(to, tokenId, tokenType) {
+    const exists = await this.exists721Nft(tokenId, this.getContractAddress());
+    if (!exists) {
+      await this.mint721Nft(
+        to,
+        tokenId,
+        0,
+        tokenType,
+        this.getContractAddress(),
+        this.getBlockNumber()
+      );
+    }
+  }
+
+  async ingameActivate(tokenId, tokenType) {
+    const logHead = this.genLogHead(' ingameActivate ');
+    const tblName = bchelper.getNftTableName(tokenType);
+    if (!tblName) {
+      this.throwError(logHead + ' token_type error :' + tokenType);
+      return;
+    }
+    if (tokenType == bcconst.BC_NFT_HERO) {
+      await this.ingameActivateHero(tblName, tokenId, tokenType);
+    }
+  }
+
+  async ingameActivateHero(tblName, tokenId, tokenType) {
+    const logHead = this.genLogHead(' ingameActivateHero ');
+    {
+      const {err, row} = await this.gameDbConn(
+        'ormSelectOne',
+        tblName,
+        [
+          ['active_token_id',  tokenId],
+        ]
+      );
+      if (err) {
+        this.throwError(logHead + err);
+      }
+      if (row) {
+        if (row['token_id'] == tokenId) {
+          return;
+        }
+      } else {
+        await this.addLog([
+          ['type', 'ingameActivateHero'],
+          ['subtype', 'active_token_id.notfound'],
+          ['net_id', this.getNetId()],
+          ['param1', tokenId],
+          ['createtime', nowTime],
+          ['modifytime', nowTime],
+        ]);
+      }
+    }
+    const nowTime = utils.getUtcTime();
+    const {err} = await this.gameDbConn(
+      'update',
+      tblName,
+      [
+        ['active_token_id',  tokenId],
+      ],
+      [
+        ['token_id',  tokenId],
+        ['activate', 1],
+        ['activate_time', nowTime],
+        ['modifytime', nowTime],
+        ['!account_id',  () => {
+          return 'null';
+        }],
+      ]
+    );
+    if (err) {
+      this.throwError(logHead + err);
+    }
+  }
+
+  async addLog(fieldsKv) {
+    const {err} = await this.bcEventDbConn(
+      'insert',
+      't_log',
+      fieldsKv
+    );
+  }
+
 }
 
 module.exports = BaseEventProcess;