fix: 在告警数据上报时进行推送kafka

This commit is contained in:
TsMask
2024-03-19 11:22:44 +08:00
parent 42a73b9dfa
commit 3b601736b3
2 changed files with 35 additions and 2 deletions

View File

@@ -65,12 +65,12 @@ func (s *AlarmImpl) parseAlarmData(v neDataModel.Alarm) model.Alarm {
AlarmType: v.AlarmType,
AlarmLevel: alarmLevel,
EventTime: date.ParseDateToStr(v.EventTime, date.YYYY_MM_DD_HH_MM_SS),
AlarmId: parse.Number(v.ID),
AlarmId: parse.Number(v.AlarmId),
CauseID: v.AlarmCode,
Cause: v.SpecificProblem,
NeRUID: v.ObjectUid,
NeUserLabel: v.NeName,
ObjectRUID: v.AlarmId,
ObjectRUID: v.ObjectUid,
ObjectUserLabel: v.ObjectName,
AddInfo: v.AddInfo,
}