custom/plugins/MolliePayments/src/Subscriber/CustomerRegistrationSubscriber.php line 76

Open in your IDE?
  1. <?php
  3. namespace Kiener\MolliePayments\Subscriber;
  5. use Kiener\MolliePayments\Service\CustomerService;
  6. use Kiener\MolliePayments\Service\LoggerService;
  7. use Kiener\MolliePayments\Service\SettingsService;
  8. use Mollie\Api\Exceptions\ApiException;
  9. use Mollie\Api\MollieApiClient;
  10. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class CustomerRegistrationSubscriber implements EventSubscriberInterface
  15. {
  17.     /** @var MollieApiClient */
  18.     private $apiClient;
  20.     /** @var CustomerService */
  21.     private $customerService;
  23.     /** @var SettingsService */
  24.     private $settingsService;
  26.     /** @var LoggerService */
  27.     private $loggerService;
  29.     /**
  30.      * Returns an array of event names this subscriber wants to listen to.
  31.      *
  32.      * The array keys are event names and the value can be:
  33.      *
  34.      * * The method name to call (priority defaults to 0)
  35.      * * An array composed of the method name to call and the priority
  36.      * * An array of arrays composed of the method names to call and respective
  37.      *   priorities, or 0 if unset
  38.      *
  39.      * For instance:
  40.      *
  41.      * * array('eventName' => 'methodName')
  42.      * * array('eventName' => array('methodName', $priority))
  43.      * * array('eventName' => array(array('methodName1', $priority), array('methodName2'))
  44.      *
  45.      * @return array The event names to listen to
  46.      */
  47.     public static function getSubscribedEvents()
  48.     {
  49.         return [
  50.             'customer.written' => 'onCustomerRegistration',
  51.         ];
  52.     }
  54.     /**
  55.      * Creates a new instance of PaymentMethodSubscriber.
  56.      *
  57.      * @param MollieApiClient $apiClient
  58.      */
  59.     public function __construct(
  60.         MollieApiClient $apiClient,
  61.         CustomerService $customerService,
  62.         SettingsService $settingsService,
  63.         LoggerService $loggerService
  64.     ) {
  65.         $this->apiClient = $apiClient;
  66.         $this->customerService = $customerService;
  67.         $this->settingsService = $settingsService;
  68.         $this->loggerService = $loggerService;
  69.     }
  71.     /**
  72.      * Refunds the transaction at Mollie if the payment state is refunded.
  73.      *
  74.      * @param CustomerRegisterEvent $customerRegisterEvent
  75.      */
  76.     public function onCustomerRegistration(EntityWrittenEvent $entityWrittenEvent): void
  77.     {
  78.         $context = $entityWrittenEvent->getContext();
  80.         if ($context === null) {
  81.             return;
  82.         }
  84.         $source = $context->getSource();
  86.         if ($source === null | !method_exists($source, 'getSalesChannelId')) {
  87.             return;
  88.         }
  90.         $settings = $this->settingsService->getSettings($source->getSalesChannelId());
  92.         if ($settings->createNoCustomersAtMollie()) {
  93.             return;
  94.         }
  96.         foreach ($entityWrittenEvent->getPayloads() as $payload) {
  97.             if (
  98.                 \array_key_exists('customFields', $payload) &&
  99.                 \array_key_exists(CustomerService::CUSTOM_FIELDS_KEY_MOLLIE_CUSTOMER_ID, $payload['customFields'])
  100.             ) {
  101.                 // Escape if the payload already writes the mollie Id to the custom Fields
  102.                 continue;
  103.             }
  105.             if (!isset($payload['firstName'], $payload['lastName'], $payload['email'], $payload['id'], $payload['guest'])) {
  106.                 // Escape if we do not have the information mollie wants
  107.                 continue;
  108.             }
  110.             $id = $payload['id'];
  111.             $name = \sprintf('%s %s', $payload['firstName'], $payload['lastName']);
  112.             $email = $payload['email'];
  114.             try {
  115.                 $mollieCustomer = $this->apiClient->customers->create(
  116.                     [
  117.                         'name'  => $name,
  118.                         'email' => $email,
  119.                     ]
  120.                 );
  122.                 $this->customerService->saveCustomerCustomFields(
  123.                     $id,
  124.                     ['customer_id' => $mollieCustomer->id],
  125.                     $entityWrittenEvent->getContext()
  126.                 );
  127.             } catch (ApiException $e) {
  128.                 $this->loggerService->addEntry('Customer could not be registered.', $context, $e);
  129.             }
  130.         }
  131.     }
  132. }