From 55275eb3900f49ae6dae3f67f21f8b1359f8594f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Mon, 26 Oct 2020 11:43:05 +0800
Subject: [PATCH] query err

---
 business/model/dao/dao_job.go | 23 ++++++++++++++---------
 1 file changed, 14 insertions(+), 9 deletions(-)

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
 }