custom/plugins/PayrexxPaymentGatewaySW6/src/Subscriber/BackendSubscriber.php line 40

  1. <?php declare(strict_types=1);
  3. namespace PayrexxPaymentGateway\Subscriber;
  5. use PayrexxPaymentGateway\Service\PayrexxApiService;
  6. use Shopware\Core\System\StateMachine\Aggregation\StateMachineState\StateMachineStateEntity;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryEntity;
  8. use Shopware\Core\Checkout\Order\OrderEntity;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Checkout\Order\OrderDefinition;
  13. use Shopware\Core\Checkout\Order\OrderEvents;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\DependencyInjection\ContainerInterface;
  18. class BackendSubscriber implements EventSubscriberInterface
  19. {
  20.     private $container;
  22.     /**
  23.      * @var PayrexxApiService
  24.      */
  25.     protected $payrexxApiService;
  27.     public function __construct(ContainerInterface $container,  PayrexxApiService $payrexxApiService)
  28.     {
  29.         $this->container = $container;
  30.         $this->payrexxApiService = $payrexxApiService;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             OrderEvents::ORDER_DELIVERY_WRITTEN_EVENT => 'onUpdateOrder'
  37.         ];
  38.     }
  40.     public function onUpdateOrder(EntityWrittenEvent $event): void
  41.     {
  42.         $context = $event->getContext();
  43.         foreach ($event->getWriteResults() as $writeResult) {
  45.             $payload = $writeResult->getPayload();
  47.             /** @var EntityRepositoryInterface $stateRepository */
  48.             $deliveryRepository = $this->container->get('order_delivery.repository');
  49.             try {
  50.                 $deliveryResult = $deliveryRepository->search(
  51.                     (new Criteria([$payload['id']]))->addAssociation('order', 'stateMachineState'),
  52.                     $context
  53.                 );
  54.             } catch (InconsistentCriteriaIdsException $e) {
  55.             }
  57.             /** @var OrderDeliveryEntity|null $deliveryInfo */
  58.             $deliveryInfo =  $deliveryResult->first();
  59.             if (!($deliveryInfo instanceof OrderDeliveryEntity)) {
  60.                 continue;
  61.             }
  63.             $deliveryState = $deliveryInfo->getStateMachineState();
  65.             if(!$deliveryState || $deliveryState->getTechnicalName() !== 'shipped') {
  66.                 continue;
  67.             }
  69.             /** @var EntityRepositoryInterface $orderRepo */
  70.             $orderRepo = $this->container->get('order.repository');
  71.             /** @var EntitySearchResult $orderR */
  72.             $orderResult = $orderRepo->search(
  73.                 (new Criteria([$deliveryInfo->getOrderId()]))->addAssociation('transactions.paymentMethod', 'transactions.customFields'),
  74.                 $context
  75.             );
  77.             /** @var OrderEntity|null $order */
  78.             $order = $orderResult->first();
  79.             if (!($order instanceof OrderEntity)) {
  80.                 continue;
  81.             }
  82.             $salesChannelId = $order->getSalesChannelId();
  84.             $transaction = $order->getTransactions()->first();
  86.             $transactionCustomFields = $transaction->getCustomFields();
  87.             if (!$transaction || !$transactionCustomFields || !$transactionCustomFields['gateway_id']) {
  88.                 continue;
  89.             }
  91.             if (!$payrexxGateway = $this->payrexxApiService->getPayrexxGateway($transactionCustomFields['gateway_id'], $salesChannelId)) {
  92.                 continue;
  93.             }
  94.             if (!$payrexxTransaction = $this->payrexxApiService->getTransactionByGateway($payrexxGateway, $salesChannelId)) {
  95.                 continue;
  96.             }
  98.             if ($payrexxTransaction->getStatus() == 'uncaptured') {
  99.                 $this->payrexxApiService->captureTransaction($payrexxTransaction->getId(), $salesChannelId);
  100.             }
  101.         }
  102.     }
  103. }