78 lines
2.0 KiB
Go
78 lines
2.0 KiB
Go
package controller
|
|
|
|
import (
|
|
"ems.agt/lib/core/utils/date"
|
|
"ems.agt/src/framework/i18n"
|
|
"ems.agt/src/framework/utils/ctx"
|
|
"ems.agt/src/framework/vo/result"
|
|
"ems.agt/src/modules/network_element/model"
|
|
neService "ems.agt/src/modules/network_element/service"
|
|
"github.com/gin-gonic/gin"
|
|
)
|
|
|
|
// 实例化控制层 PerfKPIController 结构体
|
|
var NewPerfKPI = &PerfKPIController{
|
|
neInfoService: neService.NewNeInfoImpl,
|
|
perfKPIService: neService.NewPerfKPIImpl,
|
|
}
|
|
|
|
// 性能统计
|
|
//
|
|
// PATH /kpi
|
|
type PerfKPIController struct {
|
|
// 网元信息服务
|
|
neInfoService neService.INeInfo
|
|
// 统计信息服务
|
|
perfKPIService neService.IPerfKPI
|
|
}
|
|
|
|
// 获取统计数据
|
|
//
|
|
// GET /data
|
|
func (s *PerfKPIController) GoldKPI(c *gin.Context) {
|
|
language := ctx.AcceptLanguage(c)
|
|
var querys model.GoldKPIQuery
|
|
if err := c.ShouldBindQuery(&querys); err != nil {
|
|
c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
|
|
return
|
|
}
|
|
|
|
// 时间格式校验
|
|
startTime := date.ParseStrToDate(querys.StartTime, date.YYYY_MM_DD_HH_MM_SS)
|
|
if startTime.IsZero() {
|
|
c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
|
|
}
|
|
endTime := date.ParseStrToDate(querys.EndTime, date.YYYY_MM_DD_HH_MM_SS)
|
|
if endTime.IsZero() {
|
|
c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
|
|
}
|
|
|
|
// 查询网元获取IP
|
|
neInfo := s.neInfoService.SelectNeInfoByNeTypeAndNeID(querys.NeType, querys.NeID)
|
|
if neInfo.NeId != querys.NeID || neInfo.IP == "" {
|
|
c.JSON(200, result.ErrMsg(i18n.TKey(language, "app.common.noNEInfo")))
|
|
return
|
|
}
|
|
querys.RmUID = neInfo.RmUID
|
|
|
|
// 查询数据
|
|
kpiData := s.perfKPIService.SelectGoldKPI(querys)
|
|
c.JSON(200, result.OkData(kpiData))
|
|
}
|
|
|
|
// 获取统计标题
|
|
//
|
|
// GET /title
|
|
func (s *PerfKPIController) Title(c *gin.Context) {
|
|
language := ctx.AcceptLanguage(c)
|
|
neType := c.Query("neType")
|
|
if neType == "" {
|
|
c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
|
|
return
|
|
}
|
|
|
|
kpiTitles := s.perfKPIService.SelectGoldKPITitle(neType)
|
|
|
|
c.JSON(200, result.OkData(kpiTitles))
|
|
}
|