package cc.mrbird.febs.blockchain.job;
|
|
import cc.mrbird.febs.blockchain.service.TrxUsdtUpdateService;
|
import cc.mrbird.febs.common.utils.RedisUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
/**
|
* @author wzy
|
* @date 2021-12-17
|
**/
|
@Slf4j
|
@Component
|
@ConditionalOnProperty(prefix = "app", name = "block-job", havingValue = "true")
|
public class PoolJob {
|
|
@Resource
|
private RedisUtils redisUtils;
|
@Resource
|
private TrxUsdtUpdateService trxUsdtUpdateService;
|
|
/**
|
* 归集TRC20
|
*/
|
@Scheduled(cron = "0 1/5 * * * ? ")
|
public void poolUsdtTrc20() {
|
Object trc20_pool = redisUtils.get("TRC20_POOL");
|
if(trc20_pool==null){
|
return;
|
}
|
List<String> list = (List)trc20_pool;
|
for(String address: list){
|
trxUsdtUpdateService.poolByAddress(address);
|
}
|
}
|
}
|
