src/Core/Content/Sitemap/ScheduledTask/SitemapGenerateTaskHandler.php line 78

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Sitemap\ScheduledTask;
  5. use Shopware\Core\Content\Sitemap\Event\SitemapSalesChannelCriteriaEvent;
  6. use Shopware\Core\Content\Sitemap\Service\SitemapExporterInterface;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  13. use Shopware\Core\Framework\Log\Package;
  14. use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskHandler;
  15. use Shopware\Core\System\SalesChannel\Aggregate\SalesChannelDomain\SalesChannelDomainEntity;
  16. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  17. use Shopware\Core\System\SystemConfig\SystemConfigService;
  18. use Symfony\Component\Messenger\Attribute\AsMessageHandler;
  19. use Symfony\Component\Messenger\MessageBusInterface;
  20. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  22. /**
  23.  * @internal
  24.  */
  25. #[AsMessageHandler(handles: SitemapGenerateTask::class)]
  26. #[Package('sales-channel')]
  27. final class SitemapGenerateTaskHandler extends ScheduledTaskHandler
  28. {
  29.     /**
  30.      * @internal
  31.      */
  32.     public function __construct(
  33.         EntityRepository $scheduledTaskRepository,
  34.         private readonly EntityRepository $salesChannelRepository,
  35.         private readonly SystemConfigService $systemConfigService,
  36.         private readonly MessageBusInterface $messageBus,
  37.         private readonly EventDispatcherInterface $eventDispatcher
  38.     ) {
  39.         parent::__construct($scheduledTaskRepository);
  40.     }
  42.     public function run(): void
  43.     {
  44.         $sitemapRefreshStrategy = $this->systemConfigService->getInt('core.sitemap.sitemapRefreshStrategy');
  45.         if ($sitemapRefreshStrategy !== SitemapExporterInterface::STRATEGY_SCHEDULED_TASK) {
  46.             return;
  47.         }
  49.         $criteria = new Criteria();
  50.         $criteria->addAssociation('domains');
  51.         $criteria->addFilter(new NotFilter(
  52.             NotFilter::CONNECTION_AND,
  53.             [new EqualsFilter('domains.id', null)]
  54.         ));
  56.         $criteria->addAssociation('type');
  57.         $criteria->addFilter(new EqualsFilter('type.id', Defaults::SALES_CHANNEL_TYPE_STOREFRONT));
  59.         $context = Context::createDefaultContext();
  61.         $this->eventDispatcher->dispatch(
  62.             new SitemapSalesChannelCriteriaEvent($criteria, $context)
  63.         );
  65.         $salesChannels = $this->salesChannelRepository->search($criteria, $context)->getEntities();
  67.         /** @var SalesChannelEntity $salesChannel */
  68.         foreach ($salesChannels as $salesChannel) {
  69.             if ($salesChannel->getDomains() === null) {
  70.                 continue;
  71.             }
  73.             $languageIds = $salesChannel->getDomains()->map(fn (SalesChannelDomainEntity $salesChannelDomain) => $salesChannelDomain->getLanguageId());
  75.             $languageIds = array_unique($languageIds);
  77.             foreach ($languageIds as $languageId) {
  78.                 $this->messageBus->dispatch(new SitemapMessage($salesChannel->getId(), $languageId, null, null, false));
  79.             }
  80.         }
  81.     }
  82. }