fix

wzy

2022-11-14 1bbf36d28d57fcb0b759a60bd8433549d5abe056

fix

 src/main/java/cc/mrbird/febs/dapp/chain/ChainConstants.java

@@ -3,4 +3,5 @@
public interface ChainConstants {

    public static final String REDIS_KEY_POOL_ADDRESS = "TRC20_POOL";
    String REDIS_KEY_ADDRESS_LIST = "TRC20_ADDRESS_LIST";
}

 src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java

@@ -1,9 +1,7 @@
package cc.mrbird.febs.rabbit.consumer;

import cc.mrbird.febs.dapp.chain.BlockCoinService;
import cc.mrbird.febs.dapp.chain.Trc20Service;
import cc.mrbird.febs.dapp.chain.TrxUsdtUpdateService;
import cc.mrbird.febs.dapp.chain.UsdtErc20UpdateService;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.dapp.chain.*;
import cc.mrbird.febs.dapp.chain.entity.EthUsdtChargeDto;
import cc.mrbird.febs.dapp.service.ApiIgtOnHookPlanService;
import cc.mrbird.febs.job.BlockCoinUpdateJob;
@@ -39,6 +37,9 @@

    @Resource
    TrxUsdtUpdateService trxUsdtUpdateService;

    @Resource
    private RedisUtils redisUtils;

    @RabbitListener(queues = RabbitMqConfig.MEMBER_COIN_INSIDE_QUEUE)
    public void memberCoinInside(Long withdrawId) {
@@ -80,7 +81,9 @@
        String address = split[0];
        String tag = split[1];
        if("TRC20".equals(tag)){
            log.info("添加地址成功:{}", address);
            TrxUsdtUpdateService.addressList.add(address);
            redisUtils.lSet(ChainConstants.REDIS_KEY_ADDRESS_LIST, TrxUsdtUpdateService.addressList);
            // 此时还需要给这个地址转账用于激活及后续手续费
            Trc20Service.sendTrx(Trc20Service.TRX_PRIVATE_KEY,address,new BigDecimal(10));
        }