From bd9eaf28cb817c9f9bd878e6abeb547836c2cb3f Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Sat, 20 Feb 2021 11:45:02 +0800
Subject: [PATCH] TRC20版本提交
---
src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java | 29 +++++++++++++++++++++--------
1 files changed, 21 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java b/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java
index 43af25b..0c89da5 100644
--- a/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java
+++ b/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java
@@ -23,10 +23,7 @@
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.BigInteger;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
@Service
public class TrxUsdtUpdateService {
@@ -225,7 +222,7 @@
if (trxBalance == null) {
return false;
}
- if (trxBalance.compareTo(new BigDecimal(1)) < 0) {
+ if (trxBalance.compareTo(new BigDecimal(1)) >= 0) {
// 转
BigDecimal trc20Balance = Trc20Service.getTrc20Balance(address);
if (trc20Balance == null) {
@@ -236,10 +233,27 @@
return false;
}
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);
+ }
+ }
return true;
} else {
Trc20Service.sendTrx(Trc20Service.TRX_PRIVATE_KEY, address, new BigDecimal(1));
- // 将这个地址记录，后续同步 TODO
+ // 将这个地址记录，后续同步
Object trc20_pool = redisUtils.get("TRC20_POOL");
List<String> poolList = new ArrayList<>();
if (trc20_pool != null) {
@@ -247,8 +261,7 @@
}
poolList.add(address);
redisUtils.set("TRC20_POOL", poolList);
-
+ return true;
}
- return false;
}
}
--
Gitblit v1.9.1