| | |
| | | public void usdtTc20Update() { |
| | | // 波场3秒出一个块 |
| | | Long blocnNum = TRC_BLOCK.poll(); |
| | | log.info("------>{}", blocnNum); |
| | | if (blocnNum == null) { |
| | | return; |
| | | } |
| | | log.info("=====>>{}", blocnNum); |
| | | usdtUpdateProducer.sendTrc20BlockMsg(blocnNum.toString()); |
| | | redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum); |
| | | log.info("------>>>>{}", blocnNum); |
| | | // try { |
| | | // trxUsdtUpdateService.monitorCoinListener(blocnNum); |
| | | // } catch (RestClientException | HttpException e) { |
| | |
| | | public void usdtTc20UpdateQueue() { |
| | | // 查询最新区块号 |
| | | long getnowblock = trxUsdtUpdateService.getnowblockFromTronScan() - 25; |
| | | log.info("=======>{}", getnowblock); |
| | | // 拿到redis里最新区块 |
| | | Object trc20BlockNum = redisUtils.get("USDT_TRC20_BLOCK_NUM"); |
| | | if (trc20BlockNum == null) { |