From 040cd381f2e8475e9b4eb336b704ad878f56f4fa Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 14 九月 2023 20:42:01 +0800
Subject: [PATCH] 适应性改动

---
 service/cache_store.go |   24 ++++++++++++------------
 1 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/service/cache_store.go b/service/cache_store.go
index 4c3148b..9cbd07b 100644
--- a/service/cache_store.go
+++ b/service/cache_store.go
@@ -44,17 +44,17 @@
 }
 
 const (
-	PlcCacheKey             = "plc:%v"
+	PlcCacheKey             = "plc:%v:%v"
 	CurrentTaskCacheKey     = "current_task"
-	CurrentProgressCacheKey = "current_progress"
+	CurrentProgressCacheKey = "current_progress:%v"
 )
 
-func PlcCacheGet(key string) (interface{}, bool) {
-	return defaultCacheStore.Get(fmt.Sprintf(PlcCacheKey, key))
+func PlcCacheGet(position int, key string) (interface{}, bool) {
+	return defaultCacheStore.Get(fmt.Sprintf(PlcCacheKey, position, key))
 }
 
-func PlcCacheSet(key string, value interface{}) {
-	defaultCacheStore.Add(fmt.Sprintf(PlcCacheKey, key), value)
+func PlcCacheSet(position int, key string, value interface{}) {
+	defaultCacheStore.Add(fmt.Sprintf(PlcCacheKey, position, key), value)
 }
 
 func TaskCacheSet(value *response.TaskData) {
@@ -72,17 +72,17 @@
 	return nil, false
 }
 
-func ProgressCacheGet() (*model.ProductionProgress, bool) {
-	if v, ok := defaultCacheStore.Get(CurrentProgressCacheKey); ok {
+func ProgressCacheGet(position int) (*model.ProductionProgress, bool) {
+	if v, ok := defaultCacheStore.Get(fmt.Sprintf(CurrentProgressCacheKey, position)); ok {
 		return v.(*model.ProductionProgress), ok
 	}
 	return nil, false
 }
 
-func ProgressCacheSet(value *model.ProductionProgress) {
-	defaultCacheStore.Add(CurrentProgressCacheKey, value)
+func ProgressCacheSet(position int, value *model.ProductionProgress) {
+	defaultCacheStore.Add(fmt.Sprintf(CurrentProgressCacheKey, position), value)
 }
 
-func ProgressCacheUnset() {
-	defaultCacheStore.Remove(CurrentProgressCacheKey)
+func ProgressCacheUnset(position int) {
+	defaultCacheStore.Remove(fmt.Sprintf(CurrentProgressCacheKey, position))
 }

--
Gitblit v1.8.0