From 8b8ce58477d7d652e2ef1c46d54b4c468bdae0b8 Mon Sep 17 00:00:00 2001 From: 18209 Date: Tue, 22 Jul 2025 09:16:12 +0800 Subject: [PATCH] =?UTF-8?q?=E6=81=A2=E5=A4=8D=E5=91=8A=E8=AD=A6=E7=9A=84al?= =?UTF-8?q?arm=5Ftype=5Fcode=E4=BF=AE=E6=94=B9=E6=9F=A5=E8=AF=A2=E6=9D=A1?= =?UTF-8?q?=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consumers/consumerSavoirTheme.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/consumers/consumerSavoirTheme.go b/consumers/consumerSavoirTheme.go index 20d44c5..f0fc38d 100644 --- a/consumers/consumerSavoirTheme.go +++ b/consumers/consumerSavoirTheme.go @@ -148,7 +148,7 @@ func (the *consumerSavoirTheme) judgeOffline() { log.Printf("s:%d,f:%d,sensor:%d 采集时间%s 当前时间%s", gap.StructId, gap.FactorId, theme.Sensor, theme.CreateTime, now) //拿到当前es最后一条数据和当前数据库的配置之后去查是否产生告警 - StrValue := "80040003" + StrValue := "8004" alarmQueryStr := the.getEsAlarmValueStr(gap.StructId, StrValue) allAlarmThemes, err := the.OutEs.SearchAlarmThemeData(the.Info.IoConfig.Out.Es.AlarmIndex, alarmQueryStr) log.Printf("allAlarmThemes----- > %s", allAlarmThemes) @@ -245,7 +245,7 @@ func (the *consumerSavoirTheme) getEsAlarmValueStr(structId int, alarmCode strin }, { "term": { - "alarm_code": { + "alarm_type_code": { "value": %s } }