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"])