package controllers import ( "Cold_Api/Nats/NatsServer" "Cold_Api/conf" "Cold_Api/controllers/lib" "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" "strconv" "time" ) // Handle type DeviceController struct { beego.Controller } // 设备 ------------------------------------------ func (c *DeviceController) Device_List() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") println(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_pid, T_pid_err := c.GetInt("T_pid") T_online := c.GetString("T_online") T_monitor := c.GetString("T_monitor") if admin_r.T_pid > 0 { T_pid = admin_r.T_pid } else { if T_pid_err != nil || T_pid <= 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"} c.ServeJSON() return } } r_jsons.Device_lite, r_jsons.Num = Device.Read_Device_List(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_Add() { /// 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } var err error T_sn := c.GetString("T_sn") T_MSISDN := c.GetString("T_MSISDN") T_type, _ := c.GetInt("T_type") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } var_ := Device.Device{ T_pid: T_pid, T_sn: T_sn, T_MSISDN: T_MSISDN, T_type: T_type, T_give: 1, 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(admin_r.T_uuid, "设备管理", "设备添加", var_) //MqttServer.Get_Device_Realtime(T_sn) // 更新传感器 !!! c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } func (c *DeviceController) Device_Edit() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} 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: 206, Msg: "T_sn Err!"} c.ServeJSON() return } T_VerifyTime := c.GetString("T_VerifyTime") if len(T_VerifyTime) > 5 { stamp, err := time.ParseInLocation("2006-01-02 15:04:05", T_VerifyTime, time.Local) if err == nil { Device_r.T_VerifyTime = stamp Device.Update_Device(Device_r, "T_VerifyTime") System.Add_UserLogs(admin_r.T_uuid, "设备管理", "验证时间操作", "验证时间:"+T_VerifyTime) } else { c.Data["json"] = lib.JSONS{Code: 203, Msg: "时间解析错误!" + T_VerifyTime} c.ServeJSON() return } } T_CalibrationTime := c.GetString("T_CalibrationTime") if len(T_CalibrationTime) > 5 { stamp, err := time.ParseInLocation("2006-01-02 15:04:05", T_CalibrationTime, time.Local) if err == nil { Device_r.T_CalibrationTime = stamp Device.Update_Device(Device_r, "T_CalibrationTime") System.Add_UserLogs(admin_r.T_uuid, "设备管理", "校准时间操作", "校准时间:"+T_CalibrationTime) } else { c.Data["json"] = lib.JSONS{Code: 204, Msg: "时间解析错误!" + T_CalibrationTime} c.ServeJSON() return } } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } func (c *DeviceController) Device_Del() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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) Device_Parameter_List() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } Sn := c.GetString("T_sn") DeviceParameter_lite := Device.Read_DeviceParameter_SN_List(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_SN := c.GetString("T_sn") T_devName := c.GetString("T_devName") T_uploadTime, _ := c.GetInt("T_uploadTime") T_saveTime, _ := c.GetInt("T_saveTime") T_overrunSave, _ := c.GetInt("T_overrunSave") T_overrunAlarm, _ := c.GetInt("T_overrunAlarm") T_outageAlarm, _ := c.GetInt("T_outageAlarm") T_warningDelay, _ := c.GetInt("T_warningDelay") T_lostAlarm, _ := c.GetInt("T_lostAlarm") T_batteryLimit, _ := c.GetInt("T_batteryLimit") T_warningTime, _ := c.GetInt("T_warningTime") T_enwarning, _ := c.GetInt("T_enwarning") T_decTotal, _ := c.GetInt("T_decTotal") T_chDecTotal := c.GetString("T_chDecTotal") T_company := c.GetString("T_company") T_btname := c.GetString("T_btname") T_btserverID, _ := c.GetInt("T_btserverID") T_btchar, _ := c.GetInt("T_btchar") T_Msid, _ := c.GetInt("T_Msid") 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_uuid: admin_r.T_uuid, T_uploadTime: T_uploadTime, T_SendState: 0, T_State: 2, T_sn: T_SN, T_devName: T_devName, T_saveTime: T_saveTime, T_overrunSave: T_overrunSave, T_overrunAlarm: T_overrunAlarm, T_outageAlarm: T_outageAlarm, T_lostAlarm: T_lostAlarm, T_warningTime: T_warningTime, T_warningDelay: T_warningDelay, T_batteryLimit: T_batteryLimit, T_chDecTotal: T_chDecTotal, T_decTotal: strconv.Itoa(T_decTotal), T_enwarning: T_enwarning, T_company: T_company, T_btname: T_btname, T_btserverID: strconv.Itoa(T_btserverID), T_btchar: strconv.Itoa(T_btchar), T_Msid: T_Msid, } 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(admin_r.T_uuid, "设备管理", "设备参数操作", Deviceparameter) NatsServer.Pu_DeviceParameter(Deviceparameter) Device_r.T_devName = Deviceparameter.T_devName Device.Update_Device(Device_r, "T_devName") c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 删除设备 传感器 func (c *DeviceController) Device_Parameter_Del_Device() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Ctx.Redirect(302, "Login") return } Sn := c.GetString("Sn") Id, _ := c.GetInt("Id") System.Add_UserLogs_T(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 } // 设备参数 1库房 2移动 func (c *DeviceController) Pu_DeviceParameter_T_type() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_SN := c.GetString("SN") T_type, _ := c.GetInt("T_l_p") 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 } Device_r.T_type = T_type Device.Update_Device(Device_r, "T_l_p") Device.DeviceSensor_T_type_ALL(T_SN, T_type) System.Add_UserLogs(admin_r.T_uuid, "设备管理", "设备参数操作", "类型选择(1库房 2移动):"+string(T_type)) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 设备是否弃用 0屏蔽 1正常 func (c *DeviceController) Pu_DeviceParameter_T_give() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_SN := c.GetString("SN") T_give, _ := c.GetInt("T_give") 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 } // // 1物流端 2药店端 Device_r.T_give = T_give Device.Update_Device(Device_r, "T_give") Device.DeviceSensor_t_give_ALL(T_SN, T_give) System.Add_UserLogs(admin_r.T_uuid, "设备管理", "设备丢弃参数操作", "设备丢弃( 0 丢弃 1 正常):"+string(T_give)) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 获取传感器参数 func (c *DeviceController) Read_DeviceSensorParameter() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_SN := c.GetString("T_sn") _, 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 } NatsServer.Read_DeviceSensorParameter(T_SN) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 设备-传感器 ------------------------------------------ // 传感器列表 func (c *DeviceController) DeviceSensor_List() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } type R_JSONS struct { //必须的大写开头 Data []Device.DeviceSensor_R Num int64 Page int Page_size int } var r_jsons R_JSONS page, _ := c.GetInt("page") println(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_give, T_give_err := c.GetInt("T_give") //0 :丢弃 1:正常 空:所有 if T_give_err != nil { T_give = -1 } T_datashow, T_datashow_err := c.GetInt("T_datashow") //空:正常显示 1:强制显示 屏蔽数据展示 if T_datashow_err != nil { T_datashow = -1 } var T_pid int if admin_r.T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } if T_calss_id > 0 { R_DeviceClass, err := Company.Read_CompanyNotice_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 != T_pid { c.Data["json"] = lib.JSONS{Code: 205, Msg: "R_DeviceClass.T_pid != T_pid Err!"} c.ServeJSON() return } } r_jsons.Data, r_jsons.Num = Device.Read_DeviceSensorList(T_pid, T_sn, Name, T_calss_id, T_give, T_datashow, 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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey!"} c.ServeJSON() return } 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 } // 实时数据显示排序 if v, err := c.GetInt("T_sort"); err == nil { DeviceSensor.T_sort = v Device.Update_DeviceSensor(DeviceSensor, "T_sort") System.Add_UserLogs_T(admin_r.T_uuid, "设备管理", "传感器 排序操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]"+strconv.Itoa(v)) } c.Data["json"] = lib.JSONS{Code: 200, Msg: "OK"} c.ServeJSON() return } // 删除传感器 func (c *DeviceController) DeviceSensor_Del() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Ctx.Redirect(302, "Login") return } 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(admin_r.T_uuid, "设备管理", "传感器 删除操作", "SN:"+Sn+" ["+strconv.Itoa(Id)+"]") } else { Device.Delete_DeviceSensor_ById(Sn, Id) System.Add_UserLogs_T(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_List() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } Sn := c.GetString("T_sn") Id, _ := c.GetInt("T_id") //c.Data["DeviceSensor"], _ = Device.Read_DeviceSensor_ByTsn_Tid(Sn, Id) DeviceSensorParameter_lite := Device.Read_V2DeviceSensorParameter_List(Sn, Id, 2, 10) 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_Pu() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_SN := c.GetString("T_sn") T_name := c.GetString("T_name") T_id, _ := c.GetInt("T_id") T_Tlower, _ := c.GetFloat("T_Tlower") T_Tupper, _ := c.GetFloat("T_Tupper") T_RHlower, _ := c.GetFloat("T_RHlower") T_RHupper, _ := c.GetFloat("T_RHupper") T_en, _ := c.GetInt("T_en") T_free, _ := c.GetInt("T_free") T_enprel, _ := c.GetInt("T_enprel") T_tprel, _ := c.GetFloat("T_tprel") T_tpreu, _ := c.GetFloat("T_tpreu") T_hprel, _ := c.GetFloat("T_hprel") T_hpreu, _ := c.GetFloat("T_hpreu") _, 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 := Device.DeviceSensorParameter{ T_sn: T_SN, T_id: T_id, T_Tlower: float32(T_Tlower), T_Tupper: float32(T_Tupper), T_RHlower: float32(T_RHlower), T_RHupper: float32(T_RHupper), T_en: T_en, T_free: T_free, T_enprel: T_enprel, T_tprel: float32(T_tprel), T_tpreu: float32(T_tpreu), T_hprel: float32(T_hprel), T_hpreu: float32(T_hpreu), T_uuid: admin_r.T_uuid, T_SendState: 0, T_State: 2, } dsp_id, is := Device.Add_DeviceSensorParameter(Devicesensorparameter) if !is { c.Data["json"] = lib.JSONS{Code: 209, Msg: "添加失败!"} c.ServeJSON() return } Devicesensorparameter.Id = int(dsp_id) // 更新名称 DeviceSensor.T_name = T_name Device.Update_DeviceSensor(DeviceSensor, "T_name") System.Add_UserLogs_T(admin_r.T_uuid, "设备管理", "传感器参数操作", Devicesensorparameter) NatsServer.Pu_DeviceParameter_Sensor(Devicesensorparameter) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 传感器 实时数据显示排序 func (c *DeviceController) UpDeviceSensor_Tsort() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Ctx.Redirect(302, "Login") return } 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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Ctx.Redirect(302, "Login") return } 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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Ctx.Redirect(302, "Login") return } 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(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) DeviceTask_List() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } type R_JSONS struct { //必须的大写开头 Data []Device.DeviceTask Num int64 Page int Page_size int } var r_jsons R_JSONS page, _ := c.GetInt("page") println(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_All(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } type R_JSONS struct { //必须的大写开头 Data []Warning.Warning_R Num int64 Page int Page_size int } var r_jsons R_JSONS page, _ := c.GetInt("page") println(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") T_id := c.GetString("T_id") T_title := c.GetString("T_title") Time_start := c.GetString("Time_start") Time_end := c.GetString("Time_end") T_handle, _ := c.GetInt("T_handle") T_year, _ := c.GetInt("T_year") T_month, _ := c.GetInt("T_month") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } if T_year > 0 && T_month > 0 { // 获取备份 r_jsons.Data, r_jsons.Num = Warning.Read_Warning_Backups(T_pid, strconv.Itoa(T_year), strconv.Itoa(T_month), T_sn, T_id, T_title, T_handle, Time_start, Time_end, page, page_z) } else { // 获取最新 r_jsons.Data, r_jsons.Num = Warning.Read_Warning(T_pid, T_sn, T_id, T_title, 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() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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 = 1 Warning.Update_Warning(T, "T_Text", "T_State") System.Add_UserLogs(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Ctx.Redirect(302, "Login") return } 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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } //T_sn := c.GetString("T_sn") T_sn := c.GetString("T_sn") T_id := c.GetString("T_id") T_title := c.GetString("T_title") Time_start := c.GetString("Time_start") Time_end := c.GetString("Time_end") T_handle, _ := c.GetInt("T_handle") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } Device_data, _ := Warning.Read_Warning(T_pid, T_sn, T_id, T_title, 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() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Warning.Read_WarningType_All_T_Notice_mechanism()} c.ServeJSON() return } // 设备分类 ------------------------------------------ func (c *DeviceController) CompanyClass_List() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } type R_JSONS struct { //必须的大写开头 Data []Company.CompanyClass_R Num int64 Page int Page_size int } var r_jsons R_JSONS page, _ := c.GetInt("page") println(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_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } r_jsons.Data, r_jsons.Num = Company.Read_CompanyClass_List(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } r_jsons.Data = Company.Read_CompanyClass_All(T_pid, T_name) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *DeviceController) CompanyClass_Get() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_name := c.GetString("T_name") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } t_c := Company.CompanyClass{ T_pid: 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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_name := c.GetString("T_name") id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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(admin_r.T_uuid, "设备管理", "分类修改", R_DeviceClass) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } func (c *DeviceController) CompanyClass_Del() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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(admin_r.T_uuid, "设备管理", "分类删除", strconv.Itoa(id)) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 设备分类绑定 func (c *DeviceController) DeviceClassBind_List() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") Name := c.GetString("Name") T_sn := c.GetString("T_sn") T_class_id, _ := c.GetInt("T_class_id") page_z, _ := c.GetInt("page_z") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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_class_ALL_1(T_pid, T_class_id, page, page_z, T_sn, Name, "") 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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_class_id, _ := c.GetInt("T_class_id") T_sn := c.GetString("T_sn") T_id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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_CompanyNotice_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 != 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_class_1(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_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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_class_id, _ := c.GetInt("T_class_id") T_sn := c.GetString("T_sn") T_id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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_CompanyNotice_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 != 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_class_1(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(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) Get_DeviceClassId_QRCode() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_calss_id := c.GetString("T_class_id") if len(T_calss_id) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_calss_id Err!"} c.ServeJSON() return } T_calss_id_str, _ := NatsServer.Wx_GenerateQRCode("-|" + lib.AesEncryptCBC(T_calss_id, "0123456789012345") + "|- @宝智达 微信公众号通知") if len(T_calss_id_str) == 0 { c.Data["json"] = lib.JSONS{Code: 201, Msg: "Err!"} c.ServeJSON() return } type Text struct { QR string Code string } T_calss_id_str = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=" + T_calss_id_str Text_r := Text{ QR: T_calss_id_str, Code: "请将本内容发送到 深圳市宝智达科技有限公司 微信公众号-|" + lib.AesEncryptCBC(T_calss_id, "0123456789012345") + "|- @宝智达 微信公众号通知 ", } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Text_r} c.ServeJSON() return } func (c *DeviceController) Get_DeviceClassId_QRCode2() { // 验证登录 b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_calss_id := c.GetString("T_class_id") if len(T_calss_id) == 0 { c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_calss_id Err!"} c.ServeJSON() return } T_calss_id_str, _ := NatsServer.Wx_GenerateQRCode2("-|" + lib.AesEncryptCBC(T_calss_id, "0123456789012345") + "|- @宝智达 微信公众号通知") if len(T_calss_id_str) == 0 { c.Data["json"] = lib.JSONS{Code: 201, Msg: "Err!"} c.ServeJSON() return } type Text struct { QR string Code string } T_calss_id_str = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=" + T_calss_id_str Text_r := Text{ QR: T_calss_id_str, Code: "请将本内容发送到 宝智达冷链科技有限公司 微信公众号-|" + lib.AesEncryptCBC(T_calss_id, "0123456789012345") + "|- @宝智达 微信公众号通知 ", } c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Text_r} c.ServeJSON() return } // 设备通知 ------------------------------------------ func (c *DeviceController) CompanyNotice_List() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } type R_JSONS struct { //必须的大写开头 Data []Company.CompanyNotice_R Num int64 Page int Page_size int } var r_jsons R_JSONS page, _ := c.GetInt("page") println(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_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } r_jsons.Data, r_jsons.Num = Company.Read_CompanyNotice_List(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } r_jsons.Data = Company.Read_CompanyNotice_All(T_pid, T_name) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return } func (c *DeviceController) CompanyNotice_Get() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } t_c := Company.CompanyNotice{ T_pid: T_pid, T_name: T_name, T_Notice_wx: T_Notice_wx, T_Notice_wx2: T_Notice_wx2, T_Notice_phone: T_Notice_phone, T_Notice_message: T_Notice_message, T_Notice_mailbox: T_Notice_mailbox, T_Notice_mechanism: 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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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"); !is { c.Data["json"] = lib.JSONS{Code: 203, Msg: "修改失败"} c.ServeJSON() return } System.Add_UserLogs_T(admin_r.T_uuid, "设备管理", "通知修改", R_DeviceNotice) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } func (c *DeviceController) CompanyNotice_Del() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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(admin_r.T_uuid, "设备管理", "通知删除", strconv.Itoa(id)) c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"} c.ServeJSON() return } // 设备通知绑定 func (c *DeviceController) DeviceNoticeBind_List() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } 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") Name := c.GetString("Name") T_sn := c.GetString("T_sn") T_notice_id, _ := c.GetInt("T_notice_id") page_z, _ := c.GetInt("page_z") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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_Notice_ALL_1(T_pid, T_notice_id, page, page_z, T_sn, Name, "") 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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_notice_id, _ := c.GetInt("T_notice_id") T_sn := c.GetString("T_sn") T_id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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_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(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() { // 验证登录 b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey")) if !b_ { c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"} c.ServeJSON() return } T_notice_id, _ := c.GetInt("T_notice_id") T_sn := c.GetString("T_sn") T_id, _ := c.GetInt("T_id") T_pid := admin_r.T_pid if T_pid == 0 { T_pid, _ = c.GetInt("T_pid") } 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 != 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(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_All() { type R_JSONS struct { //必须的大写开头 Data []Device.DeviceType Num int64 Page int Page_size int } var r_jsons R_JSONS r_jsons.Data = Device.Read_DeviceType_List_All() c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons} c.ServeJSON() return }