添加布控接口

zhangzengfei

2024-07-03 cabaf90c4d08a8ba3a1dea12a6aa87683bbcca81

添加布控接口

 controller/dispositionCtl.go

New file
@@ -0,0 +1,34 @@
package controller

import (
    "net/http"
    "time"

    "gat1400Exchange/vo"

    "github.com/gin-gonic/gin"
)

type DispositionController struct {
}

// 构造函数
func NewDispositionController() DispositionController {
    controller := DispositionController{}

    return controller
}

func (d DispositionController) VIIDDisposition(c *gin.Context) {
    var rsp vo.ResponseStatusList
    rsp.ResponseStatusObject = append(rsp.ResponseStatusObject, vo.ResponseStatus{
        RequestURL:   c.FullPath(),
        StatusCode:   vo.StatusSuccess,
        StatusString: vo.StatusString[vo.StatusSuccess],
        Id:           "",
        LocalTime:    time.Now().Format("20060102150405"),
    })

    c.Header("Content-Type", "application/VIID+json;charset=UTF-8")
    c.JSON(http.StatusOK, gin.H{"ResponseStatusListObject": rsp})
}

 routes/disposition.go

New file
@@ -0,0 +1,15 @@
package routes

import (
    "gat1400Exchange/controller"
    "github.com/gin-gonic/gin"
)

func InitDispositionRouters(r *gin.RouterGroup) gin.IRoutes {
    dispCtl := controller.NewDispositionController()

    r.POST("/Dispositions", dispCtl.VIIDDisposition)
    r.PUT("/Dispositions/:id", dispCtl.VIIDDisposition)

    return r
}

 routes/routes.go

@@ -34,6 +34,8 @@
    InitCaptureRouters(viidGroup)
    // 注册订阅通知接口路由
    InitSubscribesRouters(viidGroup)
    // 注册布控接口路由
    InitDispositionRouters(viidGroup)

    // web api 路由分组
    apiGroup := r.Group("/api")

 util/http.go

@@ -77,6 +77,7 @@
        return nil, err
    }

    cli.CloseIdleConnections()
    defer resp.Body.Close()
    body, err := io.ReadAll(resp.Body)
    if err != nil {

 vo/ape.go

@@ -57,3 +57,13 @@
type NotificationApeList struct {
    APEObject []Ape `json:"APEObject"`
}

type ApeStatus struct {
    ApeID       string `json:"ApeID" binding:"required"`
    IsOnline    string `json:"IsOnline" binding:"required"`
    CurrentTime string `json:"CurrentTime" binding:"required"`
}

type NotificationApeStatusList struct {
    APEStatusObject []ApeStatus `json:"APEStatusObject"`
}