package controllers

import (
	"basic.com/dbapi.git"
	"github.com/gin-gonic/gin"
	"webserver/extend/code"
	"webserver/extend/util"
)

type EventPushController struct {
}

type EventPushVo struct {
	Id           string `json:"id"`
	Name         string `json:"name"`
	TimeStart    string `json:"time_start"`
	TimeEnd      string `json:"time_end"`
	IsSatisfyAll bool   `json:"is_satisfy_all"`
	RuleText     string `json:"rule_text"`
	Enable       bool   `json:"enable"`
	LinkType     string `json:"link_type"`
	LinkDevice   string `json:"link_device"`

	IpPorts []EventPushServerPortVo `json:"ip_ports"`
	Urls    []EventUrlVo            `json:"urls"`
	Rules   []EventPushRuleVo       `json:"rules"`
}

type EventPushRuleVo struct {
	Id           string `json:"id"`
	TopicType    string `json:"topic_type"` //参数主题,目前分为五类（摄像机、底库、任务、人员、报警等级）
	TopicArg     string `json:"topic_arg"`  //主题对应的具体参数
	Operator     string `json:"operator"`
	OperatorType string `json:"operator_type"`
	RuleValue    string `json:"rule_value"`
	EventPushId  string `json:"event_push_id"`
}

type EventPushServerPortVo struct {
	ServerIp string `json:"server_ip"`
	Port     int    `json:"port"`
	Enable   bool   `json:"enable"`
}

type EventUrlVo struct {
	Url    string `json:"url"`
	Enable bool   `json:"enable"`
}

// @Security ApiKeyAuth
// @Summary 事件推送保存
// @Description 事件推送保存
// @Accept json
// @Produce json
// @Tags 事件推送
// @Param SaveArgs body controllers.EventPushVo 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/eventPush/save [post]
func (epc EventPushController) Save(c *gin.Context) {
	var saveBody EventPushVo
	if err := c.BindJSON(&saveBody); err != nil {
		util.ResponseFormat(c, code.RequestParamError, "参数有误")
		return
	}
	var api dbapi.EventPushApi
	paramBody := util.Struct2Map(saveBody)
	flag, data := api.Save(paramBody)
	if flag {
		util.ResponseFormat(c, code.Success, data)
	} else {
		util.ResponseFormat(c, code.ComError, data)
	}
}

// @Security ApiKeyAuth
// @Summary 根据事件推送主题的一级和二级选项获取最后下拉菜单列表
// @Description  根据事件推送主题的一级和二级选项获取最后下拉菜单列表
// @Accept x-www-form-urlencoded
// @Produce json
// @Tags 事件推送
// @Param topic query string true "一级主题选项,例如：camera(摄像机)"
// @Param type query string true "子选项类型，例如：name（名称）或addr（位置）"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/eventPush/findByEventTopic [get]
func (epc EventPushController) FindByEventTopic(c *gin.Context) {
	topic := c.Query("topic")
	childType := c.Query("type")
	if topic == "" {
		util.ResponseFormat(c, code.RequestParamError, "参数有误")
		return
	}
	var api dbapi.EventPushApi
	flag, data := api.FindByEventTopic(topic, childType)
	if flag {
		util.ResponseFormat(c, code.Success, data)
	} else {
		util.ResponseFormat(c, code.ComError, data)
	}
}

// @Security ApiKeyAuth
// @Summary 查全部
// @Description  查全部
// @Accept x-www-form-urlencoded
// @Produce json
// @Tags 事件推送
// @Param name 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/eventPush/findAll [get]
func (controller EventPushController) FindAll(c *gin.Context) {
	name := c.Query("name")
	var api dbapi.EventPushApi
	flag, data := api.FindAll(name)
	if flag {
		util.ResponseFormat(c, code.Success, data)
	} else {
		util.ResponseFormat(c, code.ComError, "")
	}
}

// @Security ApiKeyAuth
// @Summary 事件推送编辑
// @Description  事件推送编辑
// @Accept x-www-form-urlencoded
// @Produce json
// @Tags 事件推送
// @Param id 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/eventPush/getById [get]
func (controller EventPushController) GetById(c *gin.Context) {
	id := c.Query("id")
	if id == "" {
		util.ResponseFormat(c, code.RequestParamError, "参数有误")
		return
	}
	var api dbapi.EventPushApi
	flag, data := api.GetById(id)
	if flag {
		util.ResponseFormat(c, code.Success, data)
	} else {
		util.ResponseFormat(c, code.ComError, "")
	}
}

type ChangeStatusVo struct {
	Id     string `json:"id"`
	Enable bool   `json:"enable"`
}

// @Security ApiKeyAuth
// @Summary 改变enable状态
// @Description  改变enable状态
// @Accept json
// @Produce json
// @Tags 事件推送
// @Param statusBody body controllers.ChangeStatusVo 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/eventPush/changeStatus [post]
func (controller EventPushController) ChangeStatus(c *gin.Context) {
	var statusBody ChangeStatusVo
	err := c.BindJSON(&statusBody)
	if err != nil {
		util.ResponseFormat(c, code.RequestParamError, "参数有误")
		return
	}
	var api dbapi.EventPushApi
	flag, data := api.ChangeStatus(statusBody.Id, statusBody.Enable)
	if flag {
		util.ResponseFormat(c, code.Success, data)
	} else {
		util.ResponseFormat(c, code.ComError, data)
	}
}

// @Security ApiKeyAuth
// @Summary 根据id删除
// @Description  根据id删除
// @Accept x-www-form-urlencoded
// @Produce json
// @Tags 事件推送
// @Param id formData 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/eventPush/delete [post]
func (controller EventPushController) Delete(c *gin.Context) {
	id := c.PostForm("id")
	if id == "" {
		util.ResponseFormat(c, code.RequestParamError, "参数有误")
		return
	}
	var api dbapi.EventPushApi
	flag, data := api.Delete(id)
	if flag {
		util.ResponseFormat(c, code.Success, data)
	} else {
		util.ResponseFormat(c, code.ComError, data)
	}
}