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 } }