vendor/store.shopware.com/viocustomerprice/src/Subscriber/EntityWrittenContainerSubscriber.php line 45

Open in your IDE?
  1. <?php
  4. namespace VioCustomerPrice\Subscriber;
  7. use Exception;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use VioCustomerPrice\Entity\CustomerPriceEntity;
  19. class EntityWrittenContainerSubscriber implements EventSubscriberInterface
  20. {
  21.     private EntityRepositoryInterface $entityRepository;
  23.     public function __construct(
  24.         EntityRepositoryInterface $entityRepository
  25.     )
  26.     {
  27.         $this->entityRepository = $entityRepository;
  28.     }
  30.     /**
  31.      * @inheritDoc
  32.      */
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             EntityWrittenContainerEvent::class => "onEntityWrittenContainerEvent"
  37.         ];
  38.     }
  40.     /**
  41.      * @param EntityWrittenContainerEvent $event
  42.      * @throws InconsistentCriteriaIdsException
  43.      * @throws Exception
  44.      */
  45.     public function onEntityWrittenContainerEvent(EntityWrittenContainerEvent $event): void
  46.     {
  47.         foreach ($event->getEvents() as $nestedEvent) {
  48.             if ($nestedEvent instanceof EntityWrittenEvent) {
  49.                 foreach ($nestedEvent->getWriteResults() as $entityWriteResult) {
  50.                     if ($entityWriteResult->getEntityName() === 'vio_customer_price'
  51.                         && $entityWriteResult->getExistence() !== null
  52.                         && ($entityWriteResult->getOperation() === 'update' || $entityWriteResult->getOperation() === 'insert')
  53.                         && !array_key_exists('quantityEnd', $entityWriteResult->getPayload())
  54.                     ) {
  55.                         $this->reorderPrices($entityWriteResult->getPrimaryKey(), $event->getContext());
  56.                     }
  57.                 }
  58.             }
  59.         }
  60.     }
  62.     /**
  63.      * reorder the related prices to the given price
  64.      * @param string $priceId
  65.      * @param Context $context
  66.      * @throws InconsistentCriteriaIdsException
  67.      * @throws Exception
  68.      */
  69.     private function reorderPrices(string $priceId, Context $context): void
  70.     {
  71.         /** @var CustomerPriceEntity $customerPrice */
  72.         $customerPrice = $this->entityRepository->search(new Criteria([$priceId]), $context)->first();
  73.         if ($customerPrice !== null) {
  74.             $criteria = new Criteria();
  75.             $criteria
  76.                 ->addFilter(new EqualsFilter('customerId', $customerPrice->getCustomerId()))
  77.                 ->addFilter(new EqualsFilter('productId', $customerPrice->getProductId()))
  78.                 ->addSorting(new FieldSorting('quantityStart', FieldSorting::ASCENDING));
  79.             $prices = $this->entityRepository->search($criteria, $context);
  80.             if($prices->count() > 1){
  81.                 /** @var CustomerPriceEntity|null $lastPrice */
  82.                 $lastPrice = null;
  83.                 $updateData = [];
  84.                 /** @var CustomerPriceEntity $curPrice */
  85.                 foreach ($prices as $curPrice){
  86.                     if($lastPrice !== null) {
  87.                         $updateData[] = ['id' => $lastPrice->getId(), 'quantityEnd' => $curPrice->getQuantityStart() - 1];
  88.                     }
  89.                     $lastPrice = $curPrice;
  90.                 }
  91.                 $this->entityRepository->update($updateData, $context);
  92.             }
  93.         }
  94.     }
  95. }