src/Eccube/EventListener/LoginHistoryListener.php line 81

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Eccube\EventListener;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Eccube\Entity\LoginHistory;
  18. use Eccube\Entity\Master\LoginHistoryStatus;
  19. use Eccube\Entity\Member;
  20. use Eccube\Repository\Master\LoginHistoryStatusRepository;
  21. use Eccube\Repository\MemberRepository;
  22. use Eccube\Request\Context;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. use Symfony\Component\HttpFoundation\RequestStack;
  25. use Symfony\Component\Security\Http\Authenticator\Passport\Badge\UserBadge;
  26. use Symfony\Component\Security\Http\Event\InteractiveLoginEvent;
  27. use Symfony\Component\Security\Http\Event\LoginFailureEvent;
  28. use Symfony\Component\Security\Http\SecurityEvents;
  30. class LoginHistoryListener implements EventSubscriberInterface
  31. {
  32.     /**
  33.      * @var EntityManagerInterface
  34.      */
  35.     private $entityManager;
  37.     /**
  38.      * @var RequestStack
  39.      */
  40.     private $requestStack;
  42.     /**
  43.      * @var Context
  44.      */
  45.     private $requestContext;
  46.     /**
  47.      * @var MemberRepository
  48.      */
  49.     private $memberRepository;
  51.     /**
  52.      * @var LoginHistoryStatusRepository
  53.      */
  54.     private $loginHistoryStatusRepository;
  56.     public function __construct(
  57.         EntityManagerInterface $em,
  58.         RequestStack $requestStack,
  59.         Context $requestContext,
  60.         MemberRepository $memberRepository,
  61.         LoginHistoryStatusRepository $loginHistoryStatusRepository
  62.     ) {
  63.         $this->entityManager = $em;
  64.         $this->requestStack = $requestStack;
  65.         $this->requestContext = $requestContext;
  66.         $this->memberRepository = $memberRepository;
  67.         $this->loginHistoryStatusRepository = $loginHistoryStatusRepository;
  68.     }
  70.     /**
  71.      * @return array
  72.      */
  73.     public static function getSubscribedEvents()
  74.     {
  75.         return [
  76.             SecurityEvents::INTERACTIVE_LOGIN => 'onInteractiveLogin',
  77.             LoginFailureEvent::class => 'onAuthenticationFailure',
  78.         ];
  79.     }
  81.     public function onInteractiveLogin(InteractiveLoginEvent $event)
  82.     {
  83.         $request = $event->getRequest();
  84.         $user = $event
  85.             ->getAuthenticationToken()
  86.             ->getUser();
  88.         $Status = $this->loginHistoryStatusRepository->find(LoginHistoryStatus::SUCCESS);
  89.         if (is_null($Status)) {
  90.             return;
  91.         }
  93.         if ($user instanceof Member) {
  94.             $LoginHistory = new LoginHistory();
  95.             $LoginHistory
  96.                 ->setLoginUser($user)
  97.                 ->setUserName($user->getUsername())
  98.                 ->setStatus($Status)
  99.                 ->setClientIp($request->getClientIp());
  101.             $this->entityManager->persist($LoginHistory);
  102.             $this->entityManager->flush();
  103.         }
  104.     }
  106.     public function onAuthenticationFailure(LoginFailureEvent $event)
  107.     {
  108.         $request = $this->requestStack->getCurrentRequest();
  110.         if (!$this->requestContext->isAdmin()) {
  111.             return;
  112.         }
  114.         $Status = $this->loginHistoryStatusRepository->find(LoginHistoryStatus::FAILURE);
  115.         if (is_null($Status)) {
  116.             return;
  117.         }
  119.         $Member = null;
  120.         $userName = null;
  121.         $passport = $event->getPassport();
  122.         if ($passport->hasBadge(UserBadge::class)) {
  123.             $userName = $passport->getBadge(UserBadge::class)
  124.                 ->getUserIdentifier();
  125.             $Member = $this->memberRepository->findOneBy(['login_id' => $userName]);
  126.         }
  128.         $LoginHistory = new LoginHistory();
  129.         $LoginHistory
  130.             ->setLoginUser($Member)
  131.             ->setUserName($userName)
  132.             ->setStatus($Status)
  133.             ->setClientIp($request->getClientIp());
  135.         $this->entityManager->persist($LoginHistory);
  136.         $this->entityManager->flush();
  137.     }
  138. }