diff --git a/et_cache/cacheHandler.go b/et_cache/cacheHandler.go index b23d458..d4d8f82 100644 --- a/et_cache/cacheHandler.go +++ b/et_cache/cacheHandler.go @@ -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 {