From 682fefef1b0a709e33de520859b2e7410f6bb981 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 09 Jan 2023 16:36:08 +0800
Subject: [PATCH] 20221227 充值归集
---
src/main/java/cc/mrbird/febs/mall/chain/job/Trc20PoolAddressInitJob.java | 9 +++++++--
1 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/chain/job/Trc20PoolAddressInitJob.java b/src/main/java/cc/mrbird/febs/mall/chain/job/Trc20PoolAddressInitJob.java
index 2c64958..b25906e 100644
--- a/src/main/java/cc/mrbird/febs/mall/chain/job/Trc20PoolAddressInitJob.java
+++ b/src/main/java/cc/mrbird/febs/mall/chain/job/Trc20PoolAddressInitJob.java
@@ -16,7 +16,7 @@
@Slf4j
@Component
-@ConditionalOnProperty(prefix = "system", name = "block-job", havingValue = "true")
+@ConditionalOnProperty(prefix = "system", name = "chain-listener", havingValue = "true")
public class Trc20PoolAddressInitJob {
@Autowired
@@ -28,7 +28,8 @@
@PostConstruct
public void initCoinTrade() {
System.out.println("初始化归集地址");
- List<MemberCoinAddressEntity> addressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag("USDT", "TRC20");
+// List<MemberCoinAddressEntity> addressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag("USDT", "TRC20");
+ List<MemberCoinAddressEntity> addressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag("USDT", "ERC20");
if (CollUtil.isEmpty(addressList)) {
return;
}
@@ -39,7 +40,11 @@
}
addressList.forEach(item -> {
+ // 待归集的地址
redisUtils.sSet(ChainConstants.REDIS_KEY_POOL_ADDRESS, item.getAddress());
+
+ // 系统所有用户地址
+ redisUtils.sSet(ChainConstants.REDIS_KEY_SYSTEM_ADDRESS, item.getAddress());
});
}
}
--
Gitblit v1.9.1