1264 lines
41 KiB
Go
1264 lines
41 KiB
Go
package ue
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
"be.ems/lib/config"
|
|
"be.ems/lib/core/ctx"
|
|
"be.ems/lib/dborm"
|
|
"be.ems/lib/global"
|
|
"be.ems/lib/log"
|
|
"be.ems/lib/services"
|
|
tokenConst "be.ems/src/framework/constants/token"
|
|
neDataModel "be.ems/src/modules/network_data/model"
|
|
neDataService "be.ems/src/modules/network_data/service"
|
|
"be.ems/src/modules/network_element/model"
|
|
neService "be.ems/src/modules/network_element/service"
|
|
"github.com/go-resty/resty/v2"
|
|
"github.com/gorilla/mux"
|
|
)
|
|
|
|
// N3iwfUEInfo N3IWF在线用户信息
|
|
type N3iwfUEInfo struct {
|
|
IMSI string `json:"imsi"`
|
|
|
|
NAI string `json:"nai"`
|
|
RegState int `json:"regState"`
|
|
Activetime string `json:"activeTime"`
|
|
}
|
|
|
|
type N3iwfUEData struct {
|
|
Data []N3iwfUEInfo `json:"data"`
|
|
}
|
|
|
|
var (
|
|
UriNBState = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/nbState"
|
|
UriNBInfo = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/nbInfo"
|
|
UriSMFUEInfo = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/smf/objectType/ueInfo"
|
|
UriIMSUEInfo = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/ims/objectType/ueInfo"
|
|
UriUENum = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/ueNum"
|
|
UriPCFUser = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo"
|
|
UriPCFUserM = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo/batch/{number}"
|
|
UriPCFUserFileImport = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo/file/import"
|
|
UriPCFUserFileExport = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo/file/export"
|
|
UriNSSFAvailableAMFs = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/availableAMFs"
|
|
UriNSSFSubscriptions = config.DefaultUriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/subscriptions"
|
|
|
|
CustomUriNBState = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/nbState"
|
|
CustomUriNBInfo = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/nbInfo"
|
|
CustomUriSMFUEInfo = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/smf/objectType/ueInfo"
|
|
CustomUriIMSUEInfo = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/ims/objectType/ueInfo"
|
|
CustomUriUENum = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/ueNum"
|
|
CustomUriPCFUser = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo"
|
|
CustomUriPCFUserM = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo/batch/{number}"
|
|
CustomUriPCFUserFileImport = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo/file/import"
|
|
CustomUriPCFUserFileExport = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/pcf/objectType/ueInfo/file/export"
|
|
CustomUriNSSFAvailableAMFs = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/availableAMFs"
|
|
CustomUriNSSFSubscriptions = config.UriPrefix + "/ueManagement/{apiVersion}/elementType/{elementTypeValue}/objectType/subscriptions"
|
|
)
|
|
|
|
var client = resty.New()
|
|
|
|
func init() {
|
|
/*
|
|
client.
|
|
SetTimeout(10 * time.Second).
|
|
SetRetryCount(1).
|
|
SetRetryWaitTime(1 * time.Second).
|
|
SetRetryMaxWaitTime(2 * time.Second).
|
|
SetRetryAfter(func(client *resty.Client, resp *resty.Response) (time.Duration, error) {
|
|
return 0, errors.New("quota exceeded")
|
|
})
|
|
*/
|
|
client.SetTimeout(500 * time.Millisecond)
|
|
}
|
|
|
|
// Get AvailableAMFs from NSSF
|
|
func GetAvailableAMFsFromNSSF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("GetAvailableAMFsFromNSSF processing... ")
|
|
|
|
vars := mux.Vars(r)
|
|
neType := vars["elementTypeValue"]
|
|
if strings.ToLower(neType) != "nssf" {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
//neTypeLower := strings.ToLower(neType)
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
// SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Get system state from NF is failed:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
var response services.MapResponse
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|
|
|
|
// Get Subscriptions from NSSF
|
|
func GetSubscriptionsFromNSSF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("GetSubscriptionsFromNSSF processing... ")
|
|
|
|
vars := mux.Vars(r)
|
|
neType := vars["elementTypeValue"]
|
|
if strings.ToLower(neType) != "nssf" {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
//neTypeLower := strings.ToLower(neType)
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
// SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Get system state from NF is failed:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
var response services.MapResponse
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|
|
|
|
// SmfUEInfo SMF在线用户信息
|
|
type SmfUEInfo struct {
|
|
IMSI string `json:"imsi"`
|
|
MSISDN string `json:"msisdn"`
|
|
RatType string `json:"ratType"`
|
|
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"`
|
|
UpState string `json:"upState"`
|
|
} `json:"pduSessionInfo"`
|
|
}
|
|
|
|
type TenantUEInfo struct {
|
|
NeType string `json:"neType"`
|
|
NeID string `json:"neId"`
|
|
IMSI string `json:"imsi"`
|
|
MSISDN string `json:"msisdn"`
|
|
RatType string `json:"ratType"`
|
|
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"`
|
|
UpState string `json:"upState"`
|
|
} `json:"pduSessionInfo"`
|
|
TenantName string `json:"tenantName"`
|
|
}
|
|
|
|
type SmfUEInfoResponse struct {
|
|
Total int `json:"total"`
|
|
Data []SmfUEInfo `json:"data"`
|
|
}
|
|
|
|
type UEInfoResponse struct {
|
|
Total int `json:"total"`
|
|
TenantNum int `json:"tenantNum"`
|
|
Data []TenantUEInfo `json:"data"`
|
|
}
|
|
|
|
// Get UEInfo from NF/NFs, SMF Online users
|
|
func GetSMFUEInfoFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Debug("GetUEInfoFromNF processing... ")
|
|
|
|
neId := ctx.GetQuery(r, "neId")
|
|
neType := "smf"
|
|
// if neType == "" || neId == "" {
|
|
// log.Error("elementTypeValue/neId is empty")
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
var tenantName string
|
|
tenantNames := services.GetParamsArrByName("tenantName", r)
|
|
if len(tenantNames) > 0 {
|
|
tenantName = tenantNames[0]
|
|
}
|
|
|
|
var neInfos []model.NeInfo
|
|
if neId != "" {
|
|
neInfo := neService.NewNeInfo.SelectNeInfoByNeTypeAndNeID(neType, neId)
|
|
neInfos = append(neInfos, neInfo)
|
|
} else {
|
|
neInfos = neService.NewNeInfo.SelectNeInfoByNeType(neType)
|
|
}
|
|
|
|
var response UEInfoResponse
|
|
for _, neInfo := range neInfos {
|
|
//if neInfo.NeId == neId && neInfo.NeId != "" {
|
|
requestURI2NF := fmt.Sprintf("http://%s:%v%s", neInfo.IP, neInfo.Port, r.RequestURI)
|
|
//requestURI2NF := "http://127.0.0.1:4523/m1/3157310-1528434-default/api/rest/ueManagement/v1/elementType/smf/objectType/ueInfo?apifoxApiId=128609449"
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to Get from NF:", err)
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
continue
|
|
}
|
|
// multi-tenancy solution
|
|
var tenantID, where string
|
|
//var cols []string
|
|
if tenantName != "" {
|
|
where = fmt.Sprintf("status='1' and tenant_name='%s'", tenantName)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_id", where)
|
|
} else {
|
|
userName := ctx.LoginUserToUserName(r)
|
|
where = fmt.Sprintf("status='1' and user_name='%s'", userName)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_user", "tenant_id", where)
|
|
where = fmt.Sprintf("status='1' and tenant_id='%s'", tenantID)
|
|
tenantName, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_name", where)
|
|
}
|
|
if tenantID == "" {
|
|
var ueInfos UEInfoResponse
|
|
_ = json.Unmarshal(resp.Body(), &ueInfos)
|
|
response.Total = ueInfos.Total
|
|
for i := 0; i < len(ueInfos.Data); i++ {
|
|
where = fmt.Sprintf("status='1' and tenancy_type='IMSI' and '%s' like tenancy_key", ueInfos.Data[i].IMSI[5:])
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "parent_id", where)
|
|
where = fmt.Sprintf("status='1' and tenant_id='%s'", tenantID)
|
|
tenantName, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_name", where)
|
|
log.Tracef("tenantName: %s tenantID: %s", tenantName, tenantID)
|
|
ueInfos.Data[i].NeType = strings.ToUpper(neType)
|
|
ueInfos.Data[i].NeID = neInfo.NeId
|
|
ueInfos.Data[i].TenantName = tenantName
|
|
response.Data = append(response.Data, ueInfos.Data[i])
|
|
}
|
|
// services.ResponseWithJson(w, resp.StatusCode(), &response)
|
|
// return
|
|
} else {
|
|
//var tenantUEInfos []TenantUEInfo
|
|
var ueInfos UEInfoResponse
|
|
log.Trace("body:", string(resp.Body()))
|
|
_ = json.Unmarshal(resp.Body(), &ueInfos)
|
|
log.Trace("ueInfos:", ueInfos)
|
|
for _, n := range ueInfos.Data {
|
|
log.Trace("tenantID, n.IMSI[5:]:", tenantID, n.IMSI[5:])
|
|
// "imsi": "imsi-460000100029999",
|
|
where = fmt.Sprintf("status='1' and parent_id='%s' and tenancy_type='IMSI' and '%s' like tenancy_key", tenantID, n.IMSI[5:])
|
|
has, err := dborm.XormExistTableOne("sys_tenant", where)
|
|
if err == nil && has {
|
|
n.NeType = strings.ToUpper(neType)
|
|
n.NeID = neInfo.NeId
|
|
n.TenantName = tenantName
|
|
response.Data = append(response.Data, n)
|
|
response.TenantNum++
|
|
}
|
|
}
|
|
if ueInfos.Total > len(ueInfos.Data) {
|
|
response.Total = ueInfos.Total
|
|
} else {
|
|
response.Total = response.TenantNum
|
|
}
|
|
// var response UEInfoResponse
|
|
// response.Data = tenantUEInfos
|
|
// services.ResponseWithJson(w, resp.StatusCode(), &response)
|
|
// return
|
|
}
|
|
}
|
|
|
|
services.ResponseWithJson(w, http.StatusOK, response)
|
|
}
|
|
|
|
// ImsUEInfo IMS在线用户信息
|
|
type ImsUEInfo struct {
|
|
IMSI string `json:"imsi"`
|
|
MSISDN string `json:"msisdn"`
|
|
IMPU string `json:"impu"`
|
|
Barring int `json:"barring"`
|
|
RegState int `json:"regState"`
|
|
Activetime string `json:"activeTime"`
|
|
}
|
|
|
|
// ImsUEInfo IMS在线用户信息
|
|
type TenantImsUEInfo struct {
|
|
NeType string `json:"neType"`
|
|
NeID string `json:"neId"`
|
|
IMSI string `json:"imsi"`
|
|
MSISDN string `json:"msisdn"`
|
|
IMPU string `json:"impu"`
|
|
Barring int `json:"barring"`
|
|
RegState int `json:"regState"`
|
|
Activetime string `json:"activeTime"`
|
|
TenantName string `json:"tenantName"`
|
|
}
|
|
|
|
type ImsUEInfoResponse struct {
|
|
Total int `json:"total"`
|
|
Data []ImsUEInfo `json:"data"`
|
|
}
|
|
|
|
type TenantImsUEInfoResponse struct {
|
|
Total int `json:"total"`
|
|
Data []TenantImsUEInfo `json:"data"`
|
|
}
|
|
|
|
// Get UEInfo from NF/NFs, IMS Online users
|
|
func GetIMSUEInfoFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Debug("GetIMSUEInfoFromNF processing... ")
|
|
|
|
neId := ctx.GetQuery(r, "neId")
|
|
neType := "ims"
|
|
// if neType == "" || neId == "" {
|
|
// log.Error("elementTypeValue/neId is empty")
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
var tenantName string
|
|
tenantNames := services.GetParamsArrByName("tenantName", r)
|
|
if len(tenantNames) > 0 {
|
|
tenantName = tenantNames[0]
|
|
}
|
|
|
|
var neInfos []model.NeInfo
|
|
if neId != "" {
|
|
neInfo := neService.NewNeInfo.SelectNeInfoByNeTypeAndNeID(neType, neId)
|
|
neInfos = append(neInfos, neInfo)
|
|
} else {
|
|
neInfos = neService.NewNeInfo.SelectNeInfoByNeType(neType)
|
|
}
|
|
|
|
var response TenantImsUEInfoResponse
|
|
for _, neInfo := range neInfos {
|
|
requestURI2NF := fmt.Sprintf("http://%s:%v%s", neInfo.IP, neInfo.Port, r.RequestURI)
|
|
//requestURI2NF := "http://127.0.0.1:4523/m1/3157310-1528434-default/api/rest/ueManagement/v1/elementType/ims/objectType/ueInfo?apifoxApiId=128609458"
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to Get from NF:", err)
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
continue
|
|
}
|
|
// multi-tenancy solution
|
|
var tenantID, where string
|
|
//var cols []string
|
|
if tenantName != "" {
|
|
where = fmt.Sprintf("status='1' and tenant_name='%s'", tenantName)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_id", where)
|
|
} else {
|
|
userName := ctx.LoginUserToUserName(r)
|
|
where = fmt.Sprintf("status='1' and user_name='%s'", userName)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_user", "tenant_id", where)
|
|
where = fmt.Sprintf("status='1' and tenant_id='%s'", tenantID)
|
|
tenantName, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_name", where)
|
|
}
|
|
if tenantID == "" {
|
|
var ueInfos TenantImsUEInfoResponse
|
|
_ = json.Unmarshal(resp.Body(), &ueInfos)
|
|
for i := 0; i < len(ueInfos.Data); i++ {
|
|
where = fmt.Sprintf("status='1' and tenancy_type='IMSI' and '%s' like tenancy_key", ueInfos.Data[i].IMSI)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "parent_id", where)
|
|
where = fmt.Sprintf("status='1' and tenant_id='%s'", tenantID)
|
|
tenantName, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_name", where)
|
|
log.Tracef("tenantName: %s tenantID: %s", tenantName, tenantID)
|
|
ueInfos.Data[i].NeType = strings.ToUpper(neType)
|
|
ueInfos.Data[i].NeID = neInfo.NeId
|
|
ueInfos.Data[i].TenantName = tenantName
|
|
response.Data = append(response.Data, ueInfos.Data[i])
|
|
response.Total = i
|
|
}
|
|
// services.ResponseWithJson(w, resp.StatusCode(), &response)
|
|
// return
|
|
} else {
|
|
//var tenantUEInfos []TenantImsUEInfo
|
|
var ueInfos TenantImsUEInfoResponse
|
|
log.Trace("body:", string(resp.Body()))
|
|
_ = json.Unmarshal(resp.Body(), &ueInfos)
|
|
log.Trace("ueInfos:", ueInfos)
|
|
for _, n := range ueInfos.Data {
|
|
log.Trace("tenantID, n.IMSI:", tenantID, n.IMSI)
|
|
// "imsi": "460000100029999",
|
|
where = fmt.Sprintf("status='1' and parent_id='%s' and tenancy_type='IMSI' and '%s' like tenancy_key", tenantID, n.IMSI)
|
|
has, err := dborm.XormExistTableOne("sys_tenant", where)
|
|
if err == nil && has {
|
|
n.NeType = strings.ToUpper(neType)
|
|
n.NeID = neInfo.NeId
|
|
n.TenantName = tenantName
|
|
response.Data = append(response.Data, n)
|
|
response.Total++
|
|
}
|
|
}
|
|
// var response TenantImsUEInfoResponse
|
|
// response.Data = tenantUEInfos
|
|
// services.ResponseWithJson(w, resp.StatusCode(), &response)
|
|
// return
|
|
}
|
|
}
|
|
services.ResponseWithJson(w, http.StatusOK, response)
|
|
}
|
|
|
|
// Get UEInfo from NF/NFs, PCF Online users
|
|
func GetPCFUEInfoFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Debug("GetPCFUEInfoFromNF processing... ")
|
|
|
|
neId := ctx.GetQuery(r, "neId")
|
|
neType := "pcf"
|
|
// if neType == "" || neId == "" {
|
|
// log.Error("elementTypeValue/neId is empty")
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
|
|
neInfo := neService.NewNeInfo.SelectNeInfoByNeTypeAndNeID(neType, neId)
|
|
|
|
var response services.MapResponse
|
|
if neInfo.NeId == neId && neInfo.NeId != "" {
|
|
requestURI2NF := fmt.Sprintf("http://%s:%v%s", neInfo.IP, neInfo.Port, r.RequestURI)
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to Get from NF:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
}
|
|
log.Debug("response:", response)
|
|
}
|
|
|
|
services.ResponseWithJson(w, http.StatusOK, response)
|
|
}
|
|
|
|
// POST PCF User Info from NF/NFs
|
|
func PostPCFUserInfo(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("PostPCFUserInfo processing... ")
|
|
|
|
// vars := mux.Vars(r)
|
|
// neType := vars["elementTypeValue"]
|
|
// if neType == "" {
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
//neTypeLower := strings.ToLower(neType)
|
|
neType := "PCF"
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
body, err := io.ReadAll(io.LimitReader(r.Body, global.RequestBodyMaxLen)) //io.LimitReader限制大小
|
|
if err != nil {
|
|
log.Error("io.ReadAll is failed:", err)
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
client.SetTimeout(1 * time.Minute)
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
//SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
SetBody(body).
|
|
Post(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to post:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
var response services.MapResponse
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|
|
|
|
// PUT PCF User Info from NF/NFs
|
|
func PutPCFUserInfo(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("PutPCFUserInfo processing... ")
|
|
|
|
// vars := mux.Vars(r)
|
|
// neType := vars["elementTypeValue"]
|
|
// if neType == "" {
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
//neTypeLower := strings.ToLower(neType)
|
|
neType := "PCF"
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
body, err := io.ReadAll(io.LimitReader(r.Body, global.RequestBodyMaxLen)) //io.LimitReader限制大小
|
|
if err != nil {
|
|
log.Error("io.ReadAll is failed:", err)
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
client.SetTimeout(1 * time.Minute)
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
//SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
SetBody(body).
|
|
Put(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to put:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
var response services.MapResponse
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|
|
|
|
// Get UEInfo from NF/NFs
|
|
func DeletePCFUserInfo(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("DeletePCFUserInfo processing... ")
|
|
|
|
// vars := mux.Vars(r)
|
|
// neType := vars["elementTypeValue"]
|
|
// if neType == "" {
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
//neTypeLower := strings.ToLower(neType)
|
|
neType := "PCF"
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
//SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Delete(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to delete:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
w.WriteHeader(resp.StatusCode())
|
|
w.Write(resp.Body())
|
|
// var response services.MapResponse
|
|
// _ = json.Unmarshal(resp.Body(), &response)
|
|
// services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|
|
|
|
// Get UEInfo from SMF
|
|
func GetUENumFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("GetUENumFromNF processing... ")
|
|
|
|
vars := mux.Vars(r)
|
|
neType := vars["elementTypeValue"]
|
|
if neType == "" {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
//neTypeLower := strings.ToLower(neType)
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
// SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Get system state from NF is failed:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
var response services.MapResponse
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|
|
|
|
// SmfUENum SMF在线用户数
|
|
// type SmfUENum struct {
|
|
// UENum int `json:"ueNum"` // 当前在线用户数
|
|
// }
|
|
|
|
// UENumInfo IMS/SMF在线用户数
|
|
type UENumInfo struct {
|
|
NeType string `json:"neType"`
|
|
NeId string `json:"neId"`
|
|
Data struct {
|
|
UENum int `json:"ueNum"` // 当前在线用户数
|
|
} `json:"data"`
|
|
}
|
|
type UENumResponse struct {
|
|
UENums []UENumInfo
|
|
}
|
|
|
|
// Get UEInfo from SMF
|
|
func NewGetUENumFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("NewGetUENumFromNF processing... ")
|
|
|
|
vars := mux.Vars(r)
|
|
neType := vars["elementTypeValue"]
|
|
if neType == "" {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
//neTypeLower := strings.ToLower(neType)
|
|
//var neId string
|
|
//neIds := services.GetParamsArrByName("neId", r)
|
|
neId := ctx.GetQuery(r, "neId")
|
|
// if len(neIds) == 1 {
|
|
// neId = neIds[0]
|
|
// } else {
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
// neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
// if err != nil {
|
|
// log.Error("Failed to XormGetNeInfo:", err)
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
// } else if neInfo == nil {
|
|
// err := global.ErrCMNotFoundTargetNE
|
|
// log.Error(global.ErrCMNotFoundTargetNE)
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
// }
|
|
// log.Trace("neInfo:", neInfo)
|
|
|
|
var neInfos []model.NeInfo
|
|
if neId != "" {
|
|
neInfo := neService.NewNeInfo.SelectNeInfoByNeTypeAndNeID(neType, neId)
|
|
neInfos = append(neInfos, neInfo)
|
|
} else {
|
|
neInfos = neService.NewNeInfo.SelectNeInfoByNeType(neType)
|
|
}
|
|
|
|
var response []UENumInfo
|
|
|
|
for _, neInfo := range neInfos {
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.IP, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
// SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("failed to get UENum from NF:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
var ueNum UENumInfo
|
|
_ = json.Unmarshal(resp.Body(), &ueNum)
|
|
ueNum.NeType = strings.ToUpper(neType)
|
|
ueNum.NeId = neInfo.NeId
|
|
response = append(response, ueNum)
|
|
// services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
// return
|
|
}
|
|
}
|
|
if neId != "" {
|
|
services.ResponseWithJson(w, http.StatusOK, response[0])
|
|
} else {
|
|
services.ResponseWithJson(w, http.StatusOK, response)
|
|
}
|
|
}
|
|
|
|
// AmfNBInfo AMF的NodeB信息
|
|
type AmfNBInfo struct {
|
|
ID string `json:"id"` //NodeB ID
|
|
Name string `json:"name"` // NodeB name
|
|
Address string `json:"address"` // 基站地址
|
|
UENum int `json:"ueNum"` // UE数量
|
|
}
|
|
|
|
type TenantNBInfo struct {
|
|
ID string `json:"id"` //NodeB ID
|
|
Name string `json:"name"` // NodeB name
|
|
Address string `json:"address"` // 基站地址
|
|
UENum int `json:"ueNum"` // UE数量
|
|
TenantName string `json:"tenantName"` // Tenant Name
|
|
}
|
|
|
|
type NBInfoResponse struct {
|
|
Data []TenantNBInfo `json:"data"`
|
|
}
|
|
|
|
// Get AMF Radio Info from NF/NFs
|
|
func GetNBInfoFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("GetNBInfoFromNF processing... ")
|
|
|
|
vars := mux.Vars(r)
|
|
neType := vars["elementTypeValue"]
|
|
if neType == "" {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
//neTypeLower := strings.ToLower(neType)
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
var tenantName string
|
|
tenantNames := services.GetParamsArrByName("tenantName", r)
|
|
if len(tenantNames) > 0 {
|
|
tenantName = tenantNames[0]
|
|
}
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo(neType, neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
// for apifox mock test
|
|
//requestURI2NF := "http://127.0.0.1:4523/m1/3157310-1528434-default/api/rest/ueManagement/v1/elementType/" + strings.ToLower(neType) + "/objectType/nbInfo?apifoxApiId=128848301"
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
// SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Get system state from NF is failed:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
|
|
// multi-tenancy solution
|
|
var tenantID, where, userName, radioType string
|
|
if strings.ToLower(neType) == "mme" {
|
|
radioType = "4G"
|
|
} else if strings.ToLower(neType) == "amf" {
|
|
radioType = "5G"
|
|
}
|
|
if tenantName != "" {
|
|
where = fmt.Sprintf("status='1' and tenant_name='%s'", tenantName)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_id", where)
|
|
} else {
|
|
userName = ctx.LoginUserToUserName(r)
|
|
where = fmt.Sprintf("status='1' and user_name='%s'", userName)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_user", "tenant_id", where)
|
|
where = fmt.Sprintf("status='1' and tenant_id='%s'", tenantID)
|
|
tenantName, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_name", where)
|
|
}
|
|
log.Tracef("tenantName: %s userName: %s tenantID: %s", tenantName, userName, tenantID)
|
|
if tenantID == "" {
|
|
var response NBInfoResponse
|
|
//var nbInfo *TenantNBInfo
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
|
|
for i := 0; i < len(response.Data); i++ {
|
|
where = fmt.Sprintf("status='1' and tenancy_type='RADIO' and tenancy_key='%v'", radioType+"_"+response.Data[i].ID)
|
|
tenantID, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "parent_id", where)
|
|
where = fmt.Sprintf("status='1' and tenant_id='%s'", tenantID)
|
|
tenantName, _ = dborm.XormGetSingleColStringByWhere("sys_tenant", "tenant_name", where)
|
|
log.Tracef("tenantName: %s tenantID: %s", tenantName, tenantID)
|
|
response.Data[i].TenantName = tenantName
|
|
}
|
|
services.ResponseWithJson(w, resp.StatusCode(), &response)
|
|
return
|
|
} else {
|
|
// var response services.MapResponse
|
|
var tenantNBInfos []TenantNBInfo
|
|
var nbInfos NBInfoResponse
|
|
var nbIDs []string
|
|
// Get nodeB IDs by tenantID
|
|
where = fmt.Sprintf("status='1' and tenancy_type='RADIO' and parent_id='%v'", tenantID)
|
|
dborm.XormFindColStringArrayByWhere("sys_tenant", "tenancy_key", where, &nbIDs)
|
|
_ = json.Unmarshal(resp.Body(), &nbInfos)
|
|
for _, n := range nbInfos.Data {
|
|
if global.IsMember(radioType+"_"+n.ID, nbIDs) {
|
|
n.TenantName = tenantName
|
|
tenantNBInfos = append(tenantNBInfos, n)
|
|
}
|
|
}
|
|
log.Tracef("nbIDs: %v", nbIDs)
|
|
nbInfos.Data = tenantNBInfos
|
|
services.ResponseWithJson(w, resp.StatusCode(), &nbInfos)
|
|
return
|
|
}
|
|
}
|
|
|
|
// PostNBInfoFromNF 接收Radio数据请求
|
|
func PostNBInfoFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("PostNBInfoFromNF processing... ")
|
|
neType := ctx.GetParam(r, "elementTypeValue")
|
|
var body struct {
|
|
NeType string `json:"neType" `
|
|
NeName string `json:"neName" `
|
|
RmUID string `json:"rmUID"`
|
|
StateList []struct {
|
|
Address string `json:"address" `
|
|
Name string `json:"name" `
|
|
Position string `json:"position" `
|
|
NbName string `json:"nbName" `
|
|
RanId int64 `json:"ranId" `
|
|
State string `json:"state" ` // "OFF" or "ON"
|
|
OffTime string `json:"offTime" ` //if State=OFF, will set it
|
|
OnTime string `json:"onTime" ` //if State=ON , will set it
|
|
}
|
|
}
|
|
if err := ctx.ShouldBindJSON(r, &body); err != nil {
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
|
|
neTypeLower := strings.ToLower(body.NeType)
|
|
if neType == "" || neType != neTypeLower {
|
|
services.ResponseInternalServerError500ProcessError(w, fmt.Errorf("inconsistent network element types"))
|
|
return
|
|
}
|
|
|
|
neInfo := neService.NewNeInfo.SelectNeInfoByRmuid(body.RmUID)
|
|
if neInfo.RmUID != body.RmUID {
|
|
services.ResponseInternalServerError500ProcessError(w, fmt.Errorf("inconsistent network element rmUID"))
|
|
return
|
|
}
|
|
|
|
if len(body.StateList) == 0 {
|
|
services.ResponseInternalServerError500ProcessError(w, fmt.Errorf("no stateList"))
|
|
return
|
|
}
|
|
|
|
nbStateService := neDataService.NewNBState
|
|
for _, v := range body.StateList {
|
|
if v.Address == "" || v.State == "" {
|
|
continue
|
|
}
|
|
timeStr := v.OffTime
|
|
if v.State == "ON" {
|
|
timeStr = v.OnTime
|
|
}
|
|
nbStateService.Insert(neDataModel.NBState{
|
|
NeType: neInfo.NeType,
|
|
NeId: neInfo.NeId,
|
|
RmUid: neInfo.RmUID,
|
|
Address: v.Address,
|
|
Name: v.Name,
|
|
Position: v.Position,
|
|
NbName: v.NbName,
|
|
NbId: v.RanId,
|
|
State: v.State,
|
|
Time: timeStr,
|
|
})
|
|
}
|
|
|
|
services.ResponseStatusOK204NoContent(w)
|
|
}
|
|
|
|
// Get Radio Info from NF/NFs
|
|
func GetNBInfoAllFromNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("GetNBInfoAllFromNF processing... ")
|
|
|
|
vars := mux.Vars(r)
|
|
neType := vars["elementTypeValue"]
|
|
if neType == "" {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
//neTypeLower := strings.ToLower(neType)
|
|
// var neID string
|
|
neIDs := services.GetParamsArrByName("neId", r)
|
|
// if len(neIDs) == 1 {
|
|
// neID = neIDs[0]
|
|
// } else {
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
//var ret error
|
|
var statusCode int = 500
|
|
var dataResponse []services.MapResponse
|
|
var neInfos []dborm.NeInfo
|
|
dborm.XormGetNeInfo2(neType, neIDs, &neInfos)
|
|
for _, neInfo := range neInfos {
|
|
// neInfo, err := dborm.XormGetNeInfo(neType, neID)
|
|
// if err != nil {
|
|
// log.Error("Failed to XormGetNeInfo:", err)
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
// } else if neInfo == nil {
|
|
// err := global.ErrCMNotFoundTargetNE
|
|
// log.Error(global.ErrCMNotFoundTargetNE)
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
// }
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
//SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Failed to GET:", err)
|
|
continue
|
|
// services.ResponseInternalServerError500ProcessError(w, err)
|
|
// return
|
|
} else {
|
|
switch resp.StatusCode() {
|
|
case http.StatusOK, http.StatusCreated, http.StatusNoContent, http.StatusAccepted:
|
|
var response services.MapResponse
|
|
_ = json.Unmarshal(resp.Body(), &response)
|
|
dataResponse = append(dataResponse, response)
|
|
statusCode = http.StatusOK
|
|
}
|
|
}
|
|
}
|
|
var response services.DataResponse
|
|
response.Data = dataResponse
|
|
services.ResponseWithJson(w, statusCode, response)
|
|
}
|
|
|
|
// Get GetUEInfoFileExportNF from NF/NFs
|
|
func GetUEInfoFileExportNF(w http.ResponseWriter, r *http.Request) {
|
|
log.Info("GetUEInfoFromNF processing... ")
|
|
|
|
// vars := mux.Vars(r)
|
|
// neType := vars["elementTypeValue"]
|
|
// if neType == "" {
|
|
// services.ResponseNotFound404UriNotExist(w, r)
|
|
// return
|
|
// }
|
|
//neTypeLower := strings.ToLower(neType)
|
|
var neId string
|
|
neIds := services.GetParamsArrByName("neId", r)
|
|
if len(neIds) == 1 {
|
|
neId = neIds[0]
|
|
} else {
|
|
services.ResponseNotFound404UriNotExist(w, r)
|
|
return
|
|
}
|
|
|
|
// token, err := services.CheckFrontValidRequest(w, r)
|
|
// if err != nil {
|
|
// log.Error("Request error:", err)
|
|
// return
|
|
// }
|
|
// log.Debug("token:", token)
|
|
|
|
neInfo, err := dborm.XormGetNeInfo("PCF", neId)
|
|
if err != nil {
|
|
log.Error("Failed to XormGetNeInfo:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else if neInfo == nil {
|
|
err := global.ErrCMNotFoundTargetNE
|
|
log.Error(global.ErrCMNotFoundTargetNE)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
}
|
|
log.Trace("neInfo:", neInfo)
|
|
|
|
hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
|
|
requestURI2NF := fmt.Sprintf("%s%s", hostUri, r.RequestURI)
|
|
|
|
log.Debug("requestURI2NF:", requestURI2NF)
|
|
|
|
client.SetTimeout(3 * time.Minute)
|
|
resp, err := client.R().
|
|
EnableTrace().
|
|
SetHeaders(map[string]string{tokenConst.HEADER_KEY: r.Header.Get(tokenConst.HEADER_KEY)}).
|
|
// SetHeaders(map[string]string{"accessToken": token}).
|
|
SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
|
|
SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
|
|
Get(requestURI2NF)
|
|
if err != nil {
|
|
log.Error("Get system state from NF is failed:", err)
|
|
services.ResponseInternalServerError500ProcessError(w, err)
|
|
return
|
|
} else {
|
|
w.WriteHeader(resp.StatusCode())
|
|
w.Write(resp.Body())
|
|
// var response services.MapResponse
|
|
// _ = json.Unmarshal(resp.Body(), &response)
|
|
// services.ResponseWithJson(w, resp.StatusCode(), response)
|
|
return
|
|
}
|
|
}
|