update 避免空应用

consumers/consumerAxySkAlarm.go

@@ -247,7 +247,7 @@ func (the *consumerAxySkAlarm) judgeSK() string {
 
 		//无告警的测点,需要恢复
 		var noAlarmStationIds []string
-		var alarmStationIdMap map[string]string
+		alarmStationIdMap := map[string]string{}
 		for _, alarm := range alarms {
 			alarmStationIdMap[alarm.SourceId] = alarm.AlarmCode
 		}
@@ -261,7 +261,7 @@ func (the *consumerAxySkAlarm) judgeSK() string {
 		//恢复无告警的双控测点
 		log.Printf("无告警,待恢复的测点ids==%v", noAlarmStationIds)
 		for _, stationId := range noAlarmStationIds {
-			content := "测量值恢复正常 和 变化速率恢复正常"
+			content := "测量值恢复正常和变化速率恢复正常"
 			payload := the.skAlarmAutoElimination(trigger.StructId, trigger.StructName, stationId, "", trigger.AlarmLevel, content)
 			the.OutKafka.Publish(the.Info.IoConfig.Out.Kafka.AlarmTopic, payload)
 			hisK := fmt.Sprintf("%s_%s", stationId, fmt.Sprintf("3077000%d", trigger.AlarmLevel))