From 39601dcb527cadff2c1c96710520d768190a4714 Mon Sep 17 00:00:00 2001 From: zhangyuxiang <1323804152@qq.com> Date: Thu, 13 Nov 2025 10:16:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AE=89=E4=BF=A1=E6=99=BA?= =?UTF-8?q?=E5=AE=B8=E5=A4=A9=E9=A9=B0=E9=A1=B9=E7=9B=AE=E7=9A=84=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E8=8E=B7=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerZWYHBJCAS.go | 1 + 1 file changed, 1 insertion(+) diff --git a/consumers/consumerZWYHBJCAS.go b/consumers/consumerZWYHBJCAS.go index a513157..2938822 100644 --- a/consumers/consumerZWYHBJCAS.go +++ b/consumers/consumerZWYHBJCAS.go @@ -428,6 +428,7 @@ func (the *consumerZWYHBJCAS) getAlarmInfo(am models.AlarmMsg) []interface{} { station := models.Station{} k1 := fmt.Sprintf("station:%s", sourceId) adaptor := the.getAdaptor() + adaptor.StructInfo = the.Info.StructInfo errRedis := adaptor.Redis.GetObj(k1, &station) if errRedis != nil { log.Printf("redis 获取[s:%d]测点[%s]标签异常", structureId, sourceId)