vendor/crehler/mojebambino-engine/src/Subscriber/PropertyGroupOptionSubscriber.php line 33

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Crehler\MojeBambinoEngine\Subscriber;
  5. use Crehler\MojeBambinoEngine\Entity\Property\PropertyGroupOptionIncrementEntity;
  6. use Crehler\MojeBambinoEngine\Struct\AutoIncrementStruct;
  7. use Shopware\Core\Content\Property\PropertyEvents;
  8. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\Uuid\Uuid;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class PropertyGroupOptionSubscriber implements EventSubscriberInterface
  18. {
  19.     private EntityRepository $productGroupOptionIncrementRepository;
  21.     public function __construct(EntityRepository $productGroupOptionIncrementRepository)
  22.     {
  23.         $this->productGroupOptionIncrementRepository = $productGroupOptionIncrementRepository;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             PropertyEvents::PROPERTY_GROUP_OPTION_LOADED_EVENT => 'onProductGroupOptionEventLoaded'
  30.         ];
  31.     }
  33.     public function onProductGroupOptionEventLoaded(EntityLoadedEvent $event): void
  34.     {
  35.         if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
  36.             return;
  37.         }
  38.         try {
  41.             foreach ($event->getEntities() as $entity) {
  42.                 $criteria = new Criteria();
  43.                 $criteria->addFilter(
  44.                     new EqualsFilter('propertyGroupOptionId', $entity->getId())
  45.                 );
  47.                 /** @var PropertyGroupOptionIncrementEntity $increment */
  48.                 $increment = $this->productGroupOptionIncrementRepository->search($criteria, Context::createDefaultContext())->first();
  49.                 if (!$increment) {
  50.                     $this->productGroupOptionIncrementRepository->upsert([['propertyGroupOptionId' => $entity->getId()]], Context::createDefaultContext());
  51.                     $increment = $this->productGroupOptionIncrementRepository->search($criteria, Context::createDefaultContext())->first();
  52.                 }
  54.                 $struct = new AutoIncrementStruct($increment->getAutoIncrement());
  55.                 $entity->addExtension('autoIncrement', $struct);
  56.             }
  57.         } catch (\Throwable $exception) {
  58.             dd($exception);
  59.         }
  60.     }
  61. }