vendor/crehler/mojebambino-catalog/src/Subscriber/PageProductWrittenSubscriber.php line 46

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  3. /**
  4.  * @copyright 2020 Crehler Sp. z o. o.
  5.  * @link https://crehler.com/
  6.  * @support support@crehler.com
  7.  *
  8.  * @author Mateusz Flasiński
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Crehler\Catalog\Subscriber;
  16. use Crehler\Catalog\Entity\Catalog\Aggregate\CatalogPage\ProductDotDefinition;
  17. use Shopware\Core\Framework\Context;
  18. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  22. use Shopware\Core\Framework\Struct\ArrayEntity;
  23. use Shopware\Core\Framework\Uuid\Uuid;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. class PageProductWrittenSubscriber implements EventSubscriberInterface
  27. {
  28.     private EntityRepositoryInterface $catalogProductDotRepository;
  30.     private array $dotsCache;
  32.     private array $positionsCache;
  34.     public function __construct(EntityRepositoryInterface $catalogProductDotRepository)
  35.     {
  36.         $this->catalogProductDotRepository = $catalogProductDotRepository;
  37.         $this->dotsCache = [];
  38.         $this->positionsCache = [];
  39.     }
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return ['catalog_page_product.written' => 'onProductWritten'];
  44.     }
  46.     public function onProductWritten(EntityWrittenEvent $event): void
  47.     {
  48.         $mapping = [];
  49.         $ids = [];
  50.         foreach ($event->getWriteResults() as $entityWriteResult) {
  51.             $payload = $entityWriteResult->getPayload();
  52.             if (isset($payload['catalogPageId'])) {
  53.                 $catalogPageId = $payload['catalogPageId'];
  54.             } else {
  55.                 $catalogPageId = null;
  56.             }
  57.             if (is_string($entityWriteResult->getPrimaryKey())) {
  58.                 $ids[] = $entityWriteResult->getPrimaryKey();
  59.                 $mapping[$entityWriteResult->getPrimaryKey()] = $catalogPageId;
  60.             }
  61.             if (is_array($entityWriteResult->getPrimaryKey())) {
  62.                 $ids = array_merge($entityWriteResult->getPrimaryKey(), $ids);
  63.                 foreach ($entityWriteResult->getPrimaryKey() as $id) {
  64.                     $mapping[$id] = $catalogPageId;
  65.                 }
  66.             }
  67.         }
  69.         $ids = array_unique($ids);
  71.         $upsertCollection = [];
  73.         foreach ($ids as $id) {
  74.             if (isset($mapping[$id]) && !$mapping[$id] !== null) {
  75.                 $catalogPageId = $mapping[$id];
  76.             } else {
  77.                 continue; // TODO Get Catalog Page Id;
  78.             }
  80.             if ($this->checkDotExists($catalogPageId, $id)) {
  81.                 continue;
  82.             }
  84.             $upsertCollection[] = [
  85.                 'id' => Uuid::randomHex(),
  86.                 'catalogPageId' => $catalogPageId,
  87.                 'catalogProductId' => $id,
  88.                 'xPosition' => $this->getXPosition($catalogPageId),
  89.                 'yPosition' => ProductDotDefinition::DEFAULT_Y,
  90.                 'enabled' => false,
  91.                 'hideOnMobile' => false,
  92.                 'radius' => ProductDotDefinition::DEFAULT_RADIUS,
  93.             ];
  94.         }
  96.         if (!empty($upsertCollection)) {
  97.             $this->catalogProductDotRepository->upsert($upsertCollection, Context::createDefaultContext());
  98.         }
  99.     }
  101.     private function checkDotExists(string $catalogPageId, string $catalogProductId): bool
  102.     {
  103.         $this->initCache($catalogPageId);
  104.         /** @var ArrayEntity $element */
  105.         foreach ($this->dotsCache[$catalogPageId] as $element) {
  106.             if ($element['catalogProductId'] === $catalogProductId) {
  107.                 return true;
  108.             }
  109.         }
  111.         return false;
  112.     }
  114.     private function initCache(string $catalogPageId): void
  115.     {
  116.         if (!isset($this->dotsCache[$catalogPageId])) {
  117.             $criteria = new Criteria();
  118.             $criteria->addFilter(new EqualsFilter('catalogPageId', $catalogPageId));
  119.             $this->dotsCache[$catalogPageId] = $this->catalogProductDotRepository->search($criteria, Context::createDefaultContext())->getElements();
  120.         }
  121.     }
  123.     private function getXPosition(string $catalogPageId): int
  124.     {
  125.         if (isset($this->positionsCache[$catalogPageId])) {
  126.             $this->positionsCache[$catalogPageId] = $this->positionsCache[$catalogPageId] + ProductDotDefinition::DEFAULT_X_STEP;
  128.             return $this->positionsCache[$catalogPageId];
  129.         }
  130.         $this->initCache($catalogPageId);
  131.         $currentX = ProductDotDefinition::DEFAULT_X - ProductDotDefinition::DEFAULT_X_STEP;
  133.         /** @var ArrayEntity $element */
  134.         foreach ($this->dotsCache[$catalogPageId] as $element) {
  135.             if ($element['yPosition'] === ProductDotDefinition::DEFAULT_Y && $element['xPosition'] > $currentX) {
  136.                 $currentX = $element['xPosition'];
  137.             }
  138.         }
  140.         $this->positionsCache[$catalogPageId] = $currentX + ProductDotDefinition::DEFAULT_X_STEP;
  142.         return $this->positionsCache[$catalogPageId];
  143.     }
  144. }