fix: ws upf groupid

2024-06-26 16:52:41 +08:00
1 parent 64ccb744df
commit dbf9fb2be5
@@ -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)