package controllers

import (
	"basic.com/pubsub/protomsg.git"
	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/bhomedbapi.git"
	"basic.com/valib/logger.git"
	"sort"
	"strconv"
	"vamicro/sync-service/models"
	"vamicro/sync-service/vo"
	"vamicro/sync-service/service"
	"vamicro/extend/util"
)

type Gb28181Controller struct {

}

// @Summary 更新摄像机
// @Description "用于更新摄像机操作"
// @Accept json
// @Produce json
// @Tags camera
// @Param cam body vo.CameraEditVo true "id:摄像机id default:cid0 (string),     areaid:摄像机关联区域id default:1 (int),      name:摄像机名字 default:Testname(string) 必填； 其他参数可配 "
// @Success 200 {string} json "{"code":200, success:true,  msg:"请求处理成功", data:"修改后的摄像机信息"}"
// @Failure 500 {string} json "{"code":500, success:false   msg:"null",data:"错误信息内容"}"
// @Router /data/api-v/gb28181/camera/update [put]
func (gbc Gb28181Controller) CameraUpdate(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	var camVo vo.CameraEditVo

	err := c.BindJSON(&camVo)
	if err != nil {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}
	logger.Debug("update sensors:", camVo.Sensors)
	var sv service.CameraService
	if sv.CameraUpdate(camVo){
		sv := service.NewGb28181Service(h.Bk)
		sv.AddDbChangeMsg(protomsg.DbAction_Update)
		return &bhomeclient.Reply{ Success: true, Data: camVo.Copy2Camera()}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Summary 显示摄像机
// @Description "显示摄像机"
// @Produce json
// @Tags camera
// @Param cid   path 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/camera/show [get]
func (gbc Gb28181Controller) CameraSel(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	var cam models.Camera
	cid := c.Query("cid")

	rows, err := cam.SelectById(cid)
	if err != nil {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}
	if rows == 0 {
		return &bhomeclient.Reply{ Success: false, Msg: "没有记录"}
	}
	m := util.Struct2Map(cam)
	var sor models.Sensor
	sensors, _ := sor.FindByCameraId(cid)
	if sensors != nil {
		m["sensors"] = sensors
	} else {
		m["sensors"] = []models.Sensor{}
	}
	return &bhomeclient.Reply{ Success: true, Data: m}
}

// @Summary 显示gb28181树形结构
// @Description 显示gb28181树形结构
// @Produce json
// @Tags menu
// @Param parentId query string true "区域的id"
// @Param searchType query int true "查询类型（0:全部，1:分析摄像机，2:监控摄像机, 3:联动摄像机）"
// @Param cameraName query string false "摄像机名称"
// @Success 200 {string} json "{"code":200, msg:"目录结构数据"}"
// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息"}"
// @Router /data/api-v/gb28181/tree [get]
func (gbc Gb28181Controller) CameraGb28181Tree(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	var aram models.Area
	var searchType = 0
	var err error

	parentId := c.Query("parentId")
	if parentId == "" {
		parentId = "0"
	}
	searchTypeStr := c.Query("searchType")
	cameraName := c.Query("cameraName")
	treeType := models.TYPE_GB28181_TREE //国标树
	isPlatformStr := c.Query("isPlatform")
	isPlatform, _ := strconv.Atoi(isPlatformStr)//单机获取本机摄像机，平台获取所有摄像机

	if searchTypeStr != "" {
		searchType, err = strconv.Atoi(searchTypeStr)
		if err != nil {
			logger.Debug("err:",err)
			return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
		}
	}

	areas, err := aram.Find(parentId, cameraName, util.FiledbyStuct(models.TreeNode{}),treeType)
	if err != nil {
		logger.Debug("area.Find err:",err)
		return &bhomeclient.Reply{ Success: false, Msg: err.Error()}
	}
	var cam models.Camera

	cams, err := cam.Find(searchType, cameraName, models.TYPE_GB28181_CAMERA, isPlatform)//查国标摄像机
	if err != nil {
		logger.Debug("cam.Find err:",err)
		return &bhomeclient.Reply{ Success: false, Msg: err.Error()}
	}

	var totalCams models.CamTreeNodeList
	totalCams = cams
	sort.Sort(totalCams)

	rAreas := models.RecursiveArea(areas, cams, searchType)

	var totalAreas models.AreaList
	totalAreas = rAreas
	sort.Sort(totalAreas)

	arr := menuFormat(totalAreas, parentId, totalCams, treeType)
	var crApi bhomedbapi.CameraRuleApi
	for _,camE := range totalCams {
		if camE.Areaid == "0" {
			isRunnig := false
			isAI := false
			camera := models.Camera{}
			rows, e := camera.SelectById(camE.Id)
			if rows>0 && e==nil{
				isRunnig = camera.IsRunning
				isAI = crApi.ExistRunningTask(camE.Id) && (camera.RunType == models.TYPE_RUNTYPE_POLL || camera.RunType == models.TYPE_RUNTYPE_REALTIME)
				//if camera.RunType == models.TYPE_RUNTYPE_POLL || camera.RunType == models.TYPE_RUNTYPE_REALTIME {
				//	isAI = true
				//}
			}
			arr = append(arr,models.TreeMenu{
				Id:camE.Id,
				Type:"4",
				Name:camE.Name,
				IsRunning: isRunnig,
				IsAI: isAI,
				Rtsp:camE.Rtsp,
				CameraType: treeType,
			})
		}
	}
	return &bhomeclient.Reply{ Success: true, Data: arr }
}

// @Summary 刷新Gb28181平台树
// @Description 刷新Gb28181平台树
// @Produce json
// @Tags menu
// @Param id formData string false "国标平台id"
// @Success 200 {string} json "{"code":200, data:"",msg:"请求成功", success:true}"
// @Failure 200 {string} json "{"code":500, data:"",msg:"请求失败", success:false}"
// @Router /data/api-v/gb28181/treeRefresh [post]
func (gbc Gb28181Controller) Gb28181TreeRefresh(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	id := c.PostForm("id")
	sv := service.NewGb28181Service(h.Bk)
	if sv.RefreshById(id) {
		return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Summary 删除Gb28181平台
// @Description 删除Gb28181平台
// @Produce json
// @Tags menu
// @Success 200 {string} json "{"code":200, data:"",msg:"请求成功", success:true}"
// @Failure 200 {string} json "{"code":500, data:"",msg:"请求失败", success:false}"
// @Router /data/api-v/gb28181/treeDelete [post]
func (gbc Gb28181Controller) Gb28181TreeDelete(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	var sv service.Gb28181Service
	if sv.Delete() {
		return &bhomeclient.Reply{ Success: true, Msg: "删除成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "删除失败"}
	}
}

// @Summary 获取国标区域列表
// @Description  获取国标区域列表
// @Produce json
// @Tags gb28181
// @Param parentId query int true "parentId"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:"成功信息"}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:"错误信息内容"}"
// @Router /data/api-v/gb28181/findAreaByParentId [get]
func (gbc Gb28181Controller) FindAreaByParentId(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	parentIdStr := c.Query("parentId")
	if parentIdStr == "" {
		parentIdStr = "0"
	}
	parentId, err := strconv.Atoi(parentIdStr)
	if err !=nil {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}
	var gbaE models.GbCodeArea
	list, _ := gbaE.FindByParentId(parentId)
	if list ==nil {
		list = []models.GbCodeArea{}
	}
	return &bhomeclient.Reply{ Success: true, Data: list}
}

// @Summary 生成新的国标id
// @Description 生成新的国标id
// @Produce json
// @Tags gb28181
// @Param code query string 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/gb28181/newGbId [get]
func (gbc Gb28181Controller) NewGbId(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	areaCode := c.Query("code")
	if areaCode == "" {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}

	//生成新的国标id,生成规则：系统编码 =中心编码（8位） + 行业编码（2） + 类型编码（11-13位） + 序号（最后7位）
	//1.code为6位行政区划编码,后面需要接2位的基层接入单位编号
	if len(areaCode) >=6 {
		areaCode = areaCode[:6]
	}
	areaCode = areaCode + "00"
	newGbCode := areaCode
	//2.行业编码，第9、10位
	//00 社会治安路面接入
	//01 社会治安社区接入
	//02 社会治安内部接入
	//03 社会治安其他接入
	//04 交通路面接入
	//05 交通卡口接入
	//06 交通内部接入
	//07 交通其他接入
	//08 城市管理接入
	//09 卫生环保接入
	//10 商检海关接入
	//11 教育部门接入
	newGbCode += "01"

	//设备或用户的具体类型,其中的前端设备包含公安系统和非公安系统的前端设备,
	//终端用户包含公安系统和非公安系统的终端用户。由3位数字组成，即20位国标编码中的第11、12、13位。
	//3.设备或用户的具体类型,第11、12、13位
	//111 DVR编码
	//112 视频服务器编码
	//113 编码器编码
	//114 解码器编码
	//115 视频切换矩阵编码
	//116 音频切换矩阵编码
	//117 报警控制器编码
	//118 网络视频录像机(NVR)编码
	//130 混合硬盘录像机(HVR)编码
	//119~130 扩展的前端主设备类型
	//131 摄像机编码
	//132 网络摄像机（IPC）编码
	//133 显示器编码
	//134 报警输入设备编码（如红外、烟感、门禁等报警设备）
	//135 报警输出设备编码（如警灯、警铃等设备）
	//136 语音输入设备编码
	//137 语音输出设备
	//138 移动传输设备编码
	newGbCode += "112"


	//4. 14位为网络标识 (0、1、2、3、4为监控报警专网，5为公安信息网，6为政务网，7为Internet网，
	// 8为社会资源接入网，9为预留)
	newGbCode += "1"

	//5.序号指设备或用户的序号。由6位数字组成，即20位国标编码中的15-20位。
	newGbCode += "000001"
	logger.Debug("newGbCode：", newGbCode)
	return &bhomeclient.Reply{ Success: true, Data: newGbCode }
}

// @Summary GB28181设置查询
// @Description GB28181设置信息查询
// @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/gb28181/configShow [GET]
func (gbc Gb28181Controller) Gb28181ConfigShow(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	var conf models.Gb28181Config
	conf.Select()
	proId := ""
	cityId := ""
	zoneId := ""
	if conf.PublicId != "" && len(conf.PublicId) >6 {
		confAreaId := conf.PublicId[:6]
		var tmpArea models.GbCodeArea
		tId,_ := strconv.Atoi(confAreaId)
		rows,_ := tmpArea.SelectById(tId)
		if rows > 0 {
			if tmpArea.Level == 3 {
				zoneId = confAreaId
				cityId = strconv.Itoa(tmpArea.ParentId)
				var cityArea models.GbCodeArea
				crows,_ := cityArea.SelectById(tmpArea.ParentId)
				if crows > 0 {
					proId = strconv.Itoa(cityArea.ParentId)
				}
			} else if tmpArea.Level == 2 {
				cityId = confAreaId
				proId = strconv.Itoa(tmpArea.ParentId)
			} else if tmpArea.Level == 1 {
				proId = confAreaId
			}
		}
	}
	m := util.Struct2Map(conf)
	m["proId"] = proId
	m["cityId"] = cityId
	m["zoneId"] = zoneId
	return &bhomeclient.Reply{ Success: true, Data: m }
}

// @Summary GB28181设置信息修改
// @Description GB28181设置修改
// @Accept  json
// @Produce json
// @Tags sysset
// @Param config body models.Gb28181Config true "GB28181设置数据"
// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"
// @Failure 500 {string} json "{"code":500,  msg:"返回错误信息", success:false}"
// @Router /data/api-v/gb28181/configEdit [POST]
func (gbc Gb28181Controller) Gb28181ConfigEdit(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	var reqCon models.Gb28181Config // 前台数据绑定
	if err :=c.BindJSON(&reqCon);err !=nil{
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}
	logger.Debug("gbConfig:",reqCon)
	sv := service.NewGb28181Service(h.Bk)
	if sv.Edit(reqCon){
		return &bhomeclient.Reply{ Success: true, Msg: "保存成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "保存失败"}
	}

}

// @Summary 获取运行类型获取摄像机列表
// @Description 获取运行类型获取摄像机列表
// @Produce json
// @Tags camera
// @Param runType query int true "0：查轮询，1：查实时"
// @Param cameraName query string false "查询条件"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/gb28181/camera/getCamerasByRunType [get]
func (gbc Gb28181Controller) GetCamerasByRunType(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	runTypeStr := c.Query("runType")
	cameraName := c.Query("cameraName")
	logger.Debug("runType:",runTypeStr)
	logger.Debug("cameraName:",cameraName)
	runType, err := strconv.Atoi(runTypeStr)
	if err !=nil || (runType !=0 && runType !=1) {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}
	var sv service.CameraService
	list,err := sv.GetCamerasByRunType(runType,cameraName)
	if err !=nil {
		return &bhomeclient.Reply{ Success: false, Msg: err.Error() }
	} else {
		return &bhomeclient.Reply{ Success: true, Data: list}
	}
}

// @Summary 切换摄像机运行实时或轮询的开关
// @Description 切换摄像机运行实时或轮询的开关
// @Produce json
// @Tags camera
// @Param cameraId formData string true "摄像机id"
// @Param runEnable formData bool true "开启：true，关闭：false"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/gb28181/camera/updateRunEnable [post]
func (gbc Gb28181Controller) UpdateRunEnable(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	cameraId := c.PostForm("cameraId")
	enableStr := c.PostForm("runEnable")
	runEnable, _ := strconv.ParseBool(enableStr)
	if cameraId == "" {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}

	var sv service.CameraService
	if sv.UpdateRunEnable(cameraId, runEnable){
		sv := service.NewGb28181Service(h.Bk)
		sv.AddDbChangeMsg(protomsg.DbAction_Update)
		return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Summary 摄像机轮询和实时状态切换
// @Description 摄像机轮询和实时状态切换
// @Produce json
// @Tags camera
// @Param changeRunBody body vo.CameraChangeRunVo 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/gb28181/camera/changeRunType [post]
func (gbc Gb28181Controller) ChangeRunType(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	var ccrVo vo.CameraChangeRunVo
	if err := c.BindJSON(&ccrVo);err !=nil{
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}

	var sv service.CameraService
	if sv.ChangeRunType(ccrVo){
		sv := service.NewGb28181Service(h.Bk)
		sv.AddDbChangeMsg(protomsg.DbAction_Update)
		return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Summary 摄像机is_running状态切换
// @Description 摄像机is_running状态切换
// @Produce json
// @Tags camera
// @Param cameraId formData string true "摄像机id"
// @Param is_running formData bool true "解码中：true，停止解码：false"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/gb28181/camera/updateIsRunningState [post]
func (gbc Gb28181Controller) UpdateIsRunningState(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	cameraId := c.PostForm("cameraId")
	isRunningStr := c.PostForm("isRunning")
	isRunning, _ := strconv.ParseBool(isRunningStr)
	if cameraId == "" {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}

	var sv service.CameraService
	if sv.UpdateIsRunningState(cameraId,isRunning){
		sv := service.NewGb28181Service(h.Bk)
		sv.AddDbChangeMsg(protomsg.DbAction_Update)
		return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Router /data/api-v/gb28181/camera/updateIsRunningAll [post]
func (gbc Gb28181Controller) UpdateIsRunningAll(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	var reqBody IsRunningArg
	c.BindJSON(&reqBody)
	logger.Debug("UpdateIsRunningAll cameraId:", reqBody.CameraIds)

	var sv service.CameraService
	if sv.UpdateIsRunningAll(reqBody.CameraIds){
		sv := service.NewGb28181Service(h.Bk)
		sv.AddDbChangeMsg(protomsg.DbAction_Update)
		return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Summary 更新摄像机快照
// @Description 更新摄像机快照
// @Produce json
// @Tags camera
// @Param cameraId formData string true "摄像机id"
// @Param snapshot formData string 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/gb28181/camera/updateSnapshot [post]
func (gbc Gb28181Controller) UpdateSnapshot(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
	cameraId := c.PostForm("cameraId")
	snapshot := c.PostForm("snapshot")
	logger.Debug("cameraId:",cameraId)
	logger.Debug("snapshot:",snapshot)
	if cameraId == "" || snapshot == "" {
		return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
	}

	var sv service.CameraService
	if sv.UpdateSnapshot(cameraId, snapshot){
		return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
	}
}

// @Summary 根据server获取所有摄像机列表及信息
// @Description 根据server获取所有摄像机列表及信息
// @Produce json
// @Tags camera
// @Param serverId query string false "查本机传serverId，查所有传空"
// @Param cameraName query string false "摄像机名称"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/gb28181/getAllCamerasByServer [get]
func (gbc Gb28181Controller) GetAllCamerasByServer(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	serverId := c.Query("serverId")
	cameraName := c.Query("cameraName")
	var sv service.CameraService
	cams,err := sv.GetAllCamerasByServer(serverId,cameraName)
	if err == nil {
		return &bhomeclient.Reply{ Success: true, Data: cams}
	} else {
		return &bhomeclient.Reply{ Success: false, Msg: err.Error()}
	}
}