TokenMiddleware.php 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. <?php
  2. declare(strict_types=1);
  3. namespace App\Middleware\Auth;
  4. use App\Model\User;
  5. use Hyperf\Di\Annotation\Inject;
  6. use Phper666\JWTAuth\Exception\TokenValidException;
  7. use Phper666\JWTAuth\JWT;
  8. use Psr\Container\ContainerInterface;
  9. use Psr\Http\Message\ResponseInterface;
  10. use Psr\Http\Server\MiddlewareInterface;
  11. use Psr\Http\Message\ServerRequestInterface;
  12. use Psr\Http\Server\RequestHandlerInterface;
  13. class TokenMiddleware implements MiddlewareInterface
  14. {
  15. /**
  16. * @var ContainerInterface
  17. */
  18. protected $container;
  19. /**
  20. * @Inject()
  21. * @var JWT
  22. */
  23. protected $jwt;
  24. public function __construct(ContainerInterface $container)
  25. {
  26. $this->container = $container;
  27. }
  28. public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
  29. {
  30. try {
  31. // 获取当前TOKEN
  32. $token = $this->jwt->getToken();
  33. var_dump($token);
  34. // 验证TOKEN有效性
  35. if($this->jwt->checkToken()){
  36. $authId = $token->getClaim('authId');
  37. $user = User::where('id', $authId)->where(['enable'=> 'T'])->first();
  38. var_dump($user);
  39. if(!$user){
  40. throw new TokenValidException('Token未验证通过', 401);
  41. }
  42. }
  43. } catch (\Exception $exception){
  44. }
  45. return $handler->handle($request);
  46. }
  47. }