feat: 北向定义网元状态/配置下发接口

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

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