OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

fix: 自检产生的告警辅助信息字符重复追加

Browse Source
This commit is contained in:
TsMask
2025-07-24 14:20:32 +08:00
parent c9b9408f1d
commit 6f30d998f3
2 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/modules/crontask/processor/ne_alarm_state_check_cmd/ne_alarm_state_check_cmd.go
View File

@@ -142,10 +142,11 @@ func (s *NeAlarmStateCheckCMDProcessor) Execute(data any) (any, error) {
if err == nil { if err == nil {
continue continue
} }
if params.AddInfo != "" { addInfo := params.AddInfo
params.AddInfo = params.AddInfo + ", " + err.Error() if addInfo != "" {
addInfo = addInfo + ", " + err.Error()
} else { } else {
params.AddInfo = err.Error() addInfo = err.Error()
} }
// 事件产生时间 // 事件产生时间
@@ -164,7 +165,7 @@ func (s *NeAlarmStateCheckCMDProcessor) Execute(data any) (any, error) {
AlarmStatus: oam.ALARM_STATUS_ACTIVE, // 告警状态 AlarmStatus: oam.ALARM_STATUS_ACTIVE, // 告警状态
SpecificProblem: params.SpecificProblem, // 告警问题原因 SpecificProblem: params.SpecificProblem, // 告警问题原因
SpecificProblemID: params.SpecificProblemID, // 告警问题原因ID SpecificProblemID: params.SpecificProblemID, // 告警问题原因ID
AddInfo: params.AddInfo, // 告警辅助信息 AddInfo: addInfo, // 告警辅助信息
LocationInfo: "NE CPU/Menory/Disk: Heartbeat", // 告警定位信息 LocationInfo: "NE CPU/Menory/Disk: Heartbeat", // 告警定位信息
} }
if err = oamService.NewAlarm.Resolve(alarm); err == nil { if err = oamService.NewAlarm.Resolve(alarm); err == nil {

9
src/modules/crontask/processor/ne_alarm_state_check_license/ne_alarm_state_check_license.go
View File

@@ -80,10 +80,11 @@ func (s *NeAlarmStateCheckLicenseProcessor) Execute(data any) (any, error) {
if err == nil { if err == nil {
continue continue
} }
if params.AddInfo != "" { addInfo := params.AddInfo
params.AddInfo = params.AddInfo + ", " + err.Error() if addInfo != "" {
addInfo = addInfo + ", " + err.Error()
} else { } else {
params.AddInfo = err.Error() addInfo = err.Error()
} }
// 告警ID // 告警ID
@@ -100,7 +101,7 @@ func (s *NeAlarmStateCheckLicenseProcessor) Execute(data any) (any, error) {
AlarmStatus: oam.ALARM_STATUS_ACTIVE, // 告警状态 AlarmStatus: oam.ALARM_STATUS_ACTIVE, // 告警状态
SpecificProblem: params.SpecificProblem, // 告警问题原因 SpecificProblem: params.SpecificProblem, // 告警问题原因
SpecificProblemID: params.SpecificProblemID, // 告警问题原因ID SpecificProblemID: params.SpecificProblemID, // 告警问题原因ID
AddInfo: params.AddInfo, // 告警辅助信息 AddInfo: addInfo, // 告警辅助信息
LocationInfo: "NE License: Heartbeat", // 告警定位信息 LocationInfo: "NE License: Heartbeat", // 告警定位信息
} }
if err = oamService.NewAlarm.Resolve(alarm); err == nil { if err = oamService.NewAlarm.Resolve(alarm); err == nil {