diff --git a/src/modules/network_data/controller/upf.go b/src/modules/network_data/controller/upf.go
index 864be14b..8a6b285b 100644
--- a/src/modules/network_data/controller/upf.go
+++ b/src/modules/network_data/controller/upf.go
@@ -26,21 +26,23 @@ type UPFController struct {
 }
 
 // 总流量数 N3上行 N6下行
+// 单位 比特(bit)
 //
 // GET /totalFlow
 func (s *UPFController) TotalFlow(c *gin.Context) {
 	language := ctx.AcceptLanguage(c)
 	var querys struct {
-		NeID string `form:"neId" binding:"required"`
-		Day  int    `form:"day" binding:"required"`
+		NeType string `json:"neType" form:"neType" binding:"required"`
+		NeID   string `form:"neId" binding:"required"`
+		Day    int    `form:"day" binding:"required"`
 	}
-	if err := c.ShouldBindQuery(&querys); querys.Day <= 0 || err != nil {
+	if err := c.ShouldBindQuery(&querys); querys.Day < 0 || err != nil {
 		c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
 		return
 	}
 
 	// 查询网元获取IP
-	neInfo := s.neInfoService.SelectNeInfoByNeTypeAndNeID("UPF", querys.NeID)
+	neInfo := s.neInfoService.SelectNeInfoByNeTypeAndNeID(querys.NeType, querys.NeID)
 	if neInfo.NeId != querys.NeID || neInfo.IP == "" {
 		c.JSON(200, result.ErrMsg(i18n.TKey(language, "app.common.noNEInfo")))
 		return
diff --git a/src/modules/network_data/repository/perf_kpi.go b/src/modules/network_data/repository/perf_kpi.go
index 476eb2d0..6376d799 100644
--- a/src/modules/network_data/repository/perf_kpi.go
+++ b/src/modules/network_data/repository/perf_kpi.go
@@ -11,5 +11,5 @@ type IPerfKPI interface {
 	SelectGoldKPITitle(neType string) []model.GoldKPITitle
 
 	// SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
-	SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) []map[string]any
+	SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) map[string]any
 }
diff --git a/src/modules/network_data/repository/perf_kpi.impl.go b/src/modules/network_data/repository/perf_kpi.impl.go
index 33c583b4..87e87684 100644
--- a/src/modules/network_data/repository/perf_kpi.impl.go
+++ b/src/modules/network_data/repository/perf_kpi.impl.go
@@ -96,7 +96,7 @@ func (r *PerfKPIImpl) SelectGoldKPITitle(neType string) []model.GoldKPITitle {
 }
 
 // SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
-func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) []map[string]any {
+func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) map[string]any {
 	// 查询条件拼接
 	var conditions []string
 	var params []any
@@ -128,5 +128,5 @@ func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID, startDate, endDate strin
 	if err != nil {
 		logger.Errorf("query err => %v", err)
 	}
-	return results
+	return results[0]
 }
diff --git a/src/modules/network_data/service/perf_kpi.go b/src/modules/network_data/service/perf_kpi.go
index b6056c42..41a9364e 100644
--- a/src/modules/network_data/service/perf_kpi.go
+++ b/src/modules/network_data/service/perf_kpi.go
@@ -11,5 +11,5 @@ type IPerfKPI interface {
 	SelectGoldKPITitle(neType string) []model.GoldKPITitle
 
 	// SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
-	SelectUPFTotalFlow(neType, rmUID string, day int) []map[string]any
+	SelectUPFTotalFlow(neType, rmUID string, day int) map[string]any
 }
diff --git a/src/modules/network_data/service/perf_kpi.impl.go b/src/modules/network_data/service/perf_kpi.impl.go
index f8ce8689..42f405ef 100644
--- a/src/modules/network_data/service/perf_kpi.impl.go
+++ b/src/modules/network_data/service/perf_kpi.impl.go
@@ -40,11 +40,11 @@ func (r *PerfKPIImpl) SelectGoldKPITitle(neType string) []model.GoldKPITitle {
 }
 
 // SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
-func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID string, day int) []map[string]any {
+func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID string, day int) map[string]any {
 	// 获取当前日期
 	now := time.Now()
 	endDate := now.Format("2006-01-02")
-	// 将当前日期加天数
+	// 将当前日期前几天数
 	afterDays := now.AddDate(0, 0, -day)
 	startDate := afterDays.Format("2006-01-02")