20221117

xiaoyong931011

2022-11-23 bfbb03c514b9e60485ea13d5679e6af2e8aeb354

 src/main/java/cc/mrbird/febs/job/NotionalPoolingJob.java

@@ -1,6 +1,7 @@
package cc.mrbird.febs.job;

import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.dapp.chain.ChainConstants;
import cc.mrbird.febs.dapp.chain.TrxUsdtUpdateService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@@ -8,7 +9,9 @@
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.ExecutionException;

/**
@@ -20,7 +23,7 @@

@Slf4j
@Component
@ConditionalOnProperty(prefix = "app", name = "block-job", havingValue = "true")
@ConditionalOnProperty(prefix = "system", name = "block-job", havingValue = "true")
public class NotionalPoolingJob {
//
//    @Resource
@@ -66,18 +69,20 @@
//    }

    /**
     *  归集TRC20
     * 归集TRC20
     */
    @Scheduled(cron = "0 1/5 * * * ? ")
    @Scheduled(cron = "0 0/30 * * * ? ")
    public void poolUsdtTrc20() {
        log.info("归集TRC20执行");
        Object trc20_pool = redisUtils.get("TRC20_POOL");
        if(trc20_pool==null){
        Set<Object> poolAddress = redisUtils.sGet(ChainConstants.REDIS_KEY_POOL_ADDRESS);
        if (poolAddress == null || poolAddress.isEmpty()) {
            return;
        }
        List<String> list = (List)trc20_pool;
        for(String address: list){
           trxUsdtUpdateService.poolByAddress(address);

        for (Object address : poolAddress) {
            String next = (String) address;
            log.info("归集地址:{}", next);
            trxUsdtUpdateService.poolByAddress(next);
        }
    }
}