diff --git a/features/pm/performance.go b/features/pm/performance.go index f331020c..2371ed3b 100644 --- a/features/pm/performance.go +++ b/features/pm/performance.go @@ -328,8 +328,7 @@ func PostKPIReportFromNF(w http.ResponseWriter, r *http.Request) { // 推送自定义KPI到ws订阅组 wsService.NewWSSendImpl.ByGroupID(fmt.Sprintf("%s%s_%s", wsService.GROUP_KPI_C, neInfo.NeType, neInfo.NeId), kpiCEvent) if neInfo.NeType == "UPF" { - // 推送标识为:12_RMUID, exp: 12_4400HXUPF001 - wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_KPI_UPF+kpiReport.Task.NE.RmUID, kpiEvent) + wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_KPI_UPF+neInfo.NeId, kpiEvent) } }