logoutLogic.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. // Code scaffolded by goctl. Safe to edit.
  2. // goctl 1.10.0
  3. package auth
  4. import (
  5. "context"
  6. "fmt"
  7. "perms-system-server/internal/middleware"
  8. "perms-system-server/internal/response"
  9. "perms-system-server/internal/svc"
  10. "github.com/zeromicro/go-zero/core/limit"
  11. "github.com/zeromicro/go-zero/core/logx"
  12. )
  13. type LogoutLogic struct {
  14. logx.Logger
  15. ctx context.Context
  16. svcCtx *svc.ServiceContext
  17. }
  18. func NewLogoutLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LogoutLogic {
  19. return &LogoutLogic{
  20. Logger: logx.WithContext(ctx),
  21. ctx: ctx,
  22. svcCtx: svcCtx,
  23. }
  24. }
  25. // Logout 用户注销。递增当前用户的 tokenVersion 使所有已签发的 access/refresh 令牌立即失效,并清除用户缓存。
  26. func (l *LogoutLogic) Logout() error {
  27. userId := middleware.GetUserId(l.ctx)
  28. if userId == 0 {
  29. return response.ErrUnauthorized("未登录")
  30. }
  31. if l.svcCtx.TokenOpLimiter != nil {
  32. code, _ := l.svcCtx.TokenOpLimiter.Take(fmt.Sprintf("logout:%d", userId))
  33. if code == limit.OverQuota {
  34. return response.ErrTooManyRequests("操作过于频繁,请稍后再试")
  35. }
  36. }
  37. if _, err := l.svcCtx.SysUserModel.IncrementTokenVersion(l.ctx, userId); err != nil {
  38. return err
  39. }
  40. l.svcCtx.UserDetailsLoader.Clean(l.ctx, userId)
  41. return nil
  42. }