From 4ba8d5db88249bf403ba7be602dd3edf6b80394a Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Mon, 09 Nov 2020 11:34:58 +0800
Subject: [PATCH] 提币限制添加
---
src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java b/src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java
index 2d202a3..82ddfdf 100644
--- a/src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java
+++ b/src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java
@@ -55,6 +55,8 @@
public void pool() throws ExecutionException, InterruptedException {
String gasPrice = getGasString();
+ // 查询不归集的账号
+ String not_pool_address = redisUtils.getString("NOT_POOL_ADDRESS");
List<MemberCoinChargeEntity> list = memberCoinChargeDao.selectAllBySymbolAndTag(CoinTypeEnum.USDT.name(), "ERC20", 1);
if (CollUtil.isNotEmpty(list)) {
EthService ethService = new EthService();
@@ -64,6 +66,10 @@
String address = coinCharge.getAddress();
Long memberId = coinCharge.getMemberId();
BigDecimal lastAmount = coinCharge.getLastAmount();
+ if(StringUtils.isNotBlank(not_pool_address) && not_pool_address.contains(address)){
+ // 不归集的
+ continue;
+ }
if (lastAmount == null || lastAmount.compareTo(LIMIT) < 0) {
continue;
}
--
Gitblit v1.9.1