vendor/lnb/shopware6-lnb-subscription/src/Subscriber/Subscription/SubscriptionSubscriber.php line 164

Open in your IDE?
  1. <?php
  3. /**
  4.  * Permission is hereby granted, free of charge, to any person obtaining a
  5.  * copy of this software and associated documentation files (the "Software"),
  6.  * to deal in the Software without restriction, including without limitation
  7.  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
  8.  * and/or sell copies of the Software, and to permit persons to whom the
  9.  * Software is furnished to do so, subject to the following conditions:
  10.  *
  11.  * The above copyright notice and this permission notice shall be included in
  12.  * all copies or substantial portions of the Software.
  13.  *
  14.  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15.  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16.  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  17.  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  18.  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  19.  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  20.  * IN THE SOFTWARE.
  21.  *
  22.  * @package    LnbSubscription
  23.  * @author     Michael Lämmlein <michael.laemmlein@liebscher-bracht.com>
  24.  * @copyright  ©2022 Liebscher & Bracht
  25.  * @license    http://www.opensource.org/licenses/mit-license.php MIT-License
  26.  * @version    1.0.0
  27.  * @since      04.03.22
  28.  */
  30. declare(strict_types=1);
  32. namespace Lnb\Shopware6\LnbSubscription\Subscriber\Subscription;
  34. use Lnb\Shopware6\LnbSubscription\Event\OrderCreatedEvent;
  35. use Lnb\Shopware6\LnbSubscription\Service\SubscriptionRenewService;
  36. use Lnb\Shopware6\LnbSubscription\Struct\LineItemPayloadStruct;
  37. use Psr\Log\LoggerInterface;
  38. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  39. use Shopware\Core\Checkout\Order\OrderEntity;
  40. use Shopware\Core\Checkout\Payment\Exception\InvalidOrderException;
  41. use Shopware\Core\Checkout\Payment\Exception\PaymentProcessException;
  42. use Shopware\Core\Checkout\Payment\Exception\UnknownPaymentMethodException;
  43. use Shopware\Core\Checkout\Payment\PaymentService;
  44. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  45. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  46. use Shopware\Core\Framework\ShopwareException;
  47. use Shopware\Core\Profiling\Profiler;
  48. use Symfony\Component\DependencyInjection\Attribute\Target;
  49. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  50. use Symfony\Component\HttpFoundation\RedirectResponse;
  51. use Symfony\Component\HttpFoundation\Request;
  53. readonly class SubscriptionSubscriber implements EventSubscriberInterface
  54. {
  55.     public function __construct(
  56.         private SubscriptionRenewService $subscriptionRenewService,
  57.         private PaymentService $paymentService,
  58.         #[Target('order.repository')] private EntityRepository $orderRepository,
  59.         #[Target('order_line_item.repository')] private EntityRepository $orderLineItemRepository,
  60.         #[Target('lnb_subscription.logger')] private LoggerInterface $logger
  61.     ) {
  62.     }
  64.     public static function getSubscribedEvents()
  65.     {
  66.         return [
  67.             OrderCreatedEvent::class => [
  68.                 ['onRenew'],
  69.                 ['addSubscriptionOrderIdToOrder'],
  70.                 ['addSubscriptionOrderIdToOrderLineItem'],
  71.                 ['onHandlePayment', -2],
  72.             ]];
  73.     }
  75.     public function onRenew(OrderCreatedEvent $event): void
  76.     {
  77.         $this->subscriptionRenewService->renew($event->getSubscriptionOrderEntity(), $event->getContext());
  79.         $this->logger->info('OrderCreatedEvent renew subscription', [
  80.             'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  81.             'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  82.         ]);
  83.     }
  85.     public function onHandlePayment(OrderCreatedEvent $event): void
  86.     {
  87.         $orderId = $event->getOrderId();
  88.         $data = $event->getData();
  89.         $salesChannelContext = $event->getSalesChannelContext();
  90.         $finishUrl = null;
  91.         $errorUrl = null;
  93.         try {
  94.             $response = Profiler::trace(
  95.                 'lnb-subscription-recurring-handle-payment',
  96.                 function () use ($orderId, $data, $salesChannelContext, $finishUrl, $errorUrl): ?RedirectResponse {
  97.                     return $this->paymentService->handlePaymentByOrder(
  98.                         $orderId,
  99.                         $data,
  100.                         $salesChannelContext,
  101.                         $finishUrl,
  102.                         $errorUrl
  103.                     );
  104.                 }
  105.             );
  106.             $this->logger->info('OrderCreatedEvent::onHandlePayment: handlePaymentByOrder', [
  107.                 'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  108.                 'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  109.                 'payment_response_url' => $response?->getTargetUrl()
  110.             ]);
  111.         } catch (PaymentProcessException | InvalidOrderException | UnknownPaymentMethodException $e) {
  112.             $this->logger->error(
  113.                 'OrderCreatedEvent::onHandlePayment: An error occurred during processing the payment',
  114.                 [
  115.                 'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  116.                 'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  117.                 'exceptionMessage' => $e->getMessage()
  118.                 ]
  119.             );
  120.             // @todo on error change payment method
  121.             throw $e;
  122.         }
  124.         // Try to finalize the payment
  126.         if (!$response) {
  127.             return;
  128.         }
  130.         $request = $this->getRequestForTransaction($response);
  132.         if (!$request->get('_sw_payment_token')) {
  133.             return;
  134.         }
  136.         try {
  137.             $tokenStruct = $this->paymentService->finalizeTransaction(
  138.                 $request->get('_sw_payment_token'),
  139.                 $request,
  140.                 $salesChannelContext
  141.             );
  142.             $exception = $tokenStruct->getException();
  143.             if ($exception instanceof ShopwareException) {
  144.                 throw $exception;
  145.             }
  146.             $this->logger->info('OrderCreatedEvent::onHandlePayment: finalizeTransaction', [
  147.                 'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  148.                 'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  149.                 'tokenStruct' => $tokenStruct
  150.             ]);
  151.         } catch (PaymentProcessException | InvalidOrderException | UnknownPaymentMethodException $e) {
  152.             $this->logger->error(
  153.                 'OrderCreatedEvent::onHandlePayment: An error occurred during finalize the payment',
  154.                 [
  155.                     'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  156.                     'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  157.                     'exceptionMessage' => $e->getMessage()
  158.                 ]
  159.             );
  160.             throw $e;
  161.         }
  162.     }
  164.     public function addSubscriptionOrderIdToOrder(OrderCreatedEvent $event): void
  165.     {
  166.         $criteria = new Criteria([$event->getOrderId()]);
  167.         /** @var OrderEntity $order */
  168.         $order = $this->orderRepository->search($criteria, $event->getContext())->first();
  170.         $customFields = $order->getCustomFields();
  171.         $customFields['LnbSubscription']['lnbSubscriptionOrderId'] = $event->getSubscriptionOrderEntity()->getId();
  173.         $this->orderRepository->upsert([[
  174.             'id' => $order->getId(),
  175.             'customFields' => $customFields,
  176.             'lnbSubscriptions' => [
  177.                 [
  178.                     'id' => $event->getSubscriptionOrderEntity()->getId()
  179.                 ]
  180.             ],
  181.         ]], $event->getContext());
  183.         $this->logger->info('OrderCreatedEvent add subscriptionOrderId to order', [
  184.             'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  185.             'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  186.             'orderId' => $order->getId(),
  187.         ]);
  188.     }
  190.     public function addSubscriptionOrderIdToOrderLineItem(OrderCreatedEvent $event): void
  191.     {
  192.         $subscriptionOrderId = $event->getSubscriptionOrderEntity()->getId();
  194.         $criteria = new Criteria([$event->getOrderId()]);
  195.         $criteria->addAssociation('lineItems');
  197.         /** @var OrderEntity $order */
  198.         $order = $this->orderRepository->search($criteria, $event->getContext())->first();
  200.         $orderLineItems = $order->getLineItems()
  201.             ->filter(function (OrderLineItemEntity $orderLineItem) use ($subscriptionOrderId): bool {
  202.                 if (!isset($orderLineItem->getPayload()['LnbSubscription'])) {
  203.                     return false;
  204.                 }
  205.                 $struct = new LineItemPayloadStruct($orderLineItem->getPayload()['LnbSubscription']);
  206.                 if ($struct->getLnbSubscriptionOrderId() === $subscriptionOrderId) {
  207.                     return true;
  208.                 }
  209.                 return false;
  210.             })
  211.         ;
  213.         if (0 >= $orderLineItems->count()) {
  214.             return;
  215.         }
  217.         $update_data = [];
  218.         /** @var OrderLineItemEntity $orderLineItem */
  219.         foreach ($orderLineItems as $orderLineItem) {
  220.             $customFields = $orderLineItem->getCustomFields();
  221.             $customFields['LnbSubscription']['lnbSubscriptionOrderId'] = $subscriptionOrderId;
  222.             $update_data[] = [
  223.                 'id' => $orderLineItem->getId(),
  224.                 'customFields' => $customFields,
  225.             ];
  226.         }
  228.         $this->orderLineItemRepository->update($update_data, $event->getContext());
  230.         $this->logger->info('OrderCreatedEvent add subscriptionOrderId to orderLineItems', [
  231.             'subscriptionOrderNumber' => $event->getSubscriptionOrderEntity()->getSubscriptionOrderNumber(),
  232.             'subscriptionOrderId' => $event->getSubscriptionOrderEntity()->getId(),
  233.             'update_data' => $update_data,
  234.         ]);
  235.     }
  237.     private function getRequestForTransaction(RedirectResponse $response): Request
  238.     {
  239.         $query = (string) parse_url($response->getTargetUrl(), PHP_URL_QUERY);
  240.         parse_str($query, $result);
  242.         return new Request($result);
  243.     }
  244. }