custom/plugins/KlarnaPayment/src/Components/EventListener/ConfigWrittenSubscriber.php line 52

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace KlarnaPayment\Components\EventListener;
  7. use KlarnaPayment\Installer\Modules\PaymentMethodInstaller;
  8. use Shopware\Core\Defaults;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\System\SystemConfig\SystemConfigDefinition;
  13. use Shopware\Core\System\SystemConfig\SystemConfigService;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class ConfigWrittenSubscriber implements EventSubscriberInterface
  17. {
  18.     private const SETTING_ALLOWED_KLARNA_PAYMENTS_CODES = 'KlarnaPayment.settings.allowedKlarnaPaymentsCodes';
  20.     // TODO: Adjust this if compatibility is at least > 6.4.0.0
  21.     /** @var EntityRepository|\Shopware\Core\Checkout\Payment\DataAbstractionLayer\PaymentMethodRepositoryDecorator */
  22.     private $paymentMethodRepository;
  24.     /** @var EntityRepository */
  25.     private $salesChannelRepository;
  27.     /** @var SystemConfigService */
  28.     private $systemConfigService;
  30.     // TODO: Adjust this if compatibility is at least > 6.4.0.0
  32.     /**
  33.      * @param EntityRepository|\Shopware\Core\Checkout\Payment\DataAbstractionLayer\PaymentMethodRepositoryDecorator $paymentMethodRepository
  34.      */
  35.     public function __construct(
  36.         $paymentMethodRepository,
  37.         EntityRepository $salesChannelRepository,
  38.         SystemConfigService $systemConfigService
  39.     ) {
  40.         $this->paymentMethodRepository = $paymentMethodRepository;
  41.         $this->salesChannelRepository  = $salesChannelRepository;
  42.         $this->systemConfigService     = $systemConfigService;
  43.     }
  45.     public static function getSubscribedEvents(): array
  46.     {
  47.         return [
  48.             EntityWrittenContainerEvent::class => 'onEntityWrittenContainerEvent',
  49.         ];
  50.     }
  52.     public function onEntityWrittenContainerEvent(EntityWrittenContainerEvent $containerEvent): void
  53.     {
  54.         $event = $containerEvent->getEventByEntityName(SystemConfigDefinition::ENTITY_NAME);
  56.         if ($event === null || $event->hasErrors() === true
  57.             || $event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  58.             return;
  59.         }
  61.         $context = $event->getContext();
  63.         $writeResults = $event->getWriteResults();
  64.         /** @var \Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult $writeResult */
  65.         $writeResult = end($writeResults);
  67.         $payload                     = $writeResult->getPayload();
  68.         $configurationKey            = $payload['configurationKey'];
  69.         $configurationValue          = $payload['configurationValue'];
  70. if (isset($payload['salesChannelId'])){        
  71. $configurationSalesChannelId = $payload['salesChannelId'];
  72. }
  73.         if ($configurationKey !== self::SETTING_ALLOWED_KLARNA_PAYMENTS_CODES) {
  74.             return;
  75.         }
  77.         $activeMethodCodes = $configurationValue;
  79.         if ($configurationSalesChannelId !== null) {
  80.             array_push($activeMethodCodes, ...$this->getActiveMethodCodes());
  81.         }
  83.         $salesChannelIds = $this->salesChannelRepository->searchIds(new Criteria(), $context);
  85.         foreach ($salesChannelIds->getIds() as $checkSalesChannelId) {
  86.             if (is_string($checkSalesChannelId) && $checkSalesChannelId !== $configurationSalesChannelId) {
  87.                 array_push($activeMethodCodes, ...$this->getActiveMethodCodes($checkSalesChannelId));
  88.             }
  89.         }
  91.         $activeMethodCodes   = array_filter(array_unique($activeMethodCodes));
  92.         $inactiveMethodCodes = array_filter(array_values(array_diff(PaymentMethodInstaller::KLARNA_PAYMENTS_CODES, $activeMethodCodes)));
  93.         $upsertStatement     = [];
  95.         foreach (PaymentMethodInstaller::KLARNA_PAYMENTS_CODES as $paymentMethodId => $code) {
  96.             $upsertStatement[] = [
  97.                 'id'     => $paymentMethodId,
  98.                 'active' => !in_array($code, $inactiveMethodCodes, true),
  99.             ];
  100.         }
  102.         $this->paymentMethodRepository->update($upsertStatement, $context);
  103.     }
  105.     /**
  106.      * @return string[]
  107.      */
  108.     private function getActiveMethodCodes(?string $salesChannelId = null): array
  109.     {
  110.         $activeMethodCodes = [];
  111.         $values            = $this->systemConfigService->get(self::SETTING_ALLOWED_KLARNA_PAYMENTS_CODES, $salesChannelId);
  113.         if (!is_array($values)) {
  114.             return [];
  115.         }
  117.         foreach ($values as $code) {
  118.             if ($code === PaymentMethodInstaller::KLARNA_PAYMENTS_PAY_NOW_CODE) {
  119.                 $activeMethodCodes[] = PaymentMethodInstaller::KLARNA_PAYMENTS_PAY_NOW_CODE;
  121.                 foreach (PaymentMethodInstaller::KLARNA_PAYMENTS_CODES_PAY_NOW_STANDALONE as $standalonePaymentId) {
  122.                     $activeMethodCodes[] = PaymentMethodInstaller::KLARNA_PAYMENTS_CODES[$standalonePaymentId];
  123.                 }
  125.                 continue;
  126.             }
  128.             $activeMethodCodes[] = $code;
  129.         }
  131.         return $activeMethodCodes;
  132.     }
  133. }