| | |
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber()); |
| | | // 判断对方打款地址是否为源池地址 |
| | | if (ChainEnum.BSC_TFC_SOURCE.getAddress().toLowerCase().equals(e.to)) { |
| | | log.info("触发USDT合约监听事件"); |
| | | log.info("触发USDT合约监听事件:{}", e.from); |
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
| | | |
| | | // 如果得到触发,则休眠10秒。 因为此处监听器触发可能优先于前端调用transfer接口 |
| | |
| | | } |
| | | |
| | | if ("0x0f71bff5d92cf9de27b711e5a6b888648e5ff6cc".toLowerCase().equals(e.to)) { |
| | | log.info("触发卡牌USDT合约监听事件"); |
| | | log.info("触发卡牌USDT合约监听事件:{}", e.from); |
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
| | | |
| | | // 如果得到触发,则休眠10秒。 因为此处监听器触发可能优先于前端调用transfer接口 |
| | | try { |
| | | Thread.sleep(10000); |
| | | } catch (InterruptedException ex) { |
| | | ex.printStackTrace(); |
| | | } |
| | | |
| | | ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name()); |
| | | int decimals = sourceUsdtInstance.decimals(); |
| | | BigInteger tokens = e.tokens; |