重构生产进度存储和同步

zhangqian

2023-12-01 02f1a1173684cce572f5488edb4c928c5b1c386e

 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))
}