src/Api/EventListener/ImportListener.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\Api\EventListener;
  5. use App\Api\Event\ImportEvent;
  6. use App\Entity\Sale;
  7. use App\Entity\SaleEvent;
  8. use App\Entity\Vehicle;
  9. use Doctrine\ORM\EntityManager;
  10. use Doctrine\ORM\Event\LifecycleEventArgs;
  11. use Doctrine\ORM\Events;
  12. use Symfony\Component\Process\PhpProcess;
  13. use Symfony\Component\Process\Process;
  15. class ImportListener
  16. {
  17.     public function __construct(private readonly string $projectDir, private readonly string $env, private readonly EntityManager $em)
  18.     {
  19.     }
  21.     /**
  22.      * Event call on push from etincelle.
  23.      */
  24.     public function onPushedData(ImportEvent $event): void
  25.     {
  26.         $this->processSale($event);
  27.     }
  29.     /**
  30.      * Event call when last vehicle has been managed.
  31.      */
  32.     public function onLastData(ImportEvent $event): void
  33.     {
  34.         $entity = $event->getObject();
  35.         if ($entity instanceof Vehicle) {
  36.             $this->generateFlyers($entity->getSale());
  37.         }
  38.     }
  40.     /**
  41.      * Event call when a sale is imported.
  42.      */
  43.     public function onPersistedData(ImportEvent $event): void
  44.     {
  45.         $this->processVehicles($event);
  46.     }
  48.     /**
  49.      * General post-treatment.
  50.      */
  51.     public function onEnd(): void
  52.     {
  53.         $this->cleanEvents();
  54.     }
  56.     /**
  57.      * import sale.
  58.      */
  59.     protected function processSale(ImportEvent $event)
  60.     {
  61.         // launch sale import in a new process
  62.         $process = Process::fromShellCommandline('nohup php '.$this->projectDir.'/bin/console vpauto:etincelle:import sale '.$event->getObject().' --env='.$this->env.' > /dev/null 2>&1 &');
  63.         $process->run();
  64.     }
  66.     /**
  67.      * Import vehicles.
  68.      */
  69.     protected function processVehicles(ImportEvent $event)
  70.     {
  71.         $entity = $event->getObject();
  72.         if ($entity instanceof Sale) {
  73.             $process = Process::fromShellCommandline('nohup php '.$this->projectDir.'/bin/console vpauto:etincelle:import vehicles '.$entity->getId().' --env='.$this->env.' > /dev/null 2>&1 &');
  74.             $process->run();
  75.         }
  76.     }
  78.     /**
  79.      * Generate flyers.
  80.      */
  81.     protected function generateFlyers(Sale $sale)
  82.     {
  83.         $process = Process::fromShellCommandline('nohup php '.$this->projectDir.'/bin/console vpauto:generate:flyer '.$sale->getId().' --force --env='.$this->env.' > /dev/null 2>&1 &');
  84.         $process->run();
  85.     }
  87.     protected function cleanEvents()
  88.     {
  89.         $events = $this->em->getRepository(SaleEvent::class)->findAllInFutureSales();
  91.         foreach ($events as $event) {
  92.             if ($event->isEmpty()) {
  93.                 foreach ($event->getVehicles() as $vehicle) {
  94.                     $this->em->remove($vehicle);
  95.                 }
  96.                 $this->em->flush();
  97.                 $this->em->remove($event);
  98.             }
  99.         }
  101.         $this->em->flush();
  102.     }
  103. }