src/EventSubscriber/Import/EntityMapper/ProductTag/EntityPreInitSubscriber.php line 22

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber\Import\EntityMapper\ProductTag;
  5. use App\Application\EntityImportBundle\Event\EntityPreInitEvent;
  6. use App\Entity\SonataClassificationCategory;
  7. use App\Entity\Product;
  8. use App\Entity\ProductPreInitImport;
  9. use App\Entity\VOD\Title;
  10. use App\EventSubscriber\Import\EntityMapper\BasePreInitSubscriber;
  12. class EntityPreInitSubscriber extends BasePreInitSubscriber
  13. {
  15.     public static function getSubscribedEvents(): array
  16.     {
  17.         return [
  18.             EntityPreInitEvent::class => 'onEntityPreInit',
  19.         ];
  20.     }
  22.     public function onEntityPreInit(EntityPreInitEvent $event): void
  23.     {
  24.         if (ProductPreInitImport::class !== $event->getTargetClassName()) {
  25.             return;
  26.         }
  28.         $configuredProperties = $event->getConfigurationProperties();
  29.         $titleCodeProperty = $this->filterConfiguredProperty('titleCode', $configuredProperties, true);
  30.         $tagsProperty = $this->filterConfiguredProperty('tag', $configuredProperties, true);
  32.         if (!isset($titleCodeProperty, $tagsProperty)) {
  33.             $event->setSkipRowProcessing(true);
  35.             return;
  36.         }
  37.         $titleCode = $this->getValue($titleCodeProperty, $event->getData());
  38.         $tags = explode(',', $this->getValue($tagsProperty, $event->getData()));
  40.         if (!$titleCode || !$tags) {
  41.             $event->setSkipRowProcessing(true);
  43.             return;
  44.         }
  46.         $productRepo = $this->getEntityManager()->getRepository(Product::class);
  47.         $entity = $productRepo->findOneByNavCode($titleCode);
  49.         if ($entity instanceof Product) {
  50.             $tagRepo = $this->getEntityManager()->getRepository(SonataClassificationCategory::class);
  52.             $tags = $tagRepo->findBy([
  53.                 'context' => 'tag',
  54.                 'slug' => $tags,
  55.             ]);
  57.             $isProductUpdated = false;
  58.             foreach ($tags as $tag) {
  59.                 if (!$this->isTagExists($entity, $tag)) {
  60.                     $entity->getTags()->add($tag);
  61.                     $isProductUpdated = true;
  62.                 }
  63.             }
  65.             if (!$isProductUpdated) {
  66.                 $event->setSkipRowProcessing(true);
  68.                 return;
  69.             }
  70.             $this->updateVodTitles($entity);
  71.         }
  72.         $event->setEntity($entity);
  73.     }
  75.     private function isTagExists(Product $entity, SonataClassificationCategory $tag): bool
  76.     {
  77.         return (bool) $entity->getTags()->filter(fn (SonataClassificationCategory $category) => $category === $tag)->toArray();
  78.     }
  80.     public function updateVodTitles(Product $entity): void
  81.     {
  82.         /** @var Title $vodTitle */
  83.         foreach ($entity->getVodTitles() as $vodTitle) {
  84.             // In the definition of the field in DB there is no configuration to use CURRENT_TIMESTAMP on every update
  85.             $vodTitle->setUpdatedAt(new \DateTime());
  86.             $this->getEntityManager()->persist($vodTitle);
  87.         }
  88.         $this->getEntityManager()->flush();
  89.     }
  90. }