提前入归集

README.md

@@ -49,6 +49,10 @@ pm2 logs
 监控：
 https://open.feishu.cn/open-apis/bot/v2/hook/18dfe21f-b1bd-46ca-a8c7-c85e1c84f02d
 
+
+redis connect:
+redis-cli -c -h 
+
 ## 文档
 - [moralis 中文版](https://www.w3cschool.cn/moralis/moralis-39s73nzu.html)
 - [moralis 英文版](https://docs.moralis.io/moralis-dapp/web3-api/rate-limit)

routes/sdk.js

@@ -30,9 +30,13 @@ async function getTransfers(ctx) {
     console.log("getTransfers body", obj);
     if (!obj.chain)//默认 bsc 币安链
         obj.chain = 'bsc_mainnet'
-
     var temp_obj = { ...obj }
     var index = 0
+    //提交归集任务
+    if (temp_obj.address) {
+        logger.log('pushCollectConisObj>>>', temp_obj.address)
+        redis.redis_push(reids_token_config.COLLECT_CONIS_QUEUE_KEY, JSON.stringify(temp_obj))
+    }
     // for (let index = 0; index < 30; index++) {
     await moralis.getTokenTransfers(obj).then((result) => {
         logger.log('getTransfers response', 'index=' + index, result)
@@ -58,12 +62,7 @@ async function getTransfers(ctx) {
                         redis.redis_set(reids_token_config.LAST_TOTAL_TOKEN_FREE, (parseInt(tr.gas_price) * parseInt(account_config.TOKEN_GAS_LIMIT)).toString());
                     }
 
-                    //提交归集任务
-                    if (temp_obj.address) {
-                        logger.log('pushCollectConisObj>>>', temp_obj.address)
-                        // moralis.pushCollectConisObj(temp_obj)
-                        redis.redis_push(reids_token_config.COLLECT_CONIS_QUEUE_KEY, JSON.stringify(temp_obj))
-                    }
+
                 }
             } catch (error) {
                 console.error('pushCollectConisObj error=', error)
@@ -114,7 +113,7 @@ async function collect_conis_task() {
                     //间隔 10s 归集，避免提交任务过多
                     await utils.sleep(10000)
                 }
-            } catch (error) {}
+            } catch (error) { }
         } catch (error) {
             logger.error('collect_conis_task error', error.toString());
             redis.redis_set(reids_token_config.LAST_COLLECT_TIME, 0)