From b4e3d6efd54dc1001ab6e998bffe67c9f41ac465 Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Tue, 6 Feb 2024 18:48:37 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20KPI=E9=BB=84=E9=87=91=E6=8C=87=E6=A0=87?=
 =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E6=8E=A8=E9=80=81ws?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 features/pm/performance.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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