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/ZyytQuartz.java | 6 +++---
src/main/java/com/integrated/zyyt/controller/ZyytController.java | 35 +++++++++++++++++++++++++++++++++--
2 files changed, 36 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/integrated/zyyt/ZyytQuartz.java b/src/main/java/com/integrated/zyyt/ZyytQuartz.java
index 8aa5dcd..4f60aa3 100644
--- a/src/main/java/com/integrated/zyyt/ZyytQuartz.java
+++ b/src/main/java/com/integrated/zyyt/ZyytQuartz.java
@@ -27,7 +27,7 @@
private JdbcTemplate jdbcTemplate;
- @Scheduled(cron = "0 0/30 * * * ?")
+ @Scheduled(cron = "0 3 0/6 * * ?")
private void stationInfoTask() {
LocalDate yestDay = LocalDate.now().minus(1, ChronoUnit.DAYS);
if (ZyytUtil.canGetAgain("STATIONINFO", yestDay)) {
@@ -39,7 +39,7 @@
}
- @Scheduled(cron = "0 3/30 * * * ?")
+ @Scheduled(cron = "0 23 0/3 * * ?")
private void shkdrbTasks() {
LocalDate yestDay = LocalDate.now().minus(1, ChronoUnit.DAYS);
if (ZyytUtil.canGetAgain("YYZT_T_SHKDRB", yestDay)) {
@@ -50,7 +50,7 @@
}
}
- @Scheduled(cron = "0 7/30 * * * ?")
+ @Scheduled(cron = "0 7 0/3 * * ?")
private void djtjbTasks() {
LocalDate yestDay = LocalDate.now().minus(1, ChronoUnit.DAYS);
if (!ZyytUtil.canGetAgain("YYZT_T_DJTJB", yestDay)) {
diff --git a/src/main/java/com/integrated/zyyt/controller/ZyytController.java b/src/main/java/com/integrated/zyyt/controller/ZyytController.java
index 5205c48..8d16915 100644
--- a/src/main/java/com/integrated/zyyt/controller/ZyytController.java
+++ b/src/main/java/com/integrated/zyyt/controller/ZyytController.java
@@ -2,9 +2,9 @@
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;
@@ -22,7 +22,7 @@
* @Description
* @Version 1.0
**/
-@ControllerAdvice
+@RestController
@Slf4j
@RequestMapping("/api/zyyt")
public class ZyytController {
@@ -68,6 +68,21 @@
}
+ @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 "鍚庡彴鎵ц涓� 锛岃涓嶈閲嶅璇锋眰";
+ }
+
@GetMapping("/djtjbTasks")
/**
@@ -98,6 +113,22 @@
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