From 201e533df848965e4e7a00b056f478a42166fb40 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E5=AD=90=E9=BE=99?= Date: Thu, 20 Jul 2023 11:10:36 +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/service/task_history.go | 14 ++++++++------ src/service/task_manage.go | 4 +++- 2 files changed, 11 insertions(+), 7 deletions(-) diff --git a/src/service/task_history.go b/src/service/task_history.go index 953f85d..617f947 100644 --- a/src/service/task_history.go +++ b/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 + } } } diff --git a/src/service/task_manage.go b/src/service/task_manage.go index fa20fd5..7b3a875 100644 --- a/src/service/task_manage.go +++ b/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)) + } -- 2.26.0