custom/plugins/WbfkExpertRating/src/Subscriber/ExpertRatingEntitySubscriber.php line 35

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbfk\ExpertRating\Subscriber;
  7. use Shopware\Core\Framework\Adapter\Cache\CacheInvalidator;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Cache\EntityCacheKeyGenerator;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class ExpertRatingEntitySubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(
  18.         private readonly EntityRepository $expertRatingRepository,
  19.         private readonly EntityRepository $expertRatingPropertyRepository,
  20.         private readonly CacheInvalidator $cacheInvalidator
  21.     ) {
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             'wbfk_expert_rating.written' => 'wbfkExpertRatingWritten',
  29.             'wbfk_expert_rating.deleted' => 'wbfkExpertRatingWritten',
  30.             'wbfk_expert_rating_property.written' => 'wbfkExpertRatingPropertyWritten',
  31.             'wbfk_expert_rating_property.deleted' => 'wbfkExpertRatingPropertyWritten',
  32.         ];
  33.     }
  35.     public function wbfkExpertRatingWritten(EntityWrittenEvent $event): void
  36.     {
  37.         $this->clearProductCacheByExpertRatingIds($event->getIds(), $event->getContext());
  38.     }
  40.     public function wbfkExpertRatingPropertyWritten(EntityWrittenEvent $event): void
  41.     {
  42.         $expertRatingPropertySearchResult = $this->expertRatingPropertyRepository->search((new Criteria($event->getIds())), $event->getContext());
  43.         $expertRatingProperty = $expertRatingPropertySearchResult->first();
  45.         $this->clearProductCacheByExpertRatingIds([$expertRatingProperty->getExpertRatingId()], $event->getContext());
  46.     }
  48.     private function clearProductCacheByExpertRatingIds(array $ids, Context $context): void
  49.     {
  50.         $expertRatingSearchResult = $this->expertRatingRepository->search((new Criteria($ids))->addAssociation('expertRatingExtensions'), $context);
  51.         $expertRating = $expertRatingSearchResult->first();
  53.         $productIds = [];
  54.         foreach ($expertRating->getExpertRatingExtensions() as $product) {
  55.             $productIds[] = $product->__get('productId');
  56.         }
  58.         if (!empty($productIds)) {
  59.             $this->cacheInvalidator->invalidate(
  60.                 array_map([EntityCacheKeyGenerator::class, 'buildProductTag'], $productIds)
  61.             );
  62.         }
  63.     }
  64. }