fix: UriUEInfo接口接收解析变更Map

features/ue/ue.go

@@ -8,12 +8,14 @@ import (
 	"strings"
 	"time"
 
+	"be.ems/lib/core/ctx"
 	"be.ems/lib/dborm"
 	"be.ems/lib/global"
 	"be.ems/lib/log"
 	"be.ems/lib/services"
 	"be.ems/restagent/config"
 	tokenConst "be.ems/src/framework/constants/token"
+	neService "be.ems/src/modules/network_element/service"
 	"github.com/go-resty/resty/v2"
 	"github.com/gorilla/mux"
 )
@@ -241,66 +243,38 @@ func GetSubscriptionsFromNSSF(w http.ResponseWriter, r *http.Request) {
 
 // Get UEInfo from NF/NFs
 func GetUEInfoFromNF(w http.ResponseWriter, r *http.Request) {
-	log.Info("GetUEInfoFromNF processing... ")
+	log.Debug("GetUEInfoFromNF processing... ")
 
-	vars := mux.Vars(r)
+	neId := ctx.GetQuery(r, "neId")
-	neType := vars["elementTypeValue"]
+	neType := ctx.GetParam(r, "elementTypeValue")
-	if neType == "" {
+	if neType == "" || neId == "" {
-		services.ResponseNotFound404UriNotExist(w, r)
+		log.Error("elementTypeValue/neId is empty")
-		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)
+	neInfo := neService.NewNeInfoImpl.SelectNeInfoByNeTypeAndNeID(neType, neId)
-	// if err != nil {
-	// 	log.Error("Request error:", err)
-	// 	return
-	// }
-	// log.Debug("token:", token)
 
-	neInfo, err := dborm.XormGetNeInfo(neType, neId)
+	var response services.MapResponse
-	if err != nil {
+	if neInfo.NeId == neId && neInfo.NeId != "" {
-		log.Error("Failed to XormGetNeInfo:", err)
+		requestURI2NF := fmt.Sprintf("http://%s:%v%s", neInfo.IP, neInfo.Port, r.RequestURI)
-		services.ResponseInternalServerError500ProcessError(w, err)
+		log.Debug("requestURI2NF:", requestURI2NF)
-		return
+		resp, err := client.R().
-	} else if neInfo == nil {
+			EnableTrace().
-		err := global.ErrCMNotFoundTargetNE
+			SetHeaders(map[string]string{"User-Agent": config.GetDefaultUserAgent()}).
-		log.Error(global.ErrCMNotFoundTargetNE)
+			SetHeaders(map[string]string{"Content-Type": "application/json;charset=UTF-8"}).
-		services.ResponseInternalServerError500ProcessError(w, err)
+			Get(requestURI2NF)
-		return
+		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)
 	}
-	log.Trace("neInfo:", neInfo)
 
-	hostUri := fmt.Sprintf("http://%s:%v", neInfo.Ip, neInfo.Port)
+	services.ResponseWithJson(w, http.StatusOK, response)
-	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
-	}
 }
 
 // POST User Info from NF/NFs

lib/routes/routes.go

@@ -261,9 +261,7 @@ func init() {
 	Register("DELETE", ue.CustomUriPCFUserM, ue.DeletePCFUserInfo, nil)
 	//PCF User file
 	Register("GET", ue.UriPCFUserFileExport, ue.GetUEInfoFileExportNF, nil)
-	Register("GET", ue.CustomUriPCFUserFileExport, ue.GetUEInfoFromNF, nil)
 	Register("PUT", ue.UriPCFUserFileImport, ue.PutPCFUserInfo, nil)
-	Register("PUT", ue.CustomUriPCFUserFileImport, ue.PutPCFUserInfo, nil)
 
 	// UE Number
 	Register("GET", ue.UriUENum, ue.GetUENumFromNF, nil)