logoutLogic.go 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960
  1. // Code scaffolded by goctl. Safe to edit.
  2. // goctl 1.10.0
  3. package auth
  4. import (
  5. "context"
  6. "errors"
  7. "fmt"
  8. "perms-system-server/internal/middleware"
  9. userModel "perms-system-server/internal/model/user"
  10. "perms-system-server/internal/response"
  11. "perms-system-server/internal/svc"
  12. "github.com/zeromicro/go-zero/core/limit"
  13. "github.com/zeromicro/go-zero/core/logx"
  14. )
  15. type LogoutLogic struct {
  16. logx.Logger
  17. ctx context.Context
  18. svcCtx *svc.ServiceContext
  19. }
  20. func NewLogoutLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LogoutLogic {
  21. return &LogoutLogic{
  22. Logger: logx.WithContext(ctx),
  23. ctx: ctx,
  24. svcCtx: svcCtx,
  25. }
  26. }
  27. // Logout 用户注销。递增当前用户的 tokenVersion 使所有已签发的 access/refresh 令牌立即失效,并清除用户缓存。
  28. func (l *LogoutLogic) Logout() error {
  29. userId := middleware.GetUserId(l.ctx)
  30. if userId == 0 {
  31. return response.ErrUnauthorized("未登录")
  32. }
  33. if l.svcCtx.TokenOpLimiter != nil {
  34. code, _ := l.svcCtx.TokenOpLimiter.Take(fmt.Sprintf("logout:%d", userId))
  35. if code == limit.OverQuota {
  36. return response.ErrTooManyRequests("操作过于频繁,请稍后再试")
  37. }
  38. }
  39. if _, err := l.svcCtx.SysUserModel.IncrementTokenVersion(l.ctx, userId); err != nil {
  40. // 审计 L-R10-3:IncrementTokenVersion 在目标用户已被并发删除时会返 ErrUpdateConflict。
  41. // Logout 的语义目标本就是"让该账号的旧令牌立即失效",用户已经消失等同语义已达成,
  42. // 按幂等成功处理并继续清缓存,不要让一次正常的注销因为极罕见的删号竞态回 500。
  43. if !errors.Is(err, userModel.ErrUpdateConflict) {
  44. return err
  45. }
  46. logx.WithContext(l.ctx).Infof("logout on already-deleted user userId=%d, treated as idempotent success", userId)
  47. }
  48. l.svcCtx.UserDetailsLoader.Clean(l.ctx, userId)
  49. return nil
  50. }