vendor/crehler/arrangements/src/Subscriber/ArrangementWriteSubscriber.php line 41

Open in your IDE?
  1. <?php
  2. /**
  3.  * @copyright 2020 Crehler Sp. z o. o. <https://crehler.com>
  4.  *
  5.  * @author    Jakub Medyński <jme@crehler.com>
  6.  * @support   Crehler <support@crehler.com>
  7.  * @created   22.01.2021
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  13. namespace Crehler\Arrangements\Subscriber;
  15. use Crehler\Arrangements\Entity\Arrangement\ArrangementEntity;
  16. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. class ArrangementWriteSubscriber implements EventSubscriberInterface
  23. {
  25.     private EntityRepositoryInterface $productRepository;
  26.     private EntityRepositoryInterface $arrangementRepository;
  28.     public function __construct(EntityRepositoryInterface $productRepository, EntityRepositoryInterface $arrangementRepository)
  29.     {
  30.         $this->productRepository = $productRepository;
  31.         $this->arrangementRepository = $arrangementRepository;
  32.     }
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             'arrangement.written' => 'onArrangementWritten'
  38.         ];
  39.     }
  41.     public function onArrangementWritten(EntityWrittenEvent $event)
  42.     {
  43.         $ids = $event->getIds();
  44.         $context = $event->getContext();
  46.         $criteria = new Criteria();
  47.         $criteria->addFilter(new EqualsAnyFilter('id', $ids));
  49.         $result = $this->arrangementRepository->search($criteria, $context);
  50.         if ($result->getTotal() >= 1)
  51.         {
  52.             /** @var ArrangementEntity $arrangement */
  53.             $arrangement = $result->first();
  55.             $this->productRepository->update([[
  56.                 'id' => $arrangement->getMainProductId(),
  57.                 'active' => $arrangement->isActive()
  58.             ]], $context);
  59.         }
  60.     }
  61. }