fix: UPF流量总计7,30天累计数据查询

features/pm/performance.go

@@ -19,6 +19,8 @@ import (
 	"be.ems/lib/log"
 	"be.ems/lib/services"
 
+	"be.ems/src/framework/utils/parse"
+	neDataService "be.ems/src/modules/network_data/service"
 	neService "be.ems/src/modules/network_element/service"
 	wsService "be.ems/src/modules/ws/service"
 	"github.com/go-resty/resty/v2"
@@ -329,6 +331,10 @@ func PostKPIReportFromNF(w http.ResponseWriter, r *http.Request) {
 		wsService.NewWSSend.ByGroupID(fmt.Sprintf("%s%s_%s", wsService.GROUP_KPI_C, neInfo.NeType, neInfo.NeId), kpiCEvent)
 		if neInfo.NeType == "UPF" {
 			wsService.NewWSSend.ByGroupID(wsService.GROUP_KPI_UPF+neInfo.NeId, kpiEvent)
+			// 更新UPF总流量
+			upValue := parse.Number(kpiEvent["UPF.03"])
+			downValue := parse.Number(kpiEvent["UPF.06"])
+			neDataService.NewPerfKPI.UPFTodayFlowUpdate(neInfo.RmUID, upValue, downValue)
 		}
 	}