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