vendor/store.shopware.com/wexoquickpay/src/Subscriber/OrderDetailSubscriber.php line 109

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Wexo\Quickpay\Subscriber;
  5. use GuzzleHttp\Exception\GuzzleException;
  6. use Shopware\Core\Checkout\Cart\Order\OrderConvertedEvent;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
  8. use Shopware\Core\Checkout\Order\OrderEntity;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  14. use Shopware\Core\System\SystemConfig\SystemConfigService;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Wexo\Quickpay\Service\SubscriptionQuickpayService;
  17. use Wexo\Quickpay\ServiceInterface\QuickpayInterface;
  19. /**
  20.  * Class OrderDetailSubscriber
  21.  * @package Wexo\Quickpay\Subscriber
  22.  */
  23. class OrderDetailSubscriber implements EventSubscriberInterface
  24. {
  25.     protected EntityRepositoryInterface $orderRepository;
  26.     protected SystemConfigService $systemConfigService;
  27.     protected QuickpayInterface $paymentService;
  28.     protected SubscriptionQuickpayService $subscriptionQuickpayService;
  30.     /**
  31.      * @param EntityRepositoryInterface $orderRepository
  32.      * @param SystemConfigService $systemConfigService
  33.      * @param QuickpayInterface $paymentService
  34.      */
  35.     public function __construct(
  36.         EntityRepositoryInterface $orderRepository,
  37.         SystemConfigService $systemConfigService,
  38.         QuickpayInterface $paymentService,
  39.         SubscriptionQuickpayService $subscriptionQuickpayService
  40.     ) {
  41.         $this->orderRepository = $orderRepository;
  42.         $this->systemConfigService = $systemConfigService;
  43.         $this->paymentService = $paymentService;
  44.         $this->subscriptionQuickpayService = $subscriptionQuickpayService;
  45.     }
  47.     /**
  48.      * @return array|string[]
  49.      */
  50.     public static function getSubscribedEvents(): array
  51.     {
  52.         return [
  53.             StateMachineTransitionEvent::class => 'onStateMachineTransitionEvent',
  54.             OrderConvertedEvent::class => 'orderConvertedEvent'
  55.         ];
  56.     }
  58.     /**
  59.      * @param StateMachineTransitionEvent $event
  60.      * @throws GuzzleException
  61.      */
  62.     public function onStateMachineTransitionEvent(StateMachineTransitionEvent $event)
  63.     {
  64.         $eventName = $event->getToPlace()->getTechnicalName();
  65.         $transactionId = $event->getEntityId();
  67.         $criteria = new Criteria();
  68.         $criteria->addAssociation('transactions.paymentMethod');
  69.         $criteria->addFilter(new EqualsFilter('transactions.id', $transactionId));
  70.         $criteria->addFilter(new ContainsFilter('transactions.paymentMethod.handlerIdentifier', 'Quickpay'));
  72.         /** @var OrderEntity $order */
  73.         $order = $this->orderRepository->search(
  74.             $criteria,
  75.             $event->getContext()
  76.         )->first();
  78.         $capture = $event->getContext()->getExtension('capture');
  80.         if ($order) {
  81.             if ($eventName === OrderTransactionStates::STATE_CANCELLED) {
  82.                 $this->paymentService->cancel($order);
  83.             }
  85.             if ($capture && ! $capture->get('amount')) {
  86.                 return;
  87.             }
  89.             if ($eventName === OrderTransactionStates::STATE_PAID) {
  90.                 $this->paymentService->capture($order->getId());
  91.             }
  93.             if ($eventName === OrderTransactionStates::STATE_PARTIALLY_PAID &&
  94.                 $capture && $capture->get('amount')
  95.             ) {
  96.                 $this->paymentService->capture(
  97.                     $order->getId(),
  98.                     (float) $capture->get('amount')
  99.                 );
  100.             }
  101.         }
  102.     }
  104.     /**
  105.      * @param OrderConvertedEvent $event
  106.      * @return void
  107.      * @throws GuzzleException
  108.      */
  109.     public function orderConvertedEvent(OrderConvertedEvent $event)
  110.     {
  111.         $subscription = $event->getContext()->getExtension('subscriptionOrder');
  112.         if ($subscription) {
  113.             $this->subscriptionQuickpayService->recurring($event->getOrder()->getId());
  114.         }
  115.     }
  116. }