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

  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(private readonly EntityRepository $customerGroupRepository, private readonly EntityRepository $seoUrlRepository, private readonly EntityRepository $languageRepository, private readonly SeoUrlPersister $persister, private readonly SlugifyInterface $slugify)
  34.     {
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             'customer_group_translation.written' => 'updatedCustomerGroup',
  41.             'customer_group_registration_sales_channels.written' => 'newSalesChannelAddedToCustomerGroup',
  42.             'customer_group_translation.deleted' => 'deleteCustomerGroup',
  43.         ];
  44.     }
  46.     public function newSalesChannelAddedToCustomerGroup(EntityWrittenEvent $event): void
  47.     {
  48.         $ids = [];
  50.         foreach ($event->getWriteResults() as $writeResult) {
  51.             /** @var array<string, string> $pk */
  52.             $pk = $writeResult->getPrimaryKey();
  53.             $ids[] = $pk['customerGroupId'];
  54.         }
  56.         if (\count($ids) === 0) {
  57.             return;
  58.         }
  60.         $this->createUrls($ids, $event->getContext());
  61.     }
  63.     public function updatedCustomerGroup(EntityWrittenEvent $event): void
  64.     {
  65.         $ids = [];
  67.         foreach ($event->getWriteResults() as $writeResult) {
  68.             if ($writeResult->hasPayload('registrationTitle')) {
  69.                 /** @var array<string, string> $pk */
  70.                 $pk = $writeResult->getPrimaryKey();
  71.                 $ids[] = $pk['customerGroupId'];
  72.             }
  73.         }
  75.         if (\count($ids) === 0) {
  76.             return;
  77.         }
  79.         $this->createUrls($ids, $event->getContext());
  80.     }
  82.     public function deleteCustomerGroup(EntityDeletedEvent $event): void
  83.     {
  84.         $ids = [];
  86.         foreach ($event->getWriteResults() as $writeResult) {
  87.             /** @var array<string, string> $pk */
  88.             $pk = $writeResult->getPrimaryKey();
  89.             $ids[] = $pk['customerGroupId'];
  90.         }
  92.         if (\count($ids) === 0) {
  93.             return;
  94.         }
  96.         $criteria = new Criteria();
  97.         $criteria->addFilter(new EqualsAnyFilter('foreignKey', $ids));
  98.         $criteria->addFilter(new EqualsFilter('routeName', self::ROUTE_NAME));
  100.         /** @var array<string> $ids */
  101.         $ids = array_values($this->seoUrlRepository->searchIds($criteria, $event->getContext())->getIds());
  103.         if (\count($ids) === 0) {
  104.             return;
  105.         }
  107.         $this->seoUrlRepository->delete(array_map(fn (string $id) => ['id' => $id], $ids), $event->getContext());
  108.     }
  110.     /**
  111.      * @param list<string> $ids
  112.      */
  113.     private function createUrls(array $ids, Context $context): void
  114.     {
  115.         $criteria = new Criteria($ids);
  116.         $criteria->addFilter(new EqualsFilter('registrationActive', true));
  117.         $criteria->addAssociation('registrationSalesChannels.languages');
  118.         $criteria->addAssociation('translations');
  120.         /** @var CustomerGroupCollection $groups */
  121.         $groups = $this->customerGroupRepository->search($criteria, $context)->getEntities();
  122.         $buildUrls = [];
  124.         foreach ($groups as $group) {
  125.             if ($group->getRegistrationSalesChannels() === null) {
  126.                 continue;
  127.             }
  129.             foreach ($group->getRegistrationSalesChannels() as $registrationSalesChannel) {
  130.                 if ($registrationSalesChannel->getLanguages() === null) {
  131.                     continue;
  132.                 }
  134.                 /** @var array<string> $languageIds */
  135.                 $languageIds = $registrationSalesChannel->getLanguages()->getIds();
  136.                 $criteria = new Criteria($languageIds);
  137.                 /** @var LanguageCollection $languageCollection */
  138.                 $languageCollection = $this->languageRepository->search($criteria, $context)->getEntities();
  140.                 foreach ($languageIds as $languageId) {
  141.                     /** @var LanguageEntity $language */
  142.                     $language = $languageCollection->get($languageId);
  143.                     $title = $this->getTranslatedTitle($group->getTranslations(), $language);
  145.                     if (!isset($buildUrls[$languageId])) {
  146.                         $buildUrls[$languageId] = [
  147.                             'urls' => [],
  148.                             'salesChannel' => $registrationSalesChannel,
  149.                         ];
  150.                     }
  152.                     $buildUrls[$languageId]['urls'][] = [
  153.                         'salesChannelId' => $registrationSalesChannel->getId(),
  154.                         'foreignKey' => $group->getId(),
  155.                         'routeName' => self::ROUTE_NAME,
  156.                         'pathInfo' => '/customer-group-registration/' . $group->getId(),
  157.                         'isCanonical' => true,
  158.                         'seoPathInfo' => '/' . $this->slugify->slugify($title),
  159.                     ];
  160.                 }
  161.             }
  162.         }
  164.         foreach ($buildUrls as $languageId => $config) {
  165.             $context = new Context(
  166.                 $context->getSource(),
  167.                 $context->getRuleIds(),
  168.                 $context->getCurrencyId(),
  169.                 [$languageId]
  170.             );
  172.             $this->persister->updateSeoUrls(
  173.                 $context,
  174.                 self::ROUTE_NAME,
  175.                 array_column($config['urls'], 'foreignKey'),
  176.                 $config['urls'],
  177.                 $config['salesChannel']
  178.             );
  179.         }
  180.     }
  182.     private function getTranslatedTitle(?CustomerGroupTranslationCollection $translations, LanguageEntity $language): string
  183.     {
  184.         if ($translations === null) {
  185.             return '';
  186.         }
  188.         // Requested translation
  189.         foreach ($translations as $translation) {
  190.             if ($translation->getLanguageId() === $language->getId() && $translation->getRegistrationTitle() !== null) {
  191.                 return $translation->getRegistrationTitle();
  192.             }
  193.         }
  195.         // Inherited translation
  196.         foreach ($translations as $translation) {
  197.             if ($translation->getLanguageId() === $language->getParentId() && $translation->getRegistrationTitle() !== null) {
  198.                 return $translation->getRegistrationTitle();
  199.             }
  200.         }
  202.         // System Language
  203.         foreach ($translations as $translation) {
  204.             if ($translation->getLanguageId() === Defaults::LANGUAGE_SYSTEM && $translation->getRegistrationTitle() !== null) {
  205.                 return $translation->getRegistrationTitle();
  206.             }
  207.         }
  209.         return '';
  210.     }
  211. }