From dbf9fb2be56fb3e88b953604ea556b1da89dbd9c Mon Sep 17 00:00:00 2001
From: simonzhangsz <simonzhangsz@outlook.com>
Date: Wed, 26 Jun 2024 16:52:41 +0800
Subject: [PATCH] fix: ws upf groupid

---
 features/pm/performance.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/features/pm/performance.go b/features/pm/performance.go
index c51a9690..c4d6b670 100644
--- a/features/pm/performance.go
+++ b/features/pm/performance.go
@@ -273,7 +273,8 @@ func PostKPIReportFromNF(w http.ResponseWriter, r *http.Request) {
 	// 推送到ws订阅组
 	wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_KPI, kpiEvent)
 	if kpiReport.Task.NE.NeType == "UPF" {
-		wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_KPI_UPF, kpiEvent)
+		// 推送标识为：12_RMUID, exp: 12_4400HXUPF001
+		wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_KPI_UPF+"_"+kpiReport.Task.NE.RmUID, kpiEvent)
 	}
 
 	services.ResponseStatusOK204NoContent(w)