fix: 优化告警附加信息处理逻辑

src/modules/crontask/processor/ne_alarm_state_check_cmd/ne_alarm_state_check_cmd.go

@@ -107,6 +107,13 @@ func (s *NeAlarmStateCheckCMDProcessor) Execute(data any) (any, error) {
 		if err == nil {
 			continue
 		}
+		// 附加信息
+		addInfo := params.AddInfo
+		if addInfo != "" {
+			addInfo = addInfo + ", " + err.Error()
+		} else {
+			addInfo = err.Error()
+		}
 
 		neTypeAndId := fmt.Sprintf("%s_%s", neInfo.NeType, neInfo.NeId)
 		// 告警ID
@@ -136,15 +143,10 @@ func (s *NeAlarmStateCheckCMDProcessor) Execute(data any) (any, error) {
 		}
 		// 未记录
 		if alarmStatus == "" {
-			addInfo := params.AddInfo
-			if params.AddInfo != "" {
-				params.AddInfo = params.AddInfo + ", " + err.Error()
-			} else {
-				params.AddInfo = err.Error()
-			}
 			// 进行新增
-			newAlarm, err := s.alarmNew(neInfo, params)
+			copyParams := params
-			params.AddInfo = addInfo                       // 恢复附加信息
+			copyParams.AddInfo = addInfo
+			newAlarm, err := s.alarmNew(neInfo, copyParams)
 			triggerCount.Store(neTypeAndId, []time.Time{}) // 重置连续触发次数
 			if err != nil {
 				result[neTypeAndId] = err.Error()

src/modules/crontask/processor/ne_alarm_state_check_license/ne_alarm_state_check_license.go

@@ -87,10 +87,12 @@ func (s *NeAlarmStateCheckLicenseProcessor) Execute(data any) (any, error) {
 		if err == nil {
 			continue
 		}
-		if params.AddInfo != "" {
+		// 附加信息
-			params.AddInfo = params.AddInfo + ", " + err.Error()
+		addInfo := params.AddInfo
+		if addInfo != "" {
+			addInfo = addInfo + ", " + err.Error()
 		} else {
-			params.AddInfo = err.Error()
+			addInfo = err.Error()
 		}
 
 		neTypeAndId := fmt.Sprintf("%s_%s", neInfo.NeType, neInfo.NeId)
@@ -121,15 +123,10 @@ func (s *NeAlarmStateCheckLicenseProcessor) Execute(data any) (any, error) {
 		}
 		// 未记录
 		if alarmStatus == "" {
-			addInfo := params.AddInfo
-			if params.AddInfo != "" {
-				params.AddInfo = params.AddInfo + ", " + err.Error()
-			} else {
-				params.AddInfo = err.Error()
-			}
 			// 进行新增
-			newAlarm, err := s.alarmNew(neInfo, params)
+			copyParams := params
-			params.AddInfo = addInfo // 恢复附加信息
+			copyParams.AddInfo = addInfo
+			newAlarm, err := s.alarmNew(neInfo, copyParams)
 			if err != nil {
 				result[neTypeAndId] = err.Error()
 				continue

src/modules/crontask/processor/ne_alarm_state_check_udmdb_sync/ne_alarm_state_check_udmdb_sync.go

@@ -73,10 +73,12 @@ func (s *NeAlarmStateCheckUDMDBProcessor) Execute(data any) (any, error) {
 		if err == nil {
 			continue
 		}
-		if params.AddInfo != "" {
+		// 附加信息
-			params.AddInfo = params.AddInfo + ", " + err.Error()
+		addInfo := params.AddInfo
+		if addInfo != "" {
+			addInfo = addInfo + ", " + err.Error()
 		} else {
-			params.AddInfo = err.Error()
+			addInfo = err.Error()
 		}
 
 		neTypeAndId := fmt.Sprintf("%s_%s", neInfo.NeType, neInfo.NeId)
@@ -107,15 +109,10 @@ func (s *NeAlarmStateCheckUDMDBProcessor) Execute(data any) (any, error) {
 		}
 		// 未记录
 		if alarmStatus == "" {
-			addInfo := params.AddInfo
-			if params.AddInfo != "" {
-				params.AddInfo = params.AddInfo + ", " + err.Error()
-			} else {
-				params.AddInfo = err.Error()
-			}
 			// 进行新增
-			newAlarm, err := s.alarmNew(neInfo, params)
+			copyParams := params
-			params.AddInfo = addInfo // 恢复附加信息
+			copyParams.AddInfo = addInfo
+			newAlarm, err := s.alarmNew(neInfo, copyParams)
 			if err != nil {
 				result[neTypeAndId] = err.Error()
 				continue
@@ -183,6 +180,9 @@ func (s NeAlarmStateCheckUDMDBProcessor) serverState(neInfo neModel.NeInfo) erro
 			}
 			continue
 		}
+		if !(strings.HasPrefix(master_host, "master_") && strings.HasPrefix(master_port, "master_")) {
+			break
+		}
 	}
 
 	return fmt.Errorf("host:%s, port:%s, status down", master_host, master_port)