From e0b28c43f585bfd5fef934e08e11304d9442f7ea Mon Sep 17 00:00:00 2001 From: lucas Date: Thu, 19 Sep 2024 16:28:10 +0800 Subject: [PATCH] =?UTF-8?q?update=20=20=E5=AD=97=E7=AC=A6=E4=B8=B2?= =?UTF-8?q?=E7=B1=BB=E5=9E=8B=20=E5=AD=97=E6=AE=B5=20=20=E4=B8=8D=E8=BF=9B?= =?UTF-8?q?=E8=A1=8C=E6=BB=91=E7=AA=97=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- et_cache/cacheHandler.go | 6 ++++++ 1 file changed, 6 insertions(+) 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 {