FooMiddleware.php 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  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. // if($this->request->getUri()->getPath()=="/api/login" || $this->request->getUri()->getPath()=="/verifyCode" || $this->request->getUri()->getPath()=="/index"){
  30. // return $handler->handle($request);
  31. // }
  32. try {
  33. if($header && isset($header['token']) && $header['token'][0]!='null' && isset($header['token'][0])){
  34. $ver = $this->JWT->getClaimsByToken($header['token'][0]);
  35. // var_dump("中间件:",$ver);
  36. Context::set("UserId",$ver['uid']);
  37. if ($ver) {
  38. return $handler->handle($request);
  39. }
  40. }else{
  41. return $this->response->json(
  42. [
  43. 'code' => -1,
  44. 'data' => [],
  45. 'message' => 'token无效,请重新登录',
  46. ]
  47. );
  48. }
  49. }catch (\Exception $e){
  50. var_dump("错误消息:",$e->getMessage(),$e->getCode());
  51. return $this->response->json(
  52. [
  53. 'code' => $e->getCode(),
  54. 'data' => [],
  55. 'message' => $e->getMessage(),
  56. ]
  57. );
  58. }
  59. return false;
  60. }
  61. }