| | |
|---|
| | | package cc.mrbird.febs.dapp.service.impl; |
|---|
| | | |
|---|
| | | import cc.mrbird.febs.common.contants.AppContants; |
|---|
| | | import cc.mrbird.febs.common.utils.RedisUtils; |
|---|
| | | import cc.mrbird.febs.dapp.chain.*; |
|---|
| | | import cc.mrbird.febs.dapp.entity.DappFundFlowEntity; |
|---|
| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber()); |
|---|
| | | // redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber()); |
|---|
| | | // 判断对方打款地址是否为源池地址 |
|---|
| | | if (ChainEnum.BSC_USDT.getAddress().toLowerCase().equals(e.to)) { |
|---|
| | | |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
|---|
| | | // redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
|---|
| | | |
|---|
| | | // 如果得到触发，则休眠10秒。 因为此处监听器触发可能优先于前端调用transfer接口 |
|---|
| | | // try { |
|---|
