src/Api/EventListener/ImportAlertListener.php line 52

Open in your IDE?
  1. <?php
  3. namespace App\Api\EventListener;
  5. use App\Api\Event\ImportEvent;
  6. use App\Entity\User;
  7. use App\Entity\Vehicle;
  8. use App\Entity\VehicleAlert;
  9. use App\Mailer\TranslatableMailer;
  10. use Doctrine\ORM\EntityManager;
  11. use Psr\Log\LoggerInterface;
  12. use Symfony\Component\Mailer\Exception\TransportException;
  13. use Twig\Environment;
  15. class ImportAlertListener
  16. {
  17.     private $_em;
  18.     private $counter;
  20.     public function __construct(EntityManager $em, private readonly TranslatableMailer $mailer, private readonly Environment $templating, private readonly LoggerInterface $logger, private $from)
  21.     {
  22.         $this->_em = $em;
  23.         $this->counter['overall'] = 0;
  24.     }
  26.     public function onIgnoredData(ImportEvent $event): void
  27.     {
  28.         $data = $event->getObject();
  30.         if (isset($data->status) && 'D' === $data->status) {
  31.             if (null !== $vehicle = $this->_em->getRepository(Vehicle::class)->findOneByVehicleId($data->id)) {
  32.                 if (Vehicle::SALING_STATE_SUPPRIME === $vehicle->getSalingState()) {
  33.                     $this->counter['current'] = 0;
  35.                     foreach ($vehicle->getAlerts() as $alert) {
  36.                         $this->sendDeleted($alert->getUser(), $vehicle);
  37.                         $this->_em->remove($alert);
  38.                         ++$this->counter['current'];
  39.                     }
  41.                     foreach ($vehicle->getSelections() as $selection) {
  42.                         $this->_em->remove($selection);
  43.                     }
  45.                     $this->_em->flush();
  46.                     $this->logger->info($this->counter['current'].' deletion alert(s) sent for this Vehicle.');
  47.                 }
  48.             }
  49.         }
  50.     }
  52.     public function onPersistedData(ImportEvent $event): void
  53.     {
  54.         $entity = $event->getObject();
  56.         if ($entity instanceof Vehicle) {
  57.             $alerts = $entity->getAlerts();
  58.             $this->counter['current'] = 0;
  60.             foreach ($alerts as $alert) {
  61.                 if ($entity->isStartingPriceAvailable() && $alert->getLastPrice() !== $entity->getStartingPrice()) {
  62.                     $this->send($alert);
  64.                     $alert->setLastPrice($entity->getStartingPrice());
  65.                     $this->_em->flush($alert);
  67.                     ++$this->counter['current'];
  68.                     ++$this->counter['overall'];
  69.                 }
  70.             }
  71.             $this->logger->info($this->counter['current'].' alert(s) sent for this Vehicle.');
  72.         }
  73.     }
  75.     public function onEnd(): void
  76.     {
  77.         $this->logger->info($this->counter['overall'].' alert(s) sent overall.');
  78.     }
  80.     private function send(VehicleAlert $alert): void
  81.     {
  82.         try {
  83.             $this->mailer->send(
  84.                 $alert->getUser(),
  85.                 '/Mail/alert_vehicle_price.html.twig',
  86.                 ['alert' => $alert]
  87.             );
  88.         } catch (TransportException $e) {
  89.             $this->logger->warning(sprintf('Couldn\'t sent email to %s. Error message : %s', $alert->getUser()->getEmail(), $e->getMessage()));
  90.         }
  91.     }
  93.     private function sendDeleted(User $user, Vehicle $vehicle): void
  94.     {
  95.         try {
  96.             $this->mailer->send(
  97.                 $user,
  98.                 '/Mail/alert_vehicle_deleted.html.twig',
  99.                 ['vehicle' => $vehicle]
  100.             );
  101.         } catch (TransportException $e) {
  102.             $this->logger->warning(sprintf('Couldn\'t sent email to %s. Error message : %s', $user->getEmail(), $e->getMessage()));
  103.         }
  104.     }
  105. }