| | |
| | | package com.xcong.excoin.quartz.job; |
| | | |
| | | import cn.hutool.http.HttpException; |
| | | import com.xcong.excoin.modules.blackchain.service.TrxUsdtUpdateService; |
| | | import com.xcong.excoin.modules.coin.service.BlockCoinService; |
| | | import com.xcong.excoin.utils.RedisUtils; |
| | |
| | | redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum); |
| | | try { |
| | | trxUsdtUpdateService.monitorCoinListener(blocnNum); |
| | | } catch (RestClientException e) { |
| | | } catch (RestClientException | HttpException e) { |
| | | // 此时是连接问题 这个块需要重新扫描 |
| | | log.info("查询区块超时:" + blocnNum); |
| | | TRC_BLOCK.add(blocnNum); |
| | |
| | | |
| | | } |
| | | |
| | | @Scheduled(cron = "0 0/1 * * * ? ") |
| | | // @Scheduled(cron = "0 0/1 * * * ? ") |
| | | public void usdtTc20UpdateQueue() { |
| | | // 查询最新区块号 |
| | | long getnowblock = trxUsdtUpdateService.getnowblockFromTronScan() - 25; |