custom/plugins/MolliePayments/src/Subscriber/PaymentMethodSubscriber.php line 72

Open in your IDE?
  1. <?php
  3. namespace Kiener\MolliePayments\Subscriber;
  5. use Mollie\Api\Exceptions\ApiException;
  6. use Mollie\Api\MollieApiClient;
  7. use Mollie\Api\Resources\Profile;
  8. use Shopware\Core\Checkout\Payment\PaymentEvents;
  9. use Shopware\Core\Checkout\Payment\PaymentMethodEntity;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class PaymentMethodSubscriber implements EventSubscriberInterface
  19. {
  20.     /** @var MollieApiClient $apiClient */
  21.     private $apiClient;
  23.     /** @var EntityRepositoryInterface $paymentRepository */
  24.     private $paymentRepository;
  26.     /**
  27.      * Returns an array of event names this subscriber wants to listen to.
  28.      *
  29.      * The array keys are event names and the value can be:
  30.      *
  31.      * * The method name to call (priority defaults to 0)
  32.      * * An array composed of the method name to call and the priority
  33.      * * An array of arrays composed of the method names to call and respective
  34.      *   priorities, or 0 if unset
  35.      *
  36.      * For instance:
  37.      *
  38.      * * array('eventName' => 'methodName')
  39.      * * array('eventName' => array('methodName', $priority))
  40.      * * array('eventName' => array(array('methodName1', $priority), array('methodName2'))
  41.      *
  42.      * @return array The event names to listen to
  43.      */
  44.     public static function getSubscribedEvents()
  45.     {
  46.         return [
  47.             PaymentEvents::PAYMENT_METHOD_WRITTEN_EVENT => 'onPaymentMethodChanged'
  48.         ];
  49.     }
  51.     /**
  52.      * Creates a new instance of PaymentMethodSubscriber.
  53.      *
  54.      * @param MollieApiClient $apiClient
  55.      * @param EntityRepositoryInterface $paymentRepository
  56.      */
  57.     public function __construct(
  58.         MollieApiClient $apiClient,
  59.         EntityRepositoryInterface $paymentRepository
  60.     )
  61.     {
  62.         $this->apiClient = $apiClient;
  63.         $this->paymentRepository = $paymentRepository;
  64.     }
  66.     /**
  67.      * Activates a payment method at Mollie.
  68.      *
  69.      * @param EntityWrittenEvent $args
  70.      * @throws ApiException
  71.      */
  72.     public function onPaymentMethodChanged(EntityWrittenEvent $args)
  73.     {
  74.         foreach ($args->getPayloads() as $payload) {
  75.             $id = null;
  76.             $active = null;
  78.             // Get the payment method ID
  79.             if (isset($payload['id'])) {
  80.                 $id = $payload['id'];
  81.             }
  83.             // Get whether the payment method is active
  84.             if (isset($payload['active'])) {
  85.                 $active = $payload['active'];
  86.             }
  88.             // Activate payment method at Mollie
  89.             if ($id !== null && (bool) $active === true) {
  90.                 $paymentMethod = null;
  92.                 try {
  93.                     /** @var PaymentMethodEntity $paymentMethod */
  94.                     $paymentMethod = $this->getPaymentMethodById($id);
  95.                 } catch (InconsistentCriteriaIdsException $e) {
  96.                     //
  97.                 }
  99.                 if ($paymentMethod !== null &&
  100.                     strpos($paymentMethod->getHandlerIdentifier(), 'MolliePayments') !== false) {
  101.                     // Get custom fields of payment method
  102.                     $customFields = $paymentMethod->getCustomFields();
  104.                     // Check if Mollie's payment method name is set
  105.                     if (!isset($customFields['mollie_payment_method_name'])) {
  106.                         continue;
  107.                     }
  109.                     $profile = null;
  111.                     try {
  112.                         /** @var Profile $profile */
  113.                         $profile = $this->apiClient->profiles->get('me');
  114.                     } catch (ApiException $e) {
  115.                         //
  116.                     }
  118.                     if ($profile !== null) {
  119.                         $profile->enableMethod($customFields['mollie_payment_method_name']);
  120.                     }
  121.                 }
  122.             }
  123.         }
  124.     }
  126.     /**
  127.      * Get payment method by ID.
  128.      *
  129.      * @param $id
  130.      * @return PaymentMethodEntity
  131.      * @throws InconsistentCriteriaIdsException
  132.      */
  133.     private function getPaymentMethodById($id) : ?PaymentMethodEntity
  134.     {
  135.         // Fetch ID for update
  136.         $paymentCriteria = new Criteria();
  137.         $paymentCriteria->addFilter(new EqualsFilter('id', $id));
  139.         // Get payment methods
  140.         $paymentMethods = $this->paymentRepository->search($paymentCriteria, Context::createDefaultContext());
  142.         if ($paymentMethods->getTotal() === 0) {
  143.             return null;
  144.         }
  146.         return $paymentMethods->first();
  147.     }
  148. }