package com.xiaopeng.operation.utils.task;
|
|
import com.xiaopeng.api.model.operation.XpBanner;
|
import com.xiaopeng.operation.service.XpBannerService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* @author 无关风月
|
* @date 2026/2/26 9:49
|
*/
|
@Slf4j
|
@Component
|
public class BannerTaskUtil {
|
|
@Autowired
|
private XpBannerService bannerService;
|
|
|
/**
|
* 每隔一分钟去处理的定时任务
|
*/
|
@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();
|
}
|
}
|
|
|
}
|
