feat: 性能统计接口

src/modules/network_element/repository/perf_kpi.go

@@ -0,0 +1,12 @@
+package repository
+
+import "ems.agt/src/modules/network_element/model"
+
+// 性能统计 数据层接口
+type IPerfKPI interface {
+	// SelectGoldKPI 通过ne_type和ne_id查询网元信息
+	SelectGoldKPI(rmUID, neType string, startTime, endTime string, kpiIds []string, interval int64) []map[string]any
+
+	// SelectGoldKPITitle
+	SelectGoldKPITitle(neType string) []model.GoldKPITitle
+}

src/modules/network_element/repository/perf_kpi.impl.go

@@ -0,0 +1,77 @@
+package repository
+
+import (
+	"fmt"
+	"strings"
+
+	"ems.agt/src/framework/datasource"
+	"ems.agt/src/framework/logger"
+	"ems.agt/src/modules/network_element/model"
+)
+
+// 实例化数据层 PerfKPIImpl 结构体
+var NewPerfKPIImpl = &PerfKPIImpl{}
+
+// PerfKPIImpl 性能统计 数据层处理
+type PerfKPIImpl struct{}
+
+// SelectGoldKPI 通过网元指标数据信息
+func (r *PerfKPIImpl) SelectGoldKPI(rmUID, neType string, startTime, endTime string, kpiIds []string, interval int64) []map[string]any {
+	// 查询条件拼接
+	var conditions []string
+	var params []any
+	if rmUID != "" {
+		conditions = append(conditions, "gk.rm_uid = ?")
+		params = append(params, rmUID)
+	}
+	if neType != "" {
+		conditions = append(conditions, "gk.ne_type = ?")
+		params = append(params, neType)
+	}
+	if startTime != "" {
+		conditions = append(conditions, "gk.start_time >= ?")
+		params = append(params, startTime)
+	}
+	if endTime != "" {
+		conditions = append(conditions, "gk.start_time <= ?")
+		params = append(params, endTime)
+	}
+	// 构建查询条件语句
+	whereSql := ""
+	if len(conditions) > 0 {
+		whereSql += " where " + strings.Join(conditions, " and ")
+	}
+
+	// 查询字段列
+	timeFormat := "DATE_FORMAT(gk.start_time, '%Y-%m-%d %H:')"
+	minuteGroup := fmt.Sprintf("LPAD(FLOOR(MINUTE(gk.start_time) / %d) * %d, 2, '0')", interval, interval)
+	groupByField := fmt.Sprintf("CONCAT( %s, %s ) AS timeGroup", timeFormat, minuteGroup)
+	var fields = []string{
+		groupByField,
+		"min(CASE WHEN gk.index != '' THEN gk.index ELSE 0 END) AS startIndex",
+		"min(CASE WHEN gk.ne_name != '' THEN gk.ne_name ELSE 0 END) AS neName",
+	}
+	for _, kid := range kpiIds {
+		str := fmt.Sprintf("sum(CASE WHEN gk.kpi_id = '%s' THEN gk.value ELSE 0 END) AS '%s'", kid, kid)
+		fields = append(fields, str)
+	}
+	fieldsSql := strings.Join(fields, ",")
+
+	// 查询数据
+	querySql := fmt.Sprintf("SELECT %s FROM gold_kpi gk %s GROUP BY timeGroup", fieldsSql, whereSql)
+	results, err := datasource.RawDB("", querySql, params)
+	if err != nil {
+		logger.Errorf("query err => %v", err)
+	}
+	return results
+}
+
+// SelectGoldKPITitle 通过网元指标数据信息
+func (r *PerfKPIImpl) SelectGoldKPITitle(neType string) []model.GoldKPITitle {
+	result := []model.GoldKPITitle{}
+	tx := datasource.DefaultDB().Table("kpi_title").Where("ne_type = ?", neType).Find(&result)
+	if err := tx.Error; err != nil {
+		logger.Errorf("Delete err => %v", err)
+	}
+	return result
+}