src/EventSubscriber/ParticipationSubscriber.php line 115

Open in your IDE?
  1. <?php
  4. namespace App\EventSubscriber;
  6. use ApiPlatform\Core\Bridge\Symfony\Validator\Exception\ValidationException;
  7. use ApiPlatform\Core\EventListener\EventPriorities;
  8. use App\Entity\Participation;
  9. use App\Service\CodeDotationService;
  10. use App\Service\ConsolationPrizeService;
  11. use App\Service\WinningTimeService;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpKernel\Event\ViewEvent;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  17. use Symfony\Component\Security\Core\Security;
  18. use Symfony\Component\Security\Core\User\UserInterface;
  19. use Symfony\Component\Validator\Validator\ValidatorInterface;
  21. final class ParticipationSubscriber implements EventSubscriberInterface
  22. {
  23.     public function __construct(
  24.         private EntityManagerInterface $manager,
  25.         private ValidatorInterface $validator,
  26.         private WinningTimeService $drawService,
  27.         private ConsolationPrizeService $consolationService,
  28.         private CodeDotationService $codeService,
  29.         private Security $security
  30.     )
  31.     {
  33.     }
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             KernelEvents::VIEW => [
  39.                 ['checkExists', EventPriorities::PRE_WRITE],
  40.                 ['draw', EventPriorities::POST_WRITE],
  41.                 ['setUser', EventPriorities::PRE_VALIDATE],
  42.             ],
  43.         ];
  44.     }
  46.     public function checkExists(ViewEvent $event)
  47.     {
  48.         $this->manager
  49.             ->getConnection()
  50.             ->prepare('SET SQL_BIG_SELECTS=1')
  51.             ->executeQuery()
  52.         ;
  54.         // get new participation
  55.         $newPart = $event->getControllerResult();
  56.         if(!$newPart instanceof Participation) {
  57.             return;
  58.         }
  60.         // check participation exists with external_id
  61.         $partRepo = $this->manager->getRepository(Participation::class);
  62.         $existingPart = $partRepo
  63.             ->findOneBy([
  64.                 "operation" => $newPart->getOperation(),
  65.                 "externalId" => $newPart->getExternalId()
  66.             ])
  67.         ;
  69.         // if not exists do nothing
  70.         if( !$existingPart instanceof Participation) {
  71.             return;
  72.         }
  74.         // if exists replace new one by existing one
  75.         $event->setControllerResult($existingPart);
  76.     }
  78.     public function draw(ViewEvent $event)
  79.     {
  80.         $participation = $event->getControllerResult();
  81.         $method = $event->getRequest()->getMethod();
  83.         if (!$participation instanceof Participation || Request::METHOD_POST !== $method) {
  84.             return;
  85.         }
  86.         
  87.         $violations = $this->validator->validate($participation);
  88.         if (0 !== count($violations)) {
  89.             throw new ValidationException($violations);
  90.         }
  92.         ////  Fix doublons
  93.         $ig = $participation->getIg();
  94.         $cp = $participation->getConsolationPrize();
  95.         if( $ig || $cp ) {
  96.             $code = $participation->getCode();
  97.             if(!$code) {
  98.                 $this->codeService->get($participation);
  99.             }
  100.             return;
  101.         }
  102.         /////
  104.         // this service flush data in db
  105.         $this->drawService->draw($participation);
  107.         if ($participation->getOperation()->getConsolation() && $participation->getStatus() === Participation::STATUS_LOST) {
  108.             // this service flush data in db
  109.             $this->consolationService->draw($participation);
  110.         }
  112.         $this->codeService->get($participation);
  113.     }
  115.     public function setUser(ViewEvent $event)
  116.     {
  117.         $user = $this->security->getUser();
  118.         $request = $event->getRequest();
  119.         $object = $event->getControllerResult();
  120.         $method = $request->getMethod();
  122.         if ($method !== Request::METHOD_POST)
  123.         {
  124.             return;
  125.         }
  127.         if (!$object instanceof Participation)
  128.         {
  129.             return;
  130.         }
  132.         if (!$user instanceof UserInterface) {
  133.             throw new AuthenticationException("Token expired");
  134.         }
  135.         $object->setUser($user);
  136.     }
  137. }