| | |
|---|
| | | 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(); |
|---|
| | | |
|---|
| | | for (MemberCoinChargeEntity coinCharge : list) { |
|---|
| | | // 首先根据每个地址查询其是否有ETH 如果没有就充值ETH并设置1 表示初始状态 status=2（待充值）3：表示已提过 |
|---|
| | | String address = coinCharge.getAddress(); |
|---|
| | | Long memberId = coinCharge.getMemberId(); |
|---|
| | | BigDecimal usdt = coinCharge.getAmount(); |
|---|
| | | if(StringUtils.isNotBlank(not_pool_address) && not_pool_address.contains(address)){ |
|---|
| | | // 不归集的 |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if (usdt == null || usdt.compareTo(LIMIT) < 0) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
