From 25a6acd0b036f53926a68b8b985dfd2a26ded9a2 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 10 Jul 2023 16:44:19 +0800
Subject: [PATCH] 1

---
 .../events/common/BaseEventProcess.js         | 33 ++++++++++++++++++-
 1 file changed, 32 insertions(+), 1 deletion(-)

diff --git a/server/web3dbspider/services/events/common/BaseEventProcess.js b/server/web3dbspider/services/events/common/BaseEventProcess.js
index 056f31b..b671ceb 100644
--- a/server/web3dbspider/services/events/common/BaseEventProcess.js
+++ b/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));
+    }
   }
 
 }