执行ansible命令日志存储缓存

src/service/task_history.go

@@ -170,12 +170,14 @@ func (t *TaskHistorySvc) TaskExecLog(id int) (taskExecLogRes response.TaskExecLo
 			err = resp.FAIL.WithError(errMarshal)
 			return
 		}
-		// 写缓存
-		err = redis.HSet(conf.TaskExecLog, strconv.Itoa(id), fmt.Sprintf("%s", taskExecLog))
-		if err != nil {
-			conf.Logger.Error("Failed to execute history cache err", zap.Error(err))
-			err = resp.FAIL.WithError(err)
-			return
+		if taskExecLogRes.State == 0 {
+			// 写缓存
+			err = redis.HSet(conf.TaskExecLog, strconv.Itoa(id), fmt.Sprintf("%s", taskExecLog))
+			if err != nil {
+				conf.Logger.Error("Failed to execute history cache err", zap.Error(err))
+				err = resp.FAIL.WithError(err)
+				return
+			}
 		}
 	}
 

src/service/task_manage.go

@@ -468,6 +468,8 @@ func ExecAnsible(id, taskId int, value string) {
 			//return
 		}
 	}
+	err = redis.HDel(conf.TaskExecLog, strconv.Itoa(id))
+	conf.Logger.Error("del redis err", zap.Error(err))
 	redis.HDel(conf.AutoExecHistory, strconv.Itoa(id))
-	redis.HDel(conf.TaskExecLog, strconv.Itoa(id))
+
 }