custom/plugins/Neon6Configurator/src/Subscribers/CacheInvalidatorSubscriber.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Neon\Configurator\Subscribers;
  5. use Doctrine\DBAL\Connection;
  6. use Neon\Configurator\Core\Content\Configuration\ConfigurationDefinition;
  7. use Shopware\Core\Content\Product\Aggregate\ProductCategory\ProductCategoryDefinition;
  8. use Shopware\Core\Content\Product\SalesChannel\Detail\CachedProductDetailRoute;
  9. use Shopware\Core\Defaults;
  10. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\Uuid\Uuid;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. /**
  18.  * @internal - The functions inside this class are no public-api and can be changed without previous deprecation
  19.  */
  20. class CacheInvalidatorSubscriber implements EventSubscriberInterface
  21. {
  22.     private Connection $connection;
  24.     private CacheInvalidator $cacheInvalidator;
  26.     public function __construct(
  27.         CacheInvalidator $cacheInvalidator,
  28.         Connection       $connection
  29.     )
  30.     {
  31.         $this->cacheInvalidator = $cacheInvalidator;
  32.         $this->connection = $connection;
  33.     }
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             EntityWrittenContainerEvent::class => [
  39.                 ['invalidateProductConfigurationAssignment', 2006]
  40.             ],
  41.         ];
  42.     }
  44.     public function invalidateProductConfigurationAssignment(EntityWrittenContainerEvent $event): void
  45.     {
  47.         //invalidates the product listing route, each time a product - category assignment changed
  48.         $ids = $event->getPrimaryKeys(ConfigurationDefinition::ENTITY_NAME);
  50.         $productIds = [];
  51.         foreach ($ids as $configurationId) {
  52.             $productId = $this->connection->fetchFirstColumn(
  53.                 'SELECT product_id FROM product_translation WHERE JSON_EXTRACT(custom_fields, "$.neon_configurator_products_config") = :configurationId;',
  54.                 ['configurationId' => $configurationId]
  55.             );
  56.             if ($productId != null) {
  57.                 $productIds[] = Uuid::fromBytesToHex($productId[0]);
  58.             }
  59.         }
  61.         if (count($productIds) > 0) {
  62.             $this->cacheInvalidator->invalidate(
  63.                 array_map([CachedProductDetailRoute::class, 'buildName'], array_unique($productIds)),
  64.             );
  65.         }
  66.     }
  67. }