20211207 fish

xiaoyong931011

2021-12-07 0b4ddcc6cd1b3ca9973ba4bf1732be010a7de4e2

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

@@ -45,7 +45,7 @@
        if(EthUsdtChargeDto.Symbol.USDT_ERC20.equals(ethUsdtChargeDto.getSymbol())){
            blockCoinService.updateEthUsdtNew(ethUsdtChargeDto);
        }
        if(EthUsdtChargeDto.Symbol.USDT_TRC20.equals(ethUsdtChargeDto.getSymbol())){
        if(EthUsdtChargeDto.Symbol.USDT_TRC20.equals(ethUsdtChargeDto.getSymbol()) || EthUsdtChargeDto.Symbol.COIN_TRC20.equals(ethUsdtChargeDto.getSymbol())){
            blockCoinService.updateTrc20(ethUsdtChargeDto);
            // 同步完直接归集
            trxUsdtUpdateService.poolByAddress(ethUsdtChargeDto.getAddress());
@@ -78,7 +78,7 @@
        }
    }

    @RabbitListener(queues = RabbitMqConfig.QUEUE_TRC20_BLOCK)
    @RabbitListener(queues = RabbitMqConfig.QUEUE_TRC20_BLOCK, containerFactory = "customContainerFactory")
    public void trc20BlockMsg(String content) {
        Long blocnNum = Long.parseLong(content);
        try {