From 3d62d3ae0156a5191d08ab7ba296622af2fe124f Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Wed, 11 Jun 2025 19:11:45 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BD=9C=E4=B8=9A=E7=AE=A1=E7=90=86=E9=A1=B5=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E4=B8=80=E5=88=97=E6=98=BE=E7=A4=BA=E4=BD=9C=E4=B8=9A=E6=98=AF?= =?UTF-8?q?=E5=90=A6=E5=B7=B2=E5=8A=A0=E8=BD=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1441426846482432]定时作业管理页增加一列显示作业是否已加载 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1441426846482432 --- .../module/tenant/api/scheduler/JobSearchApi.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/main/java/neatlogic/module/tenant/api/scheduler/JobSearchApi.java b/src/main/java/neatlogic/module/tenant/api/scheduler/JobSearchApi.java index f7dc58bf..7db50dbe 100644 --- a/src/main/java/neatlogic/module/tenant/api/scheduler/JobSearchApi.java +++ b/src/main/java/neatlogic/module/tenant/api/scheduler/JobSearchApi.java @@ -26,9 +26,11 @@ import neatlogic.framework.restful.core.privateapi.PrivateApiComponentBase; import neatlogic.framework.scheduler.core.SchedulerManager; import neatlogic.framework.scheduler.dao.mapper.SchedulerMapper; import neatlogic.framework.scheduler.dto.JobClassVo; +import neatlogic.framework.scheduler.dto.JobStatusVo; import neatlogic.framework.scheduler.dto.JobVo; import neatlogic.framework.scheduler.exception.ScheduleHandlerNotFoundException; import neatlogic.framework.util.TableResultUtil; +import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; @@ -44,6 +46,9 @@ public class JobSearchApi extends PrivateApiComponentBase { @Resource private SchedulerMapper schedulerMapper; + @Resource + private SchedulerManager schedulerManager; + @Override public String getToken() { return "job/search"; @@ -88,6 +93,14 @@ public class JobSearchApi extends PrivateApiComponentBase { List jobList = new ArrayList<>(); if (rowNum > 0) { jobList = schedulerMapper.searchJob(jobVo); + for (JobVo job : jobList) { + boolean isLoad = false; + JobStatusVo jobStatusVo = job.getJobStatus(); + if (jobStatusVo != null && StringUtils.isNotBlank(jobStatusVo.getJobName()) && StringUtils.isNotBlank(jobStatusVo.getJobGroup())) { + isLoad = schedulerManager.checkJobIsExists(jobStatusVo.getJobName(), jobStatusVo.getJobGroup()); + } + job.setIsLoad(isLoad ? 1 : 0); + } } return TableResultUtil.getResult(jobList, jobVo); } -- Gitee