src/EventSubscriber/Import/EntityMapper/ProductAvailability/EntityPreInitSubscriber.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber\Import\EntityMapper\ProductAvailability;
  5. use App\Application\EntityImportBundle\Event\EntityPreInitEvent;
  6. use App\Application\EntityImportBundle\ValueObject\ConfigItemPropertiesValue;
  7. use App\Entity\Product;
  8. use App\Entity\ProductAvailability;
  9. use App\EventSubscriber\Import\EntityMapper\BasePreInitSubscriber;
  11. class EntityPreInitSubscriber extends BasePreInitSubscriber
  12. {
  13.     private $productEntity;
  14.     private $territory;
  15.     private $window;
  16.     private $data;
  19.     public static function getSubscribedEvents(): array
  20.     {
  21.         return [
  22.             EntityPreInitEvent::class => 'onEntityPreInit',
  23.         ];
  24.     }
  26.     public function onEntityPreInit(EntityPreInitEvent $event): void
  27.     {
  28.         if (
  29.             Product::class !== $event->getTargetClassName()
  30.             || 'titleCode' !== $event->getPrimaryProperty()->getName()
  31.         ) {
  32.             return;
  33.         }
  35.         $configuredProperties = $event->getConfigurationProperties();
  36.         [$titleCodeProperty, $windowProperty, $territoryProperty] = [
  37.             $event->getPrimaryProperty(),
  38.             $this->filterConfiguredProperty('window', $configuredProperties, true),
  39.             $this->filterConfiguredProperty('territory', $configuredProperties, true),
  40.         ];
  42.         if (null === $titleCodeProperty || null === $windowProperty || null === $territoryProperty) {
  43.             $event->setSkipRowProcessing(true);
  45.             return;
  46.         }
  48.         $this->data = $event->getData();
  50.         if (!$titleCode = $this->getValue($titleCodeProperty, $this->data)) {
  51.             $event->setSkipRowProcessing(true);
  53.             return;
  54.         }
  56.         if (!$this->window = $this->getValue($windowProperty, $this->data)) {
  57.             $event->setSkipRowProcessing(true);
  59.             return;
  60.         }
  62.         if (!$this->territory = $this->getValue($territoryProperty, $this->data)) {
  63.             $event->setSkipRowProcessing(true);
  65.             return;
  66.         }
  68.         $repository = $this->getEntityManager()->getRepository(Product::class);
  70.         if (!$this->productEntity = $repository->findOneByNavCode($titleCode)) {
  71.             $event->setSkipRowProcessing(true);
  73.             return;
  74.         }
  76.         $startDateProperty = $this->filterConfiguredProperty('startDate', $configuredProperties);
  77.         $endDateProperty = $this->filterConfiguredProperty('endDate', $configuredProperties);
  79.         $foundAvailability = false;
  81.         foreach ($this->productEntity->getProductAvailability() as $availability) {
  82.             /** @var \App\Entity\ProductAvailability $availability */
  83.             if ($this->window === $availability->getWindow() && $this->territory === $availability->getTerritory()) {
  84.                 $this->setStartDate($availability, $startDateProperty);
  85.                 $this->setEndDate($availability, $endDateProperty);
  87.                 $foundAvailability = true;
  88.                 $this->getEntityManager()->persist($availability);
  89.             }
  90.         }
  92.         if (!$foundAvailability) {
  93.             $this->createNewAvailability($startDateProperty, $endDateProperty);
  94.         }
  96.         $event->setEntity($this->productEntity);
  97.     }
  99.     private function createNewAvailability($startDateProperty, $endDateProperty)
  100.     {
  101.         $newProductAvailability = new ProductAvailability();
  102.         $newProductAvailability->setWindow($this->window);
  103.         $newProductAvailability->setTerritory($this->territory);
  105.         $this->setStartDate($newProductAvailability, $startDateProperty);
  106.         $this->setEndDate($newProductAvailability, $endDateProperty);
  108.         $this->productEntity->addProductAvailability($newProductAvailability);
  109.     }
  111.     private function setStartDate(ProductAvailability $entity, ConfigItemPropertiesValue $property): void
  112.     {
  113.         $value = $this->getValue($property, $this->data);
  115.         if ($value && $this->getAllowedNullableCharacter() === $value) {
  116.             $entity->setStartDate(null);
  118.             return;
  119.         }
  121.         if (!$dateTime = \DateTime::createFromFormat('d-m-Y', $value)) {
  122.             return;
  123.         }
  125.         $entity->setStartDate($dateTime);
  126.     }
  128.     private function setEndDate(ProductAvailability $entity, ConfigItemPropertiesValue $property): void
  129.     {
  130.         $value = $this->getValue($property, $this->data);
  132.         if ($value && $this->getAllowedNullableCharacter() === $value) {
  133.             $entity->setEndDate(null);
  135.             return;
  136.         }
  138.         if (!$dateTime = \DateTime::createFromFormat('d-m-Y', $value)) {
  139.             return;
  140.         }
  142.         $entity->setEndDate($dateTime);
  143.     }
  144. }