From 5acce85ef3d974da22b88641d7a9a5d789921f2d Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Wed, 26 Mar 2025 16:20:06 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20KPI=E6=8E=A8=E9=80=81ws=E8=AE=A2?=
 =?UTF-8?q?=E9=98=85=E7=BC=BA=E5=A4=B1=5Fx=E4=B8=8B=E5=88=92=E7=BA=BF?=
 =?UTF-8?q?=E6=A0=87=E8=AF=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/features/pm/performance.go b/features/pm/performance.go
index ca64b119..265c8a41 100644
--- a/features/pm/performance.go
+++ b/features/pm/performance.go
@@ -197,7 +197,7 @@ func saveKPIData(kpiReport KpiReport, index int64) int64 {
 		neInfo := neService.NewNeInfo.FindByRmuid(kpiData.RmUid)
 		if neInfo.RmUID == kpiData.RmUid {
 			// 推送到ws订阅组
-			wsService.NewWSSend.ByGroupID(fmt.Sprintf("%s%s_%s", wsService.GROUP_KPI, neInfo.NeType, neInfo.NeId), kpiEvent)
+			wsService.NewWSSend.ByGroupID(fmt.Sprintf("%s_%s_%s", wsService.GROUP_KPI, neInfo.NeType, neInfo.NeId), kpiEvent)
 			if neInfo.NeType == "UPF" {
 				// 更新UPF总流量
 				upValue := parse.Number(kpiEvent["UPF.03"])