src/AppBundle/Listener/ExceptionListener.php line 49

Open in your IDE?
  1. <?php
  3. namespace AppBundle\Listener;
  5. use AppBundle\Common\ExceptionPrintingToolkit;
  6. use Codeages\Biz\Framework\Service\Exception\AccessDeniedException;
  7. use Codeages\Biz\Framework\Service\Exception\NotFoundException;
  8. use Symfony\Component\DependencyInjection\ContainerInterface;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  13. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  14. use Symfony\Component\HttpKernel\Exception\HttpExceptionInterface;
  15. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  16. use Topxia\Service\Common\ServiceKernel;
  18. class ExceptionListener
  19. {
  20.     private $container;
  22.     public function __construct(ContainerInterface $container)
  23.     {
  24.         $this->container = $container;
  25.     }
  27.     public function onKernelException(ExceptionEvent $event)
  28.     {
  29.         $exception = $event->getThrowable();
  30.         $request = $event->getRequest();
  31.         $exception = $this->convertException($exception);
  33.         if (!$request->isXmlHttpRequest()) {
  34.             $this->setTargetPath($request);
  35.             $event->setThrowable($exception);
  37.             return;
  38.         }
  40.         $statusCode = $this->getStatusCode($exception);
  41.         $error = $this->getErrorDetails($exception, $statusCode);
  42.         $response = new JsonResponse(['error' => $error], $statusCode);
  43.         $event->setResponse($response);
  44.     }
  46.     protected function setTargetPath(Request $request)
  47.     {
  48.         if ($request->hasSession() && $request->isMethodSafe(false) && !$request->isXmlHttpRequest()) {
  49.             $request->getSession()->set('_target_path', $request->getUri());
  50.         }
  51.     }
  53.     private function getErrorDetails($exception, $statusCode)
  54.     {
  55.         $error = ['name' => 'Error'];
  57.         if ($this->container->get('kernel')->isDebug()) {
  58.             $error['message'] = $exception->getMessage();
  59.             $error['trace'] = ExceptionPrintingToolkit::printTraceAsArray($exception);
  60.         } elseif ($exception instanceof HttpExceptionInterface) {
  61.             $error['message'] = $exception->getMessage();
  62.         } else {
  63.             $error['message'] = 'Request occurs an error';
  64.         }
  66.         if (403 === $statusCode) {
  67.             $user = $this->getUser();
  68.             if ($user) {
  69.                 return ['name' => 'AccessDenied', 'message' => $this->getServiceKernel()->trans('访问被拒绝！')];
  70.             }
  72.             return ['name' => 'Unlogin', 'message' => $this->getServiceKernel()->trans('当前操作，需要登录！')];
  73.         }
  75.         return $error;
  76.     }
  78.     public function getUser()
  79.     {
  80.         if (!$this->container->has('security.token_storage')) {
  81.             throw new \LogicException('The SecurityBundle is not registered in your application.');
  82.         }
  84.         if (null === $token = $this->container->get('security.token_storage')->getToken()) {
  85.             return null;
  86.         }
  88.         if (!is_object($user = $token->getUser())) {
  89.             return null;
  90.         }
  92.         return $user;
  93.     }
  95.     private function convertException($exception)
  96.     {
  97.         if ($exception instanceof AccessDeniedException) {
  98.             return new AccessDeniedHttpException($exception->getMessage(), $exception);
  99.         }
  100.         if ($exception instanceof NotFoundException) {
  101.             return new NotFoundHttpException($exception->getMessage(), $exception);
  102.         }
  104.         return $exception;
  105.     }
  107.     private function getStatusCode($exception)
  108.     {
  109.         if (method_exists($exception, 'getStatusCode')) {
  110.             return $exception->getStatusCode();
  111.         }
  113.         $statusCode = $exception->getCode();
  114.         if (array_key_exists($statusCode, Response::$statusTexts)) {
  115.             return $statusCode;
  116.         }
  118.         return Response::HTTP_INTERNAL_SERVER_ERROR;
  119.     }
  121.     protected function getServiceKernel()
  122.     {
  123.         return ServiceKernel::instance();
  124.     }
  125. }