custom/plugins/LoyxxSeminar/src/Subscriber/OrderLoadedEventSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. namespace LoyxxSeminar\Subscriber;
  5. use LoyxxSeminar\Core\Checkout\Order\OrderParticipant\OrderParticipantCollection;
  6. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemCollection;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  9. use Shopware\Core\Checkout\Order\OrderEntity;
  10. use Shopware\Core\Checkout\Order\OrderEvents;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class OrderLoadedEventSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     protected $orderParticipantsRepository;
  24.     /**
  25.      * StorefrontRenderEventSubscriber constructor.
  26.      * @param  EntityRepositoryInterface  $orderParticipantsRepository
  27.      */
  28.     public function __construct(EntityRepositoryInterface $orderParticipantsRepository)
  29.     {
  30.         $this->orderParticipantsRepository = $orderParticipantsRepository;
  31.     }
  33.     public static function getSubscribedEvents()
  34.     {
  35.         return [
  36.             OrderEvents::ORDER_LOADED_EVENT => "addParticipantsToOderLineItems",
  37.         ];
  39.     }
  41.     public function addParticipantsToOderLineItems(EntityLoadedEvent $event)
  42.     {
  43.         // Load participants to current order line items
  44.         // Take all line item keys and the search participants for this keys
  45.         // Add participant to line item by filtering by line item key through the result
  46.         $lineItems = [];
  47.         foreach ($event->getEntities() as $order) {
  48.             /**@var OrderEntity $order */
  49.             if ($order->getLineItems() === null) {
  50.                 continue;
  51.             }
  53. //            $lineItems += $this->filterByType($order->getLineItems(),LineItem::PRODUCT_LINE_ITEM_TYPE)->getElements();
  54.             $lineItems += $order->getLineItems()->filterByType(LineItem::PRODUCT_LINE_ITEM_TYPE)->getElements();
  55.         }
  56.         if (count($lineItems) === 0) {
  57.             return;
  58.         }
  60.         $lineItemsCollection = new OrderLineItemCollection($lineItems);
  62.         $lineItemsKeys = $lineItemsCollection->getKeys();
  63.         $criteria = (new Criteria())
  64.             ->addFilter(new EqualsAnyFilter('orderLineItemId', $lineItemsKeys));
  65.         /** @var OrderParticipantCollection $participantsCollection */
  66.         $participantsCollection = $this->orderParticipantsRepository->search(
  67.             $criteria,
  68.             $event->getContext()
  69.         )->getEntities();
  70.         foreach ($lineItemsCollection as $lineItem) {
  71.             /** @var OrderLineItemEntity $lineItem */
  72.             $participants = $participantsCollection->filterByProperty('orderLineItemId', $lineItem->getId());
  73.             if ($participants->count()) {
  74.                 $lineItem->addExtension('participants', $participants);
  75.             }
  76.         }
  77.     }
  78.     private function filterByType($elements, $type)
  79.     {
  80.         return $elements->filter(function (OrderLineItemEntity $lineItem) use ($type) {
  81.             return $lineItem->getType() === $type;
  82.         });
  83.     }
  84. }