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 | 23 ++++++++++++++++-------
1 files changed, 16 insertions(+), 7 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 a96d7a8..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
@@ -2,6 +2,7 @@
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ltkj.common.enums.DataSourceType;
import com.ltkj.db.DataSourceConfig;
import com.ltkj.db.DataSourceContextHolder;
@@ -73,7 +74,9 @@
public void init() {
DataSourceContextHolder.setDataSourceKey(DataSourceType.MASTER.name());
// 鑾峰彇鎵�鏈夐渶瑕佸悓姝ユ棩蹇楃殑鐢ㄦ埛鍒楄〃
- List<DictHosp> hospList = dictHospService.list();
+ LambdaQueryWrapper<DictHosp> wrapper = new LambdaQueryWrapper<>();
+ wrapper.eq(DictHosp::getIsAutoAsyncJg,1);
+ List<DictHosp> hospList = dictHospService.list(wrapper);
hospList.forEach(this::createTask); // 涓烘瘡涓敤鎴峰垱寤轰换鍔�
// 瀹氭椂妫�鏌ユ槸鍚︽湁鏂扮殑鐢ㄦ埛闇�瑕佹坊鍔犱换鍔�
schedulePeriodicTaskCheck();
@@ -92,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));
}
@@ -216,8 +221,12 @@
// 妫�鏌ュ苟娣诲姞鏂扮殑鐢ㄦ埛浠诲姟
public void checkAndAddNewTasks() {
+ DataSourceContextHolder.setDataSourceKey(DataSourceType.MASTER.name());
// 鑾峰彇鎵�鏈夐渶瑕佸悓姝ユ棩蹇楃殑鐢ㄦ埛鍒楄〃
- List<DictHosp> hospList = dictHospService.list();
+ 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