FooMiddleware.php 2.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. <?php
  2. declare(strict_types=1);
  3. namespace App\Middleware\Auth;
  4. use Hyperf\HttpServer\Contract\RequestInterface;
  5. use Hyperf\HttpServer\Contract\ResponseInterface as HttpResponse;
  6. use Psr\Container\ContainerInterface;
  7. use Psr\Http\Message\ResponseInterface;
  8. use Psr\Http\Message\ServerRequestInterface;
  9. use Psr\Http\Server\MiddlewareInterface;
  10. use Psr\Http\Server\RequestHandlerInterface;
  11. use Hyperf\Context\Context;
  12. use Phper666\JWTAuth\JWT;
  13. class FooMiddleware implements MiddlewareInterface
  14. {
  15. protected ContainerInterface $container;
  16. protected RequestInterface $request;
  17. protected HttpResponse $response;
  18. protected JWT $JWT;
  19. public function __construct(ContainerInterface $container, HttpResponse $response, RequestInterface $request,Jwt $JWT)
  20. {
  21. $this->container = $container;
  22. $this->response = $response;
  23. $this->request = $request;
  24. $this->JWT = $JWT;
  25. }
  26. public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
  27. {
  28. $header = $request->getHeaders();
  29. try {
  30. if($header && isset($header['token']) && $header['token'][0]!='null' && isset($header['token'][0])){
  31. $ver = $this->JWT->getClaimsByToken($header['token'][0]);
  32. $tokenTime = $this->JWT->getTokenDynamicCacheTime($header['token'][0]);
  33. if($tokenTime==0){
  34. return $this->response->json(
  35. [
  36. 'code' => -1,
  37. 'data' => [],
  38. 'message' => 'token无效,请重新登录',
  39. ]
  40. );
  41. }
  42. // var_dump("中间件:",$ver);
  43. Context::set("UserId",$ver['uid']);
  44. Context::set("TypeId",$ver['type_id']);
  45. if ($ver) {
  46. return $handler->handle($request);
  47. }
  48. }else{
  49. return $this->response->json(
  50. [
  51. 'code' => -1,
  52. 'data' => [],
  53. 'message' => 'token无效,请重新登录',
  54. ]
  55. );
  56. }
  57. }catch (\Exception $e){
  58. var_dump("错误消息:",$e->getMessage(),$e->getCode());
  59. return $this->response->json(
  60. [
  61. 'code' => $e->getCode(),
  62. 'data' => [],
  63. 'message' => $e->getMessage(),
  64. ]
  65. );
  66. }
  67. return false;
  68. }
  69. }