user.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "eta/eta_mini_crm/models"
  5. "eta/eta_mini_crm/models/request"
  6. "eta/eta_mini_crm/models/response"
  7. "eta/eta_mini_crm/services"
  8. "eta/eta_mini_crm/utils"
  9. "math"
  10. "strings"
  11. "time"
  12. "github.com/beego/beego/v2/client/orm"
  13. "github.com/rdlucklib/rdluck_tools/paging"
  14. )
  15. type UserController struct {
  16. BaseAuthController
  17. }
  18. // Add
  19. // @Title 添加新客户
  20. // @Description 添加新客户
  21. // @Param request body request.UserAddReq true "type json string"
  22. // @Success 200 {object} request.UserAddReq
  23. // @router /add [post]
  24. func (this *UserController) Add() {
  25. br := new(models.BaseResponse).Init()
  26. defer func() {
  27. this.Data["json"] = br
  28. this.ServeJSON()
  29. }()
  30. var req request.UserAddReq
  31. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  32. if err != nil {
  33. br.Msg = "参数解析异常!"
  34. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  35. return
  36. }
  37. if req.RealName == "" {
  38. br.Msg = "请输入姓名"
  39. return
  40. }
  41. req.Phone = strings.TrimSpace(req.Phone)
  42. req.Email = strings.TrimSpace(req.Email)
  43. if req.Phone == "" && req.Email == "" {
  44. br.Msg = "至少输入一个手机号或邮箱"
  45. return
  46. }
  47. var userByPhone, userByEmail *models.User
  48. if req.Phone != "" {
  49. if req.AreaCode == "86" {
  50. if !utils.ValidateMobileFormatat(req.Phone) {
  51. br.Msg = "手机号格式有误, 请检查"
  52. return
  53. }
  54. }
  55. userByPhone, err = models.GetUserByPhone(req.Phone, req.AreaCode)
  56. if err != nil && err != orm.ErrNoRows {
  57. br.Msg = "添加用户失败"
  58. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  59. return
  60. }
  61. if userByPhone != nil {
  62. switch userByPhone.Status {
  63. case 0:
  64. userByPhone.Status = 2
  65. case 1:
  66. userByPhone.Status = 2
  67. default:
  68. br.Msg = "手机号已存在,请重新输入"
  69. return
  70. }
  71. }
  72. }
  73. if req.Email != "" {
  74. if !utils.ValidateEmailFormatat(req.Email) {
  75. br.Msg = "邮箱格式有误, 请检查"
  76. return
  77. }
  78. userByEmail, err = models.GetUserByEmail(req.Email)
  79. if err != nil && err != orm.ErrNoRows {
  80. br.Msg = "添加用户失败"
  81. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  82. return
  83. }
  84. if userByEmail != nil {
  85. switch userByEmail.Status {
  86. case 0:
  87. userByEmail.Status = 2
  88. case 1:
  89. userByEmail.Status = 2
  90. default:
  91. br.Msg = "邮箱已存在,请重新输入"
  92. return
  93. }
  94. }
  95. }
  96. if req.SellerId <= 0 {
  97. br.Msg = "请选择营业部/销售"
  98. return
  99. }
  100. if req.ValidStartTime == "" || req.ValidEndTime == "" {
  101. br.Msg = "请选择合理的有效期范围"
  102. return
  103. }
  104. validStartTime, err := time.Parse("2006-01-02", req.ValidStartTime)
  105. if err != nil {
  106. br.Msg = "错误的日期格式"
  107. return
  108. }
  109. validEndTime, err := time.Parse("2006-01-02", req.ValidEndTime)
  110. if err != nil {
  111. br.Msg = "错误的日期格式"
  112. return
  113. }
  114. if !validStartTime.Before(validEndTime) {
  115. br.Msg = "请选择合理的有效期范围"
  116. return
  117. }
  118. if req.Company == "" {
  119. br.Msg = "请输入所属公司"
  120. return
  121. }
  122. if userByPhone != nil && userByEmail != nil && userByPhone.UserId != userByEmail.UserId {
  123. br.Msg = "邮箱已存在,请重新输入"
  124. return
  125. }
  126. user := &models.User{}
  127. curTime := time.Now()
  128. if userByPhone == nil && userByEmail == nil {
  129. user.CreateTime = curTime
  130. user.ModifyTime = curTime
  131. }
  132. if userByEmail != nil {
  133. user = userByEmail
  134. }
  135. if userByPhone != nil {
  136. user = userByPhone
  137. }
  138. validStartTime = validStartTime.Local().Add(-time.Hour * 8)
  139. validEndTime = validEndTime.Local().Add(-time.Hour*8 + time.Hour*24)
  140. if curTime.Before(validEndTime) {
  141. user.Status = 2
  142. } else {
  143. user.Status = 0
  144. }
  145. user.RealName = req.RealName
  146. user.AreaCode = req.AreaCode
  147. user.Phone = req.Phone
  148. user.Email = req.Email
  149. user.SellerId = req.SellerId
  150. user.ValidStartTime = validStartTime
  151. user.ValidEndTime = validEndTime
  152. user.Company = req.Company
  153. user.ModifyTime = curTime
  154. err = models.SaveUser(user, req.ChartPermission)
  155. if err != nil {
  156. br.Msg = "添加客户失败"
  157. br.ErrMsg = "添加客户失败,系统错误,Err:" + err.Error()
  158. return
  159. }
  160. if user.Status == 2 {
  161. userRecord := &models.UserChangeRecord{}
  162. userRecord.UserId = user.UserId
  163. userRecord.SysUserId = this.SysUser.SysUserId
  164. userRecord.Content = this.SysUser.SysRealName + "新增用户"
  165. userRecord.Insert()
  166. }
  167. br.Msg = "添加成功"
  168. br.Success = true
  169. br.Ret = 200
  170. }
  171. // edit
  172. // @Title 编辑客户
  173. // @Description 编辑客户
  174. // @Param request body request.UserEidtReq true "type json string"
  175. // @Success 200 {object} request.UserAddReq
  176. // @router /edit [post]
  177. func (this *UserController) Edit() {
  178. br := new(models.BaseResponse).Init()
  179. defer func() {
  180. this.Data["json"] = br
  181. this.ServeJSON()
  182. }()
  183. var req request.UserEidtReq
  184. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  185. if err != nil {
  186. br.Msg = "参数解析异常!"
  187. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  188. return
  189. }
  190. if req.RealName == "" {
  191. br.Msg = "请输入姓名"
  192. return
  193. }
  194. req.Phone = strings.TrimSpace(req.Phone)
  195. req.Email = strings.TrimSpace(req.Email)
  196. if req.Phone == "" && req.Email == "" {
  197. br.Msg = "至少输入一个手机号或邮箱"
  198. return
  199. }
  200. if req.Phone != "" {
  201. if req.AreaCode == "86" {
  202. if !utils.ValidateMobileFormatat(req.Phone) {
  203. br.Msg = "手机号格式有误, 请检查"
  204. return
  205. }
  206. }
  207. user, err := models.GetUserByPhone(req.Phone, req.AreaCode)
  208. if err != nil && err != orm.ErrNoRows {
  209. br.Msg = "编辑用户失败"
  210. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  211. return
  212. }
  213. if user != nil && user.UserId != req.UserId {
  214. br.Msg = "手机号已存在,请重新输入"
  215. return
  216. }
  217. }
  218. if req.Email != "" {
  219. if !utils.ValidateEmailFormatat(req.Email) {
  220. br.Msg = "邮箱格式有误, 请检查"
  221. return
  222. }
  223. user, err := models.GetUserByEmail(req.Email)
  224. if err != nil && err != orm.ErrNoRows {
  225. br.Msg = "编辑用户失败"
  226. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  227. return
  228. }
  229. if user != nil && user.UserId != req.UserId {
  230. br.Msg = "邮箱已存在,请重新输入"
  231. return
  232. }
  233. }
  234. if req.SellerId <= 0 {
  235. br.Msg = "请选择营业部/销售"
  236. return
  237. }
  238. if req.ValidStartTime == "" || req.ValidEndTime == "" {
  239. br.Msg = "请选择合理的有效期范围"
  240. return
  241. }
  242. validStartTime, err := time.Parse("2006-01-02", req.ValidStartTime)
  243. if err != nil {
  244. br.Msg = "错误的日期格式"
  245. return
  246. }
  247. validStartTime = validStartTime.In(time.Local).Add(-time.Hour * 8)
  248. validEndTime, err := time.Parse("2006-01-02", req.ValidEndTime)
  249. if err != nil {
  250. br.Msg = "错误的日期格式"
  251. return
  252. }
  253. validEndTime = validEndTime.In(time.Local).Add(-time.Hour*8 + time.Hour*24)
  254. if !validStartTime.Before(validEndTime) {
  255. br.Msg = "请选择合理的有效期范围"
  256. return
  257. }
  258. if req.Company == "" {
  259. br.Msg = "请输入所属公司"
  260. return
  261. }
  262. user, err := models.GetUserById(req.UserId)
  263. if err != nil {
  264. if err == orm.ErrNoRows {
  265. br.Msg = "用户不存在或已删除,请重新刷新页面"
  266. br.ErrMsg = "用户不存在或已删除,请重新刷新页面,Err:" + err.Error()
  267. return
  268. }
  269. br.Msg = "编辑用户失败"
  270. br.ErrMsg = "编辑用户失败, 系统错误,Err:" + err.Error()
  271. return
  272. }
  273. user.RealName = req.RealName
  274. user.AreaCode = req.AreaCode
  275. user.Phone = req.Phone
  276. user.Email = req.Email
  277. user.SellerId = req.SellerId
  278. user.ValidStartTime = validStartTime
  279. user.ValidEndTime = validEndTime
  280. user.Company = req.Company
  281. user.ModifyTime = time.Now()
  282. curTime := time.Now()
  283. if !req.IsEnabled {
  284. user.Status = 0
  285. } else if curTime.Before(validEndTime) {
  286. user.Status = 2
  287. } else {
  288. user.Status = 1
  289. }
  290. err = models.SaveUser(user, req.ChartPermission)
  291. if err != nil {
  292. br.Msg = "添加客户失败"
  293. br.ErrMsg = "添加客户失败,系统错误,Err:" + err.Error()
  294. return
  295. }
  296. record := &models.UserChangeRecord{}
  297. record.UserId = req.UserId
  298. record.SysUserId = this.SysUser.SysUserId
  299. if user.Status == 2 {
  300. record.Content = this.SysUser.SysRealName + "新增用户"
  301. } else {
  302. record.Content = this.SysUser.SysRealName + "编辑用户"
  303. }
  304. record.Insert()
  305. br.Msg = "编辑成功"
  306. br.Success = true
  307. br.Ret = 200
  308. }
  309. // Check
  310. // @Title 编辑客户
  311. // @Description 编辑客户
  312. // @Param request body request.UserEidtReq true "type json string"
  313. // @Success 200 {object} request.UserAddReq
  314. // @router /check [post]
  315. func (this *UserController) Check() {
  316. br := new(models.BaseResponse).Init()
  317. defer func() {
  318. this.Data["json"] = br
  319. this.ServeJSON()
  320. }()
  321. var req request.UserCheckReq
  322. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  323. if err != nil {
  324. br.Msg = "参数解析异常!"
  325. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  326. return
  327. }
  328. req.Phone = strings.TrimSpace(req.Phone)
  329. req.Email = strings.TrimSpace(req.Email)
  330. if req.Phone == "" && req.Email == "" {
  331. br.Msg = "至少输入一个手机号或邮箱"
  332. return
  333. }
  334. userCheckResp := new(response.UserCheckResp)
  335. if req.Phone != "" {
  336. if req.AreaCode == "86" {
  337. if !utils.ValidateMobileFormatat(req.Phone) {
  338. br.Msg = "手机号格式有误, 请检查"
  339. return
  340. }
  341. }
  342. user, err := models.GetUserByPhone(req.Phone, req.AreaCode)
  343. if err != nil && err != orm.ErrNoRows {
  344. br.Msg = "编辑用户失败"
  345. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  346. return
  347. }
  348. if user != nil {
  349. userCheckResp.UserId = user.UserId
  350. if user.Status == 0 {
  351. br.Ret = 200
  352. br.Success = true
  353. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  354. br.Data = userCheckResp
  355. return
  356. }
  357. if user.Status == 1 {
  358. br.Ret = 200
  359. br.Success = true
  360. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  361. br.Data = userCheckResp
  362. return
  363. }
  364. if user.Status == 2 {
  365. br.Msg = "手机号已存在,请重新输入"
  366. return
  367. }
  368. }
  369. }
  370. if req.Email != "" {
  371. if !utils.ValidateEmailFormatat(req.Email) {
  372. br.Msg = "邮箱格式有误, 请检查"
  373. return
  374. }
  375. user, err := models.GetUserByEmail(req.Email)
  376. if err != nil && err != orm.ErrNoRows {
  377. br.Msg = "编辑用户失败"
  378. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  379. return
  380. }
  381. if user != nil {
  382. userCheckResp.UserId = user.UserId
  383. if user.Status == 0 {
  384. br.Ret = 200
  385. br.Success = true
  386. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  387. br.Data = userCheckResp
  388. return
  389. }
  390. if user.Status == 1 {
  391. br.Ret = 200
  392. br.Success = true
  393. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  394. br.Data = userCheckResp
  395. return
  396. }
  397. if user.Status == 2 {
  398. br.Msg = "邮箱已存在,请重新输入"
  399. return
  400. }
  401. return
  402. }
  403. }
  404. br.Ret = 200
  405. br.Success = true
  406. br.Msg = "邮箱或手机号合格"
  407. }
  408. // List
  409. // @Title 用户列表
  410. // @Description 用户列表
  411. // @Param PageSize query int true "每页数据条数"
  412. // @Param CurrentIndex query int true "当前页页码,从1开始"
  413. // @Param SellerId query string true "销售id"
  414. // @Param Status query int true "用户状态"
  415. // @Param KeyWord query string true "手机号/邮箱/姓名"
  416. // @Param IsRegistered query string true "是否注册"
  417. // @Param IsSubscribed query string true "是否关注"
  418. // @Param RegisterStartDate query string true "注册开始时间"
  419. // @Param RegisterEndDate query string true "注册结束时间"
  420. // @Param CreateStartDate query string true "创建开始时间"
  421. // @Param CreateEndDate query string true "创建结束时间"
  422. // @Param SortParam query string true "排序字段"
  423. // @Param SortType query string true "排序方式"
  424. // @Success 200 {object} response.UserListResp
  425. // @router /list [get]
  426. func (this *UserController) List() {
  427. br := new(models.BaseResponse).Init()
  428. defer func() {
  429. this.Data["json"] = br
  430. this.ServeJSON()
  431. }()
  432. pageSize, _ := this.GetInt("PageSize")
  433. currentIndex, _ := this.GetInt("CurrentIndex")
  434. sellerIdStr := this.GetString("SellerId")
  435. status := this.GetString("Status")
  436. keyWord := this.GetString("KeyWord")
  437. IsRegistered := this.GetString("IsRegistered")
  438. IsSubscribed := this.GetString("IsSubscribed")
  439. registerStartDate := this.GetString("RegisterStartDate")
  440. registerEndDate := this.GetString("RegisterEndDate")
  441. createStartDate := this.GetString("CreateStartDate")
  442. createEndDate := this.GetString("CreateEndDate")
  443. sortParma := this.GetString("SortParam")
  444. sortType := this.GetString("SortType")
  445. var condition string
  446. var sortCondition string
  447. var pars []interface{}
  448. if keyWord != "" {
  449. condition += ` AND (u.real_name LIKE ? OR u.phone LIKE ? OR u.email LIKE ?) `
  450. pars = utils.GetLikeKeywordPars(pars, keyWord, 3)
  451. }
  452. if pageSize <= 0 {
  453. pageSize = utils.PageSize20
  454. } else if pageSize > utils.PageSize100 {
  455. pageSize = utils.PageSize100
  456. }
  457. if currentIndex <= 0 {
  458. currentIndex = 1
  459. }
  460. if sortParma != "" && sortType != "" {
  461. sortCondition = " ORDER BY "
  462. var param, sort string
  463. switch sortParma {
  464. case "RegisterTime":
  465. param = "u.register_time"
  466. case "CreateTime":
  467. param = "u.create_time"
  468. case "RestDate":
  469. param = "u.valid_end_time"
  470. }
  471. switch sortType {
  472. case "asc":
  473. sort = " ASC "
  474. case "desc":
  475. sort = " DESC "
  476. }
  477. if param != "" && sort != "" {
  478. sortCondition += param + " " + sort
  479. } else {
  480. sortCondition = ""
  481. }
  482. }
  483. if sellerIdStr != "" {
  484. sellerIds := strings.Split(sellerIdStr, ",")
  485. if len(sellerIds) != 0 {
  486. condition += ` AND ( `
  487. for i, id := range sellerIds {
  488. if i == 0 {
  489. condition += ` u.seller_id = ? `
  490. pars = append(pars, id)
  491. } else {
  492. condition += ` OR u.seller_id = ? `
  493. pars = append(pars, id)
  494. }
  495. }
  496. condition += `) `
  497. }
  498. }
  499. switch status {
  500. case "禁用":
  501. condition += " AND u.status=? "
  502. pars = append(pars, 0)
  503. case "潜在":
  504. condition += " AND u.status=? "
  505. pars = append(pars, 1)
  506. case "正式":
  507. condition += " AND u.status=? "
  508. pars = append(pars, 2)
  509. case "":
  510. condition += " AND (u.status=? OR u.status=?) "
  511. pars = append(pars, 0, 2)
  512. }
  513. switch IsRegistered {
  514. case "是":
  515. condition += " AND u.is_registered=? "
  516. pars = append(pars, true)
  517. case "否":
  518. condition += " AND u.is_registered=? "
  519. pars = append(pars, false)
  520. }
  521. switch IsSubscribed {
  522. case "是":
  523. condition += " AND u.is_subscribed=? "
  524. pars = append(pars, true)
  525. case "否":
  526. condition += " AND u.is_subscribed=? "
  527. pars = append(pars, false)
  528. }
  529. if registerStartDate != "" {
  530. registerStartTime, er := time.Parse(utils.FormatDate, registerStartDate)
  531. if er != nil {
  532. br.Msg = "日期格式有误"
  533. return
  534. }
  535. condition += " AND u.register_time>? "
  536. pars = append(pars, registerStartTime)
  537. }
  538. if registerEndDate != "" {
  539. registerEndTime, er := time.Parse(utils.FormatDate, registerEndDate)
  540. if er != nil {
  541. br.Msg = "日期格式有误"
  542. return
  543. }
  544. condition += " AND u.register_time<? "
  545. pars = append(pars, registerEndTime)
  546. }
  547. if createStartDate != "" {
  548. createStartTime, er := time.Parse(utils.FormatDate, createStartDate)
  549. if er != nil {
  550. br.Msg = "日期格式有误"
  551. return
  552. }
  553. condition += " AND u.create_time>? "
  554. pars = append(pars, createStartTime)
  555. }
  556. if createEndDate != "" {
  557. createEndTime, er := time.Parse(utils.FormatDate, createEndDate)
  558. if er != nil {
  559. br.Msg = "日期格式有误"
  560. return
  561. }
  562. condition += " AND u.create_time<? "
  563. pars = append(pars, createEndTime)
  564. }
  565. if pageSize <= 0 {
  566. pageSize = utils.PageSize20
  567. } else if pageSize > utils.PageSize100 {
  568. pageSize = utils.PageSize100
  569. }
  570. if currentIndex <= 0 {
  571. currentIndex = 1
  572. }
  573. startSize := utils.StartIndex(currentIndex, pageSize)
  574. total, err := models.GetUserCount(condition, pars)
  575. if err != nil {
  576. br.Msg = "获取失败"
  577. br.ErrMsg = "获取失败,Err:" + err.Error()
  578. return
  579. }
  580. userList, err := models.GetUserListByConditonSort(condition, sortCondition, pars, startSize, pageSize)
  581. if err != nil {
  582. br.Msg = "查询用户失败"
  583. br.Msg = "查询用户失败,系统错误,Err:" + err.Error()
  584. return
  585. }
  586. for _, u := range userList {
  587. if u.ValidEndTime == "" {
  588. u.RestDate = 0
  589. } else {
  590. endTime, err := time.Parse(utils.FormatDateTime, u.ValidEndTime)
  591. if err != nil {
  592. br.Msg = "用户有效时间格式有误"
  593. br.ErrMsg = "用户有效时间格式有误,Err:" + err.Error()
  594. return
  595. }
  596. // 对天数向上取整
  597. daysBetween := int(math.Ceil(time.Until(endTime).Hours() / 24))
  598. if daysBetween < 0 {
  599. daysBetween = 0
  600. }
  601. u.RestDate = daysBetween
  602. }
  603. }
  604. page := paging.GetPaging(currentIndex, pageSize, total)
  605. resp := new(response.UserListResp)
  606. resp.Paging = page
  607. resp.List = userList
  608. br.Data = resp
  609. br.Ret = 200
  610. br.Success = true
  611. br.Msg = "获取成功"
  612. }
  613. // Detail
  614. // @Title 用户详情信息
  615. // @Description 用户详情信息
  616. // @Param UserId query int true "用户id"
  617. // @Success 200 {object} models.LoginResp
  618. // @router /detail [get]
  619. func (this *UserController) Detail() {
  620. br := new(models.BaseResponse).Init()
  621. defer func() {
  622. this.Data["json"] = br
  623. this.ServeJSON()
  624. }()
  625. UserId, _ := this.GetInt("UserId")
  626. if UserId <= 0 {
  627. br.Msg = "查询用户不存在"
  628. return
  629. }
  630. user, err := models.GetUserById(UserId)
  631. if err != nil {
  632. if err == orm.ErrNoRows {
  633. br.Msg = "用户不存在或已删除,请刷新页面"
  634. return
  635. }
  636. br.Msg = "查询用户失败"
  637. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  638. return
  639. }
  640. if user == nil {
  641. br.Msg = "用户不存在或已删除,请刷新页面"
  642. return
  643. }
  644. permissionList, err := services.GetUserPermissionById(UserId)
  645. if err != nil {
  646. br.Msg = "用户权限获取失败,请重新尝试"
  647. return
  648. }
  649. permissionMap := make(map[string][]string)
  650. for _, pm := range permissionList {
  651. permissionMap[pm.ParentName] = append(permissionMap[pm.ParentName], pm.PermissionName)
  652. }
  653. resp := new(response.UserDetailResp)
  654. resp.Detail = user
  655. resp.Permission = permissionMap
  656. br.Msg = "查询成功"
  657. br.Ret = 200
  658. br.Success = true
  659. br.Data = resp
  660. }
  661. // Delete
  662. // @Title 系统用户详情信息
  663. // @Description 用户详情信息
  664. // @Param request body request.UserDeleteReq true "type json string"
  665. // @Success 200 {object} models.LoginResp
  666. // @router /delete [post]
  667. func (this *UserController) Delete() {
  668. br := new(models.BaseResponse).Init()
  669. defer func() {
  670. this.Data["json"] = br
  671. this.ServeJSON()
  672. }()
  673. var req request.UserDeleteReq
  674. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  675. if err != nil {
  676. br.Msg = "参数解析异常!"
  677. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  678. return
  679. }
  680. err = models.DeleteUserById(req.UserId)
  681. if err != nil {
  682. br.Msg = "删除失败"
  683. br.ErrMsg = "删除失败,系统错误,Err:" + err.Error()
  684. return
  685. }
  686. br.Msg = "删除成功"
  687. br.Success = true
  688. br.Ret = 200
  689. }
  690. // @Title 开启/禁用用户
  691. // @Description 开启/禁用用户接口
  692. // @Param request body system.SysuserEditReq true "type json string"
  693. // @Success 200 操作成功
  694. // @router /editEnabled [post]
  695. func (this *UserController) EditEnabled() {
  696. br := new(models.BaseResponse).Init()
  697. defer func() {
  698. this.Data["json"] = br
  699. this.ServeJSON()
  700. }()
  701. var req request.UserEditEnabledReq
  702. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  703. if err != nil {
  704. br.Msg = "参数解析异常!"
  705. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  706. return
  707. }
  708. user, err := models.GetUserById(req.UserId)
  709. if err != nil {
  710. br.Msg = "获取数据失败"
  711. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error()
  712. return
  713. }
  714. if !req.IsEnabled {
  715. user.Status = 0
  716. err = user.Update([]string{"status"})
  717. if err != nil {
  718. br.Msg = "修改失败"
  719. br.ErrMsg = "修改系统用户数据失败,Err:" + err.Error()
  720. return
  721. }
  722. } else {
  723. validStartTime, err := time.Parse(utils.FormatDateTime, req.ValidStartTime)
  724. if err != nil {
  725. br.Msg = "日期格式不正确"
  726. return
  727. }
  728. validEndTime, err := time.Parse(utils.FormatDateTime, req.ValidEndTime)
  729. if err != nil {
  730. br.Msg = "日期格式不正确"
  731. return
  732. }
  733. if !validEndTime.After(validStartTime) {
  734. br.Msg = "有效期结束日期在开始日期之前,日期格式不正确"
  735. return
  736. }
  737. validStartTime = validStartTime.Local().Add(-time.Hour * 8)
  738. validEndTime = validEndTime.Local().Add(-time.Hour*8 + time.Hour*24)
  739. curTime := time.Now()
  740. if curTime.After(validEndTime) {
  741. br.Msg = "有效期已到期,请重新设置"
  742. return
  743. }
  744. user.Status = 2
  745. user.ModifyTime = curTime
  746. user.ValidStartTime = validStartTime
  747. user.ValidEndTime = validEndTime
  748. err = user.Update([]string{"status", "modify_time", "valid_start_time", "valid_end_time"})
  749. if err != nil {
  750. br.Msg = "修改失败"
  751. br.ErrMsg = "修改系统用户数据失败,Err:" + err.Error()
  752. return
  753. }
  754. }
  755. // 记录操作
  756. record := &models.UserChangeRecord{}
  757. record.UserId = req.UserId
  758. record.SysUserId = this.SysUser.SysUserId
  759. if user.Status == 0 {
  760. record.Content = this.SysUser.SysRealName + "禁用用户"
  761. } else {
  762. record.Content = this.SysUser.SysRealName + "启用用户"
  763. }
  764. record.Insert()
  765. br.Ret = 200
  766. br.Success = true
  767. br.IsAddLog = true
  768. br.Msg = "操作成功"
  769. }
  770. // @Title 用户信息变更记录
  771. // @Description 用户信息变更记录
  772. // @Param UserId query int true "用户id"
  773. // @Success 200 操作成功
  774. // @router /change_list [get]
  775. func (this *UserController) ChangeList() {
  776. br := new(models.BaseResponse).Init()
  777. defer func() {
  778. this.Data["json"] = br
  779. this.ServeJSON()
  780. }()
  781. userId, _ := this.GetInt("UserId")
  782. if userId <= 0 {
  783. br.Msg = "用户信息错误"
  784. return
  785. }
  786. userRcord, err := models.GetUserChangeRecordListById(userId)
  787. if err != nil {
  788. br.Msg = "用户信息变更查询失败"
  789. br.ErrMsg = "用户信息变更查询失败,系统错误,Err:" + err.Error()
  790. return
  791. }
  792. resp := new(response.UserChangeRecordResp)
  793. resp.List = userRcord
  794. br.Data = resp
  795. br.Msg = "查询成功"
  796. br.Success = true
  797. br.Ret = 200
  798. }