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)