知物云告警主题从优化成动态获取主题

consumers/consumerSavoirTheme.go

@@ -150,7 +150,7 @@ func (the *consumerSavoirTheme) judgeOffline() {
 			//拿到当前es最后一条数据和当前数据库的配置之后去查是否产生告警
 			StrValue := "80040003"
 			alarmQueryStr := the.getEsAlarmValueStr(gap.StructId, StrValue)
-			allAlarmThemes, err := the.OutEs.SearchAlarmThemeData("native_alarms", alarmQueryStr)
+			allAlarmThemes, err := the.OutEs.SearchAlarmThemeData(the.Info.IoConfig.In.Kafka.AlarmTopic, alarmQueryStr)
 			log.Printf("allAlarmThemes----- >  %s", allAlarmThemes)
 			if err != nil {
 				log.Printf("查询es 异常")