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

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.     /** @var CacheItemPoolInterface */
  25.     private $cachePool;
  27.     /** @var SalesChannelRepositoryInterface */
  28.     private $paymentMethodRepository;
  30.     /** @var EntityRepositoryInterface */
  31.     private $salesChannelRepository;
  33.     public function __construct(
  34.         CacheItemPoolInterface $cachePool,
  35.         SalesChannelRepositoryInterface $repository,
  36.         EntityRepositoryInterface $salesChannelRepository
  37.     ) {
  38.         $this->cachePool               = $cachePool;
  39.         $this->paymentMethodRepository = $repository;
  40.         $this->salesChannelRepository  = $salesChannelRepository;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             StorefrontRenderEvent::class       => 'onRender',
  47.             EntityWrittenContainerEvent::class => 'onEntityWritten',
  48.         ];
  49.     }
  51.     public function onRender(StorefrontRenderEvent $event): void
  52.     {
  53.         $cacheKey = $this->generateCacheKey(
  54.             $event->getSalesChannelContext()->getSalesChannel()->getId()
  55.         );
  57.         $activePaymentMethods = $this->cachePool->getItem($cacheKey);
  59.         if ($activePaymentMethods->get() === null) {
  60.             $activePaymentMethods->set(
  61.                 $this->collectActivePayonePaymentMethods(
  62.                     $event->getSalesChannelContext()
  63.                 )
  64.             );
  66.             $this->cachePool->save($activePaymentMethods);
  67.         }
  69.         $event->setParameter('activePaymentPaymentMethods', $activePaymentMethods->get());
  70.     }
  72.     public function onEntityWritten(EntityWrittenContainerEvent $event): void
  73.     {
  74.         $ids = [];
  76.         $paymentMethodEvents = $event->getEventByEntityName(PaymentMethodDefinition::ENTITY_NAME);
  78.         if (null !== $paymentMethodEvents) {
  79.             $ids = array_merge($ids, $this->collectPrimaryKeys($paymentMethodEvents->getIds()));
  80.         }
  82.         $salesChannelEvents = $event->getEventByEntityName(SalesChannelPaymentMethodDefinition::ENTITY_NAME);
  84.         if (null !== $salesChannelEvents) {
  85.             $ids = array_merge($ids, $this->collectPrimaryKeys($salesChannelEvents->getIds()));
  86.         }
  88.         if (empty($ids)) {
  89.             return;
  90.         }
  92.         $clearCache = false;
  94.         foreach (PaymentMethodInstaller::PAYMENT_METHODS as $paymentMethod) {
  95.             if (in_array($paymentMethod::UUID, $ids, true)) {
  96.                 $clearCache = true;
  97.             }
  98.         }
  100.         if ($clearCache) {
  101.             $this->clearCache($event->getContext());
  102.         }
  103.     }
  105.     private function collectPrimaryKeys(array $primaryKeys): array
  106.     {
  107.         $ids = [];
  109.         foreach ($primaryKeys as $key) {
  110.             if (is_array($key)) {
  111.                 $ids = array_merge($ids, array_values($key));
  112.             } else {
  113.                 $ids[] = $key;
  114.             }
  115.         }
  117.         return $ids;
  118.     }
  120.     private function collectActivePayonePaymentMethods(SalesChannelContext $context): array
  121.     {
  122.         $criteria = new Criteria();
  124.         $criteria->addFilter(new ContainsFilter('handlerIdentifier', 'PayonePayment'));
  125.         $criteria->addFilter(new EqualsFilter('active', true));
  127.         return $this->paymentMethodRepository->search($criteria, $context)->getIds();
  128.     }
  130.     private function generateCacheKey(string $salesChannel): string
  131.     {
  132.         return 'payone_payment.menu_state.' . $salesChannel;
  133.     }
  135.     private function clearCache(Context $context): void
  136.     {
  137.         $cacheKeys = [];
  139.         /** @var string[] $salesChannels */
  140.         $salesChannels = $this->salesChannelRepository->searchIds(new Criteria(), $context)->getIds();
  142.         foreach ($salesChannels as $salesChannel) {
  143.             $cacheKeys[] = $this->generateCacheKey($salesChannel);
  144.         }
  146.         if (empty($cacheKeys)) {
  147.             return;
  148.         }
  150.         $this->cachePool->deleteItems($cacheKeys);
  151.     }
  152. }