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/member/service/impl/MemberServiceImpl.java | 3 ++- src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java | 6 ++++++ 2 files changed, 8 insertions(+), 1 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; } diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java index a493a8a..d7b1e29 100644 --- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java @@ -895,8 +895,9 @@ //获取用户ID Long memberId = LoginUserUtils.getAppLoginUser().getId(); MemberEntity member = memberDao.selectById(memberId); + String golden_limit_transfer = redisUtils.getString("GOLDEN_LIMIT_TRANSFER"); // 判断是否限制 - if(1 == member.getIsTrader()){ + if(StringUtils.isNotBlank(golden_limit_transfer) && golden_limit_transfer.contains(member.getPhone())){ return Result.fail("此账号有财务问题,需联系客服"); } if (member.getCertifyStatus() != MemberEntity.CERTIFY_STATUS_Y) { -- Gitblit v1.9.1