TokenhMiddleware.php 1.5 KB

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