告警信息数据获取解析服务

handle/service/alarm.go

@@ -0,0 +1,80 @@
+package service
+
+import (
+	"omc/core/db"
+	"omc/core/emun"
+	"omc/handle/model"
+
+	"github.com/aceld/zinx/zlog"
+)
+
+// HasAlarmSeq 是否存在alarm_seq大于等于的
+func HasAlarmSeq(neType, neId string, alarmSeq int64) bool {
+	var num int64
+	if err := db.Client.Model(&model.Alarm{}).Where("ne_type = ? and ne_id = ? and alarm_seq >= ?", neType, neId, alarmSeq).Order("alarm_seq desc").Count(&num).Error; err != nil {
+		zlog.Ins().ErrorF("HasAlarmSeq db error %s", err)
+		return false
+	}
+	return num >= 0
+}
+
+// List 获取告警信息 alarm_seq大于等于的
+func List(neType, neId string, alarmSeq int64) ([]model.Alarm, error) {
+	// 从数据库读取告警记录
+	var alarms []model.Alarm
+	if err := db.Client.Model(&model.Alarm{}).Where("ne_type = ? and ne_id = ? and alarm_seq >= ?", neType, neId, alarmSeq).Order("alarm_seq asc").Find(&alarms).Error; err != nil {
+		zlog.Ins().ErrorF("AlarmList db error %s", err)
+		return nil, err
+	}
+	return alarms, nil
+}
+
+// ConvertOMCAlarm 转换上报的告警信息
+func ConvertOMCAlarm(alarms []model.Alarm) []model.OmcAlarm {
+	result := make([]model.OmcAlarm, 0)
+	for _, v := range alarms {
+		var item model.OmcAlarm
+		item.AlarmSeq = v.AlarmSeq
+		item.AlarmTitle = v.AlarmTitle
+		item.AlarmStatus = v.AlarmStatus
+		item.AlarmType = v.AlarmType
+		item.OrigSeverity = emun.OrigSeverity(v.OrigSeverity)
+		item.EventTime = v.EventTime.Format("2006-01-02 15:04:05")
+		item.AlarmId = v.AlarmId
+		item.SpecificProblemID = v.SpecificProblemId
+		item.SpecificProblem = v.SpecificProblem
+		item.NeUID = v.NeId
+		item.NeName = v.NeName
+		item.NeType = v.NeType
+		item.ObjectUID = v.ObjectUid
+		item.ObjectName = v.NeName
+		item.ObjectType = v.ObjectType
+		item.LocationInfo = v.LocationInfo
+		item.AddInfo = v.AddInfo
+		item.PVFlag = v.PvFlag
+		item.Province = v.Province
+		result = append(result, item)
+	}
+	return result
+}
+
+// 检查列表里最大的AlarmSeq
+func MaxAlarmSeq(current int64, alarms []model.OmcAlarm) int64 {
+	var maxAlarmSeq = current
+	for _, v := range alarms {
+		if v.AlarmSeq > maxAlarmSeq {
+			maxAlarmSeq = v.AlarmSeq
+		}
+	}
+	return maxAlarmSeq
+}
+
+// LastAlarmSeq 获取最新的alarm_seq 序号
+func LastAlarmSeq(neType, neId string) int64 {
+	var alarm model.Alarm
+	if err := db.Client.Model(&model.Alarm{}).Where("ne_type = ? and ne_id = ?", neType, neId).Order("alarm_seq desc").First(&alarm).Error; err != nil {
+		zlog.Ins().ErrorF("LastAlarmSeq db error %s", err)
+		return 0
+	}
+	return alarm.AlarmSeq
+}

handle/service/real_time_alarm.go

