| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber()); |
|---|
| | | // redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber()); |
|---|
| | | |
|---|
| | | String address = e.to; |
|---|
| | | String hash = e.log.getTransactionHash(); |
|---|
| | | |
|---|
| | | // List<String> tdCoinWallets = memberCoinAddressDao.selectAllSymbolAddress(CoinTypeEnum.USDT.toString(),"ERC20"); |
|---|
| | | Set<Object> addressList = redisUtils.sGet(ChainConstants.REDIS_KEY_SYSTEM_ADDRESS); |
|---|
| | | // 判断对方打款地址是否为源池地址 |
|---|
| | | if(CollUtil.isNotEmpty(addressList) && addressList.contains(address)){ |
|---|
| | | // if(CollUtil.isNotEmpty(tdCoinWallets) && tdCoinWallets.contains(address)){ |
|---|
| | | log.info("触发USDT合约监听事件"); |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
|---|
| | | // hash没有用过 |
|---|
