From 825b9cfa0e74282d79dd5da4d726cdb729ff3cb2 Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Fri, 7 Jun 2024 19:48:30 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E7=BD=91=E5=85=83=E6=95=B0=E6=8D=AECDR?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=A3=B0=E6=98=8E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/framework/utils/repo/repo.go         |  4 ++--
 src/modules/network_data/network_data.go | 21 +++++++++++++++------
 2 files changed, 17 insertions(+), 8 deletions(-)

diff --git a/src/framework/utils/repo/repo.go b/src/framework/utils/repo/repo.go
index 5bd59fe9..6e5e82f3 100644
--- a/src/framework/utils/repo/repo.go
+++ b/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))
diff --git a/src/modules/network_data/network_data.go b/src/modules/network_data/network_data.go
index 8d56e692..47d7d6d0 100644
--- a/src/modules/network_data/network_data.go
+++ b/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