1

server/web3dbspider/services/events/common/BaseEventProcess.js

@@ -96,7 +96,38 @@ class BaseEventProcess {
   }
 
   async add721NftRefresh(netId, contractAddress, contractName, tokenId) {
-
+    while (true) {
+      const nowTime = utils.getNowTime();
+      const {err} = await this.conn.upsert
+      (
+        't_erc721_refresh',
+        [
+          ['net_id', netId],
+          ['contract_address', contractAddress],
+          ['tokenId', tokenId],
+        ],
+        [
+          ['status', 0],
+          ['refresh_count', () => {
+            return 'refresh_count + 1';
+          }],
+          ['modifytime', nowTime]
+        ],
+        [
+          ['net_id', netId],
+          ['contract_address', contractAddress],
+          ['tokenId', tokenId],
+          ['status', 0],
+          ['refresh_count', 1],
+          ['createtime', nowTime]
+          ['modifytime', nowTime]
+        ]
+      );
+      if (!err) {
+        break;
+      }
+      await utils.sleep(3000 + utils.randRange(500, 1500));
+    }
   }
 
 }