loginLogic.go 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. package pub
  2. import (
  3. "context"
  4. "time"
  5. "perms-system-server/internal/middleware"
  6. "perms-system-server/internal/response"
  7. "perms-system-server/internal/svc"
  8. "perms-system-server/internal/types"
  9. "github.com/zeromicro/go-zero/core/logx"
  10. )
  11. type LoginLogic struct {
  12. logx.Logger
  13. ctx context.Context
  14. svcCtx *svc.ServiceContext
  15. }
  16. func NewLoginLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginLogic {
  17. return &LoginLogic{
  18. Logger: logx.WithContext(ctx),
  19. ctx: ctx,
  20. svcCtx: svcCtx,
  21. }
  22. }
  23. // Login 产品端登录。产品成员通过用户名密码 + productCode 登录指定产品,返回 JWT 令牌对及用户权限信息。
  24. // 当 cap.js 未启用时,需同时携带 captchaId/captchaCode 进行图片验证码校验。
  25. func (l *LoginLogic) Login(req *types.LoginReq) (resp *types.LoginResp, err error) {
  26. // cap.js 启用时拒绝传统登录接口,必须走 /auth/login/cap
  27. cfg := l.svcCtx.Config.Capjs
  28. if cfg.Enable == 1 {
  29. return nil, response.ErrBadRequest("当前已启用人机验证,请使用人机验证登录")
  30. }
  31. if req.CaptchaId == "" || req.CaptchaCode == "" {
  32. return nil, response.ErrBadRequest("验证码不能为空")
  33. }
  34. if !VerifyCaptcha(req.CaptchaId, req.CaptchaCode) {
  35. return nil, response.ErrBadRequest("验证码错误或已过期")
  36. }
  37. clientIP := middleware.GetClientIP(l.ctx)
  38. result, err := ValidateProductLogin(l.ctx, l.svcCtx, req.Username, req.Password, req.ProductCode, clientIP)
  39. if err != nil {
  40. if le, ok := err.(*LoginError); ok {
  41. switch le.Code {
  42. case 400:
  43. return nil, response.ErrBadRequest(le.Message)
  44. case 401:
  45. return nil, response.ErrUnauthorized(le.Message)
  46. case 403:
  47. return nil, response.ErrForbidden(le.Message)
  48. case 429:
  49. return nil, response.NewCodeError(429, le.Message)
  50. }
  51. }
  52. return nil, err
  53. }
  54. ud := result.UserDetails
  55. return &types.LoginResp{
  56. AccessToken: result.AccessToken,
  57. RefreshToken: result.RefreshToken,
  58. Expires: time.Now().Unix() + l.svcCtx.Config.Auth.AccessExpire,
  59. UserInfo: types.UserInfo{
  60. UserId: ud.UserId,
  61. Username: ud.Username,
  62. Nickname: ud.Nickname,
  63. Avatar: ud.Avatar,
  64. Email: ud.Email,
  65. Phone: ud.Phone,
  66. IsSuperAdmin: ud.IsSuperAdminRaw,
  67. MustChangePassword: ud.MustChangePwdRaw,
  68. MemberType: ud.MemberType,
  69. Perms: ud.Perms,
  70. },
  71. }, nil
  72. }