diff --git a/src/modules/monitor/controller/sys_job_log.go b/src/modules/monitor/controller/sys_job_log.go index 85a8a823..f84bc869 100644 --- a/src/modules/monitor/controller/sys_job_log.go +++ b/src/modules/monitor/controller/sys_job_log.go @@ -41,6 +41,12 @@ type SysJobLogController struct { func (s *SysJobLogController) List(c *gin.Context) { // 查询参数转换map querys := ctx.QueryMap(c) + // 任务ID优先级更高 + if v, ok := querys["jobId"]; ok && v != nil { + jobInfo := service.NewSysJobImpl.SelectJobById(v.(string)) + querys["jobName"] = jobInfo.JobName + querys["jobGroup"] = jobInfo.JobGroup + } data := s.sysJobLogService.SelectJobLogPage(querys) rows := data["rows"].([]model.SysJobLog) diff --git a/src/modules/monitor/repository/sys_job_log.impl.go b/src/modules/monitor/repository/sys_job_log.impl.go index cf506c4d..2e97e85b 100644 --- a/src/modules/monitor/repository/sys_job_log.impl.go +++ b/src/modules/monitor/repository/sys_job_log.impl.go @@ -59,7 +59,7 @@ func (r *SysJobLogImpl) SelectJobLogPage(query map[string]any) map[string]any { var conditions []string var params []any if v, ok := query["jobName"]; ok && v != "" { - conditions = append(conditions, "job_name like concat(?, '%')") + conditions = append(conditions, "job_name = ?") params = append(params, v) } if v, ok := query["jobGroup"]; ok && v != "" {