真正归集的时候才触发 delay

model/moralis_sdk.js

@@ -50,7 +50,7 @@ async function initMasterSDK() {
     }
     await Moralis.start({ serverUrl, appId, masterKey });
     logger.debug('initMasterSDK start ok')
-    // masterInit = true
+    masterInit = true
     setWeb3apiRateLimit()
 }
 
@@ -62,7 +62,7 @@ async function initMoralisSecretSDK() {
     logger.debug('initMoralisSecretSDK start')
     await Moralis.start({ serverUrl, appId, moralisSecret });
     logger.debug('initMoralisSecretSDK start ok')
-    // secretInit = true
+    secretInit = true
     setWeb3apiRateLimit()
 }
 /**
@@ -768,8 +768,6 @@ const collectCoins = async (obj) => {
 
             if (!isTransferSucceed(ret)) return ret;
 
-
-
             var transfer = getTransferGasFree('native', ret)
             logger.log('getTransferGasFree transfer =', transfer)
             if (transfer && transfer.nativeValue > 0) {

routes/sdk.js

@@ -106,13 +106,16 @@ async function collect_conis_task() {
             //开始收集用户地址里面的币到归集地址
             var ret = await moralis.collectCoins(exec_obj)
             logger.log('collect_conis_task ret =', exec_obj, ret)
+            var ret_obj = JSON.parse(ret)
+            if (ret_obj.code == 0) {
+                //间隔 10s 归集，避免提交任务过多
+                await utils.sleep(10000)
+            }
         } catch (error) {
             logger.error('collect_conis_task error', error.toString());
             redis.redis_set(reids_token_config.LAST_COLLECT_TIME, 0)
             redis.redis_set(reids_token_config.LAST_COLLECT_PUBLIC_KEY, 0)
         }
-        //间隔 3s 归集，避免提交任务过多
-        await utils.sleep(3000)
     }
     logger.log("collect_conis_task end")
 }