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