custom/plugins/ZeobvCartRecovery/src/Core/Subscriber/CartConvertedSubscriber.php line 78

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Zeobv\CartRecovery\Core\Subscriber;
  5. use Shopware\Core\System\SalesChannel\Context\AbstractSalesChannelContextFactory;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  8. use Shopware\Core\Checkout\Cart\Order\OrderConverter;
  9. use Shopware\Core\Checkout\Cart\CartPersisterInterface;
  10. use Shopware\Core\Framework\Uuid\Uuid;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryCollection;
  12. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Checkout\Order\OrderEntity;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Shopware\Core\Framework\Context;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  19. use Shopware\Core\Checkout\Order\Aggregate\OrderDeliveryPosition\OrderDeliveryPositionCollection;
  21. /**
  22.  * Class CartConvertedSubscriber
  23.  *
  24.  * @package Zeobv\CartRecovery\Core\Subscriber
  25.  */
  26. class CartConvertedSubscriber implements EventSubscriberInterface
  27. {
  28.     /**
  29.      * @var OrderConverter
  30.      */
  31.     protected $orderConverter;
  33.     /**
  34.      * @var CartPersisterInterface
  35.      */
  36.     protected $cartPersister;
  38.     /**
  39.      * @var AbstractSalesChannelContextFactory
  40.      */
  41.     protected $salesChannelContextFactory;
  43.     /**
  44.      * @var EntityRepositoryInterface
  45.      */
  46.     protected $orderDeliveryRepository;
  48.     /**
  49.      * @var EntityRepositoryInterface
  50.      */
  51.     protected $orderDeliveryPositionsRepository;
  53.     public function __construct(
  54.         OrderConverter $orderConverter,
  55.         CartPersisterInterface $cartPersister,
  56.         AbstractSalesChannelContextFactory $salesChannelContextFactory,
  57.         EntityRepositoryInterface $orderDeliveryRepository,
  58.         EntityRepositoryInterface $orderDeliveryPositionsRepository
  59.     )
  60.     {
  61.         $this->orderConverter = $orderConverter;
  62.         $this->cartPersister = $cartPersister;
  63.         $this->salesChannelContextFactory = $salesChannelContextFactory;
  64.         $this->orderDeliveryRepository = $orderDeliveryRepository;
  65.         $this->orderDeliveryPositionsRepository = $orderDeliveryPositionsRepository;
  66.     }
  68.     /**
  69.      * @return array|string[]
  70.      */
  71.     public static function getSubscribedEvents()
  72.     {
  73.         return [
  74.             CheckoutOrderPlacedEvent::class => 'onCheckoutOrderPlaced'
  75.         ];
  76.     }
  78.     public function onCheckoutOrderPlaced(CheckoutOrderPlacedEvent $event)
  79.     {
  80.         $order = $event->getOrder();
  82.         if ($order->getDeliveries()->count() < 1) {
  83.             $deliveries =  $this->getOrderDeliveries($order, $event->getContext());
  84.         } else {
  85.             $deliveries = $this->setDeliveryPositionsForOrderDeliveries($order->getDeliveries(), $event->getContext());
  86.         }
  88.         $order->setDeliveries($deliveries);
  90.         $cart = $this->orderConverter->convertToCart($order, $event->getContext());
  92.         $salesChannelContext = $this->salesChannelContextFactory->create(Uuid::randomHex(), $event->getSalesChannelId(), [
  93.             SalesChannelContextService::CUSTOMER_ID => $order->getOrderCustomer()->getCustomerId()
  94.         ]);
  96.         $cart->setToken($order->getId());
  97.         $cart->setName('cart_waiting_for_recovery');
  98.         $this->cartPersister->save($cart, $salesChannelContext);
  99.     }
  101.     /**
  102.      * @param OrderEntity $order
  103.      * @param Context     $context
  104.      *
  105.      * @return OrderDeliveryCollection
  106.      */
  107.     private function getOrderDeliveries(OrderEntity $order, Context $context): OrderDeliveryCollection
  108.     {
  109.         $criteria = new Criteria();
  110.         $criteria->addFilter(new EqualsFilter('orderId', $order->getId()));
  111.         $criteria->addAssociations([
  112.             'positions.orderLineItem',
  113.             'shippingOrderAddress.country',
  114.             'shippingMethod',
  115.             'state',
  116.         ]);
  118.         /** @var OrderDeliveryCollection $deliveries */
  119.         $deliveries = $this->orderDeliveryRepository->search($criteria, $context)->getEntities();
  121.         return $deliveries;
  122.     }
  124.     private function setDeliveryPositionsForOrderDeliveries(OrderDeliveryCollection $deliveries, Context $context)
  125.     {
  126.         if ($deliveries->count() < 1) {
  127.             return $deliveries;
  128.         }
  130.         $criteria = new Criteria();
  131.         $criteria->addFilter(new EqualsAnyFilter('orderDeliveryId', $deliveries->getIds()));
  132.         $criteria->addAssociations(['orderLineItem']);
  133.         $positions = $this->orderDeliveryPositionsRepository->search($criteria, $context)->getEntities();
  135.         foreach ($deliveries as $delivery) {
  136.             /** @var OrderDeliveryPositionCollection $positionsForDelivery */
  137.             $positionsForDelivery = $positions->filterByProperty('orderDeliveryId', $delivery->getId());
  138.             $delivery->setPositions($positionsForDelivery);
  139.         }
  141.         return $deliveries;
  142.     }
  143. }