From ba067c2db77cdc0b4748ba4fc07041f240354edf Mon Sep 17 00:00:00 2001 From: TsMask <340112800@qq.com> Date: Wed, 16 Jul 2025 17:00:21 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=8C=97=E5=90=91=E5=AE=9A=E4=B9=89?= =?UTF-8?q?=E7=BD=91=E5=85=83=E7=8A=B6=E6=80=81/=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E4=B8=8B=E5=8F=91=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/modules/oam/controller/api_rest.go | 20 ++++++++++++++++++++ src/modules/oam/oam.go | 4 +++- 2 files changed, 23 insertions(+), 1 deletion(-) diff --git a/src/modules/oam/controller/api_rest.go b/src/modules/oam/controller/api_rest.go index 1da4e89a..c857ec90 100644 --- a/src/modules/oam/controller/api_rest.go +++ b/src/modules/oam/controller/api_rest.go @@ -8,6 +8,7 @@ import ( "github.com/gin-gonic/gin" "github.com/tsmask/go-oam" + goOamState "github.com/tsmask/go-oam/src/modules/state/service" "be.ems/src/framework/logger" "be.ems/src/framework/resp" @@ -670,3 +671,22 @@ func (s APIRestController) ResolveAlarmHistory(c *gin.Context) { } c.JSON(200, resp.Ok(nil)) } + +// QuerySystemState 查询系统状态 +// +// GET /systemManagement/v1/elementType/:elementTypeValue/objectType/systemState +func (s APIRestController) QuerySystemState(c *gin.Context) { + elementTypeValue := c.Param("elementTypeValue") + if strings.ToLower(elementTypeValue) != "omc" { + c.JSON(200, resp.ErrMsg("elementType only omc")) + return + } + c.JSON(200, goOamState.NewState.Info()) +} + +// NeConfigOMC 网元配置对端网管信息 +// +// PUT /systemManagement/v1/elementType/:elementTypeValue/objectType/config/omcNeConfig +func (s APIRestController) NeConfigOMC(c *gin.Context) { + c.JSON(204, nil) +} diff --git a/src/modules/oam/oam.go b/src/modules/oam/oam.go index 5a116ecf..fa4cac0b 100644 --- a/src/modules/oam/oam.go +++ b/src/modules/oam/oam.go @@ -24,7 +24,7 @@ func Setup(router *gin.Engine) { // 网管接收端收KPI oam.KPIReceiveRoute(router, service.NewKPI.Resolve) - // APIRest 北向接收 + // APIRest 北向定义 aprRest := controller.NewAPIRest aprRestGroup := router.Group("/api/rest") { @@ -35,6 +35,8 @@ func Setup(router *gin.Engine) { aprRestGroup.POST("/ueManagement/v1/elementType/:elementTypeValue/objectType/nbState", aprRest.ResolveNBState) aprRestGroup.POST("/logManagement/v1/elementType/:elementTypeValue/objectType/ueEvent", aprRest.ResolveUENB) router.POST("/upload-ue/v1/:eventType", aprRest.ResolveUENBByAMF) // AMF特殊上报 + aprRestGroup.GET("/systemManagement/v1/elementType/:elementTypeValue/objectType/systemState", aprRest.QuerySystemState) + aprRestGroup.PUT("/systemManagement/v1/elementType/:elementTypeValue/objectType/config/omcNeConfig", aprRest.NeConfigOMC) } }