| | |
|---|
| | | import ( |
|---|
| | | "apsClient/constvar" |
|---|
| | | "apsClient/model" |
|---|
| | | "apsClient/model/response" |
|---|
| | | "fmt" |
|---|
| | | "github.com/spf13/cast" |
|---|
| | | "sync" |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | const ( |
|---|
| | | PlcCacheKey = "plc:%v:%v" //plc:channel:key |
|---|
| | | CurrentTaskCacheKey = "current_task" |
|---|
| | | PlcCacheKey = "plc:%v:%v" //plc:channel:key |
|---|
| | | CurrentTaskCacheKey = "current_task:%v" //current_task:channel |
|---|
| | | CurrentProgressCacheKey = "current_progress:%v" //current_progress:channel |
|---|
| | | PlcCacheKeyUpdateTime = "finish_number_update_time:%v" //finish_number_update_time:channel |
|---|
| | | ) |
|---|
| | |
|---|
| | | defaultCacheStore.Add(fmt.Sprintf(PlcCacheKeyUpdateTime, channel), value) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func TaskCacheSet(value *response.TaskData) { |
|---|
| | | defaultCacheStore.Add(CurrentTaskCacheKey, value) |
|---|
| | | func TaskFlagSet(channel int32) { |
|---|
| | | defaultCacheStore.Add(fmt.Sprintf(CurrentTaskCacheKey, channel), struct{}{}) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func TaskCacheUnset() { |
|---|
| | | defaultCacheStore.Remove(CurrentTaskCacheKey) |
|---|
| | | func TaskFlagUnset(channel int32) { |
|---|
| | | defaultCacheStore.Remove(fmt.Sprintf(CurrentTaskCacheKey, channel)) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func TaskCacheGet() (*response.TaskData, bool) { |
|---|
| | | if v, ok := defaultCacheStore.Get(CurrentTaskCacheKey); ok { |
|---|
| | | return v.(*response.TaskData), ok |
|---|
| | | func TaskFlagGet(channel int32) bool { |
|---|
| | | if _, ok := defaultCacheStore.Get(fmt.Sprintf(CurrentTaskCacheKey, channel)); ok { |
|---|
| | | return true |
|---|
| | | } |
|---|
| | | return nil, false |
|---|
| | | return false |
|---|
| | | } |
|---|
| | | |
|---|
| | | func ProgressCacheGet(channel int32) (*model.ProductionProgress, bool) { |
|---|
