src/EventSubscriber/SuiviConso/SuiviConsoSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber\SuiviConso;
  7. use App\Entity\LeakAlertActivation;
  8. use App\Event\SuiviConso\EndConsentsEvent;
  9. use App\Event\SuiviConso\EndServiceEvent;
  10. use App\Manager\LeakAlertManager;
  11. use App\Repository\App\LeakAlertActivationRepository;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class SuiviConsoSubscriber implements EventSubscriberInterface
  16. {
  17.     private $em;
  18.     private $leakAlertActivationRepository;
  19.     private $leakAlertManager;
  21.     public function __construct(
  22.         EntityManagerInterface $em,
  23.         LeakAlertActivationRepository $leakAlertActivationRepository,
  24.         LeakAlertManager $leakAlertManager
  25.     ) {
  26.         $this->em = $em;
  27.         $this->leakAlertActivationRepository = $leakAlertActivationRepository;
  28.         $this->leakAlertManager = $leakAlertManager;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             EndServiceEvent::class => 'onEndService',
  35.             EndConsentsEvent::class => 'onEndConsents',
  36.         ];
  37.     }
  39.     public function onEndService(EndServiceEvent $event)
  40.     {
  41.         $leakActivations = $this->leakAlertActivationRepository
  42.             ->findActiveByUserAndContractInfo($event->getUser(), $event->getPostNumber(), $event->getContractNumber());
  44.         if (!$leakActivations) {
  45.             return;
  46.         }
  48.         foreach ($leakActivations as $activation) {
  49.             $this->leakAlertManager->deactivate($activation);
  50.         }
  52.         $this->em->flush();
  53.     }
  55.     public function onEndConsents(EndConsentsEvent $event)
  56.     {
  57.         $leakActivations = $this->leakAlertActivationRepository->findActiveByUser($event->getUser());
  59.         if (!$leakActivations) {
  60.             return;
  61.         }
  63.         foreach ($leakActivations as $activation) {
  64.             $this->leakAlertManager->deactivate($activation);
  65.         }
  67.         $this->em->flush();
  68.     }
  69. }