| | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.xcong.excoin.configurations.RabbitMqConfig; |
|---|
| | | import com.xcong.excoin.modules.blackchain.model.EthUsdtChargeDto; |
|---|
| | | import com.xcong.excoin.modules.blackchain.service.UsdtErc20UpdateService; |
|---|
| | | import com.xcong.excoin.modules.coin.service.BlockCoinService; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|---|
| | |
|---|
| | | // 更新这个用户的余额 |
|---|
| | | blockCoinService.updateEthUsdtNew(ethUsdtChargeDto); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @RabbitListener(queues = RabbitMqConfig.QUEUE_USDT_ADDRESS) |
|---|
| | | public void addUsdtAddress(String content) { |
|---|
| | | if(!UsdtErc20UpdateService.ALL_ADDRESS_LIST.contains(content)){ |
|---|
| | | log.debug("#添加新地址---->{}#", content); |
|---|
| | | UsdtErc20UpdateService.ALL_ADDRESS_LIST.add(content); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
