| | |
|---|
| | | |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber()); |
|---|
| | | // 判断对方打款地址是否为源池地址 |
|---|
| | | if (ChainEnum.BSC_TFC_SOURCE.getAddress().toLowerCase().equals(e.to)) { |
|---|
| | | if (ChainEnum.BSC_USDT.getAddress().toLowerCase().equals(e.to)) { |
|---|
| | | log.info("触发USDT合约监听事件"); |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
|---|
| | | |
|---|
| | | // 如果得到触发，则休眠10秒。 因为此处监听器触发可能优先于前端调用transfer接口 |
|---|
| | | try { |
|---|
| | | Thread.sleep(5000); |
|---|
| | | Thread.sleep(10000); |
|---|
| | | } catch (InterruptedException ex) { |
|---|
| | | ex.printStackTrace(); |
|---|
| | | } |
|---|
| | |
|---|
| | | fundFlow.setStatus(2); |
|---|
| | | dappFundFlowDao.updateById(fundFlow); |
|---|
| | | |
|---|
| | | chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId()); |
|---|
| | | // chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
