vendor/shopware/core/Checkout/Customer/Subscriber/ProductReviewSubscriber.php line 34

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Shopware\Core\Checkout\Customer\Service\ProductReviewCountService;
  6. use Shopware\Core\Content\Product\Aggregate\ProductReview\ProductReviewDefinition;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\BeforeDeleteEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\Log\Package;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14.  * @internal
  15.  */
  16. #[Package('business-ops')]
  17. class ProductReviewSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @internal
  21.      */
  22.     public function __construct(private readonly ProductReviewCountService $productReviewCountService)
  23.     {
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             'product_review.written' => 'createReview',
  30.             BeforeDeleteEvent::class => 'deleteReview',
  31.         ];
  32.     }
  34.     public function deleteReview(BeforeDeleteEvent $event): void
  35.     {
  36.         $ids = $event->getIds(ProductReviewDefinition::ENTITY_NAME);
  38.         if (empty($ids)) {
  39.             return;
  40.         }
  42.         $this->productReviewCountService->updateReviewCount($ids, true);
  43.     }
  45.     public function createReview(EntityWrittenEvent $reviewEvent): void
  46.     {
  47.         if (
  48.             $reviewEvent->getEntityName() !== ProductReviewDefinition::ENTITY_NAME
  49.             || $reviewEvent->getContext()->getVersionId() !== Defaults::LIVE_VERSION
  50.         ) {
  51.             return;
  52.         }
  54.         $this->productReviewCountService->updateReviewCount($reviewEvent->getIds());
  55.     }
  56. }