diff --git a/features/pm/performance.go b/features/pm/performance.go index 6e91bda6..66088b09 100644 --- a/features/pm/performance.go +++ b/features/pm/performance.go @@ -17,6 +17,7 @@ import ( "ems.agt/restagent/config" "xorm.io/xorm" + wsService "ems.agt/src/modules/ws/service" "github.com/go-resty/resty/v2" _ "github.com/go-sql-driver/mysql" "github.com/gorilla/mux" @@ -194,7 +195,15 @@ func PostKPIReportFromNF(w http.ResponseWriter, r *http.Request) { goldKpi.RmUid = kpiReport.Task.NE.RmUID goldKpi.NEType = kpiReport.Task.NE.NeType goldKpi.Timestamp = global.GetFmtTimeString(layout, kpiReport.Timestamp, time.DateTime) + // 黄金指标事件对象 + kpiEvent := map[string]any{ + // kip_id ... + "neName": goldKpi.NEType, + "startIndex": goldKpi.Index, + "timeGroup": goldKpi.StartTime, + } for _, k := range kpiReport.Task.NE.KPIs { + kpiEvent[k.KPIID] = k.Value // kip_id goldKpi.KpiId = k.KPIID goldKpi.Value = k.Value goldKpi.Error = k.Err @@ -232,6 +241,9 @@ func PostKPIReportFromNF(w http.ResponseWriter, r *http.Request) { } } + // 推送到ws订阅组 + wsService.NewWSSendImpl.ByGroupID(wsService.GROUP_KPI, kpiEvent) + services.ResponseStatusOK200Null(w) }