From 07f46b6873959f36785afd5459c198ac84963d75 Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Thu, 03 Nov 2022 01:17:05 +0800
Subject: [PATCH] 修改trc20归集
---
src/main/java/cc/mrbird/febs/job/NotionalPoolingJob.java | 17 +++++++++++------
1 files changed, 11 insertions(+), 6 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/job/NotionalPoolingJob.java b/src/main/java/cc/mrbird/febs/job/NotionalPoolingJob.java
index e17e528..2326137 100644
--- a/src/main/java/cc/mrbird/febs/job/NotionalPoolingJob.java
+++ b/src/main/java/cc/mrbird/febs/job/NotionalPoolingJob.java
@@ -1,6 +1,7 @@
package cc.mrbird.febs.job;
import cc.mrbird.febs.common.utils.RedisUtils;
+import cc.mrbird.febs.dapp.chain.ChainConstants;
import cc.mrbird.febs.dapp.chain.TrxUsdtUpdateService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@@ -8,7 +9,9 @@
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
+import java.util.Iterator;
import java.util.List;
+import java.util.Set;
import java.util.concurrent.ExecutionException;
/**
@@ -66,18 +69,20 @@
// }
/**
- * 归集TRC20
+ * 归集TRC20
*/
@Scheduled(cron = "0 0/10 * * * ? ")
public void poolUsdtTrc20() {
log.info("归集TRC20执行");
- Object trc20_pool = redisUtils.get("TRC20_POOL");
- if(trc20_pool==null){
+ Set<Object> poolAddress = redisUtils.sGet(ChainConstants.REDIS_KEY_POOL_ADDRESS);
+ if (poolAddress == null || poolAddress.isEmpty()) {
return;
}
- List<String> list = (List)trc20_pool;
- for(String address: list){
- trxUsdtUpdateService.poolByAddress(address);
+
+ for (Object address : poolAddress) {
+ String next = (String) address;
+ log.info("归集地址:{}", next);
+ trxUsdtUpdateService.poolByAddress(next);
}
}
}
--
Gitblit v1.9.1