派生自 webserver
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhangzengfei
2019-10-21 e871758bd82d9a4fbce42e43c9665d869c240dfb 
 controllers/syssetcont.go


@@ -1,45 +1,54 @@


package controllers




import (


   "basic.com/dbapi.git"


   "github.com/gin-gonic/gin"


   "webserver/extend/code"


   "webserver/extend/config"


   "webserver/extend/sys"


   "webserver/extend/util"




   "basic.com/dbapi.git"


   "github.com/gin-gonic/gin"


)




type SysSetController struct {




}




type LocalConfigVo struct {


   Id string  `json:"id"`


   AlarmIp string `json:"alarm_ip,omitempty" example:"192.168.1.182"`


   AlarmPort int `json:"alarm_port,omitempty" example:"22122"`


   AlarmThresholdType int `json:"alarm_threshold_type"`//报警阈值类型设置：1:按最高分,2:按阈值以上


   AlarmThreshold int `json:"alarm_threshold"`//报警阈值


   WebPicIp string `json:"web_pic_ip,omitempty" example:""`


   WebPicPort int `json:"web_pic_port,omitempty" example:"22122"`


   EsPicIp string `json:"es_pic_ip,omitempty" example:""`


   EsPicPort  int `json:"es_pic_port,omitempty" example:"22122"`


   CutMaxDuration int `json:"cut_max_duration,omitempty" example:"20"`


   CutMinDuration int `json:"cut_min_duration,omitempty" example:"5"`


   ServerId string `json:"server_id,omitempty" example:"分析设备id"`


   ServerName string `json:"server_name,omitempty" example:"分析设备名称"`


   ServerType int `json:"server_type,omitempty" example:"1"`


   Reserved string `json:"reserved,omitempty" example:"1"`


   RealMax int `json:"real_max"`//实时处理的最大路数


   Id                 string `json:"id"`


   AlarmIp            string `json:"alarm_ip,omitempty" example:"192.168.1.182"`


   AlarmPort          int    `json:"alarm_port,omitempty" example:"22122"`


   AlarmThresholdType int    `json:"alarm_threshold_type"` //报警阈值类型设置：1:按最高分,2:按阈值以上


   AlarmThreshold     int    `json:"alarm_threshold"`      //报警阈值


   WebPicIp           string `json:"web_pic_ip,omitempty" example:""`


   WebPicPort         int    `json:"web_pic_port,omitempty" example:"22122"`


   EsPicIp            string `json:"es_pic_ip,omitempty" example:""`


   EsPicPort          int    `json:"es_pic_port,omitempty" example:"22122"`


   CutMaxDuration     int    `json:"cut_max_duration,omitempty" example:"20"`


   CutMinDuration     int    `json:"cut_min_duration,omitempty" example:"5"`


   ServerId           string `json:"server_id,omitempty" example:"分析设备id"`


   ServerName         string `json:"server_name,omitempty" example:"分析设备名称"`


   ServerType         int    `json:"server_type,omitempty" example:"1"`


   Reserved           string `json:"reserved,omitempty" example:"1"`


   RealMax            int    `json:"real_max"` //实时处理的最大路数


}




type Gb28181ConfigVo struct {


   Id string `json:"Id"`


   ServerIp string `json:"ServerIp" example:"国标服务器IP"`


   ServerPort int `json:"ServerPort" example:"平台服务端口:7060"`


   PublicId string `json:"PublicId" example:"平台服务Id"`


   GbServerPort int `json:"GbServerPort" example:"国标服务端口:8060"`


   IsAuth bool `json:"IsAuth" example:"是否开启鉴权:true"`


   Password string `json:"Password" example:"密码"`


   UpdateTime string `json:"UpdateTime"`


   Id           string `json:"Id"`


   ServerIp     string `json:"ServerIp" example:"国标服务器IP"`


   ServerPort   int    `json:"ServerPort" example:"平台服务端口:7060"`


   PublicId     string `json:"PublicId" example:"平台服务Id"`


   GbServerPort int    `json:"GbServerPort" example:"国标服务端口:8060"`


   IsAuth       bool   `json:"IsAuth" example:"是否开启鉴权:true"`


   Password     string `json:"Password" example:"密码"`


   UpdateTime   string `json:"UpdateTime"`


}




