CheckToken.php 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. <?php
  2. namespace App\Http\Middleware;
  3. use App\Models\User;
  4. use App\Models\UserSession;
  5. use Closure;
  6. use Illuminate\Http\Request;
  7. class CheckToken
  8. {
  9. private const ACTIVITY_WRITE_INTERVAL = 60;
  10. /**
  11. * 处理传入请求
  12. *
  13. * @param \Illuminate\Http\Request $request
  14. * @param \Closure $next
  15. * @return mixed
  16. */
  17. public function handle(Request $request, Closure $next)
  18. {
  19. // 1. 前台沿用 Authorization 请求头中的原始 Token
  20. $token = $request->header('authorization');
  21. // 2. 如果请求头没有 token,直接返回未授权
  22. if (empty($token)) {
  23. return response()->json([
  24. 'code' => 401,
  25. 'msg' => lang('请携带token访问')
  26. ], 401);
  27. }
  28. // 3. 查询 user_session:token 存在 + 未过期
  29. $time = now()->getTimestamp();
  30. $session = UserSession::findActiveToken($token, $time);
  31. // 4. 会话不存在或已过期
  32. if (!$session) {
  33. return response()->json([
  34. 'code' => 401,
  35. 'msg' => lang('token无效或已过期')
  36. ], 401);
  37. }
  38. // 5. 查询对应用户信息
  39. $user = User::where('user_id',$session->user_id)->first();
  40. // 6. 用户不存在
  41. if (!$user || !empty($user->getAttributes()['delete_time'])) {
  42. return response()->json([
  43. 'code' => 401,
  44. 'msg' => lang('用户不存在')
  45. ], 401);
  46. }
  47. if ((int)($user->getAttributes()['is_banned'] ?? 0) === 1) {
  48. return response()->json(['code' => 401, 'msg' => lang('账号已禁用')], 401);
  49. }
  50. if (!UserSession::renewActiveToken((string)$token, $time, (int)$session->id)) {
  51. return response()->json(['code' => 401, 'msg' => lang('token无效或已过期')], 401);
  52. }
  53. $attributes = $user->getAttributes();
  54. $cutoff = $time - self::ACTIVITY_WRITE_INTERVAL;
  55. if (array_key_exists('last_active_time', $attributes) && (int) $attributes['last_active_time'] <= $cutoff) {
  56. User::whereKey($user->getKey())
  57. ->where(fn ($query) => $query->whereNull('last_active_time')->orWhere('last_active_time', '<=', $cutoff))
  58. ->toBase()->update(['last_active_time' => $time]);
  59. }
  60. // 7. 把用户信息赋值给 $request->user
  61. $request->user = $user;
  62. // 8. 放行请求,进入控制器
  63. return $next($request);
  64. }
  65. }