Cold_Api/controllers/Device.go

package controllers

import (
	"Cold_Api/Nats/NatsServer"
	"Cold_Api/conf"
	"Cold_Api/controllers/lib"
	"Cold_Api/models/Account"
	"Cold_Api/models/Company"
	"Cold_Api/models/Device"
	"Cold_Api/models/System"
	"Cold_Api/models/Warning"
	"fmt"
	beego "github.com/beego/beego/v2/server/web"
	"github.com/xuri/excelize/v2"
	"math"
	"os"
	"strconv"
	"time"
)

// Handle
type DeviceController struct {
	beego.Controller
	Admin_r *Account.Admin // 登陆的用户
	T_pid   int            // 公司id
}

func (c *DeviceController) Prepare() {
	GetCookie := c.Ctx.GetCookie("User_tokey")
	GetString := c.GetString("User_tokey")

	User_tokey := GetCookie
	if len(User_tokey) == 0 {
		User_tokey = GetString
	}

	c.Admin_r = lib.Admin_r
	T_pid := c.Admin_r.T_pid
	if T_pid == 0 {
		T_pid, _ = Account.Redis_Tokey_T_pid_Get(User_tokey)
	}
	c.T_pid = T_pid
}

// 设备 ------------------------------------------

func (c *DeviceController) Device_List() {
	type R_JSONS struct {
		//必须的大写开头
		Device_lite []Device.Device_R
		Num         int64
		Page        int
		Page_size   int
	}
	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	Name := c.GetString("T_name")
	T_online := c.GetString("T_online")
	T_monitor := c.GetString("T_monitor")

	r_jsons.Device_lite, r_jsons.Num = Device.Read_Device_List(c.Admin_r, c.T_pid, Name, T_monitor, T_online, page, page_z)

	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return

}
func (c *DeviceController) Device_Get() {
	var r_jsons lib.R_JSONS

	T_sn := c.GetString("T_sn")
	Device_r, err := Device.Read_Device_ByT_sn(T_sn)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 303, Msg: "查询失败！"}
		c.ServeJSON()
		return
	}
	if Device_r.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 303, Msg: "无权查看！"}
		c.ServeJSON()
		return
	}

	r_jsons.Data = Device.DeviceToDevice_R(Device_r)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return

}
func (c *DeviceController) Device_Add() {
	var err error
	T_sn := c.GetString("T_sn")
	var_ := Device.Device{
		T_pid:     c.T_pid,
		T_sn:      T_sn,
		T_monitor: 1, // 监控状态 已监控
		T_State:   1, // 状态 正常
	}
	if len(T_sn) < 8 {
		c.Data["json"] = lib.JSONS{Code: 303, Msg: "SN 太短 必须8个字符以上"}
		c.ServeJSON()
		return
	}

	_, err = Device.Read_Device_ByT_sn(T_sn)
	if err == nil {
		c.Data["json"] = lib.JSONS{Code: 303, Msg: "重复SN！"}
		c.ServeJSON()
		return
	}

	var_.T_devName = "等待设备上线.."
	// 创建数据库
	if !Device.CREATE_DeviceData(T_sn) {
		c.Data["json"] = lib.JSONS{Code: 302, Msg: "添加失败!"}
		c.ServeJSON()
		return
	}
	err = Device.Add_Device(var_)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
		c.ServeJSON()
		return
	}

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "设备添加", var_)

	NatsServer.Read_DeviceParameter(T_sn) // 获取主机信息

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}
func (c *DeviceController) Device_Edit() {
	T_SN := c.GetString("T_sn")

	Device_r, err := Device.Read_Device_ByT_sn(T_SN)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 206, Msg: "T_sn Err!"}
		c.ServeJSON()
		return
	}
	clos := make([]string, 0)

	// 监控状态 0 未监控 1 监控
	T_monitor, T_monitor_err := c.GetInt("T_monitor")
	if T_monitor_err == nil {
		Device_r.T_monitor = T_monitor
		clos = append(clos, "T_monitor")
	}
	// 温度显示
	T_ist, T_ist_err := c.GetInt("T_ist")
	if T_ist_err == nil {
		Device_r.T_ist = T_ist
		clos = append(clos, "T_ist")
	}
	// 适度显示
	T_ish, T_ish_err := c.GetInt("T_ish")
	if T_ish_err == nil {
		Device_r.T_ish = T_ish
		clos = append(clos, "T_ish")
	}
	// 是否弃用
	T_State, T_State_err := c.GetInt("T_State")
	if T_State_err == nil {
		Device_r.T_State = T_State
		clos = append(clos, "T_State")
	}

	// 验证时间
	T_VerifyTime := c.GetString("T_VerifyTime")
	VerifyTime, VerifyTime_is := lib.TimeStrToTime(T_VerifyTime)
	if VerifyTime_is {
		Device_r.T_VerifyTime = VerifyTime
		clos = append(clos, "T_VerifyTime")
	}

	// 校准时间
	T_CalibrationTime := c.GetString("T_CalibrationTime")
	CalibrationTime, CalibrationTime_is := lib.TimeStrToTime(T_CalibrationTime)
	if CalibrationTime_is {
		Device_r.T_CalibrationTime = CalibrationTime
		clos = append(clos, "T_CalibrationTime")
	}

	// 巡检时间
	T_PatrolTime := c.GetString("T_PatrolTime")
	PatrolTime, PatrolTime_is := lib.TimeStrToTime(T_PatrolTime)
	if PatrolTime_is {
		Device_r.T_PatrolTime = PatrolTime
		clos = append(clos, "T_PatrolTime")
	}

	if is := Device.Update_Device(Device_r, clos...); !is {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "修改失败！"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "修改", Device_r)

	if is := Device.Update_Device_To_DeviceSensor(Device_r); is {
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器修改", Device_r)
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}

// 重启/关机
func (c *DeviceController) Device_RestartShutdown() {
	T_sn := c.GetString("T_sn")
	T_task := c.GetString("T_task")

	NatsServer.Set_RestartShutdown(Device.Device_task{
		T_sn:   T_sn,
		T_task: T_task,
	})
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "重启/关机", T_sn+"-"+T_task)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}

