diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/job/DataRecallJob.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/job/DataRecallJob.java new file mode 100644 index 0000000..645f15e --- /dev/null +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/job/DataRecallJob.java @@ -0,0 +1,35 @@ +package com.njcn.dataProcess.job; + +import com.njcn.dataProcess.controller.DataRecallController; +import com.njcn.message.message.RecallMessage; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.time.temporal.ChronoUnit; + +/** + * Description: + * Date: 2025/07/24 下午 2:22【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Component +@EnableScheduling +@RequiredArgsConstructor +@Slf4j +public class DataRecallJob { + private final DataRecallController dataRecallController; + @Scheduled(cron="0 50 14 * * ?") + public void executeHours() { + RecallMessage param = new RecallMessage(); + param.setReCallStartTime(LocalDate.now().minusDays(1)); + param.setReCallEndTime(LocalDate.now()); + dataRecallController.recall(param); + } +}