type SysClockConfigVo struct {


   TimeZone  string `json:"timeZone" example:"时区"`


   NTP       bool   `json:"ntp" example:"NTP校时"`


   NTPServer string `json:"ntpServer" example:"NTP服务器地址"`


   Interval  int    `json:"interval" example:"自动校时间隔"`


   NewTime   string `json:"newTime" example:"手动指定时间"`


}




// @Summary 存储信息查询


@@ -50,13 +59,13 @@


// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"


// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"


// @Router /data/api-v/sysset/alarmServerShow [GET]


func (sset SysSetController) AlarmServerShow(c *gin.Context){


func (sset SysSetController) AlarmServerShow(c *gin.Context) {


   var api dbapi.SysSetApi


   b, sysconf := api.GetServerInfo()


   if b{


      util.ResponseFormat(c,code.Success,sysconf)


   if b {


      util.ResponseFormat(c, code.Success, sysconf)


   } else {


      util.ResponseFormat(c,code.ComError,"查询失败")


      util.ResponseFormat(c, code.ComError, "查询失败")


   }


}




@@ -72,17 +81,17 @@


func (sset SysSetController) AlarmEdit(c *gin.Context) {


   var args LocalConfigVo


   err := c.BindJSON(&args)


   if err !=nil {


      util.ResponseFormat(c,code.RequestParamError,"参数有误")


   if err != nil {


      util.ResponseFormat(c, code.RequestParamError, "参数有误")


      return


   }


   var api dbapi.SysSetApi


   paramBody := util.Struct2Map(args)


   b,data := api.AlarmEdit(paramBody)


   b, data := api.AlarmEdit(paramBody)


   if b {


      util.ResponseFormat(c,code.Success,data)


   }else {


      util.ResponseFormat(c,code.ComError,"保存失败")


      util.ResponseFormat(c, code.Success, data)


   } else {


      util.ResponseFormat(c, code.ComError, "保存失败")


   }


}




@@ -94,7 +103,7 @@


// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"


// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"


// @Router /data/api-v/sysset/videoLenShow [GET]


func (sset SysSetController) VideoLenShow(c *gin.Context){


func (sset SysSetController) VideoLenShow(c *gin.Context) {


   var api dbapi.SysSetApi


   b, sysconf := api.GetServerInfo()


   if b {


@@ -104,7 +113,7 @@


      // 存在则修改


      util.ResponseFormat(c, code.Success, resData)


   } else {


      util.ResponseFormat(c,code.ComError,"查询失败")


      util.ResponseFormat(c, code.ComError, "查询失败")


   }


}




@@ -125,11 +134,11 @@


   max_video_len := c.Request.FormValue("max_video_len")


   min_video_len := c.Request.FormValue("min_video_len")


   var api dbapi.SysSetApi


   b,data := api.VideoLenEdit(max_video_len,min_video_len)


   if b{


      util.ResponseFormat(c,code.UpdateSuccess,data)


   b, data := api.VideoLenEdit(max_video_len, min_video_len)


   if b {


      util.ResponseFormat(c, code.UpdateSuccess, data)


   } else {


      util.ResponseFormat(c,code.ComError,"保存失败")


      util.ResponseFormat(c, code.ComError, "保存失败")


   }


}




@@ -146,8 +155,8 @@


   b, sysconf := api.GetServerInfo()


   resData := make(map[string]string, 0)


   if !b { // 查询是否存在


      util.ResponseFormat(c, code.ServiceInsideError,"查询失败")


   }else {


      util.ResponseFormat(c, code.ServiceInsideError, "查询失败")


   } else {


      resData["server_id"] = sysconf.GetServerId()


      resData["server_name"] = sysconf.GetServerName()


      ipv4, mask, _ := util.GetLocalIP(config.Server.NetworkAdapter)


@@ -178,20 +187,19 @@


// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"


// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"


// @Router /data/api-v/sysset/saveDevInfo [POST]


func (sset SysSetController) SaveDevInfo(c *gin.Context){


func (sset SysSetController) SaveDevInfo(c *gin.Context) {




   dev_name := c.PostForm("server_name")


   var api dbapi.SysSetApi


   paramBody :=make(map[string]interface{},0)


   paramBody := make(map[string]interface{}, 0)


   paramBody["serverName"] = dev_name


   b,data := api.SaveServerInfo(paramBody)


   b, data := api.SaveServerInfo(paramBody)


   if b { // 查询是否存在


      util.ResponseFormat(c,code.Success,data)


   } else {  // 存在及修改 不存在 即添加


      util.ResponseFormat(c,code.ComError,"保存失败")


      util.ResponseFormat(c, code.Success, data)


   } else { // 存在及修改 不存在 即添加


      util.ResponseFormat(c, code.ComError, "保存失败")


   }


}






// @Summary GB28181设置查询


// @Description GB28181设置信息查询


@@ -205,9 +213,9 @@


   var api dbapi.SysSetApi


   b, data := api.Gb28181ConfigShow()


   if b {


      util.ResponseFormat(c,code.Success,data)


      util.ResponseFormat(c, code.Success, data)


   } else {


      util.ResponseFormat(c,code.ComError,"查询失败")


      util.ResponseFormat(c, code.ComError, "查询失败")


   }


}




@@ -223,16 +231,106 @@


func (sset SysSetController) Gb28181ConfigEdit(c *gin.Context) {


   var args Gb28181ConfigVo


   err := c.BindJSON(&args)


   if err !=nil {


      util.ResponseFormat(c,code.RequestParamError,"参数有误")


   if err != nil {


      util.ResponseFormat(c, code.RequestParamError, "参数有误")


      return


   }


   var api dbapi.SysSetApi


   paramBody := util.Struct2Map(args)


   b, data := api.Gb28181ConfigEdit(paramBody)


   if b {


      util.ResponseFormat(c,code.UpdateSuccess,data)


      util.ResponseFormat(c, code.UpdateSuccess, data)


   } else {


      util.ResponseFormat(c,code.ComError,"更新失败")


      util.ResponseFormat(c, code.ComError, "更新失败")


   }


}




// @Summary 获取时间配置


// @Description  系统时间配置信息


// @Accept  json


// @Produce json


// @Tags sysset


// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"


// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"


// @Router /data/api-v/sysset/clockInfo [GET]


func (sset SysSetController) GetClockinfo(c *gin.Context) {


   resData := make(map[string]interface{}, 0)


   resData["time_zone"], resData["local_time"] = sys.TimeZone()


   resData["ntp"], resData["ntp_server"], resData["interval"] = sys.NTPConfig()




   util.ResponseFormat(c, code.Success, resData)


}




// @Summary 测试同步时间


// @Description 测试同步时间服务器是否可用


// @Accept  json


// @Produce json


// @Tags sysset


// @Param server query string true "时间服务器ip"


// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"


// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"


// @Router /data/api-v/sysset/ntpTest [GET]


func (sset SysSetController) TestNTPServer(c *gin.Context) {


   ntpServer := c.Query("server")




   if root := sys.CheckRootPermissions(); !root {


      util.ResponseFormat(c, code.ServiceInsideError, "服务器没有修改时间的权限")


      return


   }




   isIP, err := sys.RunNTPDate(ntpServer)


   if !isIP {


      util.ResponseFormat(c, code.RequestParamError, "指定的服务器地址错误")


      return


   }




   if err == nil {


      util.ResponseFormat(c, code.Success, "")


   } else {


      util.ResponseFormat(c, code.TaskStoped, "")


   }


}




// @Summary 设置系统时间


// @Description 校正系统时间


// @Accept  json


// @Produce json


// @Tags sysset


// @Param config body controllers.SysClockConfigVo true "校时信息"


// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"


// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"


// @Router /data/api-v/sysset/updateClock [POST]


func (sset SysSetController) SetSysClock(c *gin.Context) {


   var args SysClockConfigVo


   err := c.BindJSON(&args)


   if err != nil {


      util.ResponseFormat(c, code.RequestParamError, "参数有误")


      return


   }




   if root := sys.CheckRootPermissions(); !root {


      util.ResponseFormat(c, code.ServiceInsideError, "服务器没有修改时间的权限")


      return


   }




   if args.TimeZone != "CST" && args.TimeZone != "UTC" {


      if r := sys.SetTimeZone(args.TimeZone); !r {


         util.ResponseFormat(c, code.RequestParamError, "时区参数错误")


         return


      }


   }




   if !args.NTP {


      if r := sys.SetLocalTime(args.NewTime); !r {


         util.ResponseFormat(c, code.RequestParamError, "指定的时间参数错误")


         return


      }


   } else {


      if r := sys.EnableNTPCron(args.NTPServer, args.Interval); !r {


         util.ResponseFormat(c, code.RequestParamError, "指定的服务器地址错误")


         return


      }


   }




   util.ResponseFormat(c, code.UpdateSuccess, "配置成功")


}