package com.yami.trading.init.cache;
|
|
import com.yami.trading.bean.contract.domain.ContractApplyOrder;
|
import com.yami.trading.common.constants.RedisKeys;
|
import com.yami.trading.common.util.RedisUtil;
|
import com.yami.trading.service.contract.ContractApplyOrderService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* 系统启动时，将合约单的时间戳加载到缓存，提升后台定时轮询任务的效率，减少数据库压力
|
*
|
* @author caster
|
* @since 2023/11/23
|
**/
|
@Service
|
@Slf4j
|
public class LoadNewContractApplyOrderCache {
|
@Autowired
|
private ContractApplyOrderService contractApplyOrderService;
|
|
public void loadData() {
|
try {
|
List<ContractApplyOrder> allNewOrderList = contractApplyOrderService.findSubmitted();
|
for (ContractApplyOrder oneOrder : allNewOrderList) {
|
RedisUtil.sadd(RedisKeys.NEW_CONTRACT_APPLY_ORDERS, oneOrder.getUuid());
|
}
|
} catch (Exception e) {
|
log.error("------> LoadNewContractApplyOrderCache.loadData 执行 loadData 方法报错: ", e);
|
}
|
}
|
}
|
