custom/plugins/DkcPentagastOrderExport/src/Subscriber/OrderPaidSubscriber.php line 32

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DkcPentagastOrderExport\Subscriber;
  5. use DkcPentagastOrderExport\Service\PentagastOrderExportService;
  6. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  11. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class OrderPaidSubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(
  18.         private readonly PentagastOrderExportService $exportService,
  19.         private readonly EntityRepository $orderTransactionRepository,
  20.         private readonly EntityRepository $salesChannelRepository,
  21.         private readonly SystemConfigService $systemConfigService
  22.     ) {
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             StateMachineTransitionEvent::class => 'onStateMachineTransition',
  29.         ];
  30.     }
  32.     public function onStateMachineTransition(StateMachineTransitionEvent $event): void
  33.     {
  34.         if ($event->getStateMachineName() !== OrderTransactionStates::STATE_MACHINE) {
  35.             return;
  36.         }
  38.         if ($event->getToPlace() !== OrderTransactionStates::STATE_PAID) {
  39.             return;
  40.         }
  42.         $transactionId = $event->getEntityId();
  44.         /** @var OrderTransactionEntity|null $transaction */
  45.         $transaction = $this->orderTransactionRepository->search(
  46.             (new Criteria([$transactionId]))
  47.                 ->addAssociation('order')
  48.                 ->addAssociation('order.salesChannel')
  49.                 ->addAssociation('order.lineItems')
  50.                 ->addAssociation('order.deliveries')
  51.                 ->addAssociation('order.deliveries.shippingOrderAddress.country')
  52.                 ->addAssociation('order.transactions.paymentMethod')
  53.                 ->addAssociation('order.billingAddress.country')
  54.                 ->addAssociation('order.orderCustomer'),
  55.             $event->getContext()
  56.         )->first();
  58.         if (!$transaction) {
  59.             return;
  60.         }
  62.         $order = $transaction->getOrder();
  63.         if (!$order) {
  64.             return;
  65.         }
  67.         /** @var SalesChannelEntity|null $salesChannel */
  68.         $salesChannel = $order->getSalesChannel();
  69.         if (!$salesChannel) {
  70.             $salesChannelId = $order->getSalesChannelId();
  71.             $salesChannel = $this->salesChannelRepository->search(
  72.                 new Criteria([$salesChannelId]),
  73.                 $event->getContext()
  74.             )->first();
  75.             if (!$salesChannel) {
  76.                 return;
  77.             }
  78.         }
  80.         $salesChannelId = $salesChannel->getId();
  81.         $triggerState = (string) ($this->systemConfigService->get(
  82.             'DkcPentagastOrderExport.config.triggerState',
  83.             $salesChannelId
  84.         ) ?? 'transaction_paid');
  86.         if ($triggerState !== 'transaction_paid') {
  87.             return;
  88.         }
  90.         $this->exportService->exportOrder($order, $salesChannel);
  91.     }
  92. }