|
|
@ -33,6 +33,12 @@ func (the *CacheHandler) enqueue(p *common_models.ProcessData) *common_models.Pr |
|
|
|
|
|
|
|
for _, station := range p.Stations { |
|
|
|
for _, item := range station.Info.Proto.Items { |
|
|
|
//字符串类型不处理
|
|
|
|
itemV := station.Data.ThemeData[item.FieldName] |
|
|
|
if _, ok := itemV.(string); ok { |
|
|
|
continue |
|
|
|
} |
|
|
|
|
|
|
|
cacheItemKey := fmt.Sprintf("%s:%d:%s", redisKey.CacheWindow, station.Info.Id, item.FieldName) |
|
|
|
cacheWindow, ok := the.cacheServer.ReadCacheMap(station.Info.Id, item.FieldName) |
|
|
|
if !ok { |
|
|
|