From 0316bb78f8805116a6ddcfe5aff1968eb56673e0 Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期五, 10 二月 2023 11:10:23 +0800
Subject: [PATCH] fix(quartz): 111

---
 src/main/java/com/integrated/zyyt/controller/ZyytController.java |   46 +++++++++++++++++++++++++++++++++++++---------
 1 files changed, 37 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/integrated/zyyt/controller/ZyytController.java b/src/main/java/com/integrated/zyyt/controller/ZyytController.java
index 34ba824..8d16915 100644
--- a/src/main/java/com/integrated/zyyt/controller/ZyytController.java
+++ b/src/main/java/com/integrated/zyyt/controller/ZyytController.java
@@ -2,15 +2,14 @@
 
 import com.integrated.zyyt.service.ZyytService;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.bind.annotation.ControllerAdvice;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
 import java.lang.reflect.Method;
 import java.time.Instant;
 import java.time.LocalDate;
-import java.time.LocalTime;
 import java.time.ZoneId;
 import java.time.temporal.ChronoUnit;
 import java.util.Date;
@@ -23,7 +22,7 @@
  * @Description
  * @Version 1.0
  **/
-@ControllerAdvice
+@RestController
 @Slf4j
 @RequestMapping("/api/zyyt")
 public class ZyytController {
@@ -61,13 +60,27 @@
         LocalDate endOfYear = LocalDate.of(year, 12, 31);
         LocalDate now = LocalDate.now();
         for (LocalDate tmp = startOfYear; endOfYear.compareTo(tmp) > 0 && now.compareTo(tmp) > 0; tmp = tmp.plus(1, ChronoUnit.DAYS)) {
-            Instant instant = tmp.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant();
+//            Instant instant = tmp.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant();
 //            threadPool.submit(new ZyytTask(Date.from(instant), zyytService, "shkdrbTasks"));
-            ZyytTask shkdrbTasks = new ZyytTask(Date.from(instant), zyytService, "shkdrbTasks");
-            shkdrbTasks.call();
+            zyytService.shkdrbTasks(tmp);
         }
         return "鍚庡彴鎵ц涓� 锛岃涓嶈閲嶅璇锋眰";
 
+    }
+
+    @GetMapping("/shkdrbTasksAuto")
+    /**
+     * start 2022-12-01
+     * end 2022-12-31
+     */
+    public String shkdrbTasksMonth(String start,String end) throws Exception {
+        LocalDate startOfYear = LocalDate.parse(start);
+        LocalDate endOfYear = LocalDate.parse(end);
+        LocalDate now = LocalDate.now();
+        for (LocalDate tmp = startOfYear; endOfYear.compareTo(tmp) > 0 && now.compareTo(tmp) > 0; tmp = tmp.plus(1, ChronoUnit.DAYS)) {
+            zyytService.shkdrbTasks(tmp);
+        }
+        return "鍚庡彴鎵ц涓� 锛岃涓嶈閲嶅璇锋眰";
     }
 
 
@@ -93,14 +106,29 @@
         LocalDate endOfYear = LocalDate.of(year, 12, 31);
         LocalDate now = LocalDate.now();
         for (LocalDate tmp = startOfYear; endOfYear.compareTo(tmp) > 0 && now.compareTo(tmp) > 0; tmp = tmp.plus(1, ChronoUnit.DAYS)) {
-            Instant instant = tmp.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant();
+//            Instant instant = tmp.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant();
 //            threadPool.submit(new ZyytTask(Date.from(instant), zyytService, "djtjbTasks"));
-            ZyytTask djtjbTasks = new ZyytTask(Date.from(instant), zyytService, "djtjbTasks");
-            djtjbTasks.call();
+            zyytService.djtjbTasks(tmp);
         }
         return "123";
     }
 
+    @GetMapping("/djtjbTasksAuto")
+    /**
+     * start 2022-12-01
+     * end 2022-12-31
+     */
+    public String djtjbTasksAuto(String start,String end) throws Exception {
+        LocalDate startOfYear = LocalDate.parse(start);
+        LocalDate endOfYear = LocalDate.parse(end);
+        LocalDate now = LocalDate.now();
+        for (LocalDate tmp = startOfYear; endOfYear.compareTo(tmp) > 0 && now.compareTo(tmp) > 0; tmp = tmp.plus(1, ChronoUnit.DAYS)) {
+            zyytService.djtjbTasks(tmp);
+        }
+        return "鍚庡彴鎵ц涓� 锛岃涓嶈閲嶅璇锋眰";
+
+    }
+
 }
 
 @Slf4j

--
Gitblit v1.9.1