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

remove RJ

Browse Source
This commit is contained in:
simonzhangsz
2023-09-12 15:55:07 +08:00
parent fc8f63fca6
commit a8aed0d96e
6 changed files with 35 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
features/ue/ue.go
View File

@@ -30,17 +30,19 @@ type SmfUENum struct {
// SmfUEInfo SMF在线用户信息
type SmfUEInfo struct {
IMSI string `json:"imsi"`
MSISDN string `json:"msisdn"`
IPv4 []string `json:"ipv4"`
Dnn []string `json:"dnn"`
Tai []string `json:"tai"`
PduSessionID []int `json:"pduSessionID"`
IPv6 []string `json:"ipv6"`
SstSD []string `json:"sstSD"`
UpfN3IP []string `json:"upfN3IP"`
RanN3IP []string `json:"ranN3IP"`
Activetime []string `json:"activeTime"`
IMSI string `json:"imsi"`
MSISDN string `json:"msisdn"`
PduSessionInfo []struct {
PduSessionID int `json:"pduSessionID"`
IPv4 string `json:"ipv4"`
IPv6 string `json:"ipv6"`
Dnn string `json:"dnn"`
Tai string `json:"tai"`
SstSD string `json:"sstSD"`
UpfN3IP string `json:"upfN3IP"`
RanN3IP string `json:"ranN3IP"`
Activetime string `json:"activeTime"`
} `json:"pduSessionInfo"`
}
// ImsUEInfo IMS在线用户信息
@@ -120,7 +122,7 @@ func GetUEInfoFromNF(w http.ResponseWriter, r *http.Request) {
log.Trace("neInfo:", neInfo)
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
requestURI2NF := fmt.Sprintf("%s/%s", hostUri, r.RequestURI)
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
log.Debug("requestURI2NF:", requestURI2NF)
@@ -137,7 +139,7 @@ func GetUEInfoFromNF(w http.ResponseWriter, r *http.Request) {
} else {
var response services.DataResponse
_ = json.Unmarshal(resp.Body(), &response)
services.ResponseWithJson(w, http.StatusOK, response)
services.ResponseWithJson(w, resp.StatusCode(), response)
return
}
}
@@ -183,7 +185,7 @@ func GetUENumFromNF(w http.ResponseWriter, r *http.Request) {
log.Trace("neInfo:", neInfo)
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
requestURI2NF := fmt.Sprintf("%s/%s", hostUri, r.RequestURI)
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
log.Debug("requestURI2NF:", requestURI2NF)
@@ -200,7 +202,7 @@ func GetUENumFromNF(w http.ResponseWriter, r *http.Request) {
} else {
var response services.DataResponse
_ = json.Unmarshal(resp.Body(), &response)
services.ResponseWithJson(w, http.StatusOK, response)
services.ResponseWithJson(w, resp.StatusCode(), response)
return
}
}
@@ -246,7 +248,7 @@ func GetNBInfoFromNF(w http.ResponseWriter, r *http.Request) {
log.Trace("neInfo:", neInfo)
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
requestURI2NF := fmt.Sprintf("%s/%s", hostUri, r.RequestURI)
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
log.Debug("requestURI2NF:", requestURI2NF)
@@ -263,7 +265,7 @@ func GetNBInfoFromNF(w http.ResponseWriter, r *http.Request) {
} else {
var response services.DataResponse
_ = json.Unmarshal(resp.Body(), &response)
services.ResponseWithJson(w, http.StatusOK, response)
services.ResponseWithJson(w, resp.StatusCode(), response)
return
}
}