updateUserLogic.go 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. package user
  2. import (
  3. "context"
  4. "time"
  5. "perms-system-server/internal/consts"
  6. "perms-system-server/internal/middleware"
  7. "perms-system-server/internal/response"
  8. "perms-system-server/internal/svc"
  9. "perms-system-server/internal/types"
  10. "perms-system-server/internal/util"
  11. "github.com/zeromicro/go-zero/core/logx"
  12. )
  13. type UpdateUserLogic struct {
  14. logx.Logger
  15. ctx context.Context
  16. svcCtx *svc.ServiceContext
  17. }
  18. func NewUpdateUserLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateUserLogic {
  19. return &UpdateUserLogic{
  20. Logger: logx.WithContext(ctx),
  21. ctx: ctx,
  22. svcCtx: svcCtx,
  23. }
  24. }
  25. func (l *UpdateUserLogic) UpdateUser(req *types.UpdateUserReq) error {
  26. caller := middleware.GetUserDetails(l.ctx)
  27. if caller == nil {
  28. return response.ErrUnauthorized("未登录")
  29. }
  30. if caller.UserId == req.Id {
  31. if req.DeptId != nil || req.Status != 0 {
  32. return response.ErrForbidden("不允许修改自己的部门和状态")
  33. }
  34. } else {
  35. if !caller.IsSuperAdmin {
  36. return response.ErrForbidden("仅允许修改自己的信息或超管操作")
  37. }
  38. }
  39. user, err := l.svcCtx.SysUserModel.FindOne(l.ctx, req.Id)
  40. if err != nil {
  41. return response.ErrNotFound("用户不存在")
  42. }
  43. if req.Nickname != nil {
  44. user.Nickname = *req.Nickname
  45. }
  46. if req.Email != nil {
  47. if *req.Email != "" && !util.IsValidEmail(*req.Email) {
  48. return response.ErrBadRequest("邮箱格式不正确")
  49. }
  50. user.Email = *req.Email
  51. }
  52. if req.Phone != nil {
  53. if *req.Phone != "" && !util.IsValidPhone(*req.Phone) {
  54. return response.ErrBadRequest("手机号格式不正确")
  55. }
  56. user.Phone = *req.Phone
  57. }
  58. if req.Remark != nil {
  59. user.Remark = *req.Remark
  60. }
  61. if req.DeptId != nil {
  62. if *req.DeptId > 0 {
  63. if _, err := l.svcCtx.SysDeptModel.FindOne(l.ctx, *req.DeptId); err != nil {
  64. return response.ErrBadRequest("部门不存在")
  65. }
  66. }
  67. user.DeptId = *req.DeptId
  68. }
  69. if req.Status == consts.StatusEnabled || req.Status == consts.StatusDisabled {
  70. user.Status = req.Status
  71. }
  72. user.UpdateTime = time.Now().Unix()
  73. if err := l.svcCtx.SysUserModel.Update(l.ctx, user); err != nil {
  74. return err
  75. }
  76. l.svcCtx.UserDetailsLoader.Clean(l.ctx, req.Id)
  77. return nil
  78. }