modify

Helius

2021-05-28 f5f45a52cff2ac6773beddc5b12412b189f3c066

modify

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

@@ -53,9 +53,9 @@
        if (blocnNum == null) {
            return;
        }
//        log.info("=====>>{}", blocnNum);
        log.info("=====>>{}", blocnNum);
        usdtUpdateProducer.sendTrc20BlockMsg(blocnNum.toString());
//        redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum);
        redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum);
//        try {
//            trxUsdtUpdateService.monitorCoinListener(blocnNum);
//        } catch (RestClientException | HttpException e) {

 src/main/java/com/xcong/excoin/rabbit/consumer/UsdtUpdateConsumer.java

@@ -37,10 +37,6 @@
    @Resource
    TrxUsdtUpdateService trxUsdtUpdateService;

    @Resource
    private RedisUtils redisUtils;


    @RabbitListener(queues = RabbitMqConfig.QUEUE_USDT_UPDATE)
    public void doSomething(String content) {
        log.info("#USDT同步---->{}#", content);
@@ -85,7 +81,6 @@
    @RabbitListener(queues = RabbitMqConfig.QUEUE_TRC20_BLOCK)
    public void trc20BlockMsg(String content) {
        Long blocnNum = Long.parseLong(content);
        redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum);
        try {
            trxUsdtUpdateService.monitorCoinListener(blocnNum);
        } catch (RestClientException | HttpException e) {