@@ -1,92 +0,0 @@
-package service
-
-import (
-	"encoding/json"
-	"omc/core/db"
-	"omc/core/emun"
-	"omc/handle/model"
-
-	"github.com/aceld/zinx/zlog"
-)
-
-type OmcAlarm struct {
-	AId               int64  `json:"-"`
-	AlarmSeq          int32  `json:"alarmSeq"`          //告警序列号
-	AlarmTitle        string `json:"alarmTitle"`        //告警事件标题
-	AlarmStatus       int32  `json:"alarmStatus"`       //告警状态
-	AlarmType         string `json:"alarmType"`         //告警类型
-	OrigSeverity      int32  `json:"origSeverity"`      //原始级别
-	EventTime         string `json:"eventTime"`         //事件发生时间
-	AlarmId           string `json:"alarmId"`           //告警事件唯一标识
-	SpecificProblemID string `json:"specificProblemID"` //告警问题原因ID
-	SpecificProblem   string `json:"specificProblem"`   //告警问题原因
-	NeUID             string `json:"neUID"`             //告警网元UID
-	NeName            string `json:"neName"`            //告警网元名称
-	NeType            string `json:"neType"`            //告警网元设备类型
-	ObjectUID         string `json:"objectUID"`         //告警定位对象UID
-	ObjectName        string `json:"objectName"`        //告警定位对象名称
-	ObjectType        string `json:"objectType"`        //告警定位对象资源类型
-	LocationInfo      string `json:"locationInfo"`      //告警定位信息
-	AddInfo           string `json:"addInfo"`           //告警辅助信息[条件必选]
-	PVFlag            string `json:"PVFlag"`            //网元虚实性[条件必选]
-	Province          string `json:"province"`          //网元服务省份
-}
-
-// GetRealTimeAlarm 获取最新的告警信息
-func GetRealTimeAlarm(neType, neId string, alarmSeq int32) ([]OmcAlarm, error) {
-	var alarms []model.Alarm
-	var result []OmcAlarm
-	if err := db.Client.Model(&model.Alarm{}).Where("ne_type = ? and ne_id = ? and alarm_seq >= ?", neType, neId, alarmSeq).Order("alarm_seq asc").Find(&alarms).Error; err != nil {
-		return nil, err
-	}
-	for _, v := range alarms {
-		var item OmcAlarm
-		item.AlarmSeq = int32(v.AlarmSeq)
-		item.AlarmTitle = v.AlarmTitle
-		item.AlarmStatus = int32(v.AlarmStatus)
-		item.AlarmType = v.AlarmType
-		item.OrigSeverity = emun.OrigSeverity(v.OrigSeverity)
-		item.EventTime = v.EventTime.Format("2006-01-02 15:04:05")
-		item.AlarmId = v.AlarmId
-		item.SpecificProblemID = v.SpecificProblemID
-		item.SpecificProblem = v.SpecificProblem
-		item.NeUID = v.NeId
-		item.NeName = v.NeName
-		item.NeType = v.NeType
-		item.ObjectUID = v.ObjectUID
-		item.ObjectName = v.NeName
-		item.ObjectType = v.ObjectType
-		item.LocationInfo = v.LocationInfo
-		item.AddInfo = v.AddInfo
-		item.PVFlag = v.PVFlag
-		item.Province = v.Province
-		item.AId = int64(v.Id)
-		result = append(result, item)
-	}
-	return result, nil
-}
-
-// GetLastAlarmSeq 获取最新的alarm seq
-func GetLastAlarmSeq(neType, neId string) int32 {
-	var alarm model.Alarm
-	if err := db.Client.Model(&model.Alarm{}).Where("ne_type = ? and ne_id = ?", neType, neId).Order("alarm_seq desc").First(&alarm).Error; err != nil {
-		zlog.Ins().ErrorF("db error %s", err)
-		return 0
-	}
-	return int32(alarm.AlarmSeq) + 1
-}
-
-func GenAlarm(alarm OmcAlarm) []byte {
-	data, _ := json.Marshal(&alarm)
-	return data
-}
-
-func MaxAlarm(current int32, alarms []OmcAlarm) int32 {
-	var req = current
-	for _, v := range alarms {
-		if v.AlarmSeq > req {
-			req = v.AlarmSeq
-		}
-	}
-	return req
-}