// 版本升级
func (c *DeviceController) Device_ProductUpgrade() {
	T_sn := c.GetString("T_sn")
	T_version := c.GetString("T_version")
	T_file := c.GetString("T_file")

	NatsServer.Up_ProductUpgrade(T_sn, T_version, T_file)
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "版本升级", T_sn+"-"+T_version+"-"+T_file)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}

// 2023-02-02 弃用
//func (c *DeviceController) Device_Del() {
//	if admin_r.Id != 1 {
//		c.Data["json"] = lib.JSONS{Code: 202, Msg: "没有权限!"}
//		c.ServeJSON()
//		return
//	}
//
//	T_sn := c.GetString("T_sn")
//
//	Device_r, err := Device.Read_Device_ByT_sn(T_sn)
//	if err != nil {
//		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_sn Err!"}
//		c.ServeJSON()
//		return
//	}
//
//	Device.Delete_Device(Device_r)
//	DeviceSensor_list, _ := Device.Read_DeviceSensor_ByTsn(Device_r.T_sn)
//	for _, v := range DeviceSensor_list {
//		Device.Delete_DeviceSensor_ById(Device_r.T_sn, v.T_id)
//	}
//	Device.DELETE_DeviceSensor(Device_r.T_sn)
//	Device.DELETE_DeviceDatar(Device_r.T_sn)
//	Device.DELETE_DeviceParameter(Device_r.T_sn)
//	Device.DELETE_DeviceSensorParameter(Device_r.T_sn)
//
//	System.Add_UserLogs(admin_r.T_uuid, "设备管理", "设备删除", T_sn)
//	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
//	c.ServeJSON()
//	return
//
//}

// 设备日志
func (c *DeviceController) DeviceLogs() {

	type R_JSONS struct {
		//必须的大写开头
		DeviceLogs []Warning.DeviceLogs
		Num        int64
		Page       int
		Page_size  int
	}
	var r_jsons R_JSONS

	page, _ := c.GetInt("page")

	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_sn := c.GetString("T_sn")
	c.Data["T_sn"] = T_sn

	r_jsons.DeviceLogs, r_jsons.Num = Warning.Read_DeviceLogs_List(T_sn, page, page_z)

	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
}

// 设备参数 ------------------------------------------

// 设备参数列表
func (c *DeviceController) Device_Parameter_List() {
	Sn := c.GetString("T_sn")

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}
	DeviceParameter_lite := Device.Read_DeviceParameter_SN_List(Sn, page, page_z)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: DeviceParameter_lite}
	c.ServeJSON()
	return
}

// 获取设备参数
func (c *DeviceController) Device_Parameter_Get() {
	Sn := c.GetString("T_sn")

	DeviceParameter_lite := Device.Read_DeviceParameter_SN(Sn)
	if len(DeviceParameter_lite) == 0 {
		NatsServer.Read_DeviceParameter(Sn)
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "未同步参数，请检查设备是否正常!"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: DeviceParameter_lite}
	c.ServeJSON()
	return
}

// 修改设备参数
func (c *DeviceController) Device_Parameter_Pu() {
	//T_SN := c.GetString("T_sn")
	//T_name := c.GetString("T_name")
	//
	//T_saveT, _ := c.GetInt("T_saveT")
	//T_overA, _ := c.GetInt("T_overA")
	//T_outA, _ := c.GetInt("T_outA")
	//T_lostA, _ := c.GetInt("T_lostA")
	//T_bat, _ := c.GetInt("T_bat")
	//
	//T_warn, _ := c.GetInt("T_warn")
	//T_warnD, _ := c.GetInt("T_warnD")
	//
	//T_btname := c.GetString("T_btname")
	//T_btsid, _ := c.GetInt("T_btsid")
	//T_btchar, _ := c.GetInt("T_btchar")
	//
	//T_Msid, _ := c.GetInt("T_Msid")
	//T_State, _ := c.GetInt("T_State")
	//
	//Device_r, err := Device.Read_Device_ByT_sn(T_SN)
	//if err != nil {
	//	c.Data["json"] = lib.JSONS{Code: 206, Msg: "T_sn Err!"}
	//	c.ServeJSON()
	//	return
	//}
	//
	//Deviceparameter := Device.DeviceParameter{
	//	T_sn:        T_SN,
	//	T_name:      T_name,
	//	T_saveT:     T_saveT,
	//	T_overA:     T_overA,
	//	T_outA:      T_outA,
	//	T_lostA:     T_lostA,
	//	T_bat:       T_bat,
	//	T_warn:      T_warn,
	//	T_warnD:     T_warnD,
	//	T_btname:    T_btname,
	//	T_btsid:     T_btsid,
	//	T_btchar:    T_btchar,
	//	T_Msid:      int64(T_Msid),
	//	T_uuid:      c.Admin_r.T_uuid,
	//	T_SendState: 0,
	//	T_State:     T_State,
	//}
	//Deviceparameter, is := Device.Add_DeviceParameter(Deviceparameter)
	//if !is {
	//	c.Data["json"] = lib.JSONS{Code: 203, Msg: "Add_DeviceParameter ERR"}
	//	c.ServeJSON()
	//	return
	//}
	//System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "设备参数操作", Deviceparameter)
	//NatsServer.Pu_DeviceParameter(Deviceparameter)
	//
	//// 更新名称
	//Device_r.T_devName = Deviceparameter.T_name
	//Device.Update_Device(Device_r, "T_devName")
	//System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "修改", Device_r)

	T_SN := c.GetString("T_sn")

	Device_r, err := Device.Read_Device_ByT_sn(T_SN)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 206, Msg: "T_sn Err!"}
		c.ServeJSON()
		return
	}
	DeviceParameter_lite := Device.Read_DeviceParameter_SN(T_SN)
	if len(DeviceParameter_lite) == 0 {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "未同步参数，请检查设备是否正常!"}
		c.ServeJSON()
		return
	}

	DeviceParameter := DeviceParameter_lite[0]

	if v, err := c.GetInt("T_saveT"); err == nil {
		DeviceParameter.T_saveT = v
	}
	if v, err := c.GetInt("T_overA"); err == nil {
		DeviceParameter.T_overA = v
	}
	if v, err := c.GetInt("T_outA"); err == nil {
		DeviceParameter.T_outA = v
	}
	if v, err := c.GetInt("T_lostA"); err == nil {
		DeviceParameter.T_lostA = v
	}
	if v, err := c.GetInt("T_bat"); err == nil {
		DeviceParameter.T_bat = v
	}

	if v, err := c.GetInt("T_warn"); err == nil {
		DeviceParameter.T_warn = v
	}
	if v, err := c.GetInt("T_warnD"); err == nil {
		DeviceParameter.T_warnD = v
	}
	if v, err := c.GetInt("T_speed"); err == nil {
		DeviceParameter.T_speed = v
	}
	if v := c.GetString("T_btname"); len(v) > 0 {
		DeviceParameter.T_btname = v
	}
	if v, err := c.GetInt("T_btsid"); err == nil {
		DeviceParameter.T_btsid = v
	}
	if v, err := c.GetInt("T_btchar"); err == nil {
		DeviceParameter.T_btchar = v
	}
	if v, err := c.GetInt("T_Msid"); err == nil {
		DeviceParameter.T_Msid = int64(v)
	}

	if v := c.GetString("T_name"); len(v) > 0 {
		DeviceParameter.T_name = v
	}
	DeviceParameter.Id = 0
	DeviceParameter.T_State = 2
	DeviceParameter.T_uuid = c.Admin_r.T_uuid
	DeviceParameter.T_SendState = 0

	Deviceparameter, is := Device.Add_DeviceParameter(DeviceParameter)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "Add_DeviceParameter ERR"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "设备参数操作", Deviceparameter)
	NatsServer.Pu_DeviceParameter(Deviceparameter)

	if v := c.GetString("T_name"); len(v) > 0 {
		// 更新名称
		Device_r.T_devName = Deviceparameter.T_name
		Device.Update_Device(Device_r, "T_devName")
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "修改设备名称", Device_r)
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}

