custom/plugins/CkoShopware6/src/Subscriber/OrderStateMachineSubscriber.php line 58

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Cko\Shopware6\Subscriber;
  5. use Checkout\CheckoutApiException;
  6. use Cko\Shopware6\Factory\SettingsFactory;
  7. use Cko\Shopware6\Handler\PaymentHandler;
  8. use Cko\Shopware6\Service\CheckoutApi\CheckoutPaymentService;
  9. use Cko\Shopware6\Service\Order\AbstractOrderService;
  10. use Cko\Shopware6\Service\Order\AbstractOrderTransactionService;
  11. use Cko\Shopware6\Service\Order\OrderService;
  12. use Cko\Shopware6\Service\PaymentMethodService;
  13. use Cko\Shopware6\Struct\CheckoutApi\Resources\Payment;
  14. use Exception;
  15. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionCollection;
  16. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  17. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  18. use Shopware\Core\Checkout\Order\OrderEntity;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class OrderStateMachineSubscriber implements EventSubscriberInterface
  22. {
  23.     private PaymentMethodService $paymentMethodService;
  25.     private SettingsFactory $settingsFactory;
  27.     private CheckoutPaymentService $checkoutPaymentService;
  29.     private AbstractOrderService $orderService;
  31.     private AbstractOrderTransactionService $orderTransactionService;
  33.     public function __construct(
  34.         PaymentMethodService $paymentMethodService,
  35.         SettingsFactory $settingsFactory,
  36.         CheckoutPaymentService $checkoutPaymentService,
  37.         AbstractOrderService $orderService,
  38.         AbstractOrderTransactionService $orderTransitionService
  39.     ) {
  40.         $this->paymentMethodService = $paymentMethodService;
  41.         $this->settingsFactory = $settingsFactory;
  42.         $this->checkoutPaymentService = $checkoutPaymentService;
  43.         $this->orderService = $orderService;
  44.         $this->orderTransactionService = $orderTransitionService;
  45.     }
  47.     public static function getSubscribedEvents(): array
  48.     {
  49.         return [
  50.             'state_enter.order_delivery.state.shipped' => 'onOrderDeliveryEnterStateShipped',
  51.         ];
  52.     }
  54.     /**
  55.      * @throws CheckoutApiException
  56.      * @throws Exception
  57.      */
  58.     public function onOrderDeliveryEnterStateShipped(OrderStateMachineStateChangeEvent $event): void
  59.     {
  60.         $order = $event->getOrder();
  61.         $orderTransaction = $this->getOrderTransaction($order);
  62.         if (!$orderTransaction instanceof OrderTransactionEntity) {
  63.             return;
  64.         }
  66.         $paymentHandler = $this->paymentMethodService->getPaymentHandlerByOrderTransaction($orderTransaction);
  67.         if (!$paymentHandler instanceof PaymentHandler || !$paymentHandler->shouldCaptureAfterShipping()) {
  68.             return;
  69.         }
  71.         $checkoutOrderCustomFields = OrderService::getCheckoutOrderCustomFields($order);
  72.         $checkoutPaymentId = $checkoutOrderCustomFields->getCheckoutPaymentId();
  74.         // If empty payment detail we skip it
  75.         if (empty($checkoutPaymentId)) {
  76.             return;
  77.         }
  79.         // We get payment detail from checkout.com API
  80.         $payment = $this->checkoutPaymentService->getPaymentDetails($checkoutPaymentId, $order->getSalesChannelId());
  81.         if ($payment->getStatus() !== CheckoutPaymentService::STATUS_AUTHORIZED) {
  82.             return;
  83.         }
  85.         // Get plugin settings
  86.         $settings = $this->settingsFactory->getSettings($order->getSalesChannelId());
  88.         // Capture the payment from Checkout.com
  89.         $actionId = $paymentHandler->capturePayment($payment->getId(), $order);
  90.         $checkoutOrderCustomFields->setLastCheckoutActionId($actionId);
  92.         $this->orderService->updateCheckoutCustomFields($order, $checkoutOrderCustomFields, $event->getContext());
  94.         $this->orderTransactionService->processTransition($orderTransaction, CheckoutPaymentService::STATUS_CAPTURED, $event->getContext());
  95.         $this->orderService->processTransition($order, $settings, CheckoutPaymentService::STATUS_CAPTURED, $event->getContext());
  96.     }
  98.     private function getOrderTransaction(OrderEntity $order): ?OrderTransactionEntity
  99.     {
  100.         $orderTransactions = $order->getTransactions();
  101.         if (!$orderTransactions instanceof OrderTransactionCollection) {
  102.             return null;
  103.         }
  105.         $orderTransactions->sort(function (OrderTransactionEntity $a, OrderTransactionEntity $b): int {
  106.             return $a->getCreatedAt() <=> $b->getCreatedAt();
  107.         });
  109.         return $orderTransactions->last();
  110.     }
  111. }