src/Api/EventListener/ImportLogListener.php line 19

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\Vehicle;
  8. use Psr\Log\LoggerInterface;
  10. class ImportLogListener
  11. {
  12.     private $counter;
  14.     public function __construct(private readonly LoggerInterface $logger)
  15.     {
  16.         $this->counter = ['ignored' => 0, 'persisted' => 0];
  17.     }
  19.     public function onNewData(ImportEvent $event): void
  20.     {
  21.         $data = (array) $event->getObject();
  23.         if (isset($data['saleid'])) {
  24.             $this->logger->info('Received Sale '.$data['saleid'].'...');
  25.         } elseif (isset($data['id'])) {
  26.             dump('pouet');
  27.             $this->logger->info('Received Vehicle '.$data['id'].'...');
  28.         } else {
  29.             $this->logger->info('Received some data...');
  30.         }
  31.     }
  33.     public function onIgnoredData(ImportEvent $event): void
  34.     {
  35.         $data = (array) $event->getObject();
  37.         if (isset($data['status']) && 'D' === $data['status']) {
  38.             $this->logger->info('Vehicle deleted.');
  39.         } else {
  40.             $this->logger->warning('The object could not be resolved. This might mean something is wrong with the data.');
  41.         }
  43.         ++$this->counter['ignored'];
  44.     }
  46.     public function onPersistedData(ImportEvent $event): void
  47.     {
  48.         $entity = $event->getObject();
  50.         if ($entity instanceof Sale) {
  51.             $this->logger->info(sprintf('Sale %s imported.', $entity->getId()));
  52.         } elseif ($entity instanceof Vehicle) {
  53.             $this->logger->info(sprintf('Vehicle imported with new id %s.', $entity->getId()));
  54.         }
  56.         ++$this->counter['persisted'];
  57.     }
  59.     public function onErrorData(ImportEvent $event): void
  60.     {
  61.         $this->logger->error(sprintf('Vehicle %s error', $event->getId() ?? ''));
  62.     }
  64.     public function onEnd(ImportEvent $event): void
  65.     {
  66.         $this->logger->info(sprintf('Summary sale %s: persisted %s, ignored/deleted %s.', $event->getId() ?? '', $this->counter['persisted'], $this->counter['ignored']));
  67.     }
  68. }