From 996781d8592750f34238855426a72ba4f9a0c3d3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E5=AD=90=E9=BE=99?= <chenzilong@wodcloud.com>
Date: Wed, 19 Jul 2023 14:57:45 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=A7=E8=A1=8Cansible=E5=91=BD=E4=BB=A4?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97=E5=AD=98=E5=82=A8=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/common/client/redis.go  |  5 +++++
 src/service/task_history.go | 16 ++++++++++++++--
 2 files changed, 19 insertions(+), 2 deletions(-)

diff --git a/src/common/client/redis.go b/src/common/client/redis.go
index 5bb8916..10dc438 100644
--- a/src/common/client/redis.go
+++ b/src/common/client/redis.go
@@ -108,6 +108,11 @@ func (r Redis) Exist(key string) (int64, error) {
 	return r.Conn.Exists(strings.ToUpper(key)).Result()
 }
 
+func (r Redis) HExists(key, field string) (bool, error) {
+	key = fmt.Sprintf("%s-%s", strings.ToUpper(r.Prefix), strings.ToUpper(key))
+	return r.Conn.HExists(strings.ToUpper(key), strings.ToUpper(field)).Result()
+}
+
 func (r Redis) Keys(pattern string) ([]string, error) {
 	pattern = fmt.Sprintf("%s-%s", strings.ToUpper(r.Prefix), strings.ToUpper(pattern))
 	return r.Conn.Keys(strings.ToUpper(pattern)).Result()
diff --git a/src/service/task_history.go b/src/service/task_history.go
index eaf153d..c1c1b1e 100644
--- a/src/service/task_history.go
+++ b/src/service/task_history.go
@@ -142,12 +142,23 @@ func (t *TaskHistorySvc) TaskExecLog(id int) (taskExecLogRes response.TaskExecLo
 			err = resp.RedisConnectError.ErrorDetail(err1)
 			return
 		}
-		value, err2 := redis.HGet(conf.AutoExecHistory, cast.ToString(id))
+		//判断key值是否存在
+		b1, err2 := redis.HExists(conf.AutoExecHistory, cast.ToString(id))
 		if err2 != nil {
-			conf.Logger.Error("redis HGet err", zap.Error(err2))
+			conf.Logger.Error("redis HExists err", zap.Error(err2))
 			err = resp.RedisExecError.ErrorDetail(err2)
+		}
+		if !b1 {
+			return
+		}
+		//获取key
+		value, err3 := redis.HGet(conf.AutoExecHistory, cast.ToString(id))
+		if err3 != nil {
+			conf.Logger.Error("redis HGet err", zap.Error(err3))
+			err = resp.RedisExecError.ErrorDetail(err3)
 			return
 		}
+		//解析key
 		var execCache ExecCache
 		err = json.Unmarshal([]byte(value), &execCache)
 		if err != nil {
@@ -155,6 +166,7 @@ func (t *TaskHistorySvc) TaskExecLog(id int) (taskExecLogRes response.TaskExecLo
 			err = resp.FAIL.WithError(err)
 			return
 		}
+		conf.Logger.Info("redis HGet Log", zap.String("log", execCache.ExecLog))
 		taskExecLogRes.ExecLog = execCache.ExecLog
 		taskExecLogRes.ExecEndTime = execCache.ExecEndTime
 	}
-- 
2.26.0