20221227 充值归集

xiaoyong931011

2023-01-09 682fefef1b0a709e33de520859b2e7410f6bb981

 src/main/java/cc/mrbird/febs/mall/chain/job/Trc20PoolAddressInitJob.java

@@ -16,7 +16,7 @@

@Slf4j
@Component
@ConditionalOnProperty(prefix = "system", name = "block-job", havingValue = "true")
@ConditionalOnProperty(prefix = "system", name = "chain-listener", havingValue = "true")
public class Trc20PoolAddressInitJob {

    @Autowired
@@ -28,7 +28,8 @@
    @PostConstruct
    public void initCoinTrade() {
        System.out.println("初始化归集地址");
        List<MemberCoinAddressEntity> addressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag("USDT", "TRC20");
//        List<MemberCoinAddressEntity> addressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag("USDT", "TRC20");
        List<MemberCoinAddressEntity> addressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag("USDT", "ERC20");
        if (CollUtil.isEmpty(addressList)) {
            return;
        }
@@ -39,7 +40,11 @@
        }

        addressList.forEach(item -> {
            // 待归集的地址
            redisUtils.sSet(ChainConstants.REDIS_KEY_POOL_ADDRESS, item.getAddress());

            // 系统所有用户地址
            redisUtils.sSet(ChainConstants.REDIS_KEY_SYSTEM_ADDRESS, item.getAddress());
        });
    }
}