loginLogic.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. package pub
  2. import (
  3. "context"
  4. "time"
  5. "perms-system-server/internal/consts"
  6. authHelper "perms-system-server/internal/logic/auth"
  7. "perms-system-server/internal/model/user"
  8. "perms-system-server/internal/response"
  9. "perms-system-server/internal/svc"
  10. "perms-system-server/internal/types"
  11. "github.com/zeromicro/go-zero/core/logx"
  12. "golang.org/x/crypto/bcrypt"
  13. )
  14. type LoginLogic struct {
  15. logx.Logger
  16. ctx context.Context
  17. svcCtx *svc.ServiceContext
  18. }
  19. func NewLoginLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginLogic {
  20. return &LoginLogic{
  21. Logger: logx.WithContext(ctx),
  22. ctx: ctx,
  23. svcCtx: svcCtx,
  24. }
  25. }
  26. func (l *LoginLogic) Login(req *types.LoginReq) (resp *types.LoginResp, err error) {
  27. u, err := l.svcCtx.SysUserModel.FindOneByUsername(l.ctx, req.Username)
  28. if err != nil {
  29. if err == user.ErrNotFound {
  30. return nil, response.ErrUnauthorized("用户名或密码错误")
  31. }
  32. return nil, err
  33. }
  34. if u.Status != consts.StatusEnabled {
  35. return nil, response.ErrForbidden("账号已被冻结")
  36. }
  37. if err := bcrypt.CompareHashAndPassword([]byte(u.Password), []byte(req.Password)); err != nil {
  38. return nil, response.ErrUnauthorized("用户名或密码错误")
  39. }
  40. if u.IsSuperAdmin == consts.IsSuperAdminYes {
  41. return nil, response.ErrForbidden("超级管理员不允许通过产品端登录,请使用管理后台")
  42. }
  43. ud := l.svcCtx.UserDetailsLoader.Load(l.ctx, u.Id, req.ProductCode)
  44. accessToken, err := authHelper.GenerateAccessToken(
  45. l.svcCtx.Config.Auth.AccessSecret,
  46. l.svcCtx.Config.Auth.AccessExpire,
  47. ud.UserId, ud.Username, ud.ProductCode, ud.MemberType, ud.Perms,
  48. )
  49. if err != nil {
  50. return nil, err
  51. }
  52. refreshToken, err := authHelper.GenerateRefreshToken(
  53. l.svcCtx.Config.Auth.RefreshSecret,
  54. l.svcCtx.Config.Auth.RefreshExpire,
  55. ud.UserId, ud.ProductCode,
  56. )
  57. if err != nil {
  58. return nil, err
  59. }
  60. return &types.LoginResp{
  61. AccessToken: accessToken,
  62. RefreshToken: refreshToken,
  63. Expires: time.Now().Unix() + l.svcCtx.Config.Auth.AccessExpire,
  64. UserInfo: types.UserInfo{
  65. UserId: ud.UserId,
  66. Username: ud.Username,
  67. Nickname: ud.Nickname,
  68. Avatar: ud.Avatar,
  69. Email: ud.Email,
  70. Phone: ud.Phone,
  71. IsSuperAdmin: ud.IsSuperAdminRaw,
  72. MustChangePassword: ud.MustChangePwdRaw,
  73. MemberType: ud.MemberType,
  74. Perms: ud.Perms,
  75. },
  76. }, nil
  77. }