diff --git a/business/model/dao/dao_job.go b/business/model/dao/dao_job.go index 7873f2fef..c13f761e9 100644 --- a/business/model/dao/dao_job.go +++ b/business/model/dao/dao_job.go @@ -1,6 +1,7 @@ package dao import ( + "fmt" "time" "git.rosy.net.cn/baseapi/utils" @@ -159,15 +160,19 @@ func GetJobDetail(db *DaoDB, jobID int) (job *GetJobsResult, err error) { sqlParams = append(sqlParams, jobID) } err = GetRow(db, &job, sql, sqlParams...) - sql2 := ` - SELECT * - FROM job_step - WHERE job_id = ? - AND deleted_at = ? - ` - sqlParams2 := []interface{}{job.ID, utils.DefaultTimeValue} - err = GetRows(db, &jobSteps, sql2, sqlParams2) - job.JobSteps = jobSteps + if job != nil { + sql2 := ` + SELECT * + FROM job_step + WHERE job_id = ? + AND deleted_at = ? + ` + sqlParams2 := []interface{}{job.ID, utils.DefaultTimeValue} + err = GetRows(db, &jobSteps, sql2, sqlParams2) + job.JobSteps = jobSteps + } else { + return job, fmt.Errorf("未查到到该任务!") + } return job, err }