This commit is contained in:
akrike
2025-06-21 16:29:20 +08:00
parent 52616e29d9
commit d5bc463b59

View File

@@ -56,17 +56,19 @@ func (t *taskRepository) EditTaskEnable(id int, enable bool) (err error) {
} }
func (t *taskRepository) GetAllTaskWithProcessName() (result []model.TaskVo) { func (t *taskRepository) GetAllTaskWithProcessName() (result []model.TaskVo) {
process := query.Process p := query.Process.As("p")
p2 := query.Process.As("p2")
p3 := query.Process.As("p3")
task := query.Task task := query.Task
task.Select( task.Select(
task.ALL, task.ALL,
process.As("p").Name.As("process_name"), p.Name.As("process_name"),
process.As("p2").Name.As("target_name"), p2.Name.As("target_name"),
process.As("p3").Name.As("trigger_name"), p3.Name.As("trigger_name"),
). ).
LeftJoin(process, process.As("p").Uuid.EqCol(task.ProcessId)). LeftJoin(p, p.Uuid.EqCol(task.ProcessId)).
LeftJoin(process, process.As("p2").Uuid.EqCol(task.OperationTarget)). LeftJoin(p2, p2.Uuid.EqCol(task.OperationTarget)).
LeftJoin(process, process.As("p3").Uuid.EqCol(task.TriggerTarget)). LeftJoin(p3, p3.Uuid.EqCol(task.TriggerTarget)).
Scan(&result) Scan(&result)
return return
} }