user.go 22 KB

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