sys_admin.go 30 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130
  1. package controllers
  2. import (
  3. "encoding/base64"
  4. "encoding/json"
  5. "fmt"
  6. "github.com/rdlucklib/rdluck_tools/paging"
  7. "hongze/hz_eta_api/models"
  8. "hongze/hz_eta_api/models/company"
  9. "hongze/hz_eta_api/models/data_manage"
  10. "hongze/hz_eta_api/models/system"
  11. "hongze/hz_eta_api/services"
  12. "hongze/hz_eta_api/utils"
  13. "strconv"
  14. "strings"
  15. "time"
  16. )
  17. // 系统用户
  18. type SysAdminController struct {
  19. BaseAuthController
  20. }
  21. // @Title 根据分组或者部门获取系统用户列表
  22. // @Description 根据分组或者部门获取系统用户列表接口
  23. // @Param PageSize query int true "每页数据条数"
  24. // @Param CurrentIndex query int true "当前页页码,从1开始"
  25. // @Param DepartmentId query int true "部门ID"
  26. // @Param GroupId query int true "分组ID"
  27. // @Param TeamId query int true "小组ID"
  28. // @Param RoleId query int true "角色ID"
  29. // @Param KeyWord query string true "搜索关键词"
  30. // @Success 200 {object} system.SysuserListResp
  31. // @router /sysuser/list [get]
  32. func (this *SysAdminController) ListSysuser() {
  33. br := new(models.BaseResponse).Init()
  34. defer func() {
  35. this.Data["json"] = br
  36. this.ServeJSON()
  37. }()
  38. sysUser := this.SysUser
  39. if sysUser == nil {
  40. br.Msg = "请登录"
  41. br.ErrMsg = "请登录,SysUser Is Empty"
  42. return
  43. }
  44. pageSize, _ := this.GetInt("PageSize")
  45. currentIndex, _ := this.GetInt("CurrentIndex")
  46. departmentId, _ := this.GetInt("DepartmentId")
  47. groupId, _ := this.GetInt("GroupId")
  48. teamId, _ := this.GetInt("TeamId")
  49. roleId, _ := this.GetInt("RoleId")
  50. keyWord := this.GetString("KeyWord")
  51. var startSize int
  52. if pageSize <= 0 {
  53. pageSize = utils.PageSize20
  54. }
  55. if currentIndex <= 0 {
  56. currentIndex = 1
  57. }
  58. startSize = utils.StartIndex(currentIndex, pageSize)
  59. var condition string
  60. var pars []interface{}
  61. if departmentId > 0 {
  62. condition += ` AND department_id=? `
  63. pars = append(pars, departmentId)
  64. }
  65. if roleId > 0 {
  66. condition += ` AND role_id=? `
  67. pars = append(pars, roleId)
  68. }
  69. if keyWord != "" {
  70. condition += ` AND (real_name LIKE '%` + keyWord + `%' OR admin_name LIKE '%` + keyWord + `%' OR mobile LIKE '%` + keyWord + `%' ) `
  71. }
  72. var total int
  73. var err error
  74. if teamId <= 0 {
  75. if groupId > 0 {
  76. ids, err := system.GetGroupIdByParentId(groupId)
  77. if err != nil {
  78. br.Msg = "获取失败"
  79. br.ErrMsg = "获取失败,Err:" + err.Error()
  80. return
  81. }
  82. sGroupId := strconv.Itoa(groupId)
  83. ids = append(ids, &sGroupId)
  84. var idList []string
  85. for _, id := range ids {
  86. idList = append(idList, *id)
  87. }
  88. sid := strings.Join(idList, ",")
  89. condition += ` AND group_id IN (` + sid + `) `
  90. }
  91. total, err = system.GetSysuserListCount(condition, pars)
  92. if err != nil {
  93. br.Msg = "获取失败"
  94. br.ErrMsg = "获取失败,Err:" + err.Error()
  95. return
  96. }
  97. } else {
  98. nCondition := condition + ` AND group_id=? `
  99. nPars := append(pars, teamId)
  100. total, err = system.GetSysuserListCount(nCondition, nPars)
  101. if err != nil {
  102. br.Msg = "获取失败"
  103. br.ErrMsg = "获取失败,Err:" + err.Error()
  104. return
  105. }
  106. }
  107. var list []*system.AdminItem
  108. adminIdArr := make([]string, 0)
  109. if teamId <= 0 {
  110. //if groupId > 0 {
  111. // ids, err := system.GetGroupIdByParentId(groupId, startSize, pageSize)
  112. // if err != nil {
  113. // br.Msg = "获取失败"
  114. // br.ErrMsg = "获取失败,Err:" + err.Error()
  115. // return
  116. // }
  117. // sGroupId := strconv.Itoa(groupId)
  118. // ids = append(ids, &sGroupId)
  119. // var idList []string
  120. // for _, id := range ids {
  121. // idList = append(idList, *id)
  122. // }
  123. // sid := strings.Join(idList,",")
  124. //
  125. // condition += ` AND group_id IN (` + sid + `) `
  126. //}
  127. list, err = system.GetSysuserList(condition, pars, startSize, pageSize)
  128. if err != nil {
  129. br.Msg = "获取失败"
  130. br.ErrMsg = "获取失败,Err:" + err.Error()
  131. return
  132. }
  133. lenList := len(list)
  134. for i := 0; i < lenList; i++ {
  135. item := list[i]
  136. adminIdArr = append(adminIdArr, strconv.Itoa(item.AdminId))
  137. var secondName *string
  138. if item.GroupId != 0 {
  139. pid, err := company.GetParentIdFromGroup(item.GroupId)
  140. if err != nil {
  141. br.Msg = "获取失败"
  142. br.ErrMsg = "查询父级id异常" + err.Error()
  143. return
  144. }
  145. if pid != nil && *pid != 0 {
  146. secondName, err = company.GetGroupNamesById(*pid)
  147. if err != nil {
  148. br.Msg = "获取失败"
  149. br.ErrMsg = "查询二级组名异常" + err.Error()
  150. return
  151. }
  152. }
  153. if *pid > 0 {
  154. list[i].TeamId = list[i].GroupId
  155. list[i].GroupId = *pid
  156. }
  157. }
  158. if item.DepartmentName != "" {
  159. if item.GroupName == "" {
  160. list[i].DepartmentGroup = item.DepartmentName
  161. } else if secondName != nil {
  162. list[i].DepartmentGroup = item.DepartmentName + "/" + *secondName + "/" + item.GroupName
  163. } else {
  164. list[i].DepartmentGroup = item.DepartmentName + "/" + item.GroupName
  165. }
  166. }
  167. labelVal := 0
  168. fmt.Println("item.RoleTypeCode:", item.RoleTypeCode)
  169. fmt.Println("item.Authority:", item.Authority)
  170. if item.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  171. labelVal = 1
  172. } else if item.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN ||
  173. item.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
  174. labelVal = 2
  175. } else {
  176. if item.Authority == 1 {
  177. labelVal = 3
  178. } else if item.Authority == 2 && item.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  179. labelVal = 4
  180. } else if item.Authority == 2 && item.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP {
  181. labelVal = 5
  182. } else if item.Authority == 4 {
  183. labelVal = 4
  184. }
  185. }
  186. list[i].LabelVal = labelVal
  187. }
  188. } else {
  189. condition += ` AND group_id=? `
  190. pars = append(pars, teamId)
  191. list, err = system.GetSysuserList(condition, pars, startSize, pageSize)
  192. if err != nil {
  193. br.Msg = "获取失败"
  194. br.ErrMsg = "获取失败,Err:" + err.Error()
  195. return
  196. }
  197. groupItem, err := system.GetSysGroupById(groupId)
  198. if err != nil {
  199. br.Msg = "获取失败"
  200. br.ErrMsg = "获取失败,Err:" + err.Error()
  201. return
  202. }
  203. lenList := len(list)
  204. for i := 0; i < lenList; i++ {
  205. item := list[i]
  206. adminIdArr = append(adminIdArr, strconv.Itoa(item.AdminId))
  207. if item.DepartmentName != "" {
  208. if item.GroupName == "" {
  209. list[i].DepartmentGroup = item.DepartmentName
  210. } else if item.GroupName != "" {
  211. list[i].DepartmentGroup = item.DepartmentName + "/" + groupItem.GroupName + "/" + item.GroupName
  212. } else {
  213. list[i].DepartmentGroup = item.DepartmentName + "/" + item.GroupName
  214. }
  215. }
  216. labelVal := 0
  217. if item.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  218. labelVal = 1
  219. } else if item.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN ||
  220. item.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
  221. labelVal = 2
  222. } else {
  223. if item.Authority == 1 {
  224. labelVal = 3
  225. } else if item.Authority == 2 && item.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  226. labelVal = 4
  227. } else if item.Authority == 2 && item.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP {
  228. labelVal = 5
  229. } else if item.Authority == 4 {
  230. labelVal = 4
  231. }
  232. }
  233. list[i].LabelVal = labelVal
  234. }
  235. }
  236. //if teamId > 0 {
  237. // var groupIdSlice []string
  238. // var groupIds string
  239. // for _, item := range list {
  240. // groupIdSlice = append(groupIdSlice, strconv.Itoa(groupId))
  241. // }
  242. // groupIds = strings.Join(groupIdSlice, ",")
  243. // fmt.Println("groupIds:", groupIds)
  244. //}
  245. if teamId > 0 {
  246. for _, item := range list {
  247. item.TeamId = teamId
  248. item.GroupId = groupId
  249. }
  250. }
  251. // 研究方向分组
  252. if len(adminIdArr) > 0 {
  253. adminIds := strings.Join(adminIdArr, ",")
  254. //researchGroupList, e := system.GetAdminResearchGroupListByAdminId(adminIds)
  255. researchGroupList, e := models.GetAdminVarietyTagRelationListByAdminId(adminIds)
  256. if e != nil {
  257. br.Msg = "获取失败"
  258. br.ErrMsg = "获取研究方向分组列表失败, Err:" + e.Error()
  259. return
  260. }
  261. researchGroupAdminIdName := make(map[int]string, 0)
  262. for _, g := range researchGroupList {
  263. researchGroupAdminIdName[g.AdminId] = g.GroupNameStr
  264. }
  265. for _, v := range list {
  266. v.ResearchGroupName = researchGroupAdminIdName[v.AdminId]
  267. }
  268. }
  269. fmt.Println("teamId:", teamId)
  270. page := paging.GetPaging(currentIndex, pageSize, total)
  271. resp := new(system.SysuserListResp)
  272. resp.List = list
  273. resp.Paging = page
  274. br.Ret = 200
  275. br.Success = true
  276. br.Msg = "获取成功"
  277. br.Data = resp
  278. }
  279. // @Title 新增系统用户
  280. // @Description 新增系统用户接口
  281. // @Param request body system.SysuserAddReq true "type json string"
  282. // @Success 200 新增成功
  283. // @router /sysuser/add [post]
  284. func (this *SysAdminController) Add() {
  285. br := new(models.BaseResponse).Init()
  286. defer func() {
  287. this.Data["json"] = br
  288. this.ServeJSON()
  289. }()
  290. var req system.SysuserAddReq
  291. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  292. if err != nil {
  293. br.Msg = "参数解析异常!"
  294. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  295. return
  296. }
  297. if req.RoleId <= 0 {
  298. br.Msg = "请选择角色"
  299. br.ErrMsg = "角色ID小于等于0"
  300. return
  301. }
  302. count, err := system.GetSysAdminCount(req.AdminName)
  303. if err != nil {
  304. br.Msg = "获取数据失败"
  305. br.ErrMsg = "获取数据失败"
  306. return
  307. }
  308. if count > 0 {
  309. br.Msg = "账号已存在,请重新输入"
  310. br.IsSendEmail = false
  311. return
  312. }
  313. if req.Mobile != "" {
  314. mobileCount, err := system.GetSysAdminCountByMobile(req.Mobile, 0)
  315. if err != nil {
  316. br.Msg = "判断手机号是否存在失败"
  317. br.ErrMsg = "判断手机号是否存在失败,Err:" + err.Error()
  318. return
  319. }
  320. if mobileCount > 0 {
  321. br.Msg = "手机号已存在,请重新填写"
  322. br.IsSendEmail = false
  323. return
  324. }
  325. }
  326. //req.Mobile
  327. var roleName, departmentName, groupName, teamName string
  328. roleItem, err := system.GetSysRoleById(req.RoleId)
  329. if err != nil {
  330. if err.Error() == utils.ErrNoRow() {
  331. br.Msg = "所选角色不存在"
  332. return
  333. }
  334. br.Msg = "获取数据失败"
  335. br.ErrMsg = "获取角色数据失败,Err:" + err.Error()
  336. return
  337. }
  338. if roleItem != nil {
  339. roleName = roleItem.RoleName
  340. }
  341. if req.DepartmentId > 0 {
  342. departmentItem, err := system.GetSysDepartmentById(req.DepartmentId)
  343. if err != nil {
  344. if err.Error() == utils.ErrNoRow() {
  345. br.Msg = "所选部门不存在"
  346. return
  347. }
  348. br.Msg = "获取数据失败"
  349. br.ErrMsg = "获取部门数据失败,Err:" + err.Error()
  350. return
  351. }
  352. if departmentItem != nil {
  353. departmentName = departmentItem.DepartmentName
  354. }
  355. }
  356. if req.GroupId > 0 {
  357. groupItem, err := system.GetSysGroupById(req.GroupId)
  358. if err != nil {
  359. if err.Error() == utils.ErrNoRow() {
  360. br.Msg = "所选分组不存在"
  361. return
  362. }
  363. br.Msg = "获取数据失败"
  364. br.ErrMsg = "获取分组数据失败,Err:" + err.Error()
  365. return
  366. }
  367. if groupItem != nil {
  368. groupName = groupItem.GroupName
  369. }
  370. }
  371. if req.TeamId > 0 {
  372. teamItem, err := system.GetSysGroupById(req.TeamId)
  373. if err != nil {
  374. if err.Error() == utils.ErrNoRow() {
  375. br.Msg = "所选小组不存在"
  376. return
  377. }
  378. br.Msg = "获取数据失败"
  379. br.ErrMsg = "获取小组数据失败,Err:" + err.Error()
  380. return
  381. }
  382. if teamItem != nil {
  383. teamName = teamItem.GroupName
  384. }
  385. }
  386. pwdByte, err := base64.StdEncoding.DecodeString(req.Password)
  387. if err != nil {
  388. br.Msg = "解析数据失败"
  389. br.ErrMsg = "解析数据失败,Err:" + err.Error()
  390. return
  391. }
  392. pwdStr := string(pwdByte)
  393. pwdStr = strings.ToLower(pwdStr)
  394. if pwdStr == "" {
  395. br.Msg = "请输入密码"
  396. return
  397. }
  398. if !utils.CheckPwd(pwdStr) {
  399. br.Msg = "密码格式错误,请重新输入"
  400. return
  401. }
  402. // 员工工号
  403. req.EmployeeId = strings.TrimSpace(req.EmployeeId)
  404. admin := new(system.Admin)
  405. admin.AdminName = req.AdminName
  406. admin.RealName = req.RealName
  407. admin.Password = utils.MD5(pwdStr)
  408. admin.LastUpdatedPasswordTime = time.Now().Format(utils.FormatDateTime)
  409. admin.Enabled = 1
  410. admin.LastLoginTime = time.Now().Format(utils.FormatDateTime)
  411. admin.CreatedTime = time.Now()
  412. admin.LastUpdatedTime = time.Now().Format(utils.FormatDateTime)
  413. admin.Mobile = req.Mobile
  414. admin.RoleType = 0
  415. admin.RoleId = req.RoleId
  416. admin.RoleName = roleName
  417. admin.RoleTypeCode = roleItem.RoleTypeCode
  418. admin.DepartmentId = req.DepartmentId
  419. admin.DepartmentName = departmentName
  420. admin.AdminAvatar = req.AdminAvatar
  421. if req.TeamId <= 0 {
  422. admin.GroupId = req.GroupId
  423. admin.GroupName = groupName
  424. } else {
  425. admin.GroupId = req.TeamId
  426. admin.GroupName = teamName
  427. }
  428. if strings.Contains(admin.RoleTypeCode, "researcher") {
  429. admin.Role = "researcher"
  430. } else if strings.Contains(admin.RoleTypeCode, "seller") {
  431. admin.Role = "sales"
  432. } else {
  433. admin.Role = "admin"
  434. }
  435. admin.EmployeeId = req.EmployeeId
  436. var authority int
  437. if roleItem.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  438. authority = 3
  439. } else if roleItem.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_TEAM {
  440. authority = 4
  441. } else if roleItem.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  442. authority = 2
  443. } else {
  444. if strings.Contains(roleItem.RoleType, "销售主管") {
  445. authority = 2
  446. } else if strings.Contains(roleItem.RoleType, "部门经理") {
  447. authority = 1
  448. } else {
  449. authority = 0
  450. }
  451. }
  452. admin.Authority = authority
  453. admin.Position = req.Position
  454. admin.Province = req.Province
  455. admin.ProvinceCode = req.ProvinceCode
  456. admin.City = req.City
  457. admin.CityCode = req.CityCode
  458. err = system.AddAdmin(admin)
  459. if err != nil {
  460. br.Msg = "新增失败"
  461. br.ErrMsg = "新增失败,Err:" + err.Error()
  462. return
  463. }
  464. err = services.UpdateResearcherTagGroup(admin.AdminId, req.ResearchGroupIds)
  465. if err != nil {
  466. br.Msg = "新增失败"
  467. br.ErrMsg = "新增失败,Err:" + err.Error()
  468. return
  469. }
  470. // 清楚系统用户列表缓存key
  471. utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
  472. utils.Rc.Delete(utils.CACHE_KEY_ADMIN_ID)
  473. //thirdGroupId := 0 //角色:2=研究员,3=机构销售
  474. if admin.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  475. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  476. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  477. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT ||
  478. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT {
  479. //thirdGroupId = 2
  480. } else if admin.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER ||
  481. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP ||
  482. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER ||
  483. admin.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  484. //thirdGroupId = 3
  485. }
  486. //if thirdGroupId > 0 {
  487. // go roadshow.CreateOaUser(admin.Mobile, admin.RealName, thirdGroupId)
  488. //}
  489. // 新增弘则联系人
  490. //go services.AddHzCompanyUser(admin.Mobile, admin.RealName, this.SysUser.AdminId, this.SysUser.RealName)
  491. br.Ret = 200
  492. br.Success = true
  493. br.Msg = "新增成功"
  494. }
  495. // Edit
  496. // @Title 编辑系统用户
  497. // @Description 编辑系统用户接口
  498. // @Param request body system.SysuserEditReq true "type json string"
  499. // @Success 200 编辑成功
  500. // @router /sysuser/edit [post]
  501. func (this *SysAdminController) Edit() {
  502. br := new(models.BaseResponse).Init()
  503. defer func() {
  504. this.Data["json"] = br
  505. this.ServeJSON()
  506. }()
  507. var req system.SysuserEditReq
  508. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  509. if err != nil {
  510. br.Msg = "参数解析异常!"
  511. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  512. return
  513. }
  514. if req.RoleId <= 0 {
  515. br.Msg = "请选择角色"
  516. br.ErrMsg = "角色ID小于等于0"
  517. return
  518. }
  519. //根据用户id获取用户信息
  520. adminInfo, err := system.GetSysAdminById(req.AdminId)
  521. if err != nil {
  522. if err.Error() == utils.ErrNoRow() {
  523. br.Msg = "用户已被删除, 请刷新页面"
  524. return
  525. }
  526. br.Msg = "获取数据失败"
  527. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error() + ";AdminId:" + fmt.Sprint(req.AdminId)
  528. return
  529. }
  530. // 根据用户登录用户名获取用户信息
  531. item, err := system.GetSysAdminByName(req.AdminName)
  532. if err != nil && err.Error() != utils.ErrNoRow() {
  533. br.Msg = "获取数据失败"
  534. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error() + ";AdminName:" + req.AdminName
  535. return
  536. }
  537. if item != nil && item.AdminId != req.AdminId {
  538. br.Msg = "账号名称已存在,请重新输入"
  539. return
  540. }
  541. // 手机号
  542. if item != nil {
  543. if req.Mobile != "" && req.Mobile != item.Mobile {
  544. mobileCount, err := system.GetSysAdminCountByMobile(req.Mobile, req.AdminId)
  545. if err != nil {
  546. br.Msg = "判断手机号是否存在失败"
  547. br.ErrMsg = "判断手机号是否存在失败,Err:" + err.Error()
  548. return
  549. }
  550. if mobileCount > 0 {
  551. br.Msg = "手机号已存在,请重新填写"
  552. br.IsSendEmail = false
  553. return
  554. }
  555. }
  556. } else {
  557. mobileCount, err := system.GetSysAdminCountByMobile(req.Mobile, req.AdminId)
  558. if err != nil {
  559. br.Msg = "判断手机号是否存在失败"
  560. br.ErrMsg = "判断手机号是否存在失败,Err:" + err.Error()
  561. return
  562. }
  563. if mobileCount > 0 {
  564. br.Msg = "手机号已存在,请重新填写"
  565. br.IsSendEmail = false
  566. return
  567. }
  568. }
  569. // 角色
  570. var roleName string
  571. roleItem, err := system.GetSysRoleById(req.RoleId)
  572. if err != nil {
  573. if err.Error() == utils.ErrNoRow() {
  574. br.Msg = "角色不存在,请重新选择"
  575. br.ErrMsg = "角色不存在"
  576. return
  577. }
  578. br.Msg = "获取数据失败"
  579. br.ErrMsg = "获取角色数据失败,Err:" + err.Error()
  580. return
  581. }
  582. if roleItem != nil {
  583. roleName = roleItem.RoleName
  584. }
  585. // 员工工号
  586. req.EmployeeId = strings.TrimSpace(req.EmployeeId)
  587. if req.EmployeeId != "" {
  588. // 去重
  589. countOB := new(system.Admin)
  590. countCond := ` AND employee_id = ? AND admin_id <> ?`
  591. countPars := make([]interface{}, 0)
  592. countPars = append(countPars, req.EmployeeId, req.AdminId)
  593. countEmployee, e := countOB.GetCountByCondition(countCond, countPars)
  594. if e != nil {
  595. br.Msg = "工号去重查询失败"
  596. br.ErrMsg = "工号去重查询失败, Err: " + e.Error()
  597. return
  598. }
  599. if countEmployee > 0 {
  600. br.Msg = "工号已存在"
  601. return
  602. }
  603. }
  604. // 管理权限
  605. var authority int
  606. if roleItem.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  607. authority = 3
  608. } else if roleItem.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_TEAM {
  609. authority = 4
  610. } else if roleItem.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  611. authority = 2
  612. } else {
  613. if strings.Contains(roleItem.RoleType, "销售主管") {
  614. authority = 2
  615. } else if strings.Contains(roleItem.RoleType, "部门经理") {
  616. authority = 1
  617. } else {
  618. authority = 0
  619. }
  620. }
  621. adminInfo.AdminName = req.AdminName
  622. adminInfo.RealName = req.RealName
  623. adminInfo.LastUpdatedTime = time.Now().Format(utils.FormatDateTime)
  624. adminInfo.Mobile = req.Mobile
  625. adminInfo.RoleId = req.RoleId
  626. adminInfo.RoleName = roleName
  627. adminInfo.Enabled = req.Enabled
  628. adminInfo.Authority = authority
  629. adminInfo.Position = req.Position
  630. adminInfo.RoleTypeCode = roleItem.RoleTypeCode
  631. adminInfo.Province = req.Province
  632. adminInfo.ProvinceCode = req.ProvinceCode
  633. adminInfo.City = req.City
  634. adminInfo.CityCode = req.CityCode
  635. adminInfo.EmployeeId = req.EmployeeId
  636. cols := []string{
  637. "AdminName", "RealName", "LastUpdatedTime", "Mobile", "RoleId", "RoleName", "Enabled", "Authority",
  638. "Position", "RoleTypeCode", "Province", "ProvinceCode", "City", "CityCode", "EmployeeId",
  639. }
  640. if e := adminInfo.Update(cols); e != nil {
  641. br.Msg = "编辑失败"
  642. br.ErrMsg = "更新用户信息失败, Err:" + e.Error()
  643. return
  644. }
  645. // 用户登出
  646. logOutSystemUser(adminInfo.AdminId)
  647. // 研究方向分组
  648. if e := services.UpdateResearcherTagGroup(req.AdminId, req.ResearchGroupIds); e != nil {
  649. br.Msg = "编辑失败"
  650. br.ErrMsg = "更新用户研究方向失败, Err:" + e.Error()
  651. return
  652. }
  653. // 清楚系统用户列表缓存key
  654. utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
  655. utils.Rc.Delete(utils.CACHE_KEY_ADMIN_ID)
  656. br.Ret = 200
  657. br.Success = true
  658. br.IsAddLog = true
  659. br.Msg = "编辑成功"
  660. }
  661. // @Title 开启/禁用系统用户
  662. // @Description 开启/禁用系统用户接口
  663. // @Param request body system.SysuserEditReq true "type json string"
  664. // @Success 200 操作成功
  665. // @router /sysuser/editEnabled [post]
  666. func (this *SysAdminController) EditEnabled() {
  667. br := new(models.BaseResponse).Init()
  668. defer func() {
  669. this.Data["json"] = br
  670. this.ServeJSON()
  671. }()
  672. var req system.SysuserEditEnabledReq
  673. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  674. if err != nil {
  675. br.Msg = "参数解析异常!"
  676. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  677. return
  678. }
  679. adminItem, err := system.GetSysAdminById(req.AdminId)
  680. if err != nil {
  681. br.Msg = "获取数据失败"
  682. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error()
  683. return
  684. }
  685. if req.Enabled == 0 {
  686. //禁用
  687. err = system.DisableAdmin(req.AdminId)
  688. if err != nil {
  689. br.Msg = "修改失败"
  690. br.ErrMsg = "修改系统用户数据失败,Err:" + err.Error()
  691. return
  692. }
  693. } else {
  694. admin := new(system.Admin)
  695. admin.Enabled = req.Enabled
  696. admin.AdminId = req.AdminId
  697. err = system.EditAdminEnabled(admin)
  698. if err != nil {
  699. br.Msg = "修改失败"
  700. br.ErrMsg = "修改系统用户数据失败,Err:" + err.Error()
  701. return
  702. }
  703. }
  704. //用户被禁用的情况下,需要将他对应的token给过期
  705. if adminItem.Enabled == 1 && req.Enabled == 0 {
  706. logOutSystemUser(adminItem.AdminId)
  707. }
  708. // 联动弘则研究公司下的联系人启禁用
  709. {
  710. go services.SwitchHzUserEnabledByMobile(req.Enabled, adminItem.Mobile)
  711. }
  712. if err != nil {
  713. br.Msg = "操作失败"
  714. br.ErrMsg = "操作失败,Err:" + err.Error()
  715. return
  716. }
  717. br.Ret = 200
  718. br.Success = true
  719. br.IsAddLog = true
  720. br.Msg = "操作成功"
  721. }
  722. // @Title 删除系统用户
  723. // @Description 删除系统用户接口
  724. // @Param request body system.SysuserDeleteReq true "type json string"
  725. // @Success 200 删除成功
  726. // @router /sysuser/delete [post]
  727. func (this *SysAdminController) Delete() {
  728. br := new(models.BaseResponse).Init()
  729. defer func() {
  730. this.Data["json"] = br
  731. this.ServeJSON()
  732. }()
  733. var req system.SysuserDeleteReq
  734. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  735. if err != nil {
  736. br.Msg = "参数解析异常!"
  737. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  738. return
  739. }
  740. if req.AdminId <= 0 {
  741. br.Msg = "参数错误"
  742. br.ErrMsg = "参数错误,GroupId 小于等于0 "
  743. return
  744. }
  745. mobile := ""
  746. adminInfo, _ := system.GetSysUserById(req.AdminId)
  747. if adminInfo != nil {
  748. mobile = adminInfo.Mobile
  749. }
  750. err = system.DeleteSysuser(req.AdminId)
  751. if err != nil {
  752. br.Msg = "删除失败"
  753. br.ErrMsg = "删除失败,Err:" + err.Error()
  754. return
  755. }
  756. // 删除手工数据关联用户
  757. {
  758. go data_manage.DeleteManualUser(req.AdminId)
  759. }
  760. // 删除弘则研究公司下的相同手机号联系人
  761. {
  762. go services.DeleteHzUserByMobile(mobile)
  763. }
  764. // 清楚系统用户列表缓存key
  765. utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
  766. utils.Rc.Delete(utils.CACHE_KEY_ADMIN_ID)
  767. br.Ret = 200
  768. br.Success = true
  769. br.IsAddLog = true
  770. br.Msg = "删除成功"
  771. }
  772. /*
  773. func init() {
  774. fmt.Println("start")
  775. pwdStr:=`11111`
  776. //compile := `(\d+.*[^a-zA-Z]+){6,12}|([^a-zA-Z]+.*\d+){6,12}`
  777. compile := `([0-9a-z]+){6,12}|(a-z0-9]+){6,12}`
  778. ///^(?![0-9]+$)(?![a-zA-Z]+$)[0-9A-Za-z]{6,12}$/
  779. ///^(?![0-9]+$)(?![a-zA-Z]+$)[0-9A-Za-z]{6,12}$/
  780. reg := regexp.MustCompile(compile)
  781. flag := reg.MatchString(pwdStr)
  782. fmt.Println(flag)
  783. fmt.Println("end")
  784. }*/
  785. // SetConfig
  786. // @Title 用户信息配置接口
  787. // @Description 用户信息配置接口
  788. // @Success 200 {object} system.SetAdminConfigReq
  789. // @router /sysuser/config/set [post]
  790. func (this *SysAdminController) SetConfig() {
  791. br := new(models.BaseResponse).Init()
  792. defer func() {
  793. this.Data["json"] = br
  794. this.ServeJSON()
  795. }()
  796. sysUser := this.SysUser
  797. if sysUser == nil {
  798. br.Msg = "请登录"
  799. br.ErrMsg = "请登录,SysUser Is Empty"
  800. br.Ret = 408
  801. return
  802. }
  803. var req system.SetAdminConfigReq
  804. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  805. if err != nil {
  806. br.Msg = "参数解析异常!"
  807. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  808. return
  809. }
  810. item, err := system.GetConfigDetailByCode(this.SysUser.AdminId, req.ConfigCode)
  811. if err != nil {
  812. if err.Error() != utils.ErrNoRow() {
  813. br.Msg = "设置失败"
  814. br.ErrMsg = "设置失败,Err:" + err.Error()
  815. return
  816. }
  817. // 获取默认配置
  818. defaultConfig, err := system.GetDefaultConfigDetailByCode(req.ConfigCode)
  819. if err != nil {
  820. br.Msg = "设置失败"
  821. br.ErrMsg = "获取默认配置失败,Err:" + err.Error()
  822. return
  823. }
  824. adminConfigItem := &system.AdminConfig{
  825. //ConfigId: 0,
  826. AdminId: this.SysUser.AdminId,
  827. ConfigCode: req.ConfigCode,
  828. ConfigValue: req.ConfigValue,
  829. Remark: defaultConfig.Remark,
  830. CreateTime: time.Now(),
  831. }
  832. err = adminConfigItem.Create()
  833. if err != nil {
  834. br.Msg = "设置失败"
  835. br.ErrMsg = "设置失败,Err:" + err.Error()
  836. return
  837. }
  838. } else {
  839. // 存在配置,那么就修改
  840. item.ConfigValue = req.ConfigValue
  841. err = item.Update([]string{"ConfigValue"})
  842. if err != nil {
  843. br.Msg = "设置失败"
  844. br.ErrMsg = "设置失败,Err:" + err.Error()
  845. return
  846. }
  847. }
  848. br.Ret = 200
  849. br.Success = true
  850. br.Msg = "设置成功"
  851. }
  852. // logOutSystemUser 用户登出
  853. func logOutSystemUser(adminId int) {
  854. // 退出管理后台
  855. _ = system.ExpiredSysSessionByAdminId(adminId)
  856. // 退出随手办公小程序
  857. _ = system.UnBindAdminRecordByUserId(adminId)
  858. }
  859. // Move
  860. // @Title 移动分组
  861. // @Description 移动分组
  862. // @Param request body system.SysUserMoveReq true "type json string"
  863. // @Success 200 编辑成功
  864. // @router /sysuser/move [post]
  865. func (this *SysAdminController) Move() {
  866. br := new(models.BaseResponse).Init()
  867. defer func() {
  868. this.Data["json"] = br
  869. this.ServeJSON()
  870. }()
  871. var req system.SysUserMoveReq
  872. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  873. if err != nil {
  874. br.Msg = "参数解析异常!"
  875. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  876. return
  877. }
  878. if req.AdminId <= 0 {
  879. br.Msg = "参数有误"
  880. br.ErrMsg = "参数有误, AdminId"
  881. return
  882. }
  883. if req.DepartmentId <= 0 {
  884. br.Msg = "请选择部门"
  885. return
  886. }
  887. adminInfo, err := system.GetSysAdminById(req.AdminId)
  888. if err != nil && err.Error() != utils.ErrNoRow() {
  889. br.Msg = "获取数据失败"
  890. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error() + ";AdminId:" + fmt.Sprint(req.AdminId)
  891. return
  892. }
  893. var departmentName, groupName, teamName string
  894. if req.DepartmentId > 0 {
  895. departmentItem, err := system.GetSysDepartmentById(req.DepartmentId)
  896. if err != nil {
  897. br.Msg = "获取数据失败"
  898. br.ErrMsg = "获取部门数据失败,Err:" + err.Error()
  899. return
  900. }
  901. if departmentItem != nil {
  902. departmentName = departmentItem.DepartmentName
  903. }
  904. }
  905. if req.GroupId > 0 {
  906. groupItem, err := system.GetSysGroupById(req.GroupId)
  907. if err != nil {
  908. br.Msg = "获取数据失败"
  909. br.ErrMsg = "获取分组数据失败,Err:" + err.Error()
  910. return
  911. }
  912. if groupItem != nil {
  913. groupName = groupItem.GroupName
  914. }
  915. }
  916. if req.TeamId > 0 {
  917. teamItem, err := system.GetSysGroupById(req.TeamId)
  918. if err != nil {
  919. br.Msg = "获取数据失败"
  920. br.ErrMsg = "获取小组数据失败,Err:" + err.Error()
  921. return
  922. }
  923. if teamItem != nil {
  924. teamName = teamItem.GroupName
  925. }
  926. }
  927. adminInfo.DepartmentId = req.DepartmentId
  928. adminInfo.DepartmentName = departmentName
  929. if req.TeamId <= 0 {
  930. adminInfo.GroupId = req.GroupId
  931. adminInfo.GroupName = groupName
  932. } else {
  933. adminInfo.GroupId = req.TeamId
  934. adminInfo.GroupName = teamName
  935. }
  936. adminInfo.LastUpdatedTime = time.Now().Format(utils.FormatDateTime)
  937. if e := adminInfo.Update([]string{"DepartmentId", "DepartmentName", "GroupId", "GroupName", "LastUpdatedTime"}); e != nil {
  938. br.Msg = "操作失败"
  939. br.ErrMsg = "更新系统用户分组失败, Err: " + e.Error()
  940. return
  941. }
  942. // 修改客户关联的分组
  943. {
  944. if req.TeamId > 0 {
  945. if req.TeamId != adminInfo.GroupId {
  946. err = company.ModifyCompanyGroupId(req.AdminId, req.TeamId)
  947. if err != nil {
  948. br.Msg = "编辑失败"
  949. br.ErrMsg = "ModifyCompanyGroupId,Err:" + err.Error()
  950. return
  951. }
  952. }
  953. } else {
  954. if req.GroupId != adminInfo.GroupId {
  955. err = company.ModifyCompanyGroupId(req.AdminId, req.GroupId)
  956. if err != nil {
  957. br.Msg = "编辑失败"
  958. br.ErrMsg = "ModifyCompanyGroupId,Err:" + err.Error()
  959. return
  960. }
  961. }
  962. }
  963. if req.DepartmentId != adminInfo.DepartmentId {
  964. err = company.ModifyCompanyDepartmentId(req.AdminId, req.DepartmentId)
  965. if err != nil {
  966. br.Msg = "编辑失败"
  967. br.ErrMsg = "ModifyCompanyDepartmentId,Err:" + err.Error()
  968. return
  969. }
  970. }
  971. }
  972. // 清除系统用户列表缓存key
  973. _ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
  974. _ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN_ID)
  975. br.Ret = 200
  976. br.Success = true
  977. br.IsAddLog = true
  978. br.Msg = "操作成功"
  979. }
  980. // ResetPass
  981. // @Title 重置密码
  982. // @Description 重置密码
  983. // @Param request body system.SysUserResetPassReq true "type json string"
  984. // @Success 200 编辑成功
  985. // @router /sysuser/reset_pass [post]
  986. func (this *SysAdminController) ResetPass() {
  987. br := new(models.BaseResponse).Init()
  988. defer func() {
  989. this.Data["json"] = br
  990. this.ServeJSON()
  991. }()
  992. var req system.SysUserResetPassReq
  993. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  994. if err != nil {
  995. br.Msg = "参数解析异常!"
  996. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  997. return
  998. }
  999. if req.AdminId <= 0 {
  1000. br.Msg = "参数有误"
  1001. br.ErrMsg = "参数有误, AdminId"
  1002. return
  1003. }
  1004. req.Password = strings.TrimSpace(req.Password)
  1005. if req.Password == "" {
  1006. br.Msg = "新密码不能为空"
  1007. return
  1008. }
  1009. req.RePassword = strings.TrimSpace(req.RePassword)
  1010. if req.RePassword == "" {
  1011. br.Msg = "确认密码不能为空"
  1012. return
  1013. }
  1014. if req.Password != req.RePassword {
  1015. br.Msg = "两次输入密码不一致,请重新填写"
  1016. return
  1017. }
  1018. adminInfo, err := system.GetSysAdminById(req.AdminId)
  1019. if err != nil {
  1020. if err.Error() == utils.ErrNoRow() {
  1021. br.Msg = "用户已被删除, 请刷新页面"
  1022. return
  1023. }
  1024. br.Msg = "获取数据失败"
  1025. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error() + ";AdminId:" + fmt.Sprint(req.AdminId)
  1026. return
  1027. }
  1028. b, err := base64.StdEncoding.DecodeString(req.Password)
  1029. if err != nil {
  1030. br.Msg = "解析数据失败"
  1031. br.ErrMsg = "解析数据失败,Err:" + err.Error()
  1032. return
  1033. }
  1034. pwd := string(b)
  1035. pwd = strings.ToLower(pwd)
  1036. pwd = utils.MD5(pwd)
  1037. adminInfo.Password = pwd
  1038. adminInfo.LastUpdatedPasswordTime = time.Now().Format(utils.FormatDateTime)
  1039. adminInfo.LastUpdatedTime = time.Now().Format(utils.FormatDateTime)
  1040. if e := adminInfo.Update([]string{"Password", "LastUpdatedPasswordTime", "LastUpdatedTime"}); e != nil {
  1041. br.Msg = "操作失败"
  1042. br.ErrMsg = "更新系统用户分组失败, Err: " + e.Error()
  1043. return
  1044. }
  1045. // 清除系统用户列表缓存key
  1046. _ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN)
  1047. _ = utils.Rc.Delete(utils.CACHE_KEY_ADMIN_ID)
  1048. br.Ret = 200
  1049. br.Success = true
  1050. br.IsAddLog = true
  1051. br.Msg = "重置密码成功"
  1052. }