package controllers
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/bhomedbapi.git"
|
"basic.com/valib/logger.git"
|
"encoding/json"
|
"strconv"
|
"strings"
|
"vamicro/sync-service/models"
|
"vamicro/sync-service/service"
|
"vamicro/sync-service/vo"
|
)
|
|
type CameraPolygonController struct {
|
|
}
|
|
// @Summary 根据cameraId查询摄像机多边形
|
// @Description 根据cameraId查询摄像机多边形
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机多边形
|
// @Param cameraId query string true "摄像机id"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/polygon/findByCameraId [get]
|
func (cpc CameraPolygonController) FindByCameraId(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
cameraId := c.Query("cameraId")
|
if cameraId == "" {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
var sv service.CameraPolygonService
|
voInfo := sv.FindByCameraId(cameraId)
|
return &bhomeclient.Reply{ Success: true, Data: voInfo}
|
}
|
|
type CPN struct {
|
models.CameraPolygon
|
CameraName string `json:"camera_name"`
|
}
|
|
// @Summary 查找所有多边形,返回的是数据库的结构
|
// @Description 查找所有多边形,返回的是数据库的结构
|
// @Produce json
|
// @Tags 摄像机多边形
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/polygon/findAll [get]
|
func (cpc CameraPolygonController) FindAll(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
m := make(map[string]string)
|
idNameM := make(map[string]string)
|
|
var cameraE models.Camera
|
cams, _ := cameraE.FindAll()
|
if cams ==nil {
|
cams = make([]models.Camera,0)
|
}
|
var stackApi bhomedbapi.FileStackApi
|
flag, stackList := stackApi.FindAllDoingStacks()
|
if flag && stackList !=nil {
|
for _,f :=range stackList {
|
cams = append(cams, models.Camera{
|
Id: f.Id,
|
Name: f.Name,
|
})
|
}
|
}
|
for _,c :=range cams {
|
idNameM[c.Id] = c.Name
|
}
|
|
var model models.CameraPolygon
|
polygons := model.FindAll()
|
|
var result []CPN
|
var arr []CPN //全部区域
|
for _,p :=range polygons {
|
if nn,exist := idNameM[p.CameraId];exist {
|
me := models.CameraPolygon{
|
Id: p.CameraId,
|
CameraId: p.CameraId,
|
Name: models.CAMERAPOLYGON_AREA_ALL,
|
Polygon: "",
|
DirectionLine: "",
|
Type: models.TYPE_POLYGON,
|
DefenceState: 1,
|
}
|
|
cpn := CPN{}
|
cpn.CameraPolygon = me
|
cpn.CameraName = nn
|
if _,ok := m[p.CameraId];!ok {
|
arr = append(arr, cpn)
|
}
|
|
m[p.CameraId] = p.CameraId
|
}
|
|
cpR := CPN{}
|
cpR.CameraPolygon = p
|
if rName, ex := idNameM[p.CameraId];ex {
|
cpR.CameraName = rName
|
}
|
result = append(result, cpR)
|
}
|
|
|
if cams != nil {
|
for _,cam :=range cams {
|
if _,ok := m[cam.Id];!ok {
|
m[cam.Id] = cam.Id
|
|
me := models.CameraPolygon{
|
Id: cam.Id,
|
CameraId: cam.Id,
|
Name: models.CAMERAPOLYGON_AREA_ALL,
|
Polygon: "",
|
DirectionLine: "",
|
Type: models.TYPE_POLYGON,
|
DefenceState: 1,
|
}
|
|
cpn := CPN{}
|
cpn.CameraPolygon = me
|
if nn,exist := idNameM[cam.Id];exist {
|
cpn.CameraName = nn
|
}
|
arr = append(arr, cpn)
|
}
|
}
|
}
|
|
result = append(result, arr...)//每一个摄像机都有一个默认的全部区域
|
|
return &bhomeclient.Reply{ Success: true, Data: result}
|
}
|
|
// @Summary 添加或更新摄像机多边形
|
// @Description 添加或更新摄像机多边形
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机多边形
|
// @Param cameraPolygon body vo.CameraPolygonVo true "摄像机区域结构体，必填"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/polygon/save [post]
|
func (cpc CameraPolygonController) Save(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var cPolygon vo.CameraPolygonVo
|
|
if err := c.BindJSON(&cPolygon);err !=nil {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
if cPolygon.CameraId == "" {
|
return &bhomeclient.Reply{ Success: false, Msg: "摄像机id不能为空"}
|
}
|
|
var sv service.CameraPolygonService
|
delS, delF := sv.Save(cPolygon)
|
var msg =""
|
if len(delS) >0 {
|
msg += "删除成功:"+strings.Join(delS,",")
|
}
|
if len(delF) >0 {
|
if msg !=""{
|
msg +=";删除失败："+strings.Join(delF,",")
|
} else {
|
msg +="删除失败："+strings.Join(delF,",")
|
}
|
}
|
if msg ==""{
|
msg = "保存成功"
|
}
|
logger.Debug("polygon=>Save.msg:",msg)
|
return &bhomeclient.Reply{ Success: true, Data: msg}
|
}
|
|
// @Summary 根据多边形id更新布撤防状态
|
// @Description 根据多边形id更新布撤防状态
|
// @Produce json
|
// @Tags 摄像机多边形
|
// @Param polygonId query string true "多边形id"
|
// @Param defence_state query int true "布撤防状态(0:撤销，1：布防)"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/polygon/updateDefenceStateByPolygonId [get]
|
func (cpc CameraPolygonController)UpdateDefenceStateByPolygonId(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
polygonId := c.Query("polygonId")//多边形id
|
defenceState,err := strconv.Atoi(c.Query("defence_state"))//布撤防状态
|
logger.Debug("polygonId:", polygonId)
|
logger.Debug("defence_state:",defenceState)
|
if err !=nil || polygonId=="" || (defenceState !=0 && defenceState !=1){
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
var model models.CameraPolygon
|
if model.UpdateDefenceStateByPolygonId(polygonId,defenceState) {
|
cpc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_CameraPolygon, polygonId, protomsg.DbAction_Update, "")
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// @Summary 根据摄像机id更新布撤防状态
|
// @Description 根据摄像机id更新布撤防状态
|
// @Produce json
|
// @Tags 摄像机多边形
|
// @Param cameraId query string true "摄像机id"
|
// @Param defence_state query int true "布撤防状态(0:撤销，1：布防)"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/polygon/updateDefenceStateByCameraId [get]
|
func (cpc CameraPolygonController)UpdateDefenceStateByCameraId(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
cameraId := c.Query("cameraId")//多边形id
|
defenceState,err := strconv.Atoi(c.Query("defence_state"))//布撤防状态
|
if err !=nil || cameraId=="" || (defenceState !=0 && defenceState !=1){
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
var model models.CameraPolygon
|
if model.UpdateDefenceStateByCameraId(cameraId,defenceState) {
|
cpc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_CameraPolygon, "", protomsg.DbAction_Update, "")
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
func (cpc CameraPolygonController) addDbChangeMsg(bk bhomeclient.Broker, tChanged protomsg.TableChanged,id string,action protomsg.DbAction,info string){
|
dbMsg := protomsg.DbChangeMessage{
|
Table:tChanged,
|
Id:id,
|
Action:action,
|
Info: info,
|
}
|
pb,_ := json.Marshal(dbMsg)
|
bk.Publish(service.ProcName, pb)
|
}
|
