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. userCheckResp.Status = user.Status
  351. if user.Status == utils.UserStatusNo {
  352. br.Ret = 200
  353. br.Success = true
  354. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  355. br.Data = userCheckResp
  356. return
  357. }
  358. if user.Status == utils.UserStatusPotential {
  359. br.Ret = 200
  360. br.Success = true
  361. br.Msg = "该用户已在潜在列表,确认转客户并更新用户信息吗?"
  362. br.Data = userCheckResp
  363. return
  364. }
  365. if user.Status == utils.UserStatusFormal {
  366. br.Msg = "手机号已存在,请重新输入"
  367. return
  368. }
  369. }
  370. }
  371. if req.Email != "" {
  372. if !utils.ValidateEmailFormatat(req.Email) {
  373. br.Msg = "邮箱格式有误, 请检查"
  374. return
  375. }
  376. user, err := models.GetUserByEmail(req.Email)
  377. if err != nil && err != orm.ErrNoRows {
  378. br.Msg = "编辑用户失败"
  379. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  380. return
  381. }
  382. if user != nil {
  383. userCheckResp.UserId = user.UserId
  384. if user.Status == 0 {
  385. br.Ret = 200
  386. br.Success = true
  387. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  388. br.Data = userCheckResp
  389. return
  390. }
  391. if user.Status == 1 {
  392. br.Ret = 200
  393. br.Success = true
  394. br.Msg = "该用户已被禁用,确认启用并更新用户信息吗?"
  395. br.Data = userCheckResp
  396. return
  397. }
  398. if user.Status == 2 {
  399. br.Msg = "邮箱已存在,请重新输入"
  400. return
  401. }
  402. return
  403. }
  404. }
  405. br.Ret = 200
  406. br.Success = true
  407. br.Msg = "邮箱或手机号合格"
  408. }
  409. // List
  410. // @Title 用户列表
  411. // @Description 用户列表
  412. // @Param PageSize query int true "每页数据条数"
  413. // @Param CurrentIndex query int true "当前页页码,从1开始"
  414. // @Param SellerId query string true "销售id"
  415. // @Param Status query int true "用户状态"
  416. // @Param KeyWord query string true "手机号/邮箱/姓名"
  417. // @Param IsRegistered query string true "是否注册"
  418. // @Param IsSubscribed query string true "是否关注"
  419. // @Param RegisterStartDate query string true "注册开始时间"
  420. // @Param RegisterEndDate query string true "注册结束时间"
  421. // @Param CreateStartDate query string true "创建开始时间"
  422. // @Param CreateEndDate query string true "创建结束时间"
  423. // @Param SortParam query string true "排序字段"
  424. // @Param SortType query string true "排序方式"
  425. // @Success 200 {object} response.UserListResp
  426. // @router /list [get]
  427. func (this *UserController) List() {
  428. br := new(models.BaseResponse).Init()
  429. defer func() {
  430. this.Data["json"] = br
  431. this.ServeJSON()
  432. }()
  433. pageSize, _ := this.GetInt("PageSize")
  434. currentIndex, _ := this.GetInt("CurrentIndex")
  435. sellerIdStr := this.GetString("SellerId")
  436. status := this.GetString("Status")
  437. keyWord := this.GetString("KeyWord")
  438. IsRegistered := this.GetString("IsRegistered")
  439. IsSubscribed := this.GetString("IsSubscribed")
  440. registerStartDate := this.GetString("RegisterStartDate")
  441. registerEndDate := this.GetString("RegisterEndDate")
  442. createStartDate := this.GetString("CreateStartDate")
  443. createEndDate := this.GetString("CreateEndDate")
  444. sortParma := this.GetString("SortParam")
  445. sortType := this.GetString("SortType")
  446. var condition string
  447. var sortCondition string
  448. var pars []interface{}
  449. if keyWord != "" {
  450. condition += ` AND (u.real_name LIKE ? OR u.phone LIKE ? OR u.email LIKE ?) `
  451. pars = utils.GetLikeKeywordPars(pars, keyWord, 3)
  452. }
  453. if pageSize <= 0 {
  454. pageSize = utils.PageSize20
  455. } else if pageSize > utils.PageSize100 {
  456. pageSize = utils.PageSize100
  457. }
  458. if currentIndex <= 0 {
  459. currentIndex = 1
  460. }
  461. if sortParma != "" && sortType != "" {
  462. sortCondition = " ORDER BY "
  463. var param, sort string
  464. switch sortParma {
  465. case "RegisterTime":
  466. param = "u.register_time"
  467. case "CreateTime":
  468. param = "u.create_time"
  469. case "RestDate":
  470. param = "u.valid_end_time"
  471. }
  472. switch sortType {
  473. case "asc":
  474. sort = " ASC "
  475. case "desc":
  476. sort = " DESC "
  477. }
  478. if param != "" && sort != "" {
  479. sortCondition += param + " " + sort
  480. } else {
  481. sortCondition = ""
  482. }
  483. }
  484. if sellerIdStr != "" {
  485. sellerIds := strings.Split(sellerIdStr, ",")
  486. if len(sellerIds) != 0 {
  487. condition += ` AND ( `
  488. for i, id := range sellerIds {
  489. if i == 0 {
  490. condition += ` u.seller_id = ? `
  491. pars = append(pars, id)
  492. } else {
  493. condition += ` OR u.seller_id = ? `
  494. pars = append(pars, id)
  495. }
  496. }
  497. condition += `) `
  498. }
  499. }
  500. switch status {
  501. case "禁用":
  502. condition += " AND u.status=? "
  503. pars = append(pars, 0)
  504. case "潜在":
  505. condition += " AND u.status=? "
  506. pars = append(pars, 1)
  507. case "正式":
  508. condition += " AND u.status=? "
  509. pars = append(pars, 2)
  510. case "":
  511. condition += " AND (u.status=? OR u.status=?) "
  512. pars = append(pars, 0, 2)
  513. }
  514. switch IsRegistered {
  515. case "是":
  516. condition += " AND u.is_registered=? "
  517. pars = append(pars, true)
  518. case "否":
  519. condition += " AND u.is_registered=? "
  520. pars = append(pars, false)
  521. }
  522. switch IsSubscribed {
  523. case "是":
  524. condition += " AND u.is_subscribed=? "
  525. pars = append(pars, true)
  526. case "否":
  527. condition += " AND u.is_subscribed=? "
  528. pars = append(pars, false)
  529. }
  530. if registerStartDate != "" {
  531. registerStartTime, er := time.Parse(utils.FormatDate, registerStartDate)
  532. if er != nil {
  533. br.Msg = "日期格式有误"
  534. return
  535. }
  536. condition += " AND u.register_time>? "
  537. pars = append(pars, registerStartTime)
  538. }
  539. if registerEndDate != "" {
  540. registerEndTime, er := time.Parse(utils.FormatDate, registerEndDate)
  541. if er != nil {
  542. br.Msg = "日期格式有误"
  543. return
  544. }
  545. condition += " AND u.register_time<? "
  546. pars = append(pars, registerEndTime)
  547. }
  548. if createStartDate != "" {
  549. createStartTime, er := time.Parse(utils.FormatDate, createStartDate)
  550. if er != nil {
  551. br.Msg = "日期格式有误"
  552. return
  553. }
  554. condition += " AND u.create_time>? "
  555. pars = append(pars, createStartTime)
  556. }
  557. if createEndDate != "" {
  558. createEndTime, er := time.Parse(utils.FormatDate, createEndDate)
  559. if er != nil {
  560. br.Msg = "日期格式有误"
  561. return
  562. }
  563. condition += " AND u.create_time<? "
  564. pars = append(pars, createEndTime)
  565. }
  566. if pageSize <= 0 {
  567. pageSize = utils.PageSize20
  568. } else if pageSize > utils.PageSize100 {
  569. pageSize = utils.PageSize100
  570. }
  571. if currentIndex <= 0 {
  572. currentIndex = 1
  573. }
  574. startSize := utils.StartIndex(currentIndex, pageSize)
  575. total, err := models.GetUserCount(condition, pars)
  576. if err != nil {
  577. br.Msg = "获取失败"
  578. br.ErrMsg = "获取失败,Err:" + err.Error()
  579. return
  580. }
  581. userList, err := models.GetUserListByConditonSort(condition, sortCondition, pars, startSize, pageSize)
  582. if err != nil {
  583. br.Msg = "查询用户失败"
  584. br.Msg = "查询用户失败,系统错误,Err:" + err.Error()
  585. return
  586. }
  587. for _, u := range userList {
  588. if u.ValidEndTime == "" {
  589. u.RestDate = 0
  590. } else {
  591. endTime, err := time.Parse(utils.FormatDateTime, u.ValidEndTime)
  592. if err != nil {
  593. br.Msg = "用户有效时间格式有误"
  594. br.ErrMsg = "用户有效时间格式有误,Err:" + err.Error()
  595. return
  596. }
  597. // 对天数向上取整
  598. daysBetween := int(math.Ceil(time.Until(endTime).Hours() / 24))
  599. if daysBetween < 0 {
  600. daysBetween = 0
  601. }
  602. u.RestDate = daysBetween
  603. }
  604. }
  605. page := paging.GetPaging(currentIndex, pageSize, total)
  606. resp := new(response.UserListResp)
  607. resp.Paging = page
  608. resp.List = userList
  609. br.Data = resp
  610. br.Ret = 200
  611. br.Success = true
  612. br.Msg = "获取成功"
  613. }
  614. // Detail
  615. // @Title 用户详情信息
  616. // @Description 用户详情信息
  617. // @Param UserId query int true "用户id"
  618. // @Success 200 {object} models.LoginResp
  619. // @router /detail [get]
  620. func (this *UserController) Detail() {
  621. br := new(models.BaseResponse).Init()
  622. defer func() {
  623. this.Data["json"] = br
  624. this.ServeJSON()
  625. }()
  626. UserId, _ := this.GetInt("UserId")
  627. if UserId <= 0 {
  628. br.Msg = "查询用户不存在"
  629. return
  630. }
  631. user, err := models.GetUserById(UserId)
  632. if err != nil {
  633. if err == orm.ErrNoRows {
  634. br.Msg = "用户不存在或已删除,请刷新页面"
  635. return
  636. }
  637. br.Msg = "查询用户失败"
  638. br.ErrMsg = "查询用户失败,系统错误,Err:" + err.Error()
  639. return
  640. }
  641. if user == nil {
  642. br.Msg = "用户不存在或已删除,请刷新页面"
  643. return
  644. }
  645. permissionList, err := services.GetUserPermissionById(UserId)
  646. if err != nil {
  647. br.Msg = "用户权限获取失败,请重新尝试"
  648. return
  649. }
  650. permissionMap := make(map[string][]string)
  651. for _, pm := range permissionList {
  652. permissionMap[pm.ParentName] = append(permissionMap[pm.ParentName], pm.PermissionName)
  653. }
  654. resp := new(response.UserDetailResp)
  655. resp.Detail = user
  656. resp.Permission = permissionMap
  657. br.Msg = "查询成功"
  658. br.Ret = 200
  659. br.Success = true
  660. br.Data = resp
  661. }
  662. // Delete
  663. // @Title 系统用户详情信息
  664. // @Description 用户详情信息
  665. // @Param request body request.UserDeleteReq true "type json string"
  666. // @Success 200 {object} models.LoginResp
  667. // @router /delete [post]
  668. func (this *UserController) Delete() {
  669. br := new(models.BaseResponse).Init()
  670. defer func() {
  671. this.Data["json"] = br
  672. this.ServeJSON()
  673. }()
  674. var req request.UserDeleteReq
  675. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  676. if err != nil {
  677. br.Msg = "参数解析异常!"
  678. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  679. return
  680. }
  681. err = models.DeleteUserById(req.UserId)
  682. if err != nil {
  683. br.Msg = "删除失败"
  684. br.ErrMsg = "删除失败,系统错误,Err:" + err.Error()
  685. return
  686. }
  687. br.Msg = "删除成功"
  688. br.Success = true
  689. br.Ret = 200
  690. }
  691. // @Title 开启/禁用用户
  692. // @Description 开启/禁用用户接口
  693. // @Param request body system.SysuserEditReq true "type json string"
  694. // @Success 200 操作成功
  695. // @router /editEnabled [post]
  696. func (this *UserController) EditEnabled() {
  697. br := new(models.BaseResponse).Init()
  698. defer func() {
  699. this.Data["json"] = br
  700. this.ServeJSON()
  701. }()
  702. var req request.UserEditEnabledReq
  703. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  704. if err != nil {
  705. br.Msg = "参数解析异常!"
  706. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  707. return
  708. }
  709. user, err := models.GetUserById(req.UserId)
  710. if err != nil {
  711. br.Msg = "获取数据失败"
  712. br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error()
  713. return
  714. }
  715. if !req.IsEnabled {
  716. user.Status = 0
  717. err = user.Update([]string{"status"})
  718. if err != nil {
  719. br.Msg = "修改失败"
  720. br.ErrMsg = "修改系统用户数据失败,Err:" + err.Error()
  721. return
  722. }
  723. } else {
  724. validStartTime, err := time.Parse(utils.FormatDate, req.ValidStartTime)
  725. if err != nil {
  726. br.Msg = "日期格式不正确"
  727. return
  728. }
  729. validEndTime, err := time.Parse(utils.FormatDate, req.ValidEndTime)
  730. if err != nil {
  731. br.Msg = "日期格式不正确"
  732. return
  733. }
  734. if !validEndTime.After(validStartTime) {
  735. br.Msg = "有效期结束日期在开始日期之前,日期格式不正确"
  736. return
  737. }
  738. validStartTime = validStartTime.Local().Add(-time.Hour * 8)
  739. validEndTime = validEndTime.Local().Add(-time.Hour*8 + time.Hour*24)
  740. curTime := time.Now()
  741. if curTime.After(validEndTime) {
  742. br.Msg = "有效期已到期,请重新设置"
  743. return
  744. }
  745. user.Status = 2
  746. user.ModifyTime = curTime
  747. user.ValidStartTime = validStartTime
  748. user.ValidEndTime = validEndTime
  749. err = user.Update([]string{"status", "modify_time", "valid_start_time", "valid_end_time"})
  750. if err != nil {
  751. br.Msg = "修改失败"
  752. br.ErrMsg = "修改系统用户数据失败,Err:" + err.Error()
  753. return
  754. }
  755. }
  756. // 记录操作
  757. record := &models.UserChangeRecord{}
  758. record.UserId = req.UserId
  759. record.SysUserId = this.SysUser.SysUserId
  760. if user.Status == 0 {
  761. record.Content = this.SysUser.SysRealName + "禁用用户"
  762. } else {
  763. record.Content = this.SysUser.SysRealName + "启用用户"
  764. }
  765. record.Insert()
  766. br.Ret = 200
  767. br.Success = 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. }