// 删除设备 传感器
// 2023-02-02 弃用
func (c *DeviceController) Device_Parameter_Del_Device() {

	Sn := c.GetString("Sn")
	Id, _ := c.GetInt("Id")

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 删除操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]")

	//c.Data["Device_lite"] = Device.Read_DeviceParameter_SN(Sn)
	Device.Delete_DeviceSensor_ById(Sn, Id)

	NatsServer.Del_DeviceSensor(Device.DeviceSensor_Del{
		T_sn: Sn, T_id: Id,
	})

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"}
	c.ServeJSON()
	return
}

// 设备-传感器 ------------------------------------------

// 传感器列表
func (c *DeviceController) DeviceSensor_List() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Device.DeviceSensor_R
		Num       int64
		Page      int
		Page_size int
	}
	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_sn := c.GetString("T_sn")
	Name := c.GetString("T_name") //  包含 T_name、T_sn
	T_calss_id, _ := c.GetInt("T_calssid")
	T_type, T_type_err := c.GetInt("T_type")
	if T_type_err != nil {
		T_type = -1
	}
	T_State, T_State_err := c.GetInt("T_state")
	if T_State_err != nil {
		T_State = -1
	}
	T_datashow, T_datashow_err := c.GetInt("T_datashow") //0 屏蔽数据展示  1 正常数据展示
	if T_datashow_err != nil {
		T_datashow = -1
	}
	if T_calss_id > 0 {
		R_DeviceClass, err := Company.Read_CompanyClass_ById(T_calss_id)
		if err != nil {
			c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
			c.ServeJSON()
			return
		}
		if R_DeviceClass.T_pid != c.T_pid {
			c.Data["json"] = lib.JSONS{Code: 205, Msg: "R_DeviceClass.T_pid  ！= T_pid Err!"}
			c.ServeJSON()
			return
		}
	}
	Device.Read_DeviceSensorParameter_All_Map(T_sn, 0)
	r_jsons.Data, r_jsons.Num = Device.Read_DeviceSensorList(c.Admin_r, c.T_pid, T_sn, Name, T_calss_id, T_datashow, T_type, T_State, page, page_z)
	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}

// 修改传感器
func (c *DeviceController) DeviceSensor_Edit() {

	Sn := c.GetString("T_sn")
	Id, _ := c.GetInt("T_id")

	DeviceSensor, is := Device.Read_DeviceSensor_ByT_sn(Sn, Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "信息错误!"}
		c.ServeJSON()
		return
	}

	// 数据视图3D视图订阅
	if v, err := c.GetInt("T_type"); err == nil {
		DeviceSensor.T_type = v
		Device.Update_DeviceSensor(DeviceSensor, "T_type")
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 类型", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+strconv.Itoa(v))
	}

	// 实时数据显示排序
	if v, err := c.GetInt("T_sort"); err == nil {
		DeviceSensor.T_sort = v
		Device.Update_DeviceSensor(DeviceSensor, "T_sort")
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 排序操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+strconv.Itoa(v))
	}

	// 屏蔽数据展示
	if v, err := c.GetInt("T_datashow"); err == nil {
		DeviceSensor.T_datashow = v
		Device.Update_DeviceSensor(DeviceSensor, "T_datashow")
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 数据展示", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+strconv.Itoa(v))
	}

	// 数据视图3D视图订阅
	if v := c.GetString("T_3dview"); len(v) > 0 {
		DeviceSensor.T_3dview = v
		Device.Update_DeviceSensor(DeviceSensor, "T_3dview")
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 3D视图订阅", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+v)
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"}
	c.ServeJSON()
	return
}

// 删除传感器
func (c *DeviceController) DeviceSensor_Del() {
	Sn := c.GetString("T_sn")
	Id, _ := c.GetInt("T_id")

	_, is := Device.Read_DeviceSensor_ByT_sn(Sn, Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "信息错误!"}
		c.ServeJSON()
		return
	}

	// 0默认：从数据库删除     1：从设备删除
	T_mode, _ := c.GetInt("T_mode")

	if T_mode == 1 {
		Device.Delete_DeviceSensor_ById(Sn, Id)
		NatsServer.Del_DeviceSensor(Device.DeviceSensor_Del{
			T_sn: Sn, T_id: Id,
		})
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 删除操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]")
	} else {
		Device.Delete_DeviceSensor_ById(Sn, Id)
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 删除操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]")
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"}
	c.ServeJSON()
	return
}

// 传感器参数
func (c *DeviceController) DeviceSensor_Parameter_Get() {

	Sn := c.GetString("T_sn")
	Id, _ := c.GetInt("T_id")

	//c.Data["DeviceSensor"], _ = Device.Read_DeviceSensor_ByTsn_Tid(Sn, Id)
	DeviceSensorParameter_lite := Device.Read_DeviceSensorParameter_T_sn_T_id(Sn, Id)
	if len(DeviceSensorParameter_lite) == 0 {
		NatsServer.Read_DeviceSensorParameter(Sn)
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "未同步参数，请检查设备是否正常!"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: DeviceSensorParameter_lite}
	c.ServeJSON()
	return
}

// 传感器参数列表
func (c *DeviceController) DeviceSensor_Parameter_List() {
	Sn := c.GetString("T_sn")
	Id, _ := c.GetInt("T_id")
	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	DeviceSensorParameter_lite := Device.Read_DeviceSensorParameter_List(Sn, Id, 2, page, page_z)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: DeviceSensorParameter_lite}
	c.ServeJSON()
	return
}

// 修改传感器参数
func (c *DeviceController) DeviceSensor_Parameter_Pu() {

	T_SN := c.GetString("T_sn")
	T_id, _ := c.GetInt("T_id")
	_, err := Device.Read_Device_ByT_sn(T_SN)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 206, Msg: "T_sn Err!"}
		c.ServeJSON()
		return
	}

	DeviceSensor, is := Device.Read_DeviceSensor_ByT_sn(T_SN, T_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 208, Msg: "T_sn T_id Err!"}
		c.ServeJSON()
		return
	}

	DeviceSensorParameter, is := Device.Read_DeviceSensorParameter(T_SN, T_id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 208, Msg: "T_sn T_id Err!"}
		c.ServeJSON()
		return
	}

	T_name := DeviceSensor.T_name
	if v := c.GetString("T_name"); len(v) > 0 {
		T_name = v
	}

	T_Tlower := DeviceSensorParameter.T_Tlower
	if v, T_Tlower_err := c.GetFloat("T_Tlower"); T_Tlower_err == nil {
		T_Tlower = float32(v)
	}
	T_Tupper := DeviceSensorParameter.T_Tupper
	if v, T_Tupper_err := c.GetFloat("T_Tupper"); T_Tupper_err == nil {
		T_Tupper = float32(v)
	}
	T_RHlower := DeviceSensorParameter.T_RHlower
	if v, T_RHlower_err := c.GetFloat("T_RHlower"); T_RHlower_err == nil {
		T_RHlower = float32(v)
	}
	T_RHupper := DeviceSensorParameter.T_RHupper
	if v, T_RHupper_err := c.GetFloat("T_RHupper"); T_RHupper_err == nil {
		T_RHupper = float32(v)
	}

	T_enprel := DeviceSensorParameter.T_enprel
	if v, T_enprel_err := c.GetInt("T_enprel"); T_enprel_err == nil {
		T_enprel = v
	}
	T_tprel := DeviceSensorParameter.T_tprel
	if v, T_tprel_err := c.GetInt("T_tprel_err"); T_tprel_err == nil {
		T_tprel = float32(v)
	}
	T_tpreu := DeviceSensorParameter.T_tpreu
	if v, T_tpreu_err := c.GetInt("T_tpreu"); T_tpreu_err == nil {
		T_tpreu = float32(v)
	}
	T_hprel := DeviceSensorParameter.T_hprel
	if v, T_hprel_err := c.GetInt("T_hprel"); T_hprel_err == nil {
		T_hprel = float32(v)
	}
	T_hpreu := DeviceSensorParameter.T_hpreu
	if v, T_hpreu_err := c.GetInt("T_hpreu"); T_hpreu_err == nil {
		T_hpreu = float32(v)
	}

	T_speed := DeviceSensorParameter.T_speed
	if v, T_speed_err := c.GetInt("T_speed"); T_speed_err == nil {
		T_speed = v
	}
	T_en := DeviceSensorParameter.T_en
	if v, T_en_err := c.GetInt("T_en"); T_en_err == nil {
		T_en = v
	}
	T_free := DeviceSensorParameter.T_free
	if v, T_free_err := c.GetInt("T_free"); T_free_err == nil {
		T_free = v
	}
	Devicesensorparameter := Device.DeviceSensorParameter{
		T_sn:      T_SN,
		T_id:      T_id,
		T_name:    T_name,
		T_Tlower:  T_Tlower,
		T_Tupper:  T_Tupper,
		T_RHlower: T_RHlower,
		T_RHupper: T_RHupper,
		T_speed:   T_speed,
		T_en:      T_en,
		T_free:    T_free,

		T_enprel: T_enprel,
		T_tprel:  T_tprel,
		T_tpreu:  T_tpreu,
		T_hprel:  T_hprel,
		T_hpreu:  T_hpreu,

		T_uuid:      c.Admin_r.T_uuid,
		T_SendState: 0,
		T_State:     2, // 用户提交
	}

	Devicesensorparameter, is = Device.Add_DeviceSensorParameter(Devicesensorparameter)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 209, Msg: "Add_DeviceSensorParameter Err!"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器参数操作", Devicesensorparameter)

	// 更新名称
	if len(T_name) > 0 {
		DeviceSensor.T_name = T_name
		if is = Device.Update_DeviceSensor(DeviceSensor, "T_name"); !is {
			c.Data["json"] = lib.JSONS{Code: 209, Msg: "Update_DeviceSensor Err!"}
			c.ServeJSON()
			return
		}
		System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "修改传感器名称", DeviceSensor)
	}

	NatsServer.Pu_DeviceParameter_Sensor(Devicesensorparameter)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}

// 传感器 实时数据显示排序（未使用）
func (c *DeviceController) UpDeviceSensor_Tsort() {

	Sn := c.GetString("Sn")
	Id, _ := c.GetInt("Id")
	T_sort, _ := c.GetInt("T_sort")

	DeviceSensor, is := Device.Read_DeviceSensor_ByT_sn(Sn, Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "信息错误!"}
		c.ServeJSON()
		return
	}
	DeviceSensor.T_sort = T_sort
	//c.Data["Device_lite"] = Device.Read_DeviceParameter_SN(Sn)
	Device.Update_DeviceSensor(DeviceSensor, "T_sort")

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 排序操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+strconv.Itoa(T_sort))
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"}
	c.ServeJSON()
	return
}

// 传感器 3D视图 （未使用）
func (c *DeviceController) UpDeviceSensor_T3dview() {

	Sn := c.GetString("Sn")
	Id, _ := c.GetInt("Id")
	T_3dview := c.GetString("T_3dview")

	DeviceSensor, is := Device.Read_DeviceSensor_ByT_sn(Sn, Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "信息错误!"}
		c.ServeJSON()
		return
	}
	DeviceSensor.T_3dview = T_3dview
	//c.Data["Device_lite"] = Device.Read_DeviceParameter_SN(Sn)
	Device.Update_DeviceSensor(DeviceSensor, "T_3dview")

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "3D 视图ID操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+T_3dview)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"}
	c.ServeJSON()
	return
}

// 传感器 屏蔽数据展示 0 屏蔽数据展示  1 正常数据展示 （未使用）
func (c *DeviceController) UpDeviceSensor_T_datashow() {
	Sn := c.GetString("Sn")
	Id, _ := c.GetInt("Id")
	T_datashow, _ := c.GetInt("T_datashow")

	DeviceSensor, is := Device.Read_DeviceSensor_ByT_sn(Sn, Id)
	if !is {
		c.Data["json"] = lib.JSONS{Code: 201, Msg: "信息错误!"}
		c.ServeJSON()
		return
	}
	DeviceSensor.T_datashow = T_datashow

	Device.Update_DeviceSensor(DeviceSensor, "T_datashow")

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "传感器 数据展示（0 屏蔽数据展示  1 正常数据展示）", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+strconv.Itoa(T_datashow))
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"}
	c.ServeJSON()
	return
}

// 传感器管理列表
func (c *DeviceController) DeviceSensor_Manage_List() {

	type R_JSONS struct {
		//必须的大写开头
		Data      []Device.DeviceSensor_P
		Num       int64
		Page      int
		Page_size int
	}
	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_name := c.GetString("T_name") //  包含 T_name、T_sn
	T_calss_id, _ := c.GetInt("T_calssid")
	if T_calss_id > 0 {
		R_DeviceClass, err := Company.Read_CompanyClass_ById(T_calss_id)
		if err != nil {
			c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
			c.ServeJSON()
			return
		}
		if R_DeviceClass.T_pid != c.T_pid {
			c.Data["json"] = lib.JSONS{Code: 205, Msg: "CompanyClass.T_pid != T_pid Err!"}
			c.ServeJSON()
			return
		}
	}

	T_en, T_en_err := c.GetInt("T_en") //启用停用 0 停用  1 启用  空 所有
	if T_en_err != nil {
		T_en = -1
	}
	T_free, T_free_err := c.GetInt("T_free") // 空库 0 正常  1 空库 空 所有
	if T_free_err != nil {
		T_free = -1
	}
	T_datashow, T_datashow_err := c.GetInt("T_datashow") //数据展示 空 全部  0 屏蔽数据展示  1 正常数据展示
	if T_datashow_err != nil {
		T_datashow = -1
	}

	T_sort, T_sort_err := c.GetInt("T_sort") //排序 空 升序 1 降序
	if T_sort_err != nil {
		T_sort = -1
	}

	r_jsons.Data, r_jsons.Num = Device.Read_DeviceSensorManageList(c.Admin_r, c.T_pid, T_name, T_calss_id, T_en, T_free, T_datashow, T_sort, page, page_z)
	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}

// 设备任务 ------------------------------------------

// 任务列表
func (c *DeviceController) DeviceTask_List() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Device.DeviceTask
		Num       int64
		Page      int
		Page_size int
	}
	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_sn := c.GetString("T_sn")
	Time_start := c.GetString("Time_start")
	Time_end := c.GetString("Time_end")

	if len(T_sn) < 6 {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_sn!!!"}
		c.ServeJSON()
		return
	}

	r_jsons.Data, r_jsons.Num = Device.Read_DeviceTask_List(T_sn, Time_start, Time_end, page, page_z)
	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return

}

// 任务启停
func (c *DeviceController) DeviceTask_Post() {
	T_sn := c.GetString("T_sn")
	T_task := c.GetString("T_task")

	NatsServer.Set_DeviceTask(Device.Device_task{
		T_sn:   T_sn,
		T_task: T_task,
	})
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "远程启停", T_sn+"-"+T_task)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return

}

// 设备告警 ------------------------------------------

// 告警列表
func (c *DeviceController) DeviceWarning_List() {

	type R_JSONS struct {
		//必须的大写开头
		Data      []Warning.Warning_R
		Num       int64
		Page      int
		Page_size int
	}
	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_name := c.GetString("T_name")
	T_tp := c.GetString("T_tp")
	Time_start := c.GetString("Time_start")
	Time_end := c.GetString("Time_end")
	T_handle, _ := c.GetInt("T_handle")

	T_admin, _ := c.GetInt("T_admin")
	T_history, _ := c.GetInt("T_history")
	var T_year, T_month string
	if T_history == 1 {
		date, err := time.Parse("2006-01-02 15:04:05", Time_start)
		if err != nil {
			c.Data["json"] = lib.JSONS{Code: 200, Msg: "时间格式错误"}
			c.ServeJSON()
			return
		}
		T_year, T_month = date.Format("2006"), date.Format("01")
	}

	if T_admin == 1 {
		if T_history == 1 {
			// 获取备份
			r_jsons.Data, r_jsons.Num = Warning.Read_Admin_Warning_Backups(c.Admin_r.T_pids, T_year, T_month, T_tp, T_name, T_handle, Time_start, Time_end, page, page_z)
		} else {
			// 获取最新
			r_jsons.Data, r_jsons.Num = Warning.Read_Admin_Warning_List(c.Admin_r.T_pids, T_tp, T_name, T_handle, Time_start, Time_end, page, page_z)
		}
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
		c.ServeJSON()
		return
	}

	if T_history == 1 {
		// 获取备份
		r_jsons.Data, r_jsons.Num = Warning.Read_Warning_Backups(c.T_pid, T_year, T_month, T_tp, T_name, T_handle, Time_start, Time_end, page, page_z)
	} else {
		// 获取最新
		r_jsons.Data, r_jsons.Num = Warning.Read_Warning_List(c.T_pid, T_tp, T_name, T_handle, Time_start, Time_end, page, page_z)
	}

	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}

// 查询告警
func (c *DeviceController) DeviceWarning_Get() {
	id, _ := c.GetInt("T_id")
	T := Warning.Read_Warning_ById(id)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Warning.WarningToWarning_R(T)}
	c.ServeJSON()
	return
}

// 编辑告警（处理告警）
func (c *DeviceController) DeviceWarning_Post() {
	Id, _ := c.GetInt("T_id")
	T_Text := c.GetString("T_Text")

	T := Warning.Read_Warning_ById(Id)
	if T.Id == 0 {
		c.Data["json"] = lib.JSONS{Code: 206, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	T.T_Text = T_Text
	T.T_State = 2

	Warning.Update_Warning(T, "T_Text", "T_State")

	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "报警处理操作", strconv.Itoa(Id)+"->"+T_Text)
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 删除告警
func (c *DeviceController) DeviceWarning_Del() {
	Id, _ := c.GetInt("T_id")

	T := Warning.Read_Warning_ById(Id)
	if T.Id == 0 {
		c.Data["json"] = lib.JSONS{Code: 206, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}

	T.T_State = 0
	Warning.Update_Warning(T, "T_State")

	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "报警删除操作", strconv.Itoa(Id))
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 导出告警
func (c *DeviceController) DeviceWarning_Data_Excel() {
	T_name := c.GetString("T_name")
	T_tp := c.GetString("T_tp")
	Time_start := c.GetString("Time_start")
	Time_end := c.GetString("Time_end")
	T_handle, _ := c.GetInt("T_handle")

	Device_data, _ := Warning.Read_Warning_List(c.T_pid, T_tp, T_name, T_handle, Time_start, Time_end, 0, 9999)

	f := excelize.NewFile() // 设置单元格的值
	// 这里设置表头
	f.SetCellValue("Sheet1", "A1", "报警类型")
	f.SetCellValue("Sheet1", "B1", "Sn")
	f.SetCellValue("Sheet1", "C1", "设备名称")
	f.SetCellValue("Sheet1", "D1", "传感器")
	f.SetCellValue("Sheet1", "E1", "报警内容")
	f.SetCellValue("Sheet1", "F1", "记录时间")
	f.SetCellValue("Sheet1", "G1", "处理")
	f.SetCellValue("Sheet1", "H1", "处理时间")

	// 设置列宽
	f.SetColWidth("Sheet1", "A", "A", 20)
	f.SetColWidth("Sheet1", "B", "B", 25)
	f.SetColWidth("Sheet1", "C", "C", 30)
	f.SetColWidth("Sheet1", "D", "D", 30)
	f.SetColWidth("Sheet1", "G", "E", 30)
	f.SetColWidth("Sheet1", "H", "F", 15)
	f.SetColWidth("Sheet1", "I", "G", 30)
	f.SetColWidth("Sheet1", "J", "H", 15)

	line := 1

	// 循环写入数据
	for _, v := range Device_data {
		line++
		f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), v.T_tp)
		f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_sn+"["+strconv.Itoa(v.Id)+"]")
		f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_D_name)
		f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_DS_name)
		f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), v.T_Remark)
		f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), v.T_Ut)
		f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_Text)
		f.SetCellValue("Sheet1", fmt.Sprintf("H%d", line), v.CreateTime)

	}
	timeStr := time.Now().Format("20060102150405")
	// 保存文件
	if err := f.SaveAs("ofile/" + timeStr + ".xlsx"); err != nil {
		fmt.Println(err)
	}

	url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+timeStr+".xlsx", "ofile/"+timeStr+".xlsx")
	if !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
		c.ServeJSON()
		return
	}
	//删除文件
	err := os.Remove("ofile/" + timeStr + ".xlsx")
	if err != nil {
		fmt.Println(err)
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
	c.ServeJSON()
	return
}

// 告警提示列表
func (c *DeviceController) DeviceWarningList_T_Tips() {
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Warning.Read_WarningType_All_T_Notice_mechanism()}
	c.ServeJSON()
	return
}

// 告警类型列表
func (c *DeviceController) WarningType_List_All() {
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Warning.Read_WarningType_All()}
	c.ServeJSON()
	return
}

// 告警类型列表 - 权限关联列表
func (c *DeviceController) WarningType_Power_List_All() {

	power, err := Account.Read_Power_ById(c.Admin_r.T_power)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "获取菜单失败"}
		c.ServeJSON()
		return
	}

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Warning.Read_WarningType_Power_All(power.T_warning)}
	c.ServeJSON()
	return
}

// 设备分类 ------------------------------------------
func (c *DeviceController) CompanyClass_List() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Company.CompanyClass_R
		Num       int64
		Page      int
		Page_size int
	}

	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_name := c.GetString("T_name")

	r_jsons.Data, r_jsons.Num = Company.Read_CompanyClass_List(c.T_pid, T_name, page, page_z)
	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyClass_All() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Company.CompanyClass_R
		Num       int64
		Page      int
		Page_size int
	}

	var r_jsons R_JSONS

	T_name := c.GetString("T_name")

	r_jsons.Data = Company.Read_CompanyClass_All(c.T_pid, T_name)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyClass_Get() {
	id, _ := c.GetInt("T_id")
	R_DeviceClass, err := Company.Read_CompanyClass_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Company.CompanyClassToCompanyClass_R(R_DeviceClass)}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyClass_Add() {
	T_name := c.GetString("T_name")
	t_c := Company.CompanyClass{
		T_pid:   c.T_pid,
		T_name:  T_name,
		T_State: 1,
	}

	Id, err := Company.Add_CompanyClass(t_c)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "添加失败"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "分类添加", t_c)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyClass_Edit() {
	T_name := c.GetString("T_name")
	id, _ := c.GetInt("T_id")
	R_DeviceClass, err := Company.Read_CompanyClass_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	if len(T_name) > 0 {
		R_DeviceClass.T_name = T_name
	}

	if is := Company.Update_CompanyClass(R_DeviceClass, "T_name"); !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改失败"}
		c.ServeJSON()
		return
	}

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "分类修改", R_DeviceClass)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyClass_Del() {
	id, _ := c.GetInt("T_id")
	R_DeviceClass, err := Company.Read_CompanyClass_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}
	if is := Company.Delete_CompanyClass_ById(id); !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除失败"}
		c.ServeJSON()
		return
	}
	// 将传感器T_Class绑定的分类id替换为空字符串
	DeviceSensor_class_list := Device.Read_DeviceSensor_ALL_Class_Id(id)
	for _, v := range DeviceSensor_class_list {
		Device.DeviceSensor_Bind_T_Class_Del(v.T_sn, v.T_id, id)
	}
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "分类删除", strconv.Itoa(id))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 设备分类绑定
func (c *DeviceController) DeviceClassBind_List() {

	type R_JSONS struct {
		//必须的大写开头
		DeviceSensor_lite []Device.DeviceSensor_R
		Num               int
		Page              int
		Page_size         int
		Pages             []lib.Page_T
	}
	var r_jsons R_JSONS
	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}
	T_name := c.GetString("T_name")
	T_sn := c.GetString("T_sn")
	T_class_id, _ := c.GetInt("T_class_id")
	T_type, _ := c.GetInt("T_type")
	R_DeviceClass, err := Company.Read_CompanyClass_ById(T_class_id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}
	var cnt int64
	Device_lite, cnt := Device.Read_DeviceSensor_List_T_Class(c.T_pid, T_class_id, T_sn, T_name, T_type, page, page_z)

	r_jsons.DeviceSensor_lite = Device_lite

	page_size := math.Ceil(float64(cnt) / float64(page_z))
	r_jsons.Page = page
	r_jsons.Page_size = int(page_size)
	r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
	r_jsons.Num = int(cnt)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *DeviceController) ClassBind_Add() {

	T_class_id, _ := c.GetInt("T_class_id")
	T_sn := c.GetString("T_sn")
	T_id, _ := c.GetInt("T_id")

	if T_class_id == 0 || T_id == 0 || len(T_sn) == 0 {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_sn T_id T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if _, err := Device.Read_Device_ByT_sn(T_sn); err != nil {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	R_DeviceClass, err := Company.Read_CompanyClass_ById(T_class_id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	DeviceSensor_class_list := Device.Read_DeviceSensor_ALL_T_sn_T_id_T_Class(T_sn, T_id, T_class_id)
	if len(DeviceSensor_class_list) > 0 {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "重复绑定!"}
		c.ServeJSON()
		return
	}

	if err = Device.DeviceSensor_Bind_T_Class_Add(T_sn, T_id, T_class_id); err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "绑定失败"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "分类绑定操作", strconv.Itoa(T_class_id)+"+>"+T_sn+"-"+strconv.Itoa(T_id))
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}
func (c *DeviceController) ClassBind_Del() {
	T_class_id, _ := c.GetInt("T_class_id")
	T_sn := c.GetString("T_sn")
	T_id, _ := c.GetInt("T_id")

	if T_class_id == 0 || T_id == 0 || len(T_sn) == 0 {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_sn T_id T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if _, err := Device.Read_Device_ByT_sn(T_sn); err != nil {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	R_DeviceClass, err := Company.Read_CompanyClass_ById(T_class_id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	DeviceSensor_class_list := Device.Read_DeviceSensor_ALL_T_sn_T_id_T_Class(T_sn, T_id, T_class_id)
	if len(DeviceSensor_class_list) == 0 {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
		c.ServeJSON()
		return
	}

	if err = Device.DeviceSensor_Bind_T_Class_Del(T_sn, T_id, T_class_id); err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "删除失败"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "分类删除绑定操作", strconv.Itoa(T_class_id)+"->"+T_sn+"-"+strconv.Itoa(T_id))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 报警策略 ------------------------------------------
func (c *DeviceController) CompanyNotice_List() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Company.CompanyNotice_R
		Num       int64
		Page      int
		Page_size int
	}

	var r_jsons R_JSONS

	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}

	T_name := c.GetString("T_name")

	r_jsons.Data, r_jsons.Num = Company.Read_CompanyNotice_List(c.T_pid, T_name, page, page_z)
	r_jsons.Page = page
	r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyNotice_All() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Company.CompanyNotice_R
		Num       int64
		Page      int
		Page_size int
	}

	var r_jsons R_JSONS

	T_name := c.GetString("T_name")

	r_jsons.Data = Company.Read_CompanyNotice_All(c.T_pid, T_name)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyNotice_Get() {
	id, _ := c.GetInt("T_id")
	R_DeviceNotice, err := Company.Read_CompanyNotice_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceNotice.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Company.CompanyNoticeToCompanyNotice_R(R_DeviceNotice)}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyNotice_Add() {
	T_name := c.GetString("T_name")
	t_c := Company.CompanyNotice{
		T_pid:              c.T_pid,
		T_name:             T_name,
		T_Notice_mechanism: Warning.Read_WarningType_All_T_Notice_mechanism(),
		T_State:            1,
	}

	Id, err := Company.Add_CompanyNotice(t_c)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "添加失败"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "报警策略添加", t_c)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Id}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyNotice_Edit() {
	id, _ := c.GetInt("T_id")
	T_name := c.GetString("T_name")
	T_Notice_wx := c.GetString("T_Notice_wx")
	T_Notice_wx2 := c.GetString("T_Notice_wx2")
	T_Notice_phone := c.GetString("T_Notice_phone")
	T_Notice_message := c.GetString("T_Notice_message")
	T_Notice_mailbox := c.GetString("T_Notice_mailbox")
	T_Notice_mechanism := c.GetString("T_Notice_mechanism")

	R_DeviceNotice, err := Company.Read_CompanyNotice_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceNotice.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	R_DeviceNotice.Id = id
	if len(T_name) > 0 {
		R_DeviceNotice.T_name = T_name
	}
	if len(T_Notice_wx) > 0 {
		R_DeviceNotice.T_Notice_wx = T_Notice_wx
	}
	if len(T_Notice_wx2) > 0 {
		R_DeviceNotice.T_Notice_wx2 = T_Notice_wx2
	}
	if len(T_Notice_phone) > 0 {
		R_DeviceNotice.T_Notice_phone = T_Notice_phone
	}
	if len(T_Notice_message) > 0 {
		R_DeviceNotice.T_Notice_message = T_Notice_message
	}
	if len(T_Notice_mailbox) > 0 {
		R_DeviceNotice.T_Notice_mailbox = T_Notice_mailbox
	}
	if len(T_Notice_mechanism) > 0 {
		R_DeviceNotice.T_Notice_mechanism = T_Notice_mechanism
	}

	if is := Company.Update_CompanyNotice(R_DeviceNotice, "T_name", "T_Notice_wx", "T_Notice_wx2", "T_Notice_phone", "T_Notice_message", "T_Notice_mailbox", "T_Notice_mechanism"); !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改失败"}
		c.ServeJSON()
		return
	}

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "报警策略修改", R_DeviceNotice)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyNotice_Reset_Mechanism() {
	id, _ := c.GetInt("T_id")

	R_DeviceNotice, err := Company.Read_CompanyNotice_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceNotice.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	R_DeviceNotice.T_Notice_mechanism = Warning.Read_WarningType_All_T_Notice_mechanism()

	if is := Company.Update_CompanyNotice(R_DeviceNotice, "T_Notice_mechanism"); !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改失败"}
		c.ServeJSON()
		return
	}

	System.Add_UserLogs_T(c.Admin_r.T_uuid, "设备管理", "报警策略", R_DeviceNotice)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}
func (c *DeviceController) CompanyNotice_Del() {
	id, _ := c.GetInt("T_id")
	R_DeviceNotice, err := Company.Read_CompanyNotice_ById(id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceNotice.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}
	if is := Company.Delete_CompanyNotice_ById(id); !is {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "删除失败"}
		c.ServeJSON()
		return
	}
	DeviceSensor_class_list := Device.Read_DeviceSensor_ALL_Notice_Id(id)
	for _, v := range DeviceSensor_class_list {
		Device.DeviceSensor_Bind_T_Notice_Del(v.T_sn, v.T_id, id)
	}
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "报警策略删除", strconv.Itoa(id))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 设备通知绑定
func (c *DeviceController) DeviceNoticeBind_List() {
	type R_JSONS struct {
		//必须的大写开头
		DeviceSensor_lite []Device.DeviceSensor_R
		Num               int
		Page              int
		Page_size         int
		Pages             []lib.Page_T
	}
	var r_jsons R_JSONS
	page, _ := c.GetInt("page")
	if page < 1 {
		page = 1
	}
	page_z, _ := c.GetInt("page_z")
	if page_z < 1 {
		page_z = conf.Page_size
	}
	T_name := c.GetString("T_name")
	T_sn := c.GetString("T_sn")
	T_notice_id, _ := c.GetInt("T_notice_id")
	T_type, _ := c.GetInt("T_type")

	R_DeviceNotice, err := Company.Read_CompanyNotice_ById(T_notice_id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceNotice.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}
	var cnt int64
	Device_lite, cnt := Device.Read_DeviceSensor_List_T_Notice(c.T_pid, T_notice_id, page, page_z, T_sn, T_name, T_type)

	r_jsons.DeviceSensor_lite = Device_lite

	page_size := math.Ceil(float64(cnt) / float64(page_z))
	r_jsons.Page = page
	r_jsons.Page_size = int(page_size)
	r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
	r_jsons.Num = int(cnt)

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}
func (c *DeviceController) NoticeBind_Add() {

	T_notice_id, _ := c.GetInt("T_notice_id")
	T_sn := c.GetString("T_sn")
	T_id, _ := c.GetInt("T_id")

	if T_notice_id == 0 || T_id == 0 || len(T_sn) == 0 {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_sn T_id T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if _, err := Device.Read_Device_ByT_sn(T_sn); err != nil {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	R_CompanyNotice, err := Company.Read_CompanyNotice_ById(T_notice_id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if R_CompanyNotice.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	DeviceSensor_Notice_list := Device.Read_DeviceSensor_ALL_T_sn_T_id_T_Notice(T_sn, T_id, T_notice_id)
	if len(DeviceSensor_Notice_list) > 0 {
		c.Data["json"] = lib.JSONS{Code: 203, Msg: "重复绑定!"}
		c.ServeJSON()
		return
	}

	if err = Company.Add_T_Notice_bind(T_sn, T_id, T_notice_id); err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "通知绑定失败"}
		c.ServeJSON()
		return
	}

	if err = Device.DeviceSensor_Bind_T_Notice_Add(T_sn, T_id, T_notice_id); err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "通知绑定失败"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "报警策略绑定添加", strconv.Itoa(T_notice_id)+"+>"+T_sn+"-"+strconv.Itoa(T_id))
	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}
func (c *DeviceController) NoticeBind_Del() {

	T_notice_id, _ := c.GetInt("T_notice_id")
	T_sn := c.GetString("T_sn")
	T_id, _ := c.GetInt("T_id")

	if T_notice_id == 0 || T_id == 0 || len(T_sn) == 0 {
		c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_sn T_id T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if _, err := Device.Read_Device_ByT_sn(T_sn); err != nil {
		c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id Err!"}
		c.ServeJSON()
		return
	}
	R_DeviceClass, err := Company.Read_CompanyNotice_ById(T_notice_id)
	if err != nil {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_class_id Err!"}
		c.ServeJSON()
		return
	}
	if R_DeviceClass.T_pid != c.T_pid {
		c.Data["json"] = lib.JSONS{Code: 205, Msg: "T_pid Err!"}
		c.ServeJSON()
		return
	}

	DeviceSensor_class_list := Device.Read_DeviceSensor_ALL_T_sn_T_id_T_Notice(T_sn, T_id, T_notice_id)
	if len(DeviceSensor_class_list) == 0 {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
		c.ServeJSON()
		return
	}

	if err = Company.Delete_T_Notice_bind(T_sn, T_id, T_notice_id); err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "通知删除绑定失败"}
		c.ServeJSON()
		return
	}

	if err = Device.DeviceSensor_Bind_T_Notice_Del(T_sn, T_id, T_notice_id); err != nil {
		c.Data["json"] = lib.JSONS{Code: 200, Msg: "通知删除绑定失败"}
		c.ServeJSON()
		return
	}
	System.Add_UserLogs(c.Admin_r.T_uuid, "设备管理", "通知删除绑定删除", strconv.Itoa(T_notice_id)+"->"+T_sn+"-"+strconv.Itoa(T_id))

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
	c.ServeJSON()
	return
}

// 设备类型
func (c *DeviceController) DeviceType_List_All() {
	type R_JSONS struct {
		//必须的大写开头
		Data      []Device.DeviceSensorType
		Num       int64
		Page      int
		Page_size int
	}

	var r_jsons R_JSONS

	r_jsons.Data = Device.Read_DeviceSensorType_List_All()

	c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
	c.ServeJSON()
	return
}