query err
This commit is contained in:
@@ -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
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user