如果归集动作频繁则等待

routes/sdk.js

@@ -207,6 +207,11 @@ async function check_czz_withdraw_task() {
 
 async function collect_conis_task() {
     logger.log("collect_conis_task start")
+
+
+    var last_address = ' ';
+    var last_time = utils.getTimestamp;
+
     while (true) {
         var isPause = 0
         try {
@@ -245,6 +250,12 @@ async function collect_conis_task() {
                 logger.error('collect_conis_task isBlackList error', JSON.stringify(exec_obj));
             }
 
+
+            if (last_address && exec_obj.address && last_address == exec_obj.address && utils.getTimestamp - last_time < 2 * 60 * 1000) {
+                logger.info('collect coins wait...');
+                await utils.sleep(60000)
+            }
+
             //开始收集用户地址里面的币到归集地址
             var ret = await moralis.collectCoins(exec_obj)
             logger.log('collect_conis_task ret =', exec_obj, ret)
@@ -252,14 +263,14 @@ async function collect_conis_task() {
                 var ret_obj = JSON.parse(ret)
                 if (ret_obj.code == 0) {
                     logger.log('触发归集 delay collect_conis_task ret =', exec_obj, ret)
-                    //间隔 10s 归集，避免提交任务过多
-                    await utils.sleep(10000)
+                    last_address = exec_obj.address
                 }
             } catch (error) { }
         } catch (error) {
             logger.error('collect_conis_task error', error.toString());
         }
         logger.log("collect_conis_task cost-time", utils.getTimestamp() - start_time, exec_obj)
+        last_time = utils.getTimestamp()
     }
 }