vendor/store.shopware.com/netinexteasycoupon/src/Subscriber/CacheInvalidationSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace NetInventors\NetiNextEasyCoupon\Subscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Shopware\Core\Content\Product\SalesChannel\Detail\CachedProductDetailRoute;
  9. use Shopware\Core\Content\Product\SalesChannel\Listing\CachedProductListingRoute;
  10. use Shopware\Core\Content\Product\SalesChannel\Review\CachedProductReviewRoute;
  11. use Shopware\Core\Defaults;
  12. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Shopware\Core\Framework\Uuid\Uuid;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class CacheInvalidationSubscriber implements EventSubscriberInterface
  19. {
  20.     private Connection       $connection;
  22.     private CacheInvalidator $cacheInvalidator;
  24.     public function __construct(
  25.         Connection       $connection,
  26.         CacheInvalidator $cacheInvalidator
  27.     ) {
  28.         $this->connection       = $connection;
  29.         $this->cacheInvalidator = $cacheInvalidator;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             'neti_easy_coupon_product.written' => 'onInvalidateProductCache',
  36.         ];
  37.     }
  39.     public function onInvalidateProductCache(EntityWrittenEvent $event): void
  40.     {
  41.         $sql = '
  42.             SELECT LOWER(HEX(product_id))
  43.             FROM neti_easy_coupon_product
  44.             WHERE id IN (?) AND product_id IS NOT NULL
  45.         ';
  47.         $productIds = $this->connection->fetchFirstColumn(
  48.             $sql,
  49.             [
  50.                 Uuid::fromHexToBytesList($event->getIds()),
  51.             ],
  52.             [
  53.                 Connection::PARAM_STR_ARRAY,
  54.             ]
  55.         );
  57.         if ($productIds !== []) {
  58.             $this->cacheInvalidator->invalidate([
  59.                 'product-suggest-route',
  60.                 'product-search-route',
  61.             ], true);
  63.             /**
  64.              * @psalm-suppress MixedArgumentTypeCoercion
  65.              * The format is correct
  66.              */
  67.             $this->cacheInvalidator->invalidate(
  68.                 array_map(
  69.                     [ CachedProductListingRoute::class, 'buildName' ],
  70.                     $this->getProductCategoryIds($productIds)
  71.                 ),
  72.                 true
  73.             );
  75.             /**
  76.              * @psalm-suppress ArgumentTypeCoercion
  77.              * The format is correct
  78.              */
  79.             $this->cacheInvalidator->invalidate(
  80.                 array_map([ EntityCacheKeyGenerator::class, 'buildProductTag' ], $productIds),
  81.                 true
  82.             );
  84.             /**
  85.              * @psalm-suppress ArgumentTypeCoercion
  86.              * The format is correct
  87.              */
  88.             $this->cacheInvalidator->invalidate(
  89.                 array_map([ CachedProductDetailRoute::class, 'buildName' ], $productIds),
  90.                 true
  91.             );
  93.             /**
  94.              * @psalm-suppress ArgumentTypeCoercion
  95.              * The format is correct
  96.              */
  97.             $this->cacheInvalidator->invalidate(
  98.                 array_map([ CachedProductReviewRoute::class, 'buildName' ], $productIds),
  99.                 true
  100.             );
  101.         }
  102.     }
  104.     private function getProductCategoryIds(array $ids): array
  105.     {
  106.         return $this->connection->fetchFirstColumn(
  107.             'SELECT DISTINCT LOWER(HEX(category_id)) as category_id
  108.              FROM product_category_tree
  109.              WHERE product_id IN (:ids)
  110.              AND product_version_id = :version
  111.              AND category_version_id = :version',
  112.             [ 'ids' => Uuid::fromHexToBytesList($ids), 'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION) ],
  113.             [ 'ids' => Connection::PARAM_STR_ARRAY ]
  114.         );
  115.     }
  116. }