src/PentagastBundle/Subscriber/OrderLineSubscriber.php line 31

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * valantic CEC Deutschland GmbH
  4.  * Copyright (c) 2022.
  5.  *
  6.  * All rights reserved.
  7.  *
  8.  * @see https://www.valantic.com/
  9.  *
  10.  * @author andrei
  11.  * Date: 21.11.2022 14:24
  12.  */
  14. namespace Valantic\Bundle\PentagastBundle\Subscriber;
  16. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  17. use Shopware\Core\Checkout\Order\OrderEvents;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Valantic\Bundle\PentagastBundle\Struct\PurchasePrice;
  22. class OrderLineSubscriber implements EventSubscriberInterface
  23. {
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             OrderEvents::ORDER_LINE_ITEM_LOADED_EVENT => ['onOrderLineItemLoaded', -250],
  28.         ];
  29.     }
  31.     public function onOrderLineItemLoaded(EntityLoadedEvent $event): void
  32.     {
  33.         $eventEntities = $event->getEntities();
  35.         /** @var OrderLineItemEntity $orderLineItem */
  36.         foreach ($eventEntities as $orderLineItem) {
  37.             $purchasePriceValue = 0;
  38.             $targetOrderProductLine = $orderLineItem;
  40.             if ($orderLineItem->getType() === 'customized-products') {
  41.                 $filterResult = array_filter($eventEntities, function (OrderLineItemEntity $lineItem) use ($orderLineItem) {
  42.                     return $lineItem->getType() === 'product' && $lineItem->getParentId() === $orderLineItem->getId();
  43.                 });
  45.                 if ($filterResult) {
  46.                     $targetOrderProductLine = array_values($filterResult)[0];
  47.                 }
  48.             }
  50.             if ($targetOrderProductLine) {
  51.                 $targetPayload = $targetOrderProductLine->getPayload();
  53.                 $purchasePrices = json_decode($targetPayload['purchasePrices'] ?? '', true);
  54.                 if ($purchasePrices) {
  55.                     $purchasePriceValue = $purchasePrices['calculatedPrice'] ?? 0;
  56.                 }
  57.             }
  59.             $purchasePrice = new PurchasePrice();
  60.             $purchasePrice->setValue($purchasePriceValue);
  62.             /** @psalm-suppress DeprecatedMethod */
  63.             $orderLineItem->addExtension('purchasePrice', $purchasePrice);
  64.         }
  65.     }
  66. }