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

fix: UE事件数据上报Body变更

Browse Source
This commit is contained in:
TsMask
2024-06-17 16:48:53 +08:00
parent 348b67f701
commit 5174ca9b9c
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
features/event/event.go
View File

@@ -81,18 +81,13 @@ func PostUEEvent(w http.ResponseWriter, r *http.Request) {
log.Info("PostUEEvent processing... ") log.Info("PostUEEvent processing... ")
neType := ctx.GetParam(r, "elementTypeValue") neType := ctx.GetParam(r, "elementTypeValue")
ueEvent := new(UEEvent) var ueEvent UEEvent
if err := ctx.ShouldBindJSON(r, &ueEvent.EventJson); err != nil { if err := ctx.ShouldBindJSON(r, &ueEvent); err != nil {
services.ResponseInternalServerError500ProcessError(w, err) services.ResponseInternalServerError500ProcessError(w, err)
return return
} }
ueEvent.NeType = strings.ToUpper(neType) ueEvent.NeType = strings.ToUpper(neType)
ueEvent.Timestamp = time.Now().Unix()
if v, ok := ueEvent.EventJson["type"]; ok {
ueEvent.EventType = v.(string)
}
tableName := fmt.Sprintf("ue_event_%s", strings.ToLower(neType)) tableName := fmt.Sprintf("ue_event_%s", strings.ToLower(neType))
affected, err := dborm.XormInsertTableOne(tableName, ueEvent) affected, err := dborm.XormInsertTableOne(tableName, ueEvent)
if err != nil && affected <= 0 { if err != nil && affected <= 0 {