src/OrderProcessor/OrderShipmentProcessor.php line 36

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Sylius package.
  5.  *
  6.  * (c) Paweł Jędrzejewski
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace App\OrderProcessor;
  16. use Sylius\Component\Core\Model\OrderInterface;
  17. use Sylius\Component\Core\Model\ShipmentInterface;
  18. use Sylius\Component\Core\OrderCheckoutStates;
  19. use Sylius\Component\Order\Model\OrderInterface as BaseOrderInterface;
  20. use Sylius\Component\Order\Processor\OrderProcessorInterface;
  21. use Sylius\Component\Resource\Factory\FactoryInterface;
  22. use Sylius\Component\Shipping\Exception\UnresolvedDefaultShippingMethodException;
  23. use Sylius\Component\Shipping\Resolver\DefaultShippingMethodResolverInterface;
  24. use Sylius\Component\Shipping\Resolver\ShippingMethodsResolverInterface;
  25. use Symfony\Component\HttpFoundation\RequestStack;
  26. use Webmozart\Assert\Assert;
  28. final class OrderShipmentProcessor implements OrderProcessorInterface
  29. {
  30.     private DefaultShippingMethodResolverInterface $defaultShippingMethodResolver;
  32.     private FactoryInterface $shipmentFactory;
  34.     private ?ShippingMethodsResolverInterface $shippingMethodsResolver;
  36.     public function __construct(
  37.         DefaultShippingMethodResolverInterface $defaultShippingMethodResolver,
  38.         FactoryInterface $shipmentFactory,
  39.         ?ShippingMethodsResolverInterface $shippingMethodsResolver = null,
  40.         private RequestStack $requestStack
  41.     ) {
  42.         $this->defaultShippingMethodResolver = $defaultShippingMethodResolver;
  43.         $this->shipmentFactory = $shipmentFactory;
  44.         $this->shippingMethodsResolver = $shippingMethodsResolver;
  46.         if (2 === func_num_args() || null === $shippingMethodsResolver) {
  47.             @trigger_error(
  48.                 'Not passing ShippingMethodsResolverInterface explicitly is deprecated since 1.2 and will be prohibited in 2.0',
  49.                 \E_USER_DEPRECATED
  50.             );
  51.         }
  52.     }
  54.     public function process(BaseOrderInterface $order): void
  55.     {
  56.         /** @var OrderInterface $order */
  57.         Assert::isInstanceOf($order, OrderInterface::class);
  59.         if (!$order->canBeProcessed()) {
  60.             return;
  61.         }
  63.         if ($order->isEmpty() || !$order->isShippingRequired()) {
  64.             $order->removeShipments();
  66.             return;
  67.         }
  69.         if ($order->hasShipments()) {
  70.             $this->recalculateExistingShipmentWithProperMethod($order);
  72.             return;
  73.         }
  75.         $this->createNewOrderShipment($order);
  76.     }
  78.     public function createNewOrderShipment(OrderInterface $order): void
  79.     {
  80.         /** @var ShipmentInterface $shipment */
  81.         $shipment = $this->shipmentFactory->createNew();
  82.         $shipment->setOrder($order);
  84.         try {
  85.             $this->processShipmentUnits($order, $shipment);
  87.             $shipment->setMethod($this->defaultShippingMethodResolver->getDefaultShippingMethod($shipment));
  89.             $order->addShipment($shipment);
  90.         } catch (UnresolvedDefaultShippingMethodException $exception) {
  91.             foreach ($shipment->getUnits() as $unit) {
  92.                 $shipment->removeUnit($unit);
  93.             }
  94.         }
  95.     }
  97.     private function processShipmentUnits(BaseOrderInterface $order, ShipmentInterface $shipment): void
  98.     {
  99.         foreach ($shipment->getUnits() as $unit) {
  100.             $shipment->removeUnit($unit);
  101.         }
  103.         /** @var OrderInterface $order */
  104.         Assert::isInstanceOf($order, OrderInterface::class);
  106.         foreach ($order->getItemUnits() as $itemUnit) {
  107.             if (null === $itemUnit->getShipment()) {
  108.                 $shipment->addUnit($itemUnit);
  109.             }
  110.         }
  111.     }
  113.     private function recalculateExistingShipmentWithProperMethod(OrderInterface $order): void
  114.     {
  115.         /** @var ShipmentInterface $shipment */
  116.         $shipment = $order->getShipments()->first();
  118.         $this->processShipmentUnits($order, $shipment);
  120.         if (null === $this->shippingMethodsResolver) {
  121.             return;
  122.         }
  124.         $orderCreationAdmin = false;
  125.         if ($this->requestStack->getCurrentRequest()->getSession()->has('order_creation_admin_id') && $this->requestStack->getCurrentRequest()->getSession()->get('order_creation_admin_id') === $order->getId()) {
  126.             $orderCreationAdmin = true;
  127.         }
  129.         if ($order->getCheckoutState() === OrderCheckoutStates::STATE_CART && !$orderCreationAdmin) {
  130.             try {
  131.                 $shipment->setMethod($this->defaultShippingMethodResolver->getDefaultShippingMethod($shipment));
  132.             } catch (UnresolvedDefaultShippingMethodException $exception) {
  133.                 return;
  134.             }
  135.         }
  136.         if (!in_array($shipment->getMethod(), $this->shippingMethodsResolver->getSupportedMethods($shipment), true)) {
  137.             try {
  138.                 $shipment->setMethod($this->defaultShippingMethodResolver->getDefaultShippingMethod($shipment));
  139.             } catch (UnresolvedDefaultShippingMethodException $exception) {
  140.                 return;
  141.             }
  142.         }
  143.     }
  144. }