12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069 |
- 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/Product"
- "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_online := c.GetString("T_online")
- T_monitor := c.GetString("T_monitor")
- T_type, _ := c.GetInt("T_type")
- T_pid := admin_r.T_pid
- if T_pid == 0 {
- T_pid, _ = strconv.Atoi(c.Ctx.Request.Header.Get("T_pid"))
- }
- Product.Read_ProductType_All()
- r_jsons.Device_lite, r_jsons.Num = Device.Read_Device_List(admin_r, T_pid, Name, T_monitor, T_online, T_type, 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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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_RestartShutdown() {
- // 验证登录
- 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_RestartShutdown(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) 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) DeviceLogs() {
- type R_JSONS struct {
- //必须的大写开头
- DeviceLogs []Warning.DeviceLogs
- 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")
- c.Data["T_sn"] = T_sn
- r_jsons.DeviceLogs, r_jsons.Num = Warning.Read_DeviceLogs_ALL(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() {
- // 验证登录
- 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
- }
- // 删除设备 传感器
- // fixme 没有检查
- 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移动
- // fixme 没有检查
- 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正常
- // fixme 没有检查
- 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
- }
- // 获取传感器参数
- // fixme 没有检查
- 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_pid := admin_r.T_pid
- if T_pid == 0 {
- T_pid, _ = strconv.Atoi(c.Ctx.Request.Header.Get("T_pid"))
- }
- T_sn := c.GetString("T_sn")
- Name := c.GetString("T_name") // 包含 T_name、T_sn
- T_calss_id, _ := c.GetInt("T_calssid")
- T_notice_id, _ := c.GetInt("T_noticeid")
- 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
- }
- 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(admin_r, T_pid, T_sn, Name, T_calss_id, T_notice_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_DeviceSensorParameter_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
- }
- // 传感器 实时数据显示排序
- // fixme 没有检查
- 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视图
- // fixme 没有检查
- 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 正常数据展示
- // fixme 没有检查
- 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_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")
- T_pid := admin_r.T_pid
- if T_pid == 0 {
- T_pid, _ = strconv.Atoi(c.Ctx.Request.Header.Get("T_pid"))
- }
- 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")
- }
- Warning.Read_WarningType_All_Maps()
- if T_admin == 1 {
- if T_history == 1 {
- // 获取备份
- r_jsons.Data, r_jsons.Num = Warning.Read_Admin_Warning_Backups(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(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(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(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() {
- // 验证登录
- 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 = 2
- 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_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_pid := admin_r.T_pid
- if T_pid == 0 {
- T_pid, _ = strconv.Atoi(c.Ctx.Request.Header.Get("T_pid"))
- }
- Device_data, _ := Warning.Read_Warning(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() {
- // 验证登录
- 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) WarningType_List_All() {
- // 验证登录
- 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()}
- c.ServeJSON()
- return
- }
- // 告警类型列表
- func (c *DeviceController) WarningType_Power_List_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
- }
- power, err := Account.Read_Power_ById(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() {
- // 验证登录
- 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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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(admin_r, 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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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_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
- }
- 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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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_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
- }
- 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) 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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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")
- T_name := c.GetString("T_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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, T_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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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, _ = strconv.Atoi(c.Ctx.Request.Header.Get("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_List_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
- }
|