package controller
|
|
import (
|
"gat1400Exchange/models"
|
"gat1400Exchange/pkg/logger"
|
"gat1400Exchange/service"
|
"net/http"
|
"strconv"
|
"time"
|
|
"gat1400Exchange/config"
|
"gat1400Exchange/pkg/auth"
|
"gat1400Exchange/repository"
|
"gat1400Exchange/vo"
|
|
"github.com/gin-gonic/gin"
|
)
|
|
type SystemController struct {
|
Auth *auth.DigestAuth
|
Repository repository.SystemRepository
|
}
|
|
// 构造函数
|
func NewSystemController() SystemController {
|
svr := repository.NewSystemRepository()
|
controller := SystemController{Repository: svr}
|
|
controller.Auth = auth.NewDigestAuthenticator("Basic Realm", func(user, realm string) string {
|
// 需要在这里实现检查用户名和密码是否有效的逻辑, 目前使用固定密码
|
return config.ServeConf.Password
|
})
|
|
controller.Auth.PlainTextSecrets = true
|
|
return controller
|
}
|
|
// 设备注册
|
func (s SystemController) Register(c *gin.Context) {
|
user, _ := s.Auth.CheckAuth(c.Request)
|
if user == "" {
|
s.Auth.RequireAuth(c.Writer, c.Request)
|
c.AbortWithStatus(http.StatusUnauthorized)
|
return
|
}
|
|
rspMsg := vo.ResponseStatus{
|
RequestURL: c.FullPath(),
|
StatusCode: vo.StatusSuccess,
|
StatusString: vo.StatusString[vo.StatusSuccess],
|
Id: user,
|
LocalTime: time.Now().Format("20060102150405"),
|
}
|
|
c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
|
}
|
|
// 设备保活
|
func (s SystemController) Keepalive(c *gin.Context) {
|
var req vo.RequestKeepalive
|
if err := c.BindJSON(&req); err != nil {
|
c.AbortWithStatus(http.StatusBadRequest)
|
return
|
}
|
|
// 上报设备信息
|
var d = models.Device{
|
Id: req.KeepaliveObject.DeviceID,
|
}
|
|
err := d.Upsert()
|
if err != nil {
|
logger.Warn("Device db update camera error:%s", err.Error())
|
}
|
|
service.KeepDeviceAlive(req.KeepaliveObject.DeviceID)
|
|
rspMsg := vo.ResponseStatus{
|
RequestURL: c.FullPath(),
|
StatusCode: vo.StatusSuccess,
|
StatusString: vo.StatusString[vo.StatusSuccess],
|
Id: req.KeepaliveObject.DeviceID,
|
LocalTime: time.Now().Format("20060102150405"),
|
}
|
|
c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
|
}
|
|
// 设备退出
|
func (s SystemController) UnRegister(c *gin.Context) {
|
var req vo.RequestUnRegister
|
if err := c.BindJSON(&req); err != nil {
|
c.AbortWithStatus(http.StatusBadRequest)
|
return
|
}
|
|
// 删库
|
|
rspMsg := vo.ResponseStatus{
|
RequestURL: c.FullPath(),
|
StatusCode: vo.StatusSuccess,
|
StatusString: vo.StatusString[vo.StatusSuccess],
|
Id: req.UnRegisterObject.DeviceID,
|
LocalTime: time.Now().Format("20060102150405"),
|
}
|
|
c.JSON(http.StatusOK, gin.H{"ResponseStatusObject": rspMsg})
|
}
|
|
// 时间校准
|
func (s SystemController) Time(c *gin.Context) {
|
iTime, _ := strconv.ParseInt(time.Now().Format("20060102150405"), 10, 64)
|
rspMsg := vo.ResponseSystemTime{
|
VIIDServerID: config.ServeConf.ID,
|
LocalTime: iTime,
|
}
|
|
c.JSON(http.StatusOK, gin.H{"SystemTimeObject": rspMsg})
|
}
|
