From d4243f398b84a8b8cdcd27c35ace72f6a30a6452 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期日, 08 十月 2023 10:45:09 +0800 Subject: [PATCH] 是否可以开始增加开始时间判断,考虑进程退出和断电情况 --- service/cache_store.go | 16 ++++++++++++---- 1 files changed, 12 insertions(+), 4 deletions(-) diff --git a/service/cache_store.go b/service/cache_store.go index 2f6c515..b957062 100644 --- a/service/cache_store.go +++ b/service/cache_store.go @@ -5,6 +5,7 @@ "apsClient/model" "fmt" "github.com/spf13/cast" + "gorm.io/gorm" "sync" "time" ) @@ -79,18 +80,25 @@ } func TaskFlagSet(channel int32) { - defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), struct{}{}) + defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), true) } func TaskFlagUnset(channel int32) { - defaultCacheStore.Remove(fmt.Sprintf(CurrentTaskCacheKey, channel)) + defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), false) } func TaskFlagGet(channel int32) bool { - if _, ok := defaultCacheStore.Get(fmt.Sprintf(CurrentTaskCacheKey, channel)); ok { + if v, ok := defaultCacheStore.Get(fmt.Sprintf(CurrentTaskCacheKey, channel)); ok { + return v.(bool) + } + _, err := model.NewProceduresSearch(nil).SetStatus(model.ProcedureStatusProcessing).SetChannel(channel).First() + if err == gorm.ErrRecordNotFound { + defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), false) + return false + } else { + defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), true) return true } - return false } func ProgressCacheGet(channel int32) (*model.ProductionProgress, bool) { -- Gitblit v1.8.0