From 43acfd697a974b4d94172bf39c1a3ceb7b8953e5 Mon Sep 17 00:00:00 2001 From: fengshuonan Date: Thu, 29 Jun 2023 10:16:17 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=907.6.0=E3=80=91=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E9=80=BB=E8=BE=91=E5=88=A0=E9=99=A4=E7=AC=A6=E5=8F=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../roses/kernel/timer/modular/listener/TaskRunListener.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kernel-d-timer/timer-business/src/main/java/cn/stylefeng/roses/kernel/timer/modular/listener/TaskRunListener.java b/kernel-d-timer/timer-business/src/main/java/cn/stylefeng/roses/kernel/timer/modular/listener/TaskRunListener.java index aad0b379d..70f52699f 100644 --- a/kernel-d-timer/timer-business/src/main/java/cn/stylefeng/roses/kernel/timer/modular/listener/TaskRunListener.java +++ b/kernel-d-timer/timer-business/src/main/java/cn/stylefeng/roses/kernel/timer/modular/listener/TaskRunListener.java @@ -57,14 +57,14 @@ public class TaskRunListener extends ApplicationStartedListener implements Order // 获取数据库所有开启状态的任务 SysTimersParam sysTimersParam = new SysTimersParam(); - sysTimersParam.setDelFlag("N"); sysTimersParam.setJobStatus(TimerJobStatusEnum.RUNNING.getCode()); List list = sysTimersService.findList(sysTimersParam); // 添加定时任务到调度器 for (SysTimers sysTimers : list) { try { - timerExeService.startTimer(String.valueOf(sysTimers.getTimerId()), sysTimers.getCron(), sysTimers.getActionClass(), sysTimers.getParams()); + timerExeService.startTimer(String.valueOf(sysTimers.getTimerId()), sysTimers.getCron(), sysTimers.getActionClass(), + sysTimers.getParams()); } catch (Exception exception) { // 遇到错误直接略过这个定时器（可能多个项目公用库） log.error("定时器初始化遇到错误，略过该定时器！", exception);