User.go 26 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084
  1. package controllers
  2. import (
  3. "Cold_Api/Nats/NatsServer"
  4. "Cold_Api/conf"
  5. "Cold_Api/controllers/lib"
  6. "Cold_Api/logs"
  7. "Cold_Api/models"
  8. "Cold_Api/models/Account"
  9. "Cold_Api/models/Company"
  10. "Cold_Api/models/System"
  11. "Cold_Api/models/Warning"
  12. "github.com/beego/beego/v2/adapter/orm"
  13. beego "github.com/beego/beego/v2/server/web"
  14. uuid "github.com/satori/go.uuid"
  15. "math"
  16. "strconv"
  17. "time"
  18. )
  19. type UserController struct {
  20. beego.Controller
  21. Admin_r Account.Admin // 登陆的用户
  22. T_pid int // 公司id
  23. }
  24. func (c *UserController) Prepare() {
  25. GetCookie := c.Ctx.GetCookie("User_tokey")
  26. GetString := c.GetString("User_tokey")
  27. User_tokey := GetCookie
  28. if len(User_tokey) == 0 {
  29. User_tokey = GetString
  30. }
  31. c.Admin_r = *lib.Admin_r
  32. T_pid := c.Admin_r.T_pid
  33. if T_pid == 0 {
  34. T_pid, _ = Account.Redis_Tokey_T_pid_Get(User_tokey)
  35. }
  36. c.T_pid = T_pid
  37. }
  38. // 获取微信二维码 ( 扫描后 ,Nats 自动绑定在 Admin->T_wx )
  39. func (c *UserController) User_WxQRCode() {
  40. T_name := c.GetString("T_name")
  41. WxQRCode_str, _ := NatsServer.Wx_GenerateQRCode("-|" + lib.AesEncryptCBC(c.Admin_r.T_uuid+"/"+T_name, "0123456789012345") + "|- @宝智达冷链 微信公众号通知")
  42. WxQRCode_str = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=" + WxQRCode_str
  43. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: WxQRCode_str}
  44. c.ServeJSON()
  45. return
  46. }
  47. // 公司管理
  48. func (c *UserController) Company_Tree() {
  49. var r_jsons lib.R_JSONS
  50. T_name := c.GetString("T_name")
  51. r_jsons.Data = Account.Read_Company_Tree(c.Admin_r, T_name)
  52. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  53. c.ServeJSON()
  54. return
  55. }
  56. func (c *UserController) Company_List() {
  57. var r_jsons lib.R_JSONS
  58. T_name := c.GetString("T_name")
  59. r_jsons.Data = Account.Read_Company_List(T_name)
  60. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  61. c.ServeJSON()
  62. return
  63. }
  64. func (c *UserController) Company_Add() {
  65. T_mid, _ := c.GetInt("T_mid")
  66. T_name := c.GetString("T_name")
  67. T_plan := c.GetString("T_plan")
  68. T_data := c.GetString("T_data")
  69. T_v3d := c.GetString("T_v3d")
  70. var_ := Account.Company{
  71. T_mid: T_mid,
  72. T_name: T_name,
  73. T_State: 1,
  74. T_plan: T_plan,
  75. T_data: T_data,
  76. T_v3d: T_v3d,
  77. }
  78. id, err := Account.Add_Company(var_)
  79. if err != nil {
  80. c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
  81. c.ServeJSON()
  82. return
  83. }
  84. if c.Admin_r.T_pids != "*" {
  85. T_pids := []int{int(id)}
  86. if err = Account.Add_Company_bind(c.Admin_r, T_pids); err != nil {
  87. c.Data["json"] = lib.JSONS{Code: 200, Msg: "公司绑定失败"}
  88. c.ServeJSON()
  89. return
  90. }
  91. }
  92. System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "添加", var_)
  93. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: id}
  94. c.ServeJSON()
  95. return
  96. }
  97. func (c *UserController) Company_Edit() {
  98. Id, Id_err := c.GetInt("Id")
  99. if Id_err != nil {
  100. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  101. c.ServeJSON()
  102. return
  103. }
  104. Company_r, err := Account.Read_Company_ById(Id)
  105. if err != nil {
  106. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  107. c.ServeJSON()
  108. return
  109. }
  110. T_name := c.GetString("T_name")
  111. T_plan := c.GetString("T_plan")
  112. T_data := c.GetString("T_data")
  113. T_v3d := c.GetString("T_v3d")
  114. if len(T_name) > 0 {
  115. Company_r.T_name = T_name
  116. }
  117. if len(T_plan) > 0 {
  118. Company_r.T_plan = T_plan
  119. }
  120. if len(T_data) > 0 {
  121. Company_r.T_data = T_data
  122. }
  123. if len(T_v3d) > 0 {
  124. Company_r.T_v3d = T_v3d
  125. }
  126. is := Account.Update_Company(Company_r, "T_name", "T_plan", "T_data", "T_v3d")
  127. if !is {
  128. c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
  129. c.ServeJSON()
  130. return
  131. }
  132. System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "修改", Company_r)
  133. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  134. c.ServeJSON()
  135. return
  136. }
  137. func (c *UserController) Company_Del() {
  138. Id, Id_err := c.GetInt("Id")
  139. if Id_err != nil {
  140. c.Data["json"] = lib.JSONS{Code: 204, Msg: "Id Err!"}
  141. c.ServeJSON()
  142. return
  143. }
  144. Company_r, err := Account.Read_Company_ById(Id)
  145. if err != nil {
  146. c.Data["json"] = lib.JSONS{Code: 204, Msg: "Id Err!"}
  147. c.ServeJSON()
  148. return
  149. }
  150. ids := Account.ReadCompanyIds_T_path(Company_r.T_path)
  151. if cnt := Account.Read_Admin_Num_ByT_pid(ids); cnt > 0 {
  152. c.Data["json"] = lib.JSONS{Code: 202, Msg: "有关联用户,禁止删除!"}
  153. c.ServeJSON()
  154. return
  155. }
  156. o := orm.NewOrm()
  157. o.Begin()
  158. for _, id := range ids {
  159. if is := Account.Delete_Company(o, id); !is {
  160. o.Rollback()
  161. c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
  162. c.ServeJSON()
  163. return
  164. }
  165. if err = Account.Delete_Company_bind_T_pids(o, id); err != nil {
  166. o.Rollback()
  167. c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
  168. c.ServeJSON()
  169. return
  170. }
  171. }
  172. o.Commit()
  173. System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "删除", Company_r)
  174. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  175. c.ServeJSON()
  176. return
  177. }
  178. // 进入公司
  179. func (c *UserController) Company_Entry() {
  180. GetCookie := c.Ctx.GetCookie("User_tokey")
  181. GetString := c.GetString("User_tokey")
  182. User_tokey := GetCookie
  183. if len(User_tokey) == 0 {
  184. User_tokey = GetString
  185. }
  186. T_pid, _ := c.GetInt("T_pid")
  187. if T_pid < 0 {
  188. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
  189. c.ServeJSON()
  190. return
  191. }
  192. Account.Redis_Tokey_T_pid_Set(User_tokey, T_pid)
  193. System.Add_UserLogs_T(c.Admin_r.T_uuid, "公司管理", "进入公司", T_pid)
  194. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  195. c.ServeJSON()
  196. return
  197. }
  198. // 检查 Tokey 是否过期
  199. // 用户管理
  200. func (c *UserController) User_List() {
  201. var r_jsons lib.R_JSONS
  202. page, _ := c.GetInt("page")
  203. if page < 1 {
  204. page = 1
  205. }
  206. page_z, _ := c.GetInt("page_z")
  207. if page_z < 1 {
  208. page_z = conf.Page_size
  209. }
  210. T_name := c.GetString("T_name")
  211. Account.Read_Power_All_Map()
  212. r_jsons.Data, r_jsons.Num = Account.Read_Admin_List(c.T_pid, T_name, page, page_z)
  213. r_jsons.Page = page
  214. r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))
  215. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  216. c.ServeJSON()
  217. return
  218. }
  219. func (c *UserController) User_Get() {
  220. T_uuid := c.GetString("T_uuid")
  221. if len(T_uuid) < 8 {
  222. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  223. c.ServeJSON()
  224. return
  225. }
  226. admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
  227. if err != nil {
  228. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  229. c.ServeJSON()
  230. return
  231. }
  232. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Account.AdminToAdmin_R(admin_r)}
  233. c.ServeJSON()
  234. return
  235. }
  236. func (c *UserController) User_Info() {
  237. type User_ struct {
  238. User Account.Admin_R
  239. //Power Account.Power // 权限
  240. //Menu map[string]Account.Menu_R // 菜单
  241. //Menu []Account.Menu // 菜单
  242. }
  243. Admin_r := User_{}
  244. Admin_r.User = Account.AdminToAdmin_R(c.Admin_r)
  245. //Admin_r.Power, _ = Account.Read_Power_ById(admin_r.T_power)
  246. //Admin_r.Menu = Account.Read_Menu_Tree(Power.T_menu, T_pid)
  247. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Admin_r}
  248. c.ServeJSON()
  249. return
  250. }
  251. func (c *UserController) User_Post() {
  252. admin_r := c.Admin_r
  253. T_name := c.GetString("T_name")
  254. T_pass := c.GetString("T_pass")
  255. T_phone := c.GetString("T_phone")
  256. T_mail := c.GetString("T_mail")
  257. T_wx := c.GetString("T_wx")
  258. if len(T_pass) < 8 && len(T_pass) > 0 {
  259. c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
  260. c.ServeJSON()
  261. return
  262. }
  263. if len(T_name) > 0 {
  264. admin_r.T_name = T_name
  265. }
  266. if len(T_pass) >= 8 {
  267. admin_r.T_pass = T_pass
  268. }
  269. if len(T_phone) > 0 {
  270. admin_r.T_phone = T_phone
  271. }
  272. if len(T_mail) > 0 {
  273. admin_r.T_mail = T_mail
  274. }
  275. if len(T_wx) > 0 {
  276. admin_r.T_wx = T_wx
  277. }
  278. is := Account.Update_Admin(admin_r, "T_name", "T_pass", "T_phone", "T_mail", "T_wx")
  279. if !is {
  280. c.Data["json"] = lib.JSONS{Code: 204, Msg: "修改失败!"}
  281. c.ServeJSON()
  282. return
  283. }
  284. admin_r.T_pass = "******"
  285. System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "修改个人信息", admin_r)
  286. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  287. c.ServeJSON()
  288. return
  289. }
  290. func (c *UserController) User_Add() {
  291. T_power, _ := c.GetInt("T_power")
  292. T_name := c.GetString("T_name")
  293. T_user := c.GetString("T_user")
  294. T_pass := c.GetString("T_pass")
  295. T_phone := c.GetString("T_phone")
  296. T_mail := c.GetString("T_mail")
  297. T_wx := c.GetString("T_wx")
  298. T_uuid := uuid.NewV4().String()
  299. var_ := Account.Admin{
  300. T_uuid: T_uuid,
  301. T_pid: c.T_pid,
  302. T_name: T_name,
  303. T_user: T_user,
  304. T_phone: T_phone,
  305. T_mail: T_mail,
  306. T_wx: T_wx,
  307. T_pass: T_pass,
  308. T_power: T_power,
  309. T_State: 1,
  310. }
  311. if len(T_pass) < 8 {
  312. c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
  313. c.ServeJSON()
  314. return
  315. }
  316. _, err := Account.Read_Admin_T_user(T_user)
  317. if err == nil {
  318. c.Data["json"] = lib.JSONS{Code: 302, Msg: "账户重复!"}
  319. c.ServeJSON()
  320. return
  321. }
  322. _, err = Account.Add_Admin(var_)
  323. if err != nil {
  324. c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
  325. c.ServeJSON()
  326. return
  327. }
  328. var_.T_pass = "******"
  329. System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "添加", var_)
  330. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  331. c.ServeJSON()
  332. return
  333. }
  334. func (c *UserController) User_Edit() {
  335. T_uuid := c.GetString("T_uuid")
  336. if len(T_uuid) < 8 {
  337. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  338. c.ServeJSON()
  339. return
  340. }
  341. r, err := Account.Read_Admin_ByUuid(T_uuid)
  342. if err != nil {
  343. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  344. c.ServeJSON()
  345. return
  346. }
  347. T_power, T_power_err := c.GetInt("T_power")
  348. T_name := c.GetString("T_name")
  349. T_pass := c.GetString("T_pass")
  350. T_phone := c.GetString("T_phone")
  351. T_mail := c.GetString("T_mail")
  352. if T_power_err == nil {
  353. r.T_power = T_power
  354. }
  355. if len(T_pass) < 8 && len(T_pass) > 0 {
  356. c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
  357. c.ServeJSON()
  358. return
  359. }
  360. if len(T_name) > 0 {
  361. r.T_name = T_name
  362. }
  363. if len(T_pass) >= 8 {
  364. r.T_pass = T_pass
  365. }
  366. if len(T_phone) > 0 {
  367. r.T_phone = T_phone
  368. }
  369. if len(T_mail) > 0 {
  370. r.T_mail = T_mail
  371. }
  372. is := Account.Update_Admin(r, "T_power", "T_pid", "T_name", "T_pass", "T_phone", "T_mail")
  373. if !is {
  374. c.Data["json"] = lib.JSONS{Code: 204, Msg: "修改失败!"}
  375. c.ServeJSON()
  376. return
  377. }
  378. if len(T_name) > 0 {
  379. if is = Company.Update_CompanyNotice_Bind_By_T_uuid(T_uuid, T_name); !is {
  380. logs.Println("修改用户 => 修改用户关联报警通知失败", T_uuid, T_name)
  381. }
  382. }
  383. r.T_pass = "******"
  384. System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "编辑", r)
  385. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  386. c.ServeJSON()
  387. return
  388. }
  389. func (c *UserController) User_Del() {
  390. T_uuid := c.GetString("T_uuid")
  391. if len(T_uuid) <= 0 {
  392. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  393. c.ServeJSON()
  394. return
  395. }
  396. admin_r_lod, err := Account.Read_Admin_ByUuid(T_uuid)
  397. if err != nil {
  398. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  399. c.ServeJSON()
  400. return
  401. }
  402. if is := Account.Delete_Admin(admin_r_lod); !is {
  403. c.Data["json"] = lib.JSONS{Code: 200, Msg: "删除失败!"}
  404. c.ServeJSON()
  405. return
  406. }
  407. if is := Company.Delete_CompanyNotice_Bind_By_T_uuid(T_uuid); !is {
  408. logs.Println("删除用户 => 删除用户关联报警通知失败", T_uuid)
  409. }
  410. System.Add_UserLogs_T(c.Admin_r.T_uuid, "用户管理", "删除", T_uuid)
  411. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  412. c.ServeJSON()
  413. return
  414. }
  415. // 管理员
  416. func (c *UserController) User_Home() {
  417. // 验证登录
  418. admin_r := c.Admin_r
  419. type Info struct {
  420. T_name string // 姓名
  421. T_pid int // 公司id
  422. T_Days int // 服务天输
  423. Admin []Account.Admin_ // 专属管理员
  424. WarningNum int64 // 报警数量
  425. UntreatedWarningNum int64 // 未处理报警数量
  426. WorkOrderNum int64 // 工单数量
  427. UntreatedWorkOrderNum int64 // 未处理工单数量
  428. }
  429. var info Info
  430. info.T_name = admin_r.T_name
  431. info.T_pid = admin_r.T_pid
  432. if admin_r.T_pid > 0 {
  433. power, _ := Account.Read_Power_ById(admin_r.T_power)
  434. company, _ := Account.Read_Company_ById(admin_r.T_pid)
  435. info.T_Days = lib.GetDiffDays(time.Now(), company.CreateTime)
  436. AdminList := Account.Read_Admin_List_T_pids(admin_r.T_pid)
  437. var Admin_ []Account.Admin_
  438. for _, v := range AdminList {
  439. Admin_ = append(Admin_, Account.Admin_RToAdmin_(v))
  440. }
  441. info.Admin = Admin_
  442. info.WarningNum = Warning.Read_Warning_ALL_T_State_Count(admin_r.T_pid, 1, power.T_warning, true)
  443. info.UntreatedWarningNum = Warning.Read_Warning_ALL_T_State_Count(admin_r.T_pid, 3, power.T_warning, false)
  444. }
  445. if admin_r.T_pid == 0 {
  446. info.WorkOrderNum, info.UntreatedWorkOrderNum = NatsServer.Read_WorkOrderT_State_Count(admin_r.T_pids)
  447. }
  448. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: info}
  449. c.ServeJSON()
  450. return
  451. }
  452. // 内部用户管理
  453. func (c *UserController) Admin_List() {
  454. var r_jsons lib.R_JSONS
  455. page, _ := c.GetInt("page")
  456. if page < 1 {
  457. page = 1
  458. }
  459. page_z, _ := c.GetInt("page_z")
  460. if page_z < 1 {
  461. page_z = conf.Page_size
  462. }
  463. T_name := c.GetString("T_name")
  464. Account.Read_Power_All_Map()
  465. r_jsons.Data, r_jsons.Num = Account.Read_Admin_List(0, T_name, page, page_z)
  466. r_jsons.Page = page
  467. r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))
  468. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  469. c.ServeJSON()
  470. return
  471. }
  472. func (c *UserController) Admin_Get() {
  473. T_uuid := c.GetString("T_uuid")
  474. if len(T_uuid) < 8 {
  475. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  476. c.ServeJSON()
  477. return
  478. }
  479. admin_r, err := Account.Read_Admin_ByUuid(T_uuid)
  480. if err != nil {
  481. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  482. c.ServeJSON()
  483. return
  484. }
  485. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Account.AdminToAdmin_R(admin_r)}
  486. c.ServeJSON()
  487. return
  488. }
  489. func (c *UserController) Admin_Add() {
  490. T_power, _ := c.GetInt("T_power")
  491. T_name := c.GetString("T_name")
  492. T_user := c.GetString("T_user")
  493. T_pass := c.GetString("T_pass")
  494. T_phone := c.GetString("T_phone")
  495. T_mail := c.GetString("T_mail")
  496. T_wx := c.GetString("T_wx")
  497. var_ := Account.Admin{
  498. T_uuid: uuid.NewV4().String(),
  499. T_pid: 0,
  500. T_name: T_name,
  501. T_user: T_user,
  502. T_phone: T_phone,
  503. T_mail: T_mail,
  504. T_wx: T_wx,
  505. T_pass: T_pass,
  506. T_power: T_power,
  507. T_State: 1,
  508. }
  509. if len(T_pass) < 8 {
  510. c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
  511. c.ServeJSON()
  512. return
  513. }
  514. _, err := Account.Read_Admin_T_user(T_user)
  515. if err == nil {
  516. c.Data["json"] = lib.JSONS{Code: 302, Msg: "账户重复!"}
  517. c.ServeJSON()
  518. return
  519. }
  520. _, err = Account.Add_Admin(var_)
  521. if err != nil {
  522. c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
  523. c.ServeJSON()
  524. return
  525. }
  526. var_.T_pass = "******"
  527. System.Add_UserLogs_T(c.Admin_r.T_uuid, "内部用户管理", "添加", var_)
  528. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  529. c.ServeJSON()
  530. return
  531. }
  532. func (c *UserController) Admin_Edit() {
  533. T_uuid := c.GetString("T_uuid")
  534. if len(T_uuid) < 8 {
  535. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  536. c.ServeJSON()
  537. return
  538. }
  539. r, err := Account.Read_Admin_ByUuid(T_uuid)
  540. if err != nil {
  541. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  542. c.ServeJSON()
  543. return
  544. }
  545. T_power, T_power_err := c.GetInt("T_power")
  546. T_name := c.GetString("T_name")
  547. T_pass := c.GetString("T_pass")
  548. T_phone := c.GetString("T_phone")
  549. T_mail := c.GetString("T_mail")
  550. T_wx := c.GetString("T_wx")
  551. if T_power_err == nil {
  552. r.T_power = T_power
  553. }
  554. if len(T_pass) < 8 && len(T_pass) > 0 {
  555. c.Data["json"] = lib.JSONS{Code: 202, Msg: "密码异常!"}
  556. c.ServeJSON()
  557. return
  558. }
  559. if len(T_name) > 0 {
  560. r.T_name = T_name
  561. }
  562. if len(T_pass) >= 8 {
  563. r.T_pass = T_pass
  564. }
  565. if len(T_phone) > 0 {
  566. r.T_phone = T_phone
  567. }
  568. if len(T_mail) > 0 {
  569. r.T_mail = T_mail
  570. }
  571. if len(T_wx) > 0 {
  572. r.T_wx = T_wx
  573. }
  574. is := Account.Update_Admin(r, "T_power", "T_name", "T_pass", "T_phone", "T_mail", "T_wx")
  575. if !is {
  576. c.Data["json"] = lib.JSONS{Code: 204, Msg: "修改失败!"}
  577. c.ServeJSON()
  578. return
  579. }
  580. if len(T_name) > 0 {
  581. if is = Company.Update_CompanyNotice_Bind_By_T_uuid(T_uuid, "内管-"+T_name); !is {
  582. logs.Println("修改内部用户 => 修改内部用户关联报警通知失败", T_uuid, T_name)
  583. }
  584. }
  585. r.T_pass = "********"
  586. System.Add_UserLogs_T(c.Admin_r.T_uuid, "内部用户管理", "修改", r)
  587. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  588. c.ServeJSON()
  589. return
  590. }
  591. func (c *UserController) Admin_Del() {
  592. T_uuid := c.GetString("T_uuid")
  593. if len(T_uuid) <= 0 {
  594. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  595. c.ServeJSON()
  596. return
  597. }
  598. admin_r_lod, err := Account.Read_Admin_ByUuid(T_uuid)
  599. if err != nil {
  600. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  601. c.ServeJSON()
  602. return
  603. }
  604. if admin_r_lod.Id == 1 {
  605. c.Data["json"] = lib.JSONS{Code: 202, Msg: "无权删除!"}
  606. c.ServeJSON()
  607. return
  608. }
  609. if is := Account.Delete_Admin(admin_r_lod); !is {
  610. c.Data["json"] = lib.JSONS{Code: 200, Msg: "删除失败!"}
  611. c.ServeJSON()
  612. return
  613. }
  614. if is := Company.Delete_CompanyNotice_Bind_By_T_uuid(T_uuid); !is {
  615. logs.Println("删除内部用户 => 删除内部用户关联报警通知失败", T_uuid)
  616. }
  617. System.Add_UserLogs_T(c.Admin_r.T_uuid, "内部用户管理", "删除", T_uuid)
  618. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  619. c.ServeJSON()
  620. return
  621. }
  622. // 报警通知的用户列表
  623. func (c *UserController) User_Notice_List() {
  624. type R_JSONS struct {
  625. //必须的大写开头
  626. AdminList []Account.Admin_R
  627. UserList []Account.Admin_R
  628. }
  629. var r_jsons R_JSONS
  630. // 绑定公司id的内部用户列表
  631. r_jsons.AdminList = Account.Read_Admin_List_T_pids(c.T_pid)
  632. // 绑定公司id的公司用户列表
  633. r_jsons.UserList = Account.Read_Admin_List_T_pid(c.T_pid)
  634. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  635. c.ServeJSON()
  636. return
  637. }
  638. // 管理员绑定公司
  639. func (c *UserController) AdminCompanyBind_List() {
  640. var r_jsons lib.R_JSONS
  641. T_uuid := c.GetString("T_uuid")
  642. if len(T_uuid) < 8 {
  643. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  644. c.ServeJSON()
  645. return
  646. }
  647. r, err := Account.Read_Admin_ByUuid(T_uuid)
  648. if err != nil {
  649. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  650. c.ServeJSON()
  651. return
  652. }
  653. r_jsons.Data = Account.Read_Company_List_ByT_pids(r.T_pids)
  654. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  655. c.ServeJSON()
  656. return
  657. }
  658. func (c *UserController) AdminCompanyBind_Add() {
  659. T_uuid := c.GetString("T_uuid")
  660. if len(T_uuid) < 8 {
  661. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  662. c.ServeJSON()
  663. return
  664. }
  665. T_pid, _ := c.GetInt("T_pid")
  666. if T_pid == 0 {
  667. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
  668. c.ServeJSON()
  669. return
  670. }
  671. r, err := Account.Read_Admin_ByUuid(T_uuid)
  672. if err != nil {
  673. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  674. c.ServeJSON()
  675. return
  676. }
  677. Company_r, err := Account.Read_Company_ById(T_pid)
  678. if err != nil {
  679. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_pid Err!"}
  680. c.ServeJSON()
  681. return
  682. }
  683. T_pids := Account.ReadCompanyIds_T_path(Company_r.T_path)
  684. if err = Account.Add_Company_bind(r, T_pids); err != nil {
  685. c.Data["json"] = lib.JSONS{Code: 200, Msg: "公司绑定失败"}
  686. c.ServeJSON()
  687. return
  688. }
  689. System.Add_UserLogs(c.Admin_r.T_uuid, "内部用户管理", "公司绑定添加", T_uuid+"-"+strconv.Itoa(T_pid))
  690. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  691. c.ServeJSON()
  692. return
  693. }
  694. func (c *UserController) AdminCompanyBind_Del() {
  695. T_uuid := c.GetString("T_uuid")
  696. if len(T_uuid) < 8 {
  697. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_uuid Err!"}
  698. c.ServeJSON()
  699. return
  700. }
  701. T_pid, _ := c.GetInt("T_pid")
  702. if T_pid == 0 {
  703. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_pid Err!"}
  704. c.ServeJSON()
  705. return
  706. }
  707. r, err := Account.Read_Admin_ByUuid(T_uuid)
  708. Company_r, err := Account.Read_Company_ById(T_pid)
  709. if err != nil {
  710. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_pid Err!"}
  711. c.ServeJSON()
  712. return
  713. }
  714. T_pids := Account.ReadCompanyIds_T_path(Company_r.T_path)
  715. if err = Account.Delete_Company_bind(r, T_pids); err != nil {
  716. c.Data["json"] = lib.JSONS{Code: 200, Msg: "公司绑定失败"}
  717. c.ServeJSON()
  718. return
  719. }
  720. if is := Company.Delete_CompanyNotice_Bind_By_T_uuid_T_pid(T_uuid, T_pids); !is {
  721. logs.Println("删除内部用户公司绑定 => 删除内部用户绑定的公司关联报警通知失败", T_uuid)
  722. }
  723. System.Add_UserLogs(c.Admin_r.T_uuid, "内部用户管理", "公司绑定删除", T_uuid+"-"+strconv.Itoa(T_pid))
  724. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  725. c.ServeJSON()
  726. return
  727. }
  728. // 权限管理
  729. func (c *UserController) Power_List() {
  730. var r_jsons lib.R_JSONS
  731. page, _ := c.GetInt("page")
  732. if page < 1 {
  733. page = 1
  734. }
  735. page_z, _ := c.GetInt("page_z")
  736. if page_z < 1 {
  737. page_z = conf.Page_size
  738. }
  739. Name := c.GetString("T_name")
  740. r_jsons.Data, r_jsons.Num = Account.Read_Power_List(Name, page, page_z)
  741. r_jsons.Page = page
  742. r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))
  743. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  744. c.ServeJSON()
  745. return
  746. }
  747. // 添加用户 权限选择列表
  748. func (c *UserController) Power_List_All() {
  749. r, err := Account.Read_Power_ById(c.Admin_r.T_power)
  750. if err != nil {
  751. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  752. c.ServeJSON()
  753. return
  754. }
  755. var r_jsons lib.R_JSONS
  756. r_jsons.Data = Account.Read_Power_List_ALL_User(r.T_select)
  757. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  758. c.ServeJSON()
  759. return
  760. }
  761. func (c *UserController) Power_Get() {
  762. type Data struct {
  763. Power Account.Power_
  764. Menu []Account.Menu
  765. Menu_checked []int
  766. Select []Account.Power_R
  767. Warning []Warning.WarningType_R
  768. }
  769. var data Data
  770. id, id_err := c.GetInt("T_id")
  771. if id_err != nil || id == 0 {
  772. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
  773. c.ServeJSON()
  774. return
  775. }
  776. power, err := Account.Read_Power_ById(id)
  777. if err != nil {
  778. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
  779. c.ServeJSON()
  780. return
  781. }
  782. data.Power = Account.PowerToPower_(power)
  783. data.Menu, data.Menu_checked = Account.Read_Menu_List_All()
  784. if err != nil {
  785. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_menu Err!"}
  786. c.ServeJSON()
  787. return
  788. }
  789. if power.T_menu != "*" {
  790. data.Menu_checked = models.SplitStringToIntIds(power.T_menu, "M")
  791. }
  792. if err != nil {
  793. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_menu Err!"}
  794. c.ServeJSON()
  795. return
  796. }
  797. data.Select = Account.Read_Power_List_ALL_T_select(power.T_select)
  798. if err != nil {
  799. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_select Err!"}
  800. c.ServeJSON()
  801. return
  802. }
  803. data.Warning = Warning.Read_WarningType_All_Power_T_Warning(power.T_warning)
  804. if err != nil {
  805. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_warning Err!"}
  806. c.ServeJSON()
  807. return
  808. }
  809. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: data}
  810. c.ServeJSON()
  811. return
  812. }
  813. func (c *UserController) Power_Add() {
  814. T_name := c.GetString("T_name")
  815. T_select := c.GetString("T_select")
  816. T_warning := c.GetString("T_warning")
  817. T_menu := c.GetString("T_menu")
  818. var_ := Account.Power{
  819. T_name: T_name,
  820. T_select: T_select,
  821. T_warning: T_warning,
  822. T_menu: T_menu,
  823. T_State: 1,
  824. }
  825. _, err := Account.Add_Power(var_)
  826. if err != nil {
  827. c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
  828. c.ServeJSON()
  829. return
  830. }
  831. System.Add_UserLogs_T(c.Admin_r.T_uuid, "权限管理", "添加", var_)
  832. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  833. c.ServeJSON()
  834. return
  835. }
  836. func (c *UserController) Power_Edit() {
  837. Id, Id_err := c.GetInt("T_id")
  838. if Id_err != nil || Id == 0 {
  839. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  840. c.ServeJSON()
  841. return
  842. }
  843. if Id == 1 {
  844. c.Data["json"] = lib.JSONS{Code: 202, Msg: "无权修改!"}
  845. c.ServeJSON()
  846. return
  847. }
  848. r, err := Account.Read_Power_ById(Id)
  849. if err != nil {
  850. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  851. c.ServeJSON()
  852. return
  853. }
  854. T_name := c.GetString("T_name")
  855. T_select := c.GetString("T_select")
  856. T_warning := c.GetString("T_warning")
  857. T_menu := c.GetString("T_menu")
  858. if len(T_name) > 0 {
  859. r.T_name = T_name
  860. }
  861. if len(T_select) > 0 {
  862. r.T_select = T_select
  863. }
  864. if len(T_warning) > 0 {
  865. r.T_warning = T_warning
  866. }
  867. if len(T_menu) > 0 {
  868. r.T_menu = T_menu
  869. }
  870. is := Account.Update_Power(r, "T_name", "T_select", "T_warning", "T_menu")
  871. if !is {
  872. c.Data["json"] = lib.JSONS{Code: 302, Msg: "修改失败!"}
  873. c.ServeJSON()
  874. return
  875. }
  876. System.Add_UserLogs_T(c.Admin_r.T_uuid, "权限管理", "修改", r)
  877. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  878. c.ServeJSON()
  879. return
  880. }
  881. func (c *UserController) Power_Del() {
  882. id, id_err := c.GetInt("T_id")
  883. if id_err != nil || id == 0 {
  884. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  885. c.ServeJSON()
  886. return
  887. }
  888. r, err := Account.Read_Power_ById(id)
  889. if err != nil {
  890. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  891. c.ServeJSON()
  892. return
  893. }
  894. if cnt := Account.Read_Admin_Num_ByT_power(id); cnt > 0 {
  895. c.Data["json"] = lib.JSONS{Code: 202, Msg: "有关联用户,禁止删除!"}
  896. c.ServeJSON()
  897. return
  898. }
  899. is := Account.Delete_Power(r)
  900. if !is {
  901. c.Data["json"] = lib.JSONS{Code: 302, Msg: "删除失败!"}
  902. c.ServeJSON()
  903. return
  904. }
  905. System.Add_UserLogs(c.Admin_r.T_uuid, "权限管理", "删除", strconv.Itoa(id))
  906. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  907. c.ServeJSON()
  908. return
  909. }
  910. // 菜单列表
  911. func (c *UserController) User_Menu_List() {
  912. var r_jsons lib.R_JSONS
  913. power, err := Account.Read_Power_ById(c.Admin_r.T_power)
  914. if err != nil {
  915. c.Data["json"] = lib.JSONS{Code: 200, Msg: "获取菜单失败"}
  916. c.ServeJSON()
  917. return
  918. }
  919. logs.Println("登录用户 菜单 pid 为:", c.T_pid)
  920. r_jsons.Data = Account.Read_Menu_Bind_List(power.Id, power.T_menu, c.T_pid)
  921. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  922. c.ServeJSON()
  923. return
  924. }
  925. // 权限菜单列表
  926. func (c *UserController) Menu_List_All() {
  927. var r_jsons lib.R_JSONS
  928. r_jsons.Data, _ = Account.Read_Menu_List_All()
  929. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  930. c.ServeJSON()
  931. return
  932. }