modify

Helius

2021-06-08 ffd586b4b93665e1bf90df114e5eda71b47f20a8

 src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java

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