custom/plugins/PayonePayment/src/EventListener/StorefrontRenderEventListener.php line 69

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace PayonePayment\EventListener;
  7. use PayonePayment\Installer\PaymentMethodInstaller;
  8. use Psr\Cache\CacheItemPoolInterface;
  9. use Shopware\Core\Checkout\Payment\PaymentMethodDefinition;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\System\SalesChannel\Aggregate\SalesChannelPaymentMethod\SalesChannelPaymentMethodDefinition;
  17. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  18. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  19. use Shopware\Storefront\Event\StorefrontRenderEvent;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. class StorefrontRenderEventListener implements EventSubscriberInterface
  23. {
  24.     private CacheItemPoolInterface $cachePool;
  26.     private SalesChannelRepositoryInterface $paymentMethodRepository;
  28.     private EntityRepositoryInterface $salesChannelRepository;
  30.     public function __construct(
  31.         CacheItemPoolInterface $cachePool,
  32.         SalesChannelRepositoryInterface $repository,
  33.         EntityRepositoryInterface $salesChannelRepository
  34.     ) {
  35.         $this->cachePool = $cachePool;
  36.         $this->paymentMethodRepository = $repository;
  37.         $this->salesChannelRepository = $salesChannelRepository;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             StorefrontRenderEvent::class => 'onRender',
  44.             EntityWrittenContainerEvent::class => 'onEntityWritten',
  45.         ];
  46.     }
  48.     public function onRender(StorefrontRenderEvent $event): void
  49.     {
  50.         $cacheKey = $this->generateCacheKey(
  51.             $event->getSalesChannelContext()->getSalesChannel()->getId()
  52.         );
  54.         $activePaymentMethods = $this->cachePool->getItem($cacheKey);
  56.         if ($activePaymentMethods->get() === null) {
  57.             $activePaymentMethods->set(
  58.                 $this->collectActivePayonePaymentMethods(
  59.                     $event->getSalesChannelContext()
  60.                 )
  61.             );
  63.             $this->cachePool->save($activePaymentMethods);
  64.         }
  66.         $event->setParameter('activePaymentPaymentMethods', $activePaymentMethods->get());
  67.     }
  69.     public function onEntityWritten(EntityWrittenContainerEvent $event): void
  70.     {
  71.         $ids = [];
  73.         $paymentMethodEvents = $event->getEventByEntityName(PaymentMethodDefinition::ENTITY_NAME);
  75.         if ($paymentMethodEvents !== null) {
  76.             $ids = array_merge($ids, $this->collectPrimaryKeys($paymentMethodEvents->getIds()));
  77.         }
  79.         $salesChannelEvents = $event->getEventByEntityName(SalesChannelPaymentMethodDefinition::ENTITY_NAME);
  81.         if ($salesChannelEvents !== null) {
  82.             $ids = array_merge($ids, $this->collectPrimaryKeys($salesChannelEvents->getIds()));
  83.         }
  85.         if (empty($ids)) {
  86.             return;
  87.         }
  89.         $clearCache = false;
  91.         foreach (PaymentMethodInstaller::PAYMENT_METHODS as $paymentMethod) {
  92.             if (\in_array($paymentMethod::UUID, $ids, true)) {
  93.                 $clearCache = true;
  94.             }
  95.         }
  97.         if ($clearCache) {
  98.             $this->clearCache($event->getContext());
  99.         }
  100.     }
  102.     private function collectPrimaryKeys(array $primaryKeys): array
  103.     {
  104.         $ids = [];
  106.         foreach ($primaryKeys as $key) {
  107.             if (\is_array($key)) {
  108.                 $ids = array_merge($ids, array_values($key));
  109.             } else {
  110.                 $ids[] = $key;
  111.             }
  112.         }
  114.         return $ids;
  115.     }
  117.     private function collectActivePayonePaymentMethods(SalesChannelContext $context): array
  118.     {
  119.         $criteria = new Criteria();
  121.         $criteria->addFilter(new ContainsFilter('handlerIdentifier', 'PayonePayment'));
  122.         $criteria->addFilter(new EqualsFilter('active', true));
  124.         return $this->paymentMethodRepository->search($criteria, $context)->getIds();
  125.     }
  127.     private function generateCacheKey(string $salesChannel): string
  128.     {
  129.         return 'payone_payment.menu_state.' . $salesChannel;
  130.     }
  132.     private function clearCache(Context $context): void
  133.     {
  134.         $cacheKeys = [];
  136.         /** @var string[] $salesChannels */
  137.         $salesChannels = $this->salesChannelRepository->searchIds(new Criteria(), $context)->getIds();
  139.         foreach ($salesChannels as $salesChannel) {
  140.             $cacheKeys[] = $this->generateCacheKey($salesChannel);
  141.         }
  143.         if (empty($cacheKeys)) {
  144.             return;
  145.         }
  147.         $this->cachePool->deleteItems($cacheKeys);
  148.     }
  149. }