|  |  | 
 |  |  |  | 
 |  |  |     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(); | 
 |  |  | 
 |  |  |                 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; | 
 |  |  |                 } |