From 02f1a1173684cce572f5488edb4c928c5b1c386e Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 01 十二月 2023 09:35:31 +0800
Subject: [PATCH] 重构生产进度存储和同步
---
service/report_work.go | 2 +-
service/cache_store.go | 11 -----------
2 files changed, 1 insertions(+), 12 deletions(-)
diff --git a/service/cache_store.go b/service/cache_store.go
index e8b9832..877217a 100644
--- a/service/cache_store.go
+++ b/service/cache_store.go
@@ -145,17 +145,6 @@
}
}
-func ProgressCacheGet(deviceID string, channel int32) (*model.ProductionProgress, bool) {
- if v, ok := defaultCacheStore.Get(fmt.Sprintf(CurrentProgressCacheKey, deviceID, channel)); ok {
- return v.(*model.ProductionProgress), ok
- }
- return nil, false
-}
-
-func ProgressCacheSet(deviceID string, channel int32, value *model.ProductionProgress) {
- defaultCacheStore.Add(fmt.Sprintf(CurrentProgressCacheKey, deviceID, channel), value)
-}
-
func ProgressCacheUnset(deviceID string, channel int32) {
defaultCacheStore.Remove(fmt.Sprintf(CurrentProgressCacheKey, deviceID, channel))
}
diff --git a/service/report_work.go b/service/report_work.go
index a89ae40..ea25a57 100644
--- a/service/report_work.go
+++ b/service/report_work.go
@@ -92,7 +92,7 @@
return err
}
- err = NewProgressService().UpdateProgressByProceduresId(procedure.ID, int64(params.ReportAmount))
+ err = NewProgressService().UpdateProgressByProceduresId(procedure.ID, params.ReportAmount)
return nil
}
--
Gitblit v1.8.0