ref: 网元公共配置数据转化取值

src/modules/network_element/service/ne_info.impl.go

@@ -598,9 +598,7 @@ func (r *NeInfoImpl) NeConfOAMWirte(neType, neId string, content any, sync bool)
 		neFilePath := fmt.Sprintf("/usr/local/etc/%s/%s", neTypeLower, fileName)
 		neFileDir := filepath.Dir(neFilePath)
 		// 修改网元文件权限
-		if _, err = sshClient.RunCMD(fmt.Sprintf("sudo mkdir -p %s && sudo chmod o+w %s && sudo chmod o+w %s", neFileDir, neFileDir, neFilePath)); err != nil {
-			sshClient.RunCMD(fmt.Sprintf("sudo touch %s && sudo chmod o+w %s", neFilePath, neFilePath))
-		}
+		sshClient.RunCMD(fmt.Sprintf("sudo mkdir -p %s && sudo chmod o+w %s && sudo touch %s && sudo chmod o+w %s", neFileDir, neFileDir, neFilePath, neFilePath))
 		// 复制到网元进行覆盖
 		if err = sftpClient.CopyFileLocalToRemote(localFilePath, neFilePath); err != nil {
 			return fmt.Errorf("please check if scp remote copy is allowed")
@@ -684,3 +682,77 @@ func (r *NeInfoImpl) NeConfPara5GWirte(content map[string]any, syncNE []string)
 
 	return nil
 }
+
+// NeConfPara5GConvert 网元公共配置数据转化 content网元公共配置文件读取内容
+func (r *NeInfoImpl) NeConfPara5GDataConvert(content map[string]any) map[string]string {
+	basic := content["basic"].(map[string]any)
+	external := content["external"].(map[string]any)
+	sbi := content["sbi"].(map[string]any)
+
+	mcc := "460"
+	mnc := "01"
+	if plmnId, plmnIdOk := basic["plmnId"].(map[string]any); plmnIdOk {
+		mcc = plmnId["mcc"].(string)
+		mnc = plmnId["mnc"].(string)
+	}
+
+	sst := "1"
+	sd := "000001"
+	if plmnId, plmnIdOk := basic["snssai"].(map[string]any); plmnIdOk {
+		sst = plmnId["sst"].(string)
+		sd = plmnId["sd"].(string)
+	}
+
+	n3IPAmdMask := external["upfn3_ip"].(string)
+	n3Arr := strings.Split(n3IPAmdMask, "/")
+	n3IP := n3Arr[0]
+	n3Mask := parse.ConvertIPMask(parse.Number(n3Arr[1]))
+
+	n6IPAmdMask := external["upfn6_ip"].(string)
+	n6Arr := strings.Split(n6IPAmdMask, "/")
+	n6IP := n6Arr[0]
+	n6Mask := parse.ConvertIPMask(parse.Number(n6Arr[1]))
+
+	ueIPAmdMask := external["ue_pool"].(string)
+	ueArr := strings.Split(ueIPAmdMask, "/")
+	ueIP := ueArr[0]
+	ueMask := parse.ConvertIPMask(parse.Number(ueArr[1]))
+
+	return map[string]string{
+		// basic
+		"TAC":      basic["tac"].(string),
+		"MCC":      mcc,
+		"MNC":      mnc,
+		"SST":      sst,
+		"SD":       sd,
+		"DNN_DATA": basic["dnn_data"].(string),
+		"DNN_IMS":  basic["dnn_ims"].(string),
+
+		// external
+		"N2_IP":   external["amfn2_ip"].(string),
+		"UE_POOL": external["ue_pool"].(string),
+		"UE_IP":   ueIP,
+		"UE_MASK": ueMask,
+		"N3_IP":   n3IP,
+		"N3_MASK": n3Mask,
+		"N3_GW":   external["upfn3_gw"].(string),
+		"N6_IP":   n6IP,
+		"N6_MASK": n6Mask,
+		"N6_GW":   external["upfn6_gw"].(string),
+
+		// sbi
+		"OMC_IP":   sbi["omc_ip"].(string),
+		"IMS_IP":   sbi["ims_ip"].(string),
+		"AMF_IP":   sbi["amf_ip"].(string),
+		"AUSF_IP":  sbi["ausf_ip"].(string),
+		"UDM_IP":   sbi["udm_ip"].(string),
+		"ADB_IP":   sbi["adb_ip"].(string),
+		"SMF_IP":   sbi["smf_ip"].(string),
+		"PCF_IP":   sbi["pcf_ip"].(string),
+		"NSSF_IP":  sbi["nssf_ip"].(string),
+		"NRF_IP":   sbi["nrf_ip"].(string),
+		"UPF_IP":   sbi["upf_ip"].(string),
+		"MME_IP":   sbi["mme_ip"].(string),
+		"N3IWF_IP": sbi["n3iwf_ip"].(string),
+	}
+}