package com.xiaopeng.operation.utils.task;
|
|
import com.xiaopeng.api.model.operation.XpBanner;
|
import com.xiaopeng.api.vo.operation.XpLogMessage;
|
import com.xiaopeng.common.core.constant.CacheConstants;
|
import com.xiaopeng.operation.service.XpBannerService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.ZoneOffset;
|
import java.util.List;
|
import java.util.Set;
|
|
/**
|
* @author 无关风月
|
* @date 2026/2/26 9:49
|
*/
|
@Slf4j
|
@Component
|
public class BannerTaskUtil {
|
|
@Autowired
|
private XpBannerService bannerService;
|
|
@Resource
|
private MongoTemplate mongoTemplate;
|
|
|
/**
|
* 每隔一分钟去处理的定时任务
|
*/
|
@Scheduled(fixedRate = 60000)
|
public void taskMinute() {
|
try {
|
log.info("处理的banner状态定时任务开始执行，当前时间：{}", LocalDateTime.now());
|
// 根据banner开始、结束时间修改banner状态
|
List<XpBanner> banners = bannerService.list();
|
for (XpBanner banner : banners) {
|
// 如果当前时间小于开始时间 那么状态为未开始 当前时间大于结束时间状态为已结束 否则为进行中
|
if (banner.getStartTime().isAfter(LocalDateTime.now())) {
|
banner.setStatus(0);
|
}else if (banner.getEndTime().isBefore(LocalDateTime.now())){
|
banner.setStatus(2);
|
}else{
|
banner.setStatus(1);
|
}
|
}
|
bannerService.updateBatchById(banners);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
/**
|
* 删除移动端日志
|
*/
|
@Scheduled(cron = "0 0 0 * * ?")
|
public void removeLogMessage() {
|
//删除大于2天的日志记录
|
LocalDateTime now = LocalDateTime.now();
|
LocalDateTime twoDayAgo = now.minusDays(2);
|
mongoTemplate.remove(new Query(Criteria.where("timestamp").lt(twoDayAgo.toEpochSecond(ZoneOffset.of("+8")))), XpLogMessage.class);
|
}
|
}
|
