feat: KPI黄金指标事件推送ws

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)
 }