vendor/store.shopware.com/mltisafemultisafepay/src/Subscriber/OrderDeliveryStateChangeEvent.php line 80

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * Copyright © MultiSafepay, Inc. All rights reserved.
  4.  * See DISCLAIMER.md for disclaimer details.
  5.  */
  7. namespace MultiSafepay\Shopware6\Subscriber;
  9. use Exception;
  10. use MultiSafepay\Api\Transactions\UpdateRequest;
  11. use MultiSafepay\Exception\ApiException;
  12. use MultiSafepay\Exception\InvalidApiKeyException;
  13. use MultiSafepay\Shopware6\Factory\SdkFactory;
  14. use MultiSafepay\Shopware6\Util\OrderUtil;
  15. use MultiSafepay\Shopware6\Util\PaymentUtil;
  16. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryEntity;
  17. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryStates;
  18. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  21. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. class OrderDeliveryStateChangeEvent implements EventSubscriberInterface
  25. {
  26.     /**
  27.      * @var EntityRepository
  28.      */
  29.     private $orderDeliveryRepository;
  31.     /**
  32.      * @var SdkFactory
  33.      */
  34.     private $sdkFactory;
  36.     /**
  37.      * @var PaymentUtil
  38.      */
  39.     private $paymentUtil;
  41.     /**
  42.      * @var OrderUtil
  43.      */
  44.     private $orderUtil;
  46.     /**
  47.      * OrderDeliveryStateChangeEvent constructor.
  48.      *
  49.      * @param EntityRepository $orderDeliveryRepository
  50.      * @param SdkFactory $sdkFactory
  51.      * @param PaymentUtil $paymentUtil
  52.      * @param OrderUtil $orderUtil
  53.      */
  54.     public function __construct(
  55.         EntityRepository $orderDeliveryRepository,
  56.         SdkFactory $sdkFactory,
  57.         PaymentUtil $paymentUtil,
  58.         OrderUtil $orderUtil
  59.     ) {
  60.         $this->orderDeliveryRepository = $orderDeliveryRepository;
  61.         $this->sdkFactory = $sdkFactory;
  62.         $this->paymentUtil = $paymentUtil;
  63.         $this->orderUtil = $orderUtil;
  64.     }
  66.     /**
  67.      * {@inheritDoc}
  68.      */
  69.     public static function getSubscribedEvents(): array
  70.     {
  71.         return [
  72.             'state_machine.order_delivery.state_changed' => 'onOrderDeliveryStateChanged',
  73.         ];
  74.     }
  76.     /**
  77.      * @param StateMachineStateChangeEvent $event
  78.      * @throws Exception
  79.      */
  80.     public function onOrderDeliveryStateChanged(StateMachineStateChangeEvent $event): void
  81.     {
  82.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER
  83.             || $event->getStateName() !== OrderDeliveryStates::STATE_SHIPPED
  84.         ) {
  85.             return;
  86.         }
  88.         $context = $event->getContext();
  89.         $orderDelivery = $this->getOrderDeliveryData($event);
  90.         $trackAndTraceCode = $orderDelivery->getTrackingCodes();
  91.         $orderId = $orderDelivery->getOrderId();
  93.         if (!$this->paymentUtil->isMultiSafepayPaymentMethod($orderId, $context)) {
  94.             return;
  95.         }
  97.         try {
  98.             $order = $this->orderUtil->getOrder($orderId, $context);
  99.             $this->sdkFactory->create($order->getSalesChannelId())
  100.                 ->getTransactionManager()
  101.                 ->update(
  102.                     $order->getOrderNumber(),
  103.                     (new UpdateRequest())->addStatus('shipped')->addData([
  104.                         'tracktrace_code' => reset($trackAndTraceCode),
  105.                         'carrier' => '',
  106.                         'ship_date' => date('Y-m-d H:i:s'),
  107.                         'reason' => 'Shipped',
  108.                     ])
  109.                 );
  110.         } catch (InvalidApiKeyException $invalidApiKeyException) {
  111.             return;
  112.         } catch (ApiException $apiException) {
  113.             return;
  114.         }
  115.     }
  117.     /**
  118.      * Get Order delivery data
  119.      *
  120.      * @param StateMachineStateChangeEvent $event
  121.      * @return mixed|null
  122.      * @throws InconsistentCriteriaIdsException
  123.      */
  124.     private function getOrderDeliveryData(StateMachineStateChangeEvent $event): OrderDeliveryEntity
  125.     {
  126.         $orderDelivery = $this->orderDeliveryRepository->search(
  127.             new Criteria([$event->getTransition()->getEntityId()]),
  128.             $event->getContext()
  129.         )->first();
  131.         return $orderDelivery;
  132.     }
  133. }