1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113 |
- package controllers
- import (
- "Cold_Api/Nats/NatsServer"
- "Cold_Api/conf"
- "Cold_Api/controllers/lib"
- "Cold_Api/models/Account"
- "Cold_Api/models/Company"
- "Cold_Api/models/Device"
- "Cold_Api/models/System"
- "Cold_Api/models/Warning"
- "encoding/json"
- "fmt"
- "github.com/beego/beego/v2/adapter/orm"
- "github.com/beego/beego/v2/core/logs"
- beego "github.com/beego/beego/v2/server/web"
- uuid "github.com/satori/go.uuid"
- "github.com/shopspring/decimal"
- "github.com/xuri/excelize/v2"
- "math"
- "os"
- "strconv"
- "strings"
- "time"
- )
- type UserController struct {
- beego.Controller
- Admin_r Account.Admin // 登陆的用户
- T_pid int // 公司id
- }
- func (c *UserController) Prepare() {
- GetCookie := c.Ctx.GetCookie("User_tokey")
- GetString := c.GetString("User_tokey")
- User_tokey := GetCookie
- if len(User_tokey) == 0 {
- User_tokey = GetString
- }
- if Account.Admin_r == nil {
- return
- }
- c.Admin_r = *Account.Admin_r
- T_pid := c.Admin_r.T_pid
- EntryPid, _ := Account.Redis_Tokey_T_pid_Get(User_tokey)
- if EntryPid > 0 {
- T_pid = EntryPid
- }
- c.T_pid = T_pid
- }
- // 获取微信二维码 ( 扫描后 ,Nats 自动绑定在 Admin->T_wx )
- func (c *UserController) User_WxQRCode() {
- T_name := c.GetString("T_name")
- WxQRCode_str, _ := NatsServer.Wx_GenerateQRCode("-|" + lib.AesEncryptCBC(c.Admin_r.T_uuid+"/"+T_name, "0123456789012345") + "|- @宝智达冷链 微信公众号通知")
- WxQRCode_str = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=" + WxQRCode_str
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: WxQRCode_str}
- c.ServeJSON()
- return
- }
- // 用户绑定的公司列表
- func (c *UserController) Company_Tree() {
- var r_jsons lib.R_JSONS
- T_name := c.GetString("T_name")
- r_jsons.Data = Account.Read_Company_Tree(c.Admin_r, T_name)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) Company_Transport_List() {
- var r_jsons lib.R_JSONS
- T_name := c.GetString("T_name")
- r_jsons.Data = Account.Read_Transport_Company_List(T_name)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- // 所有公司树
- func (c *UserController) Company_List() {
- var r_jsons lib.R_JSONS
- T_name := c.GetString("T_name")
- r_jsons.Data = Account.Read_Company_List(T_name)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) Company_Get() {
- var r_jsons lib.R_JSONS
- Company_r, err := Account.Read_Company_ById(c.T_pid)
- if err != nil {
- logs.Warning(lib.FuncName(), "获取公司信息失败", err)
- }
- r_jsons.Data = Account.CompanyToCompany_R(Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) Company_Add() {
- T_mid, _ := c.GetInt("T_mid")
- T_name := c.GetString("T_name")
- T_plan := c.GetString("T_plan")
- T_data := c.GetString("T_data")
- T_v3d := c.GetString("T_v3d")
- T_type, _ := c.GetInt("T_type")
- T_Address := c.GetString("T_Address")
- T_coordinate := c.GetString("T_coordinate")
- var_ := Account.Company{
- T_mid: T_mid,
- T_name: T_name,
- T_State: 1,
- T_plan: T_plan,
- T_data: T_data,
- T_v3d: T_v3d,
- T_warning: 1,
- T_type: T_type,
- T_Address: T_Address,
- T_coordinate: T_coordinate,
- }
- id, err := Account.Add_Company(var_)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
- c.ServeJSON()
- return
- }
- if c.Admin_r.T_pids != "*" {
- T_pids := []int{int(id)}
- if err = Account.Add_Company_bind(c.Admin_r, T_pids); err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "公司绑定失败"}
- c.ServeJSON()
- return
- }
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "添加", var_)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: id}
- c.ServeJSON()
- return
- }
- func (c *UserController) Company_Edit() {
- Id, Id_err := c.GetInt("Id")
- if Id_err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_name := c.GetString("T_name")
- T_type, _ := c.GetInt("T_type")
- T_Address := c.GetString("T_Address")
- T_coordinate := c.GetString("T_coordinate")
- if len(T_name) > 0 {
- Company_r.T_name = T_name
- }
- if T_type > 0 {
- Company_r.T_type = T_type
- }
- if len(T_Address) > 0 {
- Company_r.T_Address = T_Address
- }
- if len(T_coordinate) > 0 {
- Company_r.T_coordinate = T_coordinate
- }
- is := Account.Update_Company(Company_r, "T_name", "T_type", "T_Address", "T_coordinate")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "修改", Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 数字孪生
- func (c *UserController) Company_DigitalTwin() {
- Id, Id_err := c.GetInt("Id")
- if Id_err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_plan := c.GetString("T_plan")
- T_data := c.GetString("T_data")
- T_v3d := c.GetString("T_v3d")
- T_warning, _ := c.GetInt("T_warning")
- Company_r.T_plan = T_plan
- Company_r.T_data = T_data
- Company_r.T_v3d = T_v3d
- Company_r.T_warning = T_warning
- is := Account.Update_Company(Company_r, "T_plan", "T_data", "T_v3d", "T_warning")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "修改数字孪生", Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 充值
- func (c *UserController) Company_Pay() {
- Id, Id_err := c.GetInt("Id")
- if Id_err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_balance, _ := c.GetFloat("T_balance")
- T_money64, _ := decimal.NewFromFloat(float64(Company_r.T_money) + T_balance).Round(2).Float64()
- Company_r.T_money = float32(T_money64)
- is := Account.Update_Company(Company_r, "T_money")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "充值失败!"}
- c.ServeJSON()
- return
- }
- // 添加充值记录
- bill := Company.CompanyBill{
- T_pid: Company_r.Id,
- T_type: "充值",
- T_project: "充值",
- T_bill: "充值",
- T_charging: float32(T_balance),
- T_balance: float32(T_money64),
- }
- _, err = Company.Add_CompanyBill(bill)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "充值失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "充值", Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 报警统计
- func (c *UserController) Company_Warning() {
- Id, Id_err := c.GetInt("Id")
- if Id_err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_warning, _ := c.GetInt("T_warning")
- if T_warning > 0 {
- Company_r.T_warning = T_warning
- }
- is := Account.Update_Company(Company_r, "T_warning")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "修改报警统计", Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) Company_Del() {
- Id, Id_err := c.GetInt("Id")
- if Id_err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- ids := Account.ReadCompanyIds_T_path(Company_r.T_path)
- if cnt := Account.Read_Admin_Num_ByT_pid(ids); cnt > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "有关联用户,禁止删除!"}
- c.ServeJSON()
- return
- }
- o := orm.NewOrm()
- o.Begin()
- for _, id := range ids {
- if is := Account.Delete_Company(o, id); !is {
- o.Rollback()
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
- c.ServeJSON()
- return
- }
- if err = Account.Delete_Company_bind_T_pids(o, id); err != nil {
- o.Rollback()
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
- c.ServeJSON()
- return
- }
- }
- o.Commit()
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "删除", Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 进入公司
- func (c *UserController) Company_Entry() {
- GetCookie := c.Ctx.GetCookie("User_tokey")
- GetString := c.GetString("User_tokey")
- User_tokey := GetCookie
- if len(User_tokey) == 0 {
- User_tokey = GetString
- }
- T_pid, _ := c.GetInt("T_pid")
- // 操作pid
- company_r, err := Account.Read_Company_ById(T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- visit := false
- if c.Admin_r.T_pid > 0 && strings.Contains(company_r.T_path, fmt.Sprintf("/%d/", c.Admin_r.T_pid)) {
- visit = true
- }
- if c.Admin_r.T_pid == 0 {
- if c.Admin_r.T_pids == "*" {
- visit = true
- } else {
- pids := lib.SplitStringToIntIds(c.Admin_r.T_pids, "P")
- if len(pids) > 0 {
- list := Account.ReadCompanyIds_T_pids(pids)
- for _, v := range list {
- if T_pid == v {
- visit = true
- break
- }
- }
- }
- }
- }
- if !visit {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "没有权限!"}
- c.ServeJSON()
- return
- }
- Account.Redis_Tokey_T_pid_Set(User_tokey, T_pid)
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "进入公司", T_pid)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 记账扣费
- func (c *UserController) Company_Charging() {
- Id, Id_err := c.GetInt("Id")
- if Id_err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_Charging, _ := c.GetInt("T_Charging")
- Company_r.T_Charging = T_Charging
- is := Account.Update_Company(Company_r, "T_Charging")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "充值失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "记账扣费", Company_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 检查 Tokey 是否过期
- // 用户管理
- func (c *UserController) User_List() {
- var r_jsons lib.R_JSONS
- page, _ := c.GetInt("page")
- if page < 1 {
- page = 1
- }
- page_z, _ := c.GetInt("page_z")
- if page_z < 1 {
- page_z = conf.Page_size
- }
- T_name := c.GetString("T_name")
- Account.Read_Power_All_Map()
- r_jsons.Data, r_jsons.Num = Account.Read_Admin_List(c.T_pid, T_name, page, page_z)
- r_jsons.Page = page
- r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) User_Get() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Account.AdminToAdmin_R(admin_r)}
- c.ServeJSON()
- return
- }
- func (c *UserController) User_Info() {
- type User_ struct {
- User Account.Admin_R
- //Power Account.Power // 权限
- //Menu map[string]Account.Menu_R // 菜单
- //Menu []Account.Menu // 菜单
- }
- Admin_r := User_{}
- Admin_r.User = Account.AdminToAdmin_R(c.Admin_r)
- //Admin_r.Power, _ = Account.Read_Power_ById(admin_r.T_power)
- //Admin_r.Menu = Account.Read_Menu_Tree(Power.T_menu, T_pid)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Admin_r}
- c.ServeJSON()
- return
- }
- func (c *UserController) User_Post() {
- admin_r := c.Admin_r
- T_name := c.GetString("T_name")
- T_pass := c.GetString("T_pass")
- T_phone := c.GetString("T_phone")
- T_mail := c.GetString("T_mail")
- T_wx := c.GetString("T_wx")
- if len(T_pass) < 8 && len(T_pass) > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
- c.ServeJSON()
- return
- }
- if len(T_name) > 0 {
- admin_r.T_name = T_name
- }
- if len(T_pass) >= 8 {
- admin_r.T_pass = T_pass
- }
- if len(T_phone) > 0 {
- admin_r.T_phone = T_phone
- }
- if len(T_mail) > 0 {
- admin_r.T_mail = T_mail
- }
- if len(T_wx) > 0 {
- if T_wx == "-" {
- T_wx = ""
- }
- admin_r.T_wx = T_wx
- }
- is := Account.Update_Admin(admin_r, "T_name", "T_pass", "T_phone", "T_mail", "T_wx")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- admin_r.T_pass = "******"
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "修改个人信息", admin_r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) User_Add() {
- T_power, _ := c.GetInt("T_power")
- T_name := c.GetString("T_name")
- T_user := c.GetString("T_user")
- T_pass := c.GetString("T_pass")
- T_phone := c.GetString("T_phone")
- T_mail := c.GetString("T_mail")
- T_wx := c.GetString("T_wx")
- T_uuid := uuid.NewV4().String()
- var_ := Account.Admin{
- T_uuid: T_uuid,
- T_pid: c.T_pid,
- T_name: T_name,
- T_user: T_user,
- T_phone: T_phone,
- T_mail: T_mail,
- T_wx: T_wx,
- T_pass: T_pass,
- T_power: T_power,
- T_State: 1,
- }
- if len(T_pass) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
- c.ServeJSON()
- return
- }
- _, err := Account.Read_Admin_T_user(T_user)
- if err == nil {
- c.Data["json"] = lib.JSONS{Code: 302, Msg: "账户重复!"}
- c.ServeJSON()
- return
- }
- _, err = Account.Add_Admin(var_)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
- c.ServeJSON()
- return
- }
- var_.T_pass = "******"
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "添加", var_)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) User_Edit() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- T_power, T_power_err := c.GetInt("T_power")
- T_name := c.GetString("T_name")
- T_pass := c.GetString("T_pass")
- T_phone := c.GetString("T_phone")
- T_mail := c.GetString("T_mail")
- if T_power_err == nil {
- r.T_power = T_power
- }
- if len(T_pass) < 8 && len(T_pass) > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
- c.ServeJSON()
- return
- }
- if len(T_name) > 0 {
- r.T_name = T_name
- }
- if len(T_pass) >= 8 {
- r.T_pass = T_pass
- }
- if len(T_phone) > 0 {
- r.T_phone = T_phone
- }
- if len(T_mail) > 0 {
- r.T_mail = T_mail
- }
- is := Account.Update_Admin(r, "T_power", "T_pid", "T_name", "T_pass", "T_phone", "T_mail")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- if len(T_name) > 0 {
- if is = Company.Update_CompanyNotice_Bind_By_T_uuid(T_uuid, T_name); !is {
- logs.Info("修改用户 => 修改用户关联报警通知失败", T_uuid, T_name)
- }
- }
- r.T_pass = "******"
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "编辑", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) User_Del() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) <= 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- admin_r_lod, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- if is := Account.Delete_Admin(admin_r_lod); !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
- c.ServeJSON()
- return
- }
- if is := Company.Delete_CompanyNotice_Bind_By_T_uuid(T_uuid); !is {
- logs.Info("删除用户 => 删除用户关联报警通知失败", T_uuid)
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "删除", T_uuid)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 管理员
- func (c *UserController) User_Home() {
- // 报警标识
- //设备管理-设备报警 callthepolice
- //公司管理-设备报警 companyCallthepolice
- //T_warning_sign := c.GetString("T_warning_sign")
- power, err := Account.Read_Power_ById(c.Admin_r.T_power)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "获取菜单失败"}
- c.ServeJSON()
- return
- }
- ret := Account.Read_Menu_Bind_List(power.Id, power.T_menu, c.T_pid)
- var T_warning_sign string
- for _, v := range ret.MenuPermission {
- if v == Warning.CompanyCallthepolice {
- T_warning_sign = Warning.CompanyCallthepolice
- break
- }
- if v == Warning.Callthepolice {
- T_warning_sign = Warning.Callthepolice
- }
- }
- // 验证登录
- admin_r := c.Admin_r
- type NoticeRecord struct {
- Sms int // 短信
- Phone int // 电话
- }
- type Info struct {
- T_name string // 姓名
- T_pids string // 内部用户绑定的公司id
- T_pid int // 公司id
- T_Days int // 服务天数
- Admin []Account.Admin_ // 专属管理员
- WarningSign string // 报警标识
- WarningNum int64 // 报警数量
- UntreatedWarningNum int64 // 未处理报警数量
- NewsNum int64 // 消息数量
- WorkOrderNum int64 // 工单数量
- WarningRate float32 // 设备报警率
- UntreatedWorkOrderNum int64 // 未处理工单数量
- Balance float32 // 余额
- NoticeRecord NoticeRecord // 通知记录
- CompanyKey string
- CompanyName string
- }
- var info Info
- info.T_name = admin_r.T_name
- info.T_pid = admin_r.T_pid
- var Company_r Account.Company
- if c.T_pid > 0 {
- Company_r, err = Account.Read_Company_ById(c.T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- info.CompanyKey = Company_r.T_key
- info.CompanyName = Company_r.T_name
- }
- if admin_r.T_pid > 0 {
- info.WarningSign = T_warning_sign
- bindSN, err := Account.Read_UserDevice_List(c.Admin_r)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- power, _ := Account.Read_Power_ById(admin_r.T_power)
- company, _ := Account.Read_Company_ById(admin_r.T_pid)
- info.T_Days = lib.GetDiffDays(time.Now(), company.CreateTime)
- AdminList := Account.Read_Admin_List_T_pids(admin_r.T_pid)
- var Admin_ []Account.Admin_
- for _, v := range AdminList {
- Admin_ = append(Admin_, Account.Admin_RToAdmin_(v))
- }
- info.Admin = Admin_
- T_pids := []int{}
- // 拥有公司管理-设备报警权限 统计公司及其所有子公司的今日报警数量、未处理报警数量、我的消息数量
- if T_warning_sign == Warning.CompanyCallthepolice {
- T_pids = Account.ReadCompanyIds_T_path(Company_r.T_path)
- info.WarningNum = Warning.Read_Warning_ALL_T_State_Count(0, T_pids, 1, bindSN, power.T_warning, true)
- info.UntreatedWarningNum = Warning.Read_Warning_ALL_T_State_Count(0, T_pids, 3, bindSN, power.T_warning, false)
- info.NewsNum = Warning.Read_Warning_ALL_T_State_Count(0, T_pids, 1, bindSN, "T1003|T1002|", false)
- }
- // 拥有设备管理-设备报警权限 统计本公司今日报警数量、未处理报警数量、我的消息数量
- if T_warning_sign == Warning.Callthepolice {
- info.WarningNum = Warning.Read_Warning_ALL_T_State_Count(admin_r.T_pid, T_pids, 1, bindSN, power.T_warning, true)
- info.UntreatedWarningNum = Warning.Read_Warning_ALL_T_State_Count(admin_r.T_pid, T_pids, 3, bindSN, power.T_warning, false)
- info.NewsNum = Warning.Read_Warning_ALL_T_State_Count(admin_r.T_pid, T_pids, 1, bindSN, "T1003|T1002|", false)
- }
- info.Balance = company.T_money
- info.NoticeRecord.Sms = Warning.Get_WarningSandNum_CurrentMonth(admin_r.T_pid, 1)
- info.NoticeRecord.Phone = Warning.Get_WarningSandNum_CurrentMonth(admin_r.T_pid, 2)
- }
- if admin_r.T_pid == 0 {
- if len(admin_r.T_pids) > 0 && admin_r.T_pids != "*" {
- info.T_pids = admin_r.T_pids
- info.WarningRate = Warning.Read_WarningRate_Yesterday(admin_r.T_uuid)
- }
- info.WorkOrderNum, info.UntreatedWorkOrderNum = NatsServer.Read_WorkOrderT_State_Count(admin_r.T_pids)
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: info}
- c.ServeJSON()
- return
- }
- // 内部用户管理
- func (c *UserController) Admin_List() {
- var r_jsons lib.R_JSONS
- page, _ := c.GetInt("page")
- if page < 1 {
- page = 1
- }
- page_z, _ := c.GetInt("page_z")
- if page_z < 1 {
- page_z = conf.Page_size
- }
- T_name := c.GetString("T_name")
- if c.Admin_r.T_pid > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "无权查看!"}
- c.ServeJSON()
- return
- }
- T_bind_company, _ := c.GetInt("T_bind_company") // 管理员绑定公司 0-全部 1-绑定公司
- Account.Read_Power_All_Map()
- userList, num := Account.Read_Admin_List(0, T_name, page, page_z)
- r_jsons.Data, r_jsons.Num = userList, num
- // 过滤已绑定公司列表
- if T_bind_company == 1 {
- var adminList []Account.Admin_R
- for _, v := range userList {
- if len(v.T_pids) == 0 || v.T_pids == "*" {
- continue
- }
- adminList = append(adminList, v)
- }
- r_jsons.Data = adminList
- }
- 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 *UserController) Admin_Get() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Account.AdminToAdmin_R(admin_r)}
- c.ServeJSON()
- return
- }
- func (c *UserController) Admin_Add() {
- T_power, _ := c.GetInt("T_power")
- T_name := c.GetString("T_name")
- T_user := c.GetString("T_user")
- T_pass := c.GetString("T_pass")
- T_phone := c.GetString("T_phone")
- T_mail := c.GetString("T_mail")
- T_wx := c.GetString("T_wx")
- var_ := Account.Admin{
- T_uuid: uuid.NewV4().String(),
- T_pid: 0,
- T_name: T_name,
- T_user: T_user,
- T_phone: T_phone,
- T_mail: T_mail,
- T_wx: T_wx,
- T_pass: T_pass,
- T_power: T_power,
- T_State: 1,
- }
- if len(T_pass) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
- c.ServeJSON()
- return
- }
- _, err := Account.Read_Admin_T_user(T_user)
- if err == nil {
- c.Data["json"] = lib.JSONS{Code: 302, Msg: "账户重复!"}
- c.ServeJSON()
- return
- }
- _, err = Account.Add_Admin(var_)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
- c.ServeJSON()
- return
- }
- var_.T_pass = "******"
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "内部用户管理", "添加", var_)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) Admin_Edit() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- T_power, T_power_err := c.GetInt("T_power")
- T_user := c.GetString("T_user")
- T_name := c.GetString("T_name")
- T_pass := c.GetString("T_pass")
- T_phone := c.GetString("T_phone")
- T_mail := c.GetString("T_mail")
- T_wx := c.GetString("T_wx")
- if T_power_err == nil {
- r.T_power = T_power
- }
- if len(T_pass) < 8 && len(T_pass) > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
- c.ServeJSON()
- return
- }
- if len(T_user) > 0 {
- var admin Account.Admin
- admin, err = Account.Read_Admin_T_user(T_user)
- if err == nil && admin.T_uuid != T_uuid {
- c.Data["json"] = lib.JSONS{Code: 302, Msg: "用户名重复!"}
- c.ServeJSON()
- return
- }
- r.T_user = T_user
- }
- if len(T_name) > 0 {
- r.T_name = T_name
- }
- if len(T_pass) >= 8 {
- r.T_pass = T_pass
- }
- if len(T_phone) > 0 {
- r.T_phone = T_phone
- }
- if len(T_mail) > 0 {
- r.T_mail = T_mail
- }
- if len(T_wx) > 0 {
- r.T_wx = T_wx
- }
- is := Account.Update_Admin(r, "T_user", "T_power", "T_name", "T_pass", "T_phone", "T_mail", "T_wx")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- if len(T_name) > 0 {
- if is = Company.Update_CompanyNotice_Bind_By_T_uuid(T_uuid, "内管-"+T_name); !is {
- logs.Info("修改内部用户 => 修改内部用户关联报警通知失败", T_uuid, T_name)
- }
- }
- r.T_pass = "********"
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "内部用户管理", "修改", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) Admin_Del() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) <= 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- admin_r_lod, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- if admin_r_lod.Id == 1 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "无权删除!"}
- c.ServeJSON()
- return
- }
- if is := Account.Delete_Admin(admin_r_lod); !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
- c.ServeJSON()
- return
- }
- if is := Company.Delete_CompanyNotice_Bind_By_T_uuid(T_uuid); !is {
- logs.Info("删除内部用户 => 删除内部用户关联报警通知失败", T_uuid)
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "内部用户管理", "删除", T_uuid)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 报警通知的用户列表
- func (c *UserController) User_Notice_List() {
- T_name := c.GetString("T_name")
- type R_JSONS struct {
- //必须的大写开头
- AdminList []Account.Admin_R
- UserList []Account.Admin_R
- }
- var AdminList, UserList []Account.Admin_R
- var r_jsons R_JSONS
- // 操作pid
- company_r, err := Account.Read_Company_ById(c.T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- T_pids := []int{}
- for _, v := range strings.Split(strings.Trim(company_r.T_path, "/"), "/") {
- pid, _ := strconv.Atoi(v)
- T_pids = append(T_pids, pid)
- }
- // 绑定公司id的内部用户列表
- AdminList = Account.Read_Admin_List_T_pids(c.T_pid)
- // 绑定公司id的公司用户列表
- //r_jsons.UserList = Account.Read_Admin_List_T_pid(c.T_pid)
- // 绑定上级公司用户列表
- UserList = Account.Read_Parent_Admin_List(T_pids)
- if len(T_name) > 0 {
- for _, v := range AdminList {
- if strings.Contains(v.T_name, T_name) {
- r_jsons.AdminList = append(r_jsons.AdminList, v)
- }
- }
- for _, v := range UserList {
- if strings.Contains(v.T_name, T_name) {
- r_jsons.UserList = append(r_jsons.UserList, v)
- }
- }
- } else {
- r_jsons.AdminList = AdminList
- r_jsons.UserList = UserList
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- // 管理员绑定公司
- func (c *UserController) AdminCompanyBind_List() {
- var r_jsons lib.R_JSONS
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- r_jsons.Data = Account.Read_Company_List_ByT_pids(r.T_pids)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) AdminCompanyBind_Add() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- T_pid, _ := c.GetInt("T_pid")
- if T_pid == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- if r.T_pids == "*" {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- Company_r, err := Account.Read_Company_ById(T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
- c.ServeJSON()
- return
- }
- T_pids := Account.ReadCompanyIds_T_path(Company_r.T_path)
- if err = Account.Add_Company_bind(r, T_pids); err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "公司绑定失败"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs(c.Admin_r.T_uuid, "内部用户管理", "公司绑定添加", T_uuid+"-"+strconv.Itoa(T_pid))
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) AdminCompanyBind_Del() {
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- T_pid, _ := c.GetInt("T_pid")
- if T_pid == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Admin_ByUuid(T_uuid)
- Company_r, err := Account.Read_Company_ById(T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
- c.ServeJSON()
- return
- }
- T_pids := Account.ReadCompanyIds_T_path(Company_r.T_path)
- if len(T_pids) == 0 {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- if err = Account.Delete_Company_bind(r, T_pids); err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "公司绑定失败"}
- c.ServeJSON()
- return
- }
- if is := Company.Delete_CompanyNotice_Bind_By_T_uuid_T_pid(T_uuid, T_pids); !is {
- logs.Info("删除内部用户公司绑定 => 删除内部用户绑定的公司关联报警通知失败", T_uuid)
- }
- System.Add_UserLogs(c.Admin_r.T_uuid, "内部用户管理", "公司绑定删除", T_uuid+"-"+strconv.Itoa(T_pid))
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 权限管理
- func (c *UserController) Power_List() {
- var r_jsons lib.R_JSONS
- page, _ := c.GetInt("page")
- if page < 1 {
- page = 1
- }
- page_z, _ := c.GetInt("page_z")
- if page_z < 1 {
- page_z = conf.Page_size
- }
- Name := c.GetString("T_name")
- r_jsons.Data, r_jsons.Num = Account.Read_Power_List(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 *UserController) Power_List_All() {
- r, err := Account.Read_Power_ById(c.Admin_r.T_power)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- var r_jsons lib.R_JSONS
- r_jsons.Data = Account.Read_Power_List_ALL_User(r.T_select)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) Power_Get() {
- type Data struct {
- Power Account.Power_
- Menu []Account.Menu
- Menu_checked []int
- Select []Account.Power_R
- Warning []Warning.WarningType_R
- }
- var data Data
- id, id_err := c.GetInt("T_id")
- if id_err != nil || id == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
- c.ServeJSON()
- return
- }
- power, err := Account.Read_Power_ById(id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
- c.ServeJSON()
- return
- }
- data.Power = Account.PowerToPower_(power)
- data.Menu, data.Menu_checked = Account.Read_Menu_List_All()
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_menu Err!"}
- c.ServeJSON()
- return
- }
- if power.T_menu != "*" {
- data.Menu_checked = lib.SplitStringToIntIds(power.T_menu, "M")
- }
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_menu Err!"}
- c.ServeJSON()
- return
- }
- data.Select = Account.Read_Power_List_ALL_T_select(power.T_select)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_select Err!"}
- c.ServeJSON()
- return
- }
- data.Warning = Warning.Read_WarningType_All_Power_T_Warning(power.T_warning)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_warning Err!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: data}
- c.ServeJSON()
- return
- }
- func (c *UserController) Power_Add() {
- T_name := c.GetString("T_name")
- T_select := c.GetString("T_select")
- T_warning := c.GetString("T_warning")
- T_menu := c.GetString("T_menu")
- var_ := Account.Power{
- T_name: T_name,
- T_select: T_select,
- T_warning: T_warning,
- T_menu: T_menu,
- T_State: 1,
- }
- _, err := Account.Add_Power(var_)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "权限管理", "添加", var_)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) Power_Edit() {
- Id, Id_err := c.GetInt("T_id")
- if Id_err != nil || Id == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- if Id == 1 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "无权修改!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Power_ById(Id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_name := c.GetString("T_name")
- T_select := c.GetString("T_select")
- T_warning := c.GetString("T_warning")
- T_menu := c.GetString("T_menu")
- if len(T_name) > 0 {
- r.T_name = T_name
- }
- if len(T_select) > 0 {
- r.T_select = T_select
- }
- if len(T_warning) > 0 {
- r.T_warning = T_warning
- }
- if len(T_menu) > 0 {
- r.T_menu = T_menu
- }
- is := Account.Update_Power(r, "T_name", "T_select", "T_warning", "T_menu")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 302, Msg: "修改失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs_T(c.Admin_r.T_uuid, "权限管理", "修改", r)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) Power_Del() {
- id, id_err := c.GetInt("T_id")
- if id_err != nil || id == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- r, err := Account.Read_Power_ById(id)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- if cnt := Account.Read_Admin_Num_ByT_power(id); cnt > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "有关联用户,禁止删除!"}
- c.ServeJSON()
- return
- }
- is := Account.Delete_Power(r)
- if !is {
- c.Data["json"] = lib.JSONS{Code: 302, Msg: "删除失败!"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs(c.Admin_r.T_uuid, "权限管理", "删除", strconv.Itoa(id))
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- // 菜单列表
- func (c *UserController) User_Menu_List() {
- type R_JSONS struct {
- //必须的大写开头
- Data interface{}
- Permission interface{}
- }
- var r_jsons R_JSONS
- power, err := Account.Read_Power_ById(c.Admin_r.T_power)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "获取菜单失败"}
- c.ServeJSON()
- return
- }
- //logs.Info("登录用户 菜单 pid 为:", c.T_pid)
- ret := Account.Read_Menu_Bind_List(power.Id, power.T_menu, c.T_pid)
- r_jsons.Data = ret.Menu
- r_jsons.Permission = ret.Permission
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- // 权限菜单列表
- func (c *UserController) Menu_List_All() {
- var r_jsons lib.R_JSONS
- r_jsons.Data, _ = Account.Read_Menu_List_All()
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) Menu_Excel() {
- filename := fmt.Sprintf("冷链3.0菜单")
- f := excelize.NewFile()
- Style1, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Bold: true, Size: 16, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"},
- })
- Style2, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Bold: true, Size: 14, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "left", Color: "000000", Style: 1},
- {Type: "top", Color: "000000", Style: 1},
- {Type: "bottom", Color: "000000", Style: 1},
- {Type: "right", Color: "000000", Style: 1},
- },
- })
- f.MergeCell("Sheet1", "A1", "G1")
- f.SetRowStyle("Sheet1", 1, 1, Style1)
- f.SetCellValue("Sheet1", "A1", "Menu")
- f.SetRowHeight("Sheet1", 1, 30)
- f.MergeCell("Sheet1", "H1", "M1")
- f.SetRowStyle("Sheet1", 1, 1, Style1)
- f.SetCellValue("Sheet1", "H1", "API")
- f.SetRowHeight("Sheet1", 1, 30)
- f.SetCellStyle("Sheet1", "A2", "G2", Style2)
- f.SetRowHeight("Sheet1", 2, 25)
- // 这里设置表头
- f.SetCellValue("Sheet1", "A2", "ID")
- f.SetCellValue("Sheet1", "B2", "t_mid")
- f.SetCellValue("Sheet1", "C2", "t_name")
- f.SetCellValue("Sheet1", "D2", "t_permission")
- f.SetCellValue("Sheet1", "E2", "t_sort")
- f.SetCellValue("Sheet1", "F2", "t_pid")
- f.SetCellValue("Sheet1", "G2", "t_icon")
- f.SetCellValue("Sheet1", "H2", "ID")
- f.SetCellValue("Sheet1", "I2", "t__menu__id")
- f.SetCellValue("Sheet1", "J2", "t_name")
- f.SetCellValue("Sheet1", "K2", "t_uri")
- f.SetCellValue("Sheet1", "L2", "t_method")
- f.SetCellValue("Sheet1", "M2", "t_enable")
- // 设置列宽
- f.SetColWidth("Sheet1", "A", "M", 15)
- line := 2
- menu := Account.Read_Menu_All()
- for _, m := range menu {
- Menu_Call(f, m, line)
- }
- Style11, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Size: 10, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "top", Color: "000000", Style: 1},
- },
- })
- Style22, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Size: 10, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "left", Color: "000000", Style: 1},
- },
- })
- Style33, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Size: 10, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "right", Color: "000000", Style: 1},
- },
- })
- Style44, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Size: 10, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "bottom", Color: "000000", Style: 1},
- },
- })
- //// 循环写入数据
- for _, v := range menu {
- line1 := line
- line = Menu_Call(f, v, line)
- f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line1), fmt.Sprintf("M%d", line1), Style11)
- f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("A%d", line), Style22)
- f.SetCellStyle("Sheet1", fmt.Sprintf("M%d", line), fmt.Sprintf("M%d", line), Style33)
- f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("M%d", line), Style44)
- }
- timeStr := filename + fmt.Sprintf("(%s)", lib.GetRandstring(8, "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", 0))
- // 保存文件
- if err := f.SaveAs("ofile/" + timeStr + ".xlsx"); err != nil {
- logs.Error(err)
- }
- var url string
- ////// 上传 OSS
- //url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+timeStr+".xlsx", "ofile/"+timeStr+".xlsx")
- //if !is {
- // c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"}
- // c.ServeJSON()
- // return
- //}
- ////删除目录
- //err = os.Remove("ofile/" + timeStr + ".xlsx")
- //if err != nil {
- // logs.Error(err)
- //}
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
- c.ServeJSON()
- return
- }
- func Menu_Call(f *excelize.File, v Account.Menu, line int) int {
- line++
- f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), v.Id)
- f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_mid)
- f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_name)
- f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_permission)
- f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), v.T_sort)
- f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), v.T_pid)
- f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_icon)
- apiList := Account.Read_API_List_ByMenuId(v.Id)
- for _, api := range apiList {
- f.SetCellValue("Sheet1", fmt.Sprintf("H%d", line), api.Id)
- f.SetCellValue("Sheet1", fmt.Sprintf("I%d", line), api.T_Menu_Id)
- f.SetCellValue("Sheet1", fmt.Sprintf("J%d", line), api.T_name)
- f.SetCellValue("Sheet1", fmt.Sprintf("K%d", line), api.T_uri)
- f.SetCellValue("Sheet1", fmt.Sprintf("L%d", line), api.T_method)
- f.SetCellValue("Sheet1", fmt.Sprintf("M%d", line), api.T_enable)
- line++
- }
- return line
- }
- // 流量池
- func (c *UserController) Flow_Pool() {
- var r_jsons lib.R_JSONS
- r_jsons.Data, _ = lib.Yidong_group_data_margin()
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- // 账单下载
- func (c *UserController) CompanyBill_Excel() {
- T_month := c.GetString("T_month")
- _, err := time.Parse("2006-01", T_month)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "日期格式错误!"}
- c.ServeJSON()
- return
- }
- year, month := strings.Split(T_month, "-")[0], strings.Split(T_month, "-")[1]
- company, _ := Account.Read_Company_ById(c.Admin_r.T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- filename := fmt.Sprintf("%s%s年%s月账单", company.T_name, year, month)
- f := excelize.NewFile()
- Style1, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Bold: true, Size: 16, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center"},
- })
- Style2, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Bold: true, Size: 14, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "left", Color: "000000", Style: 1},
- {Type: "top", Color: "000000", Style: 1},
- {Type: "bottom", Color: "000000", Style: 1},
- {Type: "right", Color: "000000", Style: 1},
- },
- })
- f.MergeCell("Sheet1", "A1", "G1")
- f.SetRowStyle("Sheet1", 1, 1, Style1)
- f.SetCellValue("Sheet1", "A1", filename)
- f.SetRowHeight("Sheet1", 1, 30)
- f.SetCellStyle("Sheet1", "A2", "G2", Style2)
- f.SetRowHeight("Sheet1", 2, 25)
- // 这里设置表头
- f.SetCellValue("Sheet1", "A2", "编号")
- f.SetCellValue("Sheet1", "B2", "项目")
- f.SetCellValue("Sheet1", "C2", "说明")
- f.SetCellValue("Sheet1", "D2", "扣费/充值")
- f.SetCellValue("Sheet1", "E2", "金额(元)")
- f.SetCellValue("Sheet1", "F2", "余额(元)")
- f.SetCellValue("Sheet1", "G2", "时间")
- // 设置列宽
- f.SetColWidth("Sheet1", "A", "A", 10)
- f.SetColWidth("Sheet1", "B", "B", 50)
- f.SetColWidth("Sheet1", "C", "C", 15)
- f.SetColWidth("Sheet1", "D", "D", 12)
- f.SetColWidth("Sheet1", "E", "E", 15)
- f.SetColWidth("Sheet1", "F", "F", 15)
- f.SetColWidth("Sheet1", "G", "G", 20)
- line := 2
- CompanyBill_List, err := Company.Read_CompanyBill_List(c.Admin_r.T_pid, T_month)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- // 循环写入数据
- for i, v := range CompanyBill_List {
- line++
- f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), i+1)
- f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_project)
- f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_bill)
- f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_type)
- f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), v.T_charging)
- f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), v.T_balance)
- f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.CreateTime.Format("2006-01-02"))
- }
- Style4, _ := f.NewStyle(
- &excelize.Style{
- Font: &excelize.Font{Size: 12, Family: "宋体"},
- Alignment: &excelize.Alignment{Horizontal: "center", Vertical: "center", WrapText: true},
- Border: []excelize.Border{
- {Type: "left", Color: "000000", Style: 1},
- {Type: "top", Color: "000000", Style: 1},
- {Type: "bottom", Color: "000000", Style: 1},
- {Type: "right", Color: "000000", Style: 1},
- },
- })
- f.SetCellStyle("Sheet1", "A2", fmt.Sprintf("G%d", line), Style4)
- timeStr := filename + fmt.Sprintf("(%s)", lib.GetRandstring(8, "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789", 0))
- // 保存文件
- if err = f.SaveAs("ofile/" + timeStr + ".xlsx"); err != nil {
- logs.Error(err)
- }
- var url string
- //// 上传 OSS
- url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+timeStr+".xlsx", "ofile/"+timeStr+".xlsx")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "oss!"}
- c.ServeJSON()
- return
- }
- //删除目录
- err = os.Remove("ofile/" + timeStr + ".xlsx")
- if err != nil {
- logs.Error(err)
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
- c.ServeJSON()
- return
- }
- // 获取微信支付二维码
- func (c *UserController) WxPay_QRCode() {
- if c.Admin_r.T_pid == 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "非公司用户不能充值"}
- c.ServeJSON()
- return
- }
- Total, _ := c.GetFloat("Total")
- Title := "冷链3.0-" + c.Admin_r.T_user
- res, err := lib.PayTransactionNative(Title, Total)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: err.Error()}
- c.ServeJSON()
- return
- }
- if res.Code != 200 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: res.Message}
- c.ServeJSON()
- return
- }
- var_ := Company.CompanyPayOrder{
- T_pid: c.Admin_r.T_pid,
- T_type: "微信",
- T_title: Title,
- T_total: Total,
- T_order_no: res.OrderNo,
- T_remark: c.Admin_r.T_uuid,
- }
- _, err = Company.Add_CompanyPayOrder(var_)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "添加订单失败!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: res}
- c.ServeJSON()
- return
- }
- // 微信支付回调
- func (c *UserController) WxPay_Notify() {
- type RequestBody struct {
- TradeNo string
- Status string
- }
- type JSON struct {
- Code int
- Message string
- }
- buf := make([]byte, 1024)
- n, _ := c.Ctx.Request.Body.Read(buf)
- logs.Info("Body================ ", string(buf[0:n]))
- //解密
- adc_str, _ := lib.AesDeCrypt(buf[0:n], []byte(conf.Weixin_PwdKey))
- //adc_str, _ := lib.AesDeCrypt(buf[0:n], []byte(conf.Weixin_PwdKey))
- var body RequestBody
- logs.Info("data================ ", string(adc_str))
- err := json.Unmarshal(adc_str, &body)
- if err != nil {
- c.Data["json"] = JSON{Code: 202, Message: "json.Unmarshal is err:" + err.Error()}
- c.ServeJSON()
- }
- payOrder, err := Company.Get_CompanyPayOrder_ByT_order_no(body.TradeNo)
- if err != nil {
- c.Data["json"] = JSON{Code: 202, Message: "查询失败!"}
- c.ServeJSON()
- return
- }
- //交易状态
- //SUCCESS:支付成功
- //REFUND:转入退款
- //NOTPAY:未支付
- //CLOSED:已关闭
- //REVOKED:已撤销(付款码支付)
- //USERPAYING:用户支付中(付款码支付)
- //PAYERROR:支付失败(其他原因,如银行返回失败)
- payOrder.T_status = body.Status
- err = Company.Update_CompanyPayOrder(payOrder, "T_status")
- if err != nil {
- c.Data["json"] = JSON{Code: 202, Message: "更新状态失败!"}
- c.ServeJSON()
- return
- }
- // 添加充值记录
- // 余额加上充值金额
- if body.Status == "SUCCESS" {
- Company_r, err := Account.Read_Company_ById(payOrder.T_pid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
- c.ServeJSON()
- return
- }
- T_money64, _ := decimal.NewFromFloat(float64(Company_r.T_money) + payOrder.T_total).Round(2).Float64()
- Company_r.T_money = float32(T_money64)
- is := Account.Update_Company(Company_r, "T_money")
- if !is {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "充值失败!"}
- c.ServeJSON()
- return
- }
- }
- c.Data["json"] = JSON{Code: 200, Message: "成功"}
- c.ServeJSON()
- return
- }
- // 获取微信支付订单状态
- func (c *UserController) WxPay_GetOrderState() {
- OrderNo := c.GetString("OrderNo")
- payOrder, err := Company.Get_CompanyPayOrder_ByT_order_no(OrderNo)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "成功", Data: payOrder}
- c.ServeJSON()
- return
- }
- // 设备分类绑定
- func (c *UserController) UserDeviceBind_List() {
- var r_jsons lib.R_JSONS
- page, _ := c.GetInt("page")
- if page < 1 {
- page = 1
- }
- page_z, _ := c.GetInt("page_z")
- if page_z < 1 {
- page_z = conf.Page_size
- }
- T_name := c.GetString("T_name")
- T_uuid := c.GetString("T_uuid")
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- bindSN, err := Account.Read_UserDevice_List(admin_r)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- if len(bindSN) == 0 {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- r_jsons.Data, r_jsons.Num = Device.Read_Device_List(&c.Admin_r, bindSN, c.T_pid, T_name, "", "", -1, 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 *UserController) UserDeviceUnbind_List() {
- var r_jsons lib.R_JSONS
- page, _ := c.GetInt("page")
- if page < 1 {
- page = 1
- }
- page_z, _ := c.GetInt("page_z")
- if page_z < 1 {
- page_z = conf.Page_size
- }
- T_name := c.GetString("T_name")
- T_uuid := c.GetString("T_uuid")
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- bindSN, err := Account.Read_UserDevice_List(admin_r)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- r_jsons.Data, r_jsons.Num = Device.Read_User_Unbind_Device_List(&c.Admin_r, bindSN, c.T_pid, T_name, page, page_z)
- r_jsons.Page = page
- r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
- c.ServeJSON()
- return
- }
- func (c *UserController) UserDeviceBind_Add() {
- T_sn := c.GetString("T_sn")
- T_uuid := c.GetString("T_uuid")
- T_oneHey, _ := c.GetInt("T_oneKey") // 一键绑定
- if T_oneHey == 1 {
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- bindSN, err := Account.Read_UserDevice_List(admin_r)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "查询失败!"}
- c.ServeJSON()
- return
- }
- Unbind_Device_List, _ := Device.Read_User_Unbind_Device_List(&c.Admin_r, bindSN, c.T_pid, "", 0, 9999)
- var UserDeviceList []Account.UserDevice
- for _, r := range Unbind_Device_List {
- UserDeviceList = append(UserDeviceList, Account.UserDevice{T_sn: r.T_sn, T_uuid: T_uuid})
- }
- if _, err = Account.Add_UserDevice_Multi(T_uuid, UserDeviceList); err != nil {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "绑定失败"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs(c.Admin_r.T_uuid, "用户管理", "一键绑定主机操作", T_uuid+"-"+T_sn)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- if len(T_uuid) == 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 len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- device, err := Device.Read_Device_ByT_sn(T_sn)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
- c.ServeJSON()
- return
- }
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- if admin_r.T_pid != device.T_pid {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
- c.ServeJSON()
- return
- }
- userdievice, err := Account.Read_UserDevice_ByT_uuid_T_sn(T_uuid, T_sn)
- if userdievice.Id > 0 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "重复绑定!"}
- c.ServeJSON()
- return
- }
- if _, err = Account.Add_UserDevice(Account.UserDevice{T_sn: T_sn, T_uuid: T_uuid}); err != nil {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "绑定失败"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs(c.Admin_r.T_uuid, "用户管理", "绑定主机操作", T_uuid+"-"+T_sn)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- func (c *UserController) UserDeviceBind_Del() {
- T_sn := c.GetString("T_sn")
- T_uuid := c.GetString("T_uuid")
- if len(T_uuid) == 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 len(T_uuid) < 8 {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- device, 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
- }
- admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
- if err != nil {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
- c.ServeJSON()
- return
- }
- if admin_r.T_pid != device.T_pid {
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
- c.ServeJSON()
- return
- }
- userdievice, err := Account.Read_UserDevice_ByT_uuid_T_sn(T_uuid, T_sn)
- if err != nil {
- if err.Error() == orm.ErrNoRows.Error() {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
- c.Data["json"] = lib.JSONS{Code: 202, Msg: "解绑失败!"}
- c.ServeJSON()
- return
- }
- if err = Account.Delete_UserDevice(Account.UserDevice{Id: userdievice.Id, T_sn: T_sn, T_uuid: T_uuid}); err != nil {
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "删除失败"}
- c.ServeJSON()
- return
- }
- System.Add_UserLogs(c.Admin_r.T_uuid, "用户管理", "解绑主机操作", T_uuid+"-"+T_sn)
- c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
- c.ServeJSON()
- return
- }
|