fix bug

routes/sdk.js

@@ -86,9 +86,10 @@ async function getAllTokenWithdrawInfoLists(ctx) {
 async function collect_conis_task() {
     logger.log("collect_conis_task start")
     while (true) {
+        var start_time = utils.getTimestamp()
         var exec_obj = await redis.redis_pop(reids_token_config.COLLECT_CONIS_QUEUE_KEY)
         if (!exec_obj) {
-            await utils.sleep(10000)
+            await utils.sleep(30000)
             logger.log("没有归集任务")
             continue
         }
@@ -97,7 +98,7 @@ async function collect_conis_task() {
             logger.log('collect_conis_task exec item>>>>', exec_obj);
 
             if (exec_obj.address == await redis.readRedis(reids_token_config.LAST_COLLECT_PUBLIC_KEY) && utils.getTimestamp() - await redis.readRedis(reids_token_config.LAST_COLLECT_TIME) < 60 * 2 * 1000) {
-                logger.log('间隔不足 2 分钟', exec_obj);
+                logger.log('间隔不足 1 分钟', exec_obj);
                 continue
             }
 
@@ -106,20 +107,21 @@ 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)
-            // }
+            try {
+                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)
+                }
+            } catch (error) {}
         } 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)
         }
-
-        await utils.sleep(10000)
+        logger.log("collect_conis_task cost-time", utils.getTimestamp() - start_time, exec_obj)
     }
-    logger.log("collect_conis_task end")
 }