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/dapp/chain/TrxUsdtUpdateService.java | 26 +++-----------------------
1 files changed, 3 insertions(+), 23 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/chain/TrxUsdtUpdateService.java b/src/main/java/cc/mrbird/febs/dapp/chain/TrxUsdtUpdateService.java
index d41ebc5..ee5722e 100644
--- a/src/main/java/cc/mrbird/febs/dapp/chain/TrxUsdtUpdateService.java
+++ b/src/main/java/cc/mrbird/febs/dapp/chain/TrxUsdtUpdateService.java
@@ -290,6 +290,7 @@
public boolean poolByAddress(String address) {
BigDecimal trc20Balance = Trc20Service.getTrc20Balance(address);
if (trc20Balance == null || trc20Balance.compareTo(new BigDecimal("0.05")) < 1) {
+ redisUtils.setRemove(ChainConstants.REDIS_KEY_POOL_ADDRESS, address);
return false;
}
@@ -306,33 +307,12 @@
}
Trc20Service.sendTrc20(coinAddressEntity.getPrivateKey(), Trc20Service.POOL_ADDRESS, trc20Balance);
// 需要将存在redis的待归集地址删除
- Object trc20_pool = redisUtils.get("TRC20_POOL");
- if (trc20_pool != null) {
- List<String> poolList = (List) trc20_pool;
- Iterator<String> iterator = poolList.iterator();
- while (iterator.hasNext()) {
- String next = iterator.next();
- if (address.equals(next)) {
- iterator.remove();
- }
- }
- if (CollectionUtils.isEmpty(poolList)) {
- redisUtils.del("TRC20_POOL");
- } else {
- redisUtils.set("TRC20_POOL", poolList);
- }
- }
+ redisUtils.setRemove(ChainConstants.REDIS_KEY_POOL_ADDRESS, address);
return true;
} else {
Trc20Service.sendTrx(Trc20Service.TRX_PRIVATE_KEY, address, TRX_FEE);
// 将这个地址记录，后续同步
- Object trc20_pool = redisUtils.get("TRC20_POOL");
- List<String> poolList = new ArrayList<>();
- if (trc20_pool != null) {
- poolList = (List) trc20_pool;
- }
- poolList.add(address);
- redisUtils.set("TRC20_POOL", poolList);
+ redisUtils.sSet(ChainConstants.REDIS_KEY_POOL_ADDRESS, address);
return true;
}
}
--
Gitblit v1.9.1