From 6d5d2a339e32d152269c9f3718b0a688f7ef57ec Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Thu, 24 Jul 2025 14:55:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=87=AA=E5=8A=A8=E8=A1=A5?=
 =?UTF-8?q?=E6=8B=9B=E7=A8=B3=E6=80=81=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/dataProcess/job/DataRecallJob.java   | 35 +++++++++++++++++++
 1 file changed, 35 insertions(+)
 create mode 100644 data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/job/DataRecallJob.java

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);
+    }
+}