From cabaf90c4d08a8ba3a1dea12a6aa87683bbcca81 Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期三, 03 七月 2024 01:07:51 +0800 Subject: [PATCH] 添加布控接口 --- controller/dispositionCtl.go | 34 +++++++++++++++++ routes/disposition.go | 15 +++++++ util/http.go | 1 vo/ape.go | 10 +++++ routes/routes.go | 2 + 5 files changed, 62 insertions(+), 0 deletions(-) diff --git a/controller/dispositionCtl.go b/controller/dispositionCtl.go new file mode 100644 index 0000000..9c07d6c --- /dev/null +++ b/controller/dispositionCtl.go @@ -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}) +} diff --git a/routes/disposition.go b/routes/disposition.go new file mode 100644 index 0000000..903637c --- /dev/null +++ b/routes/disposition.go @@ -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 +} diff --git a/routes/routes.go b/routes/routes.go index d64926d..946480f 100644 --- a/routes/routes.go +++ b/routes/routes.go @@ -34,6 +34,8 @@ InitCaptureRouters(viidGroup) // 娉ㄥ唽璁㈤槄閫氱煡鎺ュ彛璺敱 InitSubscribesRouters(viidGroup) + // 娉ㄥ唽甯冩帶鎺ュ彛璺敱 + InitDispositionRouters(viidGroup) // web api 璺敱鍒嗙粍 apiGroup := r.Group("/api") diff --git a/util/http.go b/util/http.go index 2820bd0..ff0dcc8 100644 --- a/util/http.go +++ b/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 { diff --git a/vo/ape.go b/vo/ape.go index cae2ebd..d820256 100644 --- a/vo/ape.go +++ b/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"` +} -- Gitblit v1.8.0