From 60890359b3052847fb9e61d4675147aba20fec73 Mon Sep 17 00:00:00 2001 From: cy <1664593601@qq.com> Date: 星期四, 09 二月 2023 17:00:06 +0800 Subject: [PATCH] fix(quartz): 111 --- src/main/java/com/integrated/zyyt/controller/ZyytController.java | 21 ++++++++++----------- 1 files changed, 10 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/integrated/zyyt/controller/ZyytController.java b/src/main/java/com/integrated/zyyt/controller/ZyytController.java index b1b072d..5205c48 100644 --- a/src/main/java/com/integrated/zyyt/controller/ZyytController.java +++ b/src/main/java/com/integrated/zyyt/controller/ZyytController.java @@ -10,13 +10,10 @@ 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; import java.util.concurrent.Callable; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; /** * @ClassName ZyytController @@ -29,7 +26,7 @@ @Slf4j @RequestMapping("/api/zyyt") public class ZyytController { - private ExecutorService threadPool = Executors.newFixedThreadPool(6); +// private ExecutorService threadPool = Executors.newFixedThreadPool(6); @Resource private ZyytService zyytService; @@ -58,13 +55,14 @@ @GetMapping("/shkdrbTasksYear") - public String shkdrbTasksYear(int year) { + public String shkdrbTasksYear(int year) throws Exception { LocalDate startOfYear = LocalDate.of(year, 1, 1); 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(); - threadPool.submit(new ZyytTask(Date.from(instant), zyytService, "shkdrbTasks")); +// Instant instant = tmp.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant(); +// threadPool.submit(new ZyytTask(Date.from(instant), zyytService, "shkdrbTasks")); + zyytService.shkdrbTasks(tmp); } return "鍚庡彴鎵ц涓� 锛岃涓嶈閲嶅璇锋眰"; @@ -88,15 +86,16 @@ * @params isForece 1寮哄埗鏇存柊 2涓嶅己鍒� * */ - public String djtjbTasksYear(int year) { + public String djtjbTasksYear(int year) throws Exception { LocalDate startOfYear = LocalDate.of(year, 1, 1); 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(); - threadPool.submit(new ZyytTask(Date.from(instant), zyytService, "djtjbTasks")); +// Instant instant = tmp.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant(); +// threadPool.submit(new ZyytTask(Date.from(instant), zyytService, "djtjbTasks")); + zyytService.djtjbTasks(tmp); } - return "鍚庡彴鎵ц涓� 锛岃涓嶈閲嶅璇锋眰"; + return "123"; } } -- Gitblit v1.9.1