OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

feat: UPF总流量数 N3上行 N6下行

Browse Source
This commit is contained in:
TsMask
2024-01-29 15:47:29 +08:00
parent ba936d0a46
commit f1b17e00ab
5 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/modules/network_data/controller/upf.go
View File

@@ -26,21 +26,23 @@ type UPFController struct {
} }
// 总流量数 N3上行 N6下行 // 总流量数 N3上行 N6下行
// 单位 比特(bit)
// //
// GET /totalFlow // GET /totalFlow
func (s *UPFController) TotalFlow(c *gin.Context) { func (s *UPFController) TotalFlow(c *gin.Context) {
language := ctx.AcceptLanguage(c) language := ctx.AcceptLanguage(c)
var querys struct { var querys struct {
NeID string `form:"neId" binding:"required"` NeType string `json:"neType" form:"neType" binding:"required"`
Day int `form:"day" binding:"required"` NeID string `form:"neId" binding:"required"`
Day int `form:"day" binding:"required"`
} }
if err := c.ShouldBindQuery(&querys); querys.Day <= 0 || err != nil { if err := c.ShouldBindQuery(&querys); querys.Day < 0 || err != nil {
c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400"))) c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400")))
return return
} }
// 查询网元获取IP // 查询网元获取IP
neInfo := s.neInfoService.SelectNeInfoByNeTypeAndNeID("UPF", querys.NeID) neInfo := s.neInfoService.SelectNeInfoByNeTypeAndNeID(querys.NeType, querys.NeID)
if neInfo.NeId != querys.NeID || neInfo.IP == "" { if neInfo.NeId != querys.NeID || neInfo.IP == "" {
c.JSON(200, result.ErrMsg(i18n.TKey(language, "app.common.noNEInfo"))) c.JSON(200, result.ErrMsg(i18n.TKey(language, "app.common.noNEInfo")))
return return

2
src/modules/network_data/repository/perf_kpi.go
View File

@@ -11,5 +11,5 @@ type IPerfKPI interface {
SelectGoldKPITitle(neType string) []model.GoldKPITitle SelectGoldKPITitle(neType string) []model.GoldKPITitle
// SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行 // SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) []map[string]any SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) map[string]any
} }

4
src/modules/network_data/repository/perf_kpi.impl.go
View File

@@ -96,7 +96,7 @@ func (r *PerfKPIImpl) SelectGoldKPITitle(neType string) []model.GoldKPITitle {
} }
// SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行 // SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) []map[string]any { func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID, startDate, endDate string) map[string]any {
// 查询条件拼接 // 查询条件拼接
var conditions []string var conditions []string
var params []any var params []any
@@ -128,5 +128,5 @@ func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID, startDate, endDate strin
if err != nil { if err != nil {
logger.Errorf("query err => %v", err) logger.Errorf("query err => %v", err)
} }
return results return results[0]
} }

2
src/modules/network_data/service/perf_kpi.go
View File

@@ -11,5 +11,5 @@ type IPerfKPI interface {
SelectGoldKPITitle(neType string) []model.GoldKPITitle SelectGoldKPITitle(neType string) []model.GoldKPITitle
// SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行 // SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
SelectUPFTotalFlow(neType, rmUID string, day int) []map[string]any SelectUPFTotalFlow(neType, rmUID string, day int) map[string]any
} }

4
src/modules/network_data/service/perf_kpi.impl.go
View File

@@ -40,11 +40,11 @@ func (r *PerfKPIImpl) SelectGoldKPITitle(neType string) []model.GoldKPITitle {
} }
// SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行 // SelectUPFTotalFlow 查询UPF总流量 N3上行 N6下行
func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID string, day int) []map[string]any { func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID string, day int) map[string]any {
// 获取当前日期 // 获取当前日期
now := time.Now() now := time.Now()
endDate := now.Format("2006-01-02") endDate := now.Format("2006-01-02")
// 将当前日期加天数 // 将当前日期前几天数
afterDays := now.AddDate(0, 0, -day) afterDays := now.AddDate(0, 0, -day)
startDate := afterDays.Format("2006-01-02") startDate := afterDays.Format("2006-01-02")