From 3067ad92965d6b48db42b4cd7a37f2116e52f4c0 Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期四, 03 七月 2025 14:44:48 +0800
Subject: [PATCH] zjh20250703

---
 ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java |   14 +++++++++-----
 1 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
index b1cf8b7..b3d9624 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
@@ -95,15 +95,17 @@
         // 灏嗚鐢ㄦ埛ID娣诲姞鍒板凡璋冨害浠诲姟闆嗗悎涓�
         scheduledTasks.add(dictHosp.getCode());
         // 鍒涘缓瀹氭椂浠诲姟锛屼换鍔″皢鍦�15鍒嗛挓鍚庢墽琛�
-        taskScheduler.schedule(() -> {
+/*        taskScheduler.schedule(() -> {
             try {
-                // 鎵ц浠诲姟鐨勮秴鏃舵帶鍒�
-                taskScheduler.schedule(() -> {
-                    executeTask(dictHosp);
-                }, Instant.now());
+
             } catch (Exception e) {
                 log.error("鍒涘缓浠诲姟鏃跺彂鐢熷紓甯革細{}", e.getMessage());
             }
+        }, Instant.now().plus(15, ChronoUnit.MINUTES));*/
+        log.info("浠诲姟鍒涘缓鎴愬姛 ->{}",dictHosp.getCode());
+        // 鎵ц浠诲姟鐨勮秴鏃舵帶鍒�
+        taskScheduler.schedule(() -> {
+            executeTask(dictHosp);
         }, Instant.now().plus(15, ChronoUnit.MINUTES));
     }
 
@@ -219,10 +221,12 @@
 
     // 妫�鏌ュ苟娣诲姞鏂扮殑鐢ㄦ埛浠诲姟
     public void checkAndAddNewTasks() {
+        DataSourceContextHolder.setDataSourceKey(DataSourceType.MASTER.name());
         // 鑾峰彇鎵�鏈夐渶瑕佸悓姝ユ棩蹇楃殑鐢ㄦ埛鍒楄〃
         LambdaQueryWrapper<DictHosp> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(DictHosp::getIsAutoAsyncJg,1);
         List<DictHosp> hospList = dictHospService.list(wrapper);
+        log.info("妫�鏌ュ苟娣诲姞闇�瑕佸悓姝ョ殑鍖婚櫌鍒楄〃:{}", JSONUtil.toJsonStr(hospList));
         hospList.forEach(this::createTask);
         taskScheduler.schedule(this::checkAndAddNewTasks, Instant.now().plus(2, ChronoUnit.MINUTES));
     }

--
Gitblit v1.8.0