custom/plugins/MolliePayments/src/Subscriber/OrderDeliverySubscriber.php line 78

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Kiener\MolliePayments\Subscriber;
  5. use Kiener\MolliePayments\Components\ShipmentManager\ShipmentManager;
  6. use Kiener\MolliePayments\Service\OrderService;
  7. use Kiener\MolliePayments\Service\SettingsService;
  8. use Kiener\MolliePayments\Struct\PaymentMethod\PaymentMethodAttributes;
  9. use Psr\Log\LoggerInterface;
  10. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  11. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  17. use Shopware\Core\System\StateMachine\Aggregation\StateMachineTransition\StateMachineTransitionActions;
  18. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class OrderDeliverySubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var SettingsService
  25.      */
  26.     private $settings;
  28.     /**
  29.      * @var ShipmentManager
  30.      */
  31.     private $mollieShipment;
  33.     /**
  34.      * @var OrderService
  35.      */
  36.     private $orderService;
  38.     /**
  39.      * @var EntityRepository
  40.      */
  41.     private $repoOrderTransactions;
  43.     /**
  44.      * @var LoggerInterface
  45.      */
  46.     private $logger;
  48.     /**
  49.      * @param SettingsService $settings
  50.      * @param ShipmentManager $mollieShipment
  51.      * @param OrderService $orderService
  52.      * @param EntityRepository $repoOrderTransactions
  53.      * @param LoggerInterface $logger
  54.      */
  55.     public function __construct(SettingsService $settings, ShipmentManager $mollieShipment, OrderService $orderService, EntityRepository $repoOrderTransactions, LoggerInterface $logger)
  56.     {
  57.         $this->settings = $settings;
  58.         $this->mollieShipment = $mollieShipment;
  59.         $this->orderService = $orderService;
  60.         $this->repoOrderTransactions = $repoOrderTransactions;
  61.         $this->logger = $logger;
  62.     }
  65.     /**
  66.      * @return array<mixed>
  67.      */
  68.     public static function getSubscribedEvents(): array
  69.     {
  70.         return [
  71.             'state_machine.order_delivery.state_changed' => 'onOrderDeliveryChanged',
  72.         ];
  73.     }
  75.     /**
  76.      * @param StateMachineStateChangeEvent $event
  77.      */
  78.     public function onOrderDeliveryChanged(StateMachineStateChangeEvent $event): void
  79.     {
  80.         if ($event->getTransitionSide() !== StateMachineStateChangeEvent::STATE_MACHINE_TRANSITION_SIDE_ENTER) {
  81.             return;
  82.         }
  84.         $transitionName = $event->getTransition()->getTransitionName();
  86.         if ($transitionName !== StateMachineTransitionActions::ACTION_SHIP) {
  87.             return;
  88.         }
  90.         # get the configuration of the sales channel from the order
  91.         $configSalesChannel = $this->settings->getSettings($event->getSalesChannelId());
  94.         # if we don't even configure automatic shipping
  95.         # then don't even look into our order to find out if we should actually starts
  96.         if (!$configSalesChannel->getAutomaticShipping()) {
  97.             return;
  98.         }
  100.         $orderDeliveryId = $event->getTransition()->getEntityId();
  102.         try {
  103.             $order = $this->orderService->getOrderByDeliveryId($orderDeliveryId, $event->getContext());
  105.             $swTransaction = $this->getLatestOrderTransaction($order->getId(), $event->getContext());
  106.             if (!$swTransaction) {
  107.                 throw new \Exception('Order '.$order->getOrderNumber().' does not have transactions');
  108.             }
  109.             # verify if the customer really paid with Mollie in the end
  110.             $paymentMethod = $swTransaction->getPaymentMethod();
  112.             if (!$paymentMethod instanceof PaymentMethodEntity) {
  113.                 throw new \Exception('Transaction ' . $swTransaction->getId() . ' has no payment method!');
  114.             }
  116.             $paymentMethodAttributes = new PaymentMethodAttributes($paymentMethod);
  118.             if (!$paymentMethodAttributes->isMolliePayment()) {
  119.                 # just skip it if it has been paid
  120.                 # with another payment provider
  121.                 # do NOT throw an error
  122.                 return;
  123.             }
  125.             $this->logger->info('Starting Shipment through Order Delivery Transition for order: ' . $order->getOrderNumber());
  127.             $this->mollieShipment->shipOrderRest($order, null, $event->getContext());
  128.         } catch (\Throwable $ex) {
  129.             $this->logger->error('Failed to transfer delivery state to mollie: '.$ex->getMessage(), ['exception' => $ex]);
  130.             return;
  131.         }
  132.     }
  134.     private function getLatestOrderTransaction(string $orderId, Context $context):?OrderTransactionEntity
  135.     {
  136.         $criteria = new Criteria();
  137.         $criteria->addFilter(new EqualsFilter('order.id', $orderId));
  138.         $criteria->addAssociation('order');
  139.         $criteria->addAssociation('stateMachineState');
  140.         $criteria->addAssociation('paymentMethod');
  141.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  144.         $result = $this->repoOrderTransactions->search($criteria, $context);
  146.         return $result->first();
  147.     }
  148. }