custom/plugins/NetiNextEasyCouponDesigns/src/Subscriber/CacheInvalidationSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace NetInventors\NetiNextEasyCouponDesigns\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_ec_design.written' => 'onInvalidateProductCache',
  36.         ];
  37.     }
  39.     public function onInvalidateProductCache(EntityWrittenEvent $event): void
  40.     {
  41.         $sql = '
  42.             SELECT LOWER(HEX(ecp.product_id))
  43.             FROM neti_ec_design ecd
  44.             LEFT JOIN neti_ec_design_product   ecdp ON ecdp.design_id = ecd.id
  45.             LEFT JOIN neti_easy_coupon_product ecp  ON ecp.id         = ecdp.product_id
  46.             WHERE ecd.id IN (?)
  47.               AND ecp.product_id IS NOT NULL
  48.         ';
  50.         /** @var string[] $productIds */
  51.         $productIds = $this->connection->fetchFirstColumn(
  52.             $sql,
  53.             [
  54.                 Uuid::fromHexToBytesList($event->getIds()),
  55.             ],
  56.             [
  57.                 Connection::PARAM_STR_ARRAY,
  58.             ]
  59.         );
  61.         if ($productIds !== []) {
  62.             $this->cacheInvalidator->invalidate([
  63.                 'product-suggest-route',
  64.                 'product-search-route',
  65.             ], true);
  67.             /**
  68.              * @psalm-suppress MixedArgumentTypeCoercion The first parameter is of type string[]
  69.              */
  70.             $this->cacheInvalidator->invalidate(
  71.                 array_map(
  72.                     [ CachedProductListingRoute::class, 'buildName' ],
  73.                     $this->getProductCategoryIds($productIds)
  74.                 ),
  75.                 true
  76.             );
  78.             /**
  79.              * @psalm-suppress MixedArgumentTypeCoercion The first parameter is of type string[]
  80.              */
  81.             $this->cacheInvalidator->invalidate(
  82.                 array_map([ EntityCacheKeyGenerator::class, 'buildProductTag' ], $productIds),
  83.                 true
  84.             );
  86.             /**
  87.              * @psalm-suppress MixedArgumentTypeCoercion The first parameter is of type string[]
  88.              */
  89.             $this->cacheInvalidator->invalidate(
  90.                 array_map([ CachedProductDetailRoute::class, 'buildName' ], $productIds),
  91.                 true
  92.             );
  94.             /**
  95.              * @psalm-suppress MixedArgumentTypeCoercion The first parameter is of type string[]
  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. }