custom/plugins/ZeobvBundleProducts/src/Core/Subscriber/OrderLineItemQuantitySubscriber.php line 34

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Zeobv\BundleProducts\Core\Subscriber;
  7. use Shopware\Core\Checkout\Order\OrderEvents;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. class OrderLineItemQuantitySubscriber implements EventSubscriberInterface
  18. {
  19.     protected EntityRepositoryInterface $orderLineItemRepository;
  21.     public function __construct(
  22.         EntityRepositoryInterface $orderLineItemRepository
  23.     ) {
  24.         $this->orderLineItemRepository = $orderLineItemRepository;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             OrderEvents::ORDER_LINE_ITEM_WRITTEN_EVENT => 'onOrderLineItemWritten',
  31.         ];
  32.     }
  34.     public function onOrderLineItemWritten(EntityWrittenEvent $event): void
  35.     {
  36.         /** @var EntityWriteResult $writeResult */
  37.         foreach ($event->getWriteResults() as $writeResult) {
  38.             if (
  39.                 $writeResult->getOperation() !== EntityWriteResult::OPERATION_UPDATE
  40.                 || !$writeResult->hasPayload('quantity')
  41.                 || $writeResult->getProperty('quantity') <= 1
  42.             ) {
  43.                 continue;
  44.             }
  46.             /** @var array|string $id */
  47.             $id = $writeResult->getPrimaryKey();
  49.             $id = !is_array($id) ? [$id] : $id;
  51.             $criteria = new Criteria();
  52.             $criteria->addFilter(new EqualsAnyFilter('parentId', $id));
  54.             $result = $this->orderLineItemRepository->search($criteria, $event->getContext());
  56.             if ($result->getTotal() <= 0) {
  57.                 continue;
  58.             }
  60.             $orderLineItemPatchData = [];
  62.             /** @var OrderLineItemEntity $item */
  63.             foreach ($result as $item) {
  64.                 $payload = $item->getPayload();
  65.                 if (!is_array($payload) || !key_exists('quantity', $payload)) {
  66.                     continue 2;
  67.                 }
  69.                 $orderLineItemPatchData[] = [
  70.                     'id' => $item->getId(),
  71.                     'quantity' => $payload['quantity'] * $writeResult->getProperty('quantity')
  72.                 ];
  73.             }
  75.             if (empty($orderLineItemPatchData)) {
  76.                 continue;
  77.             }
  79.             $this->orderLineItemRepository->update($orderLineItemPatchData, $event->getContext());
  80.         }
  81.     }
  82. }