feat: 网元数据CDR接口声明

src/framework/utils/repo/repo.go

@@ -66,12 +66,12 @@ func SetFieldValue(obj any, fieldName string, value any) {
 			}
 			fieldValue.SetFloat(floatValue)
 		case reflect.Struct:
-			fmt.Printf("%s 时间解析 %s %v \n", fieldName, fieldValue.Type(), value)
+			fmt.Printf("%s time resolution %s %v \n", fieldName, fieldValue.Type(), value)
 			if fieldValue.Type() == reflect.TypeOf(time.Time{}) && value != nil {
 				// 解析 value 并转换为 time.Time 类型
 				parsedTime, err := time.Parse("2006-01-02 15:04:05 +0800 CST", fmt.Sprintf("%v", value))
 				if err != nil {
-					fmt.Println("时间解析出错:", err)
+					fmt.Println("Time resolution error:", err)
 				} else {
 					// 设置字段的值
 					fieldValue.Set(reflect.ValueOf(parsedTime))

src/modules/network_data/network_data.go

@@ -44,49 +44,58 @@ func Setup(router *gin.Engine) {
 	// 网元IMS
 	imsGroup := neDataGroup.Group("/ims")
 	{
-		// CDR会话事件列表
 		imsGroup.GET("/cdr/list",
 			middleware.PreAuthorize(nil),
 			controller.NewIMSController.CDRList,
 		)
-		// CDR会话删除
 		imsGroup.DELETE("/cdr/:cdrIds",
 			middleware.PreAuthorize(nil),
 			collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.imsCDR", collectlogs.BUSINESS_TYPE_DELETE)),
 			controller.NewIMSController.CDRRemove,
 		)
+		imsGroup.POST("/cdr/export",
+			middleware.PreAuthorize(nil),
+			collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.imsCDR", collectlogs.BUSINESS_TYPE_EXPORT)),
+			controller.NewIMSController.CDRExport,
+		)
 	}
 
 	// 网元SMF
 	smfGroup := neDataGroup.Group("/smf")
 	{
-		// CDR会话事件列表
 		smfGroup.GET("/cdr/list",
 			middleware.PreAuthorize(nil),
 			controller.NewSMFController.CDRList,
 		)
-		// CDR会话删除
 		smfGroup.DELETE("/cdr/:cdrIds",
 			middleware.PreAuthorize(nil),
 			collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.smfCDR", collectlogs.BUSINESS_TYPE_DELETE)),
 			controller.NewSMFController.CDRRemove,
 		)
+		smfGroup.POST("/cdr/export",
+			middleware.PreAuthorize(nil),
+			collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.smfCDR", collectlogs.BUSINESS_TYPE_EXPORT)),
+			controller.NewSMFController.CDRExport,
+		)
 	}
 
 	// 网元AMF
 	amfGroup := neDataGroup.Group("/amf")
 	{
-		// UE会话事件
 		amfGroup.GET("/ue/list",
 			middleware.PreAuthorize(nil),
 			controller.NewAMFController.UEList,
 		)
-		// UE会话删除
 		amfGroup.DELETE("/ue/:ueIds",
 			middleware.PreAuthorize(nil),
 			collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.amfUE", collectlogs.BUSINESS_TYPE_DELETE)),
 			controller.NewAMFController.UERemove,
 		)
+		amfGroup.POST("/ue/export",
+			middleware.PreAuthorize(nil),
+			collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.amfUE", collectlogs.BUSINESS_TYPE_EXPORT)),
+			controller.NewAMFController.UEExport,
+		)
 	}
 
 	// 网元UPF