vendor/shopware/core/Checkout/Customer/Subscriber/CustomerGroupSubscriber.php line 68

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Cocur\Slugify\SlugifyInterface;
  6. use Shopware\Core\Checkout\Customer\Aggregate\CustomerGroup\CustomerGroupCollection;
  7. use Shopware\Core\Checkout\Customer\Aggregate\CustomerGroupTranslation\CustomerGroupTranslationCollection;
  8. use Shopware\Core\Content\Seo\SeoUrlPersister;
  9. use Shopware\Core\Defaults;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Shopware\Core\Framework\Log\Package;
  18. use Shopware\Core\System\Language\LanguageCollection;
  19. use Shopware\Core\System\Language\LanguageEntity;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. /**
  23.  * @internal
  24.  */
  25. #[Package('customer-order')]
  26. class CustomerGroupSubscriber implements EventSubscriberInterface
  27. {
  28.     private const ROUTE_NAME = 'frontend.account.customer-group-registration.page';
  30.     /**
  31.      * @internal
  32.      */
  33.     public function __construct(
  34.         private readonly EntityRepository $customerGroupRepository,
  35.         private readonly EntityRepository $seoUrlRepository,
  36.         private readonly EntityRepository $languageRepository,
  37.         private readonly SeoUrlPersister $persister,
  38.         private readonly SlugifyInterface $slugify
  39.     ) {
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             'customer_group_translation.written' => 'updatedCustomerGroup',
  46.             'customer_group_registration_sales_channels.written' => 'newSalesChannelAddedToCustomerGroup',
  47.             'customer_group_translation.deleted' => 'deleteCustomerGroup',
  48.         ];
  49.     }
  51.     public function newSalesChannelAddedToCustomerGroup(EntityWrittenEvent $event): void
  52.     {
  53.         $ids = [];
  55.         foreach ($event->getWriteResults() as $writeResult) {
  56.             /** @var array<string, string> $pk */
  57.             $pk = $writeResult->getPrimaryKey();
  58.             $ids[] = $pk['customerGroupId'];
  59.         }
  61.         if (\count($ids) === 0) {
  62.             return;
  63.         }
  65.         $this->createUrls($ids, $event->getContext());
  66.     }
  68.     public function updatedCustomerGroup(EntityWrittenEvent $event): void
  69.     {
  70.         $ids = [];
  72.         foreach ($event->getWriteResults() as $writeResult) {
  73.             if ($writeResult->hasPayload('registrationTitle')) {
  74.                 /** @var array<string, string> $pk */
  75.                 $pk = $writeResult->getPrimaryKey();
  76.                 $ids[] = $pk['customerGroupId'];
  77.             }
  78.         }
  80.         if (\count($ids) === 0) {
  81.             return;
  82.         }
  84.         $this->createUrls($ids, $event->getContext());
  85.     }
  87.     public function deleteCustomerGroup(EntityDeletedEvent $event): void
  88.     {
  89.         $ids = [];
  91.         foreach ($event->getWriteResults() as $writeResult) {
  92.             /** @var array<string, string> $pk */
  93.             $pk = $writeResult->getPrimaryKey();
  94.             $ids[] = $pk['customerGroupId'];
  95.         }
  97.         if (\count($ids) === 0) {
  98.             return;
  99.         }
  101.         $criteria = new Criteria();
  102.         $criteria->addFilter(new EqualsAnyFilter('foreignKey', $ids));
  103.         $criteria->addFilter(new EqualsFilter('routeName', self::ROUTE_NAME));
  105.         /** @var array<string> $ids */
  106.         $ids = array_values($this->seoUrlRepository->searchIds($criteria, $event->getContext())->getIds());
  108.         if (\count($ids) === 0) {
  109.             return;
  110.         }
  112.         $this->seoUrlRepository->delete(array_map(fn (string $id) => ['id' => $id], $ids), $event->getContext());
  113.     }
  115.     /**
  116.      * @param list<string> $ids
  117.      */
  118.     private function createUrls(array $ids, Context $context): void
  119.     {
  120.         $criteria = new Criteria($ids);
  121.         $criteria->addFilter(new EqualsFilter('registrationActive', true));
  122.         $criteria->addAssociation('registrationSalesChannels.languages');
  123.         $criteria->addAssociation('translations');
  125.         /** @var CustomerGroupCollection $groups */
  126.         $groups = $this->customerGroupRepository->search($criteria, $context)->getEntities();
  127.         $buildUrls = [];
  129.         foreach ($groups as $group) {
  130.             if ($group->getRegistrationSalesChannels() === null) {
  131.                 continue;
  132.             }
  134.             foreach ($group->getRegistrationSalesChannels() as $registrationSalesChannel) {
  135.                 if ($registrationSalesChannel->getLanguages() === null) {
  136.                     continue;
  137.                 }
  139.                 /** @var array<string> $languageIds */
  140.                 $languageIds = $registrationSalesChannel->getLanguages()->getIds();
  141.                 $criteria = new Criteria($languageIds);
  142.                 /** @var LanguageCollection $languageCollection */
  143.                 $languageCollection = $this->languageRepository->search($criteria, $context)->getEntities();
  145.                 foreach ($languageIds as $languageId) {
  146.                     /** @var LanguageEntity $language */
  147.                     $language = $languageCollection->get($languageId);
  148.                     $title = $this->getTranslatedTitle($group->getTranslations(), $language);
  150.                     if (!isset($buildUrls[$languageId])) {
  151.                         $buildUrls[$languageId] = [
  152.                             'urls' => [],
  153.                             'salesChannel' => $registrationSalesChannel,
  154.                         ];
  155.                     }
  157.                     $buildUrls[$languageId]['urls'][] = [
  158.                         'salesChannelId' => $registrationSalesChannel->getId(),
  159.                         'foreignKey' => $group->getId(),
  160.                         'routeName' => self::ROUTE_NAME,
  161.                         'pathInfo' => '/customer-group-registration/' . $group->getId(),
  162.                         'isCanonical' => true,
  163.                         'seoPathInfo' => '/' . $this->slugify->slugify($title),
  164.                     ];
  165.                 }
  166.             }
  167.         }
  169.         foreach ($buildUrls as $languageId => $config) {
  170.             $context = new Context(
  171.                 $context->getSource(),
  172.                 $context->getRuleIds(),
  173.                 $context->getCurrencyId(),
  174.                 [$languageId]
  175.             );
  177.             $this->persister->updateSeoUrls(
  178.                 $context,
  179.                 self::ROUTE_NAME,
  180.                 array_column($config['urls'], 'foreignKey'),
  181.                 $config['urls'],
  182.                 $config['salesChannel']
  183.             );
  184.         }
  185.     }
  187.     private function getTranslatedTitle(?CustomerGroupTranslationCollection $translations, LanguageEntity $language): string
  188.     {
  189.         if ($translations === null) {
  190.             return '';
  191.         }
  193.         // Requested translation
  194.         foreach ($translations as $translation) {
  195.             if ($translation->getLanguageId() === $language->getId() && $translation->getRegistrationTitle() !== null) {
  196.                 return $translation->getRegistrationTitle();
  197.             }
  198.         }
  200.         // Inherited translation
  201.         foreach ($translations as $translation) {
  202.             if ($translation->getLanguageId() === $language->getParentId() && $translation->getRegistrationTitle() !== null) {
  203.                 return $translation->getRegistrationTitle();
  204.             }
  205.         }
  207.         // System Language
  208.         foreach ($translations as $translation) {
  209.             if ($translation->getLanguageId() === Defaults::LANGUAGE_SYSTEM && $translation->getRegistrationTitle() !== null) {
  210.                 return $translation->getRegistrationTitle();
  211.             }
  212.         }
  214.         return '';
  215.     }
  216. }