From 290f2a28f42ef340db651901fa513c6beae8d899 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期四, 21 九月 2023 11:34:21 +0800 Subject: [PATCH] 待机逻辑更改,超过配置的时间数据不变认为待机 --- service/cache_store.go | 26 ++++++++++++++++++++++++-- 1 files changed, 24 insertions(+), 2 deletions(-) diff --git a/service/cache_store.go b/service/cache_store.go index 9cbd07b..9b7b74d 100644 --- a/service/cache_store.go +++ b/service/cache_store.go @@ -1,10 +1,13 @@ package service import ( + "apsClient/constvar" "apsClient/model" "apsClient/model/response" "fmt" + "github.com/spf13/cast" "sync" + "time" ) type CacheStore struct { @@ -44,9 +47,10 @@ } const ( - PlcCacheKey = "plc:%v:%v" + PlcCacheKey = "plc:%v:%v" //plc:position:key CurrentTaskCacheKey = "current_task" - CurrentProgressCacheKey = "current_progress:%v" + CurrentProgressCacheKey = "current_progress:%v" //current_progress:position + PlcCacheKeyUpdateTime = "finish_number_update_time:%v" //finish_number_update_time:position ) func PlcCacheGet(position int, key string) (interface{}, bool) { @@ -54,9 +58,27 @@ } func PlcCacheSet(position int, key string, value interface{}) { + if key == constvar.PlcCacheKeyFinishNumber { + oldFinishNumber, exists := PlcCacheGet(position, key) + if !exists || cast.ToInt(oldFinishNumber) != cast.ToInt(value) { //finishNumber鏈変簡鍙樺寲锛岃缃洿鏂版椂闂寸紦瀛� + FinishUpdateTimeSet(position, time.Now().Unix()) + } + } defaultCacheStore.Add(fmt.Sprintf(PlcCacheKey, position, key), value) } +func FinishUpdateTimeGet(position int) interface{} { + val, ok := defaultCacheStore.Get(fmt.Sprintf(PlcCacheKeyUpdateTime, position)) + if ok { + return val + } + return 0 +} + +func FinishUpdateTimeSet(position int, value interface{}) { + defaultCacheStore.Add(fmt.Sprintf(PlcCacheKeyUpdateTime, position), value) +} + func TaskCacheSet(value *response.TaskData) { defaultCacheStore.Add(CurrentTaskCacheKey, value) } -- Gitblit v1.8.0