src/Core/Content/Sitemap/ScheduledTask/SitemapMessageHandler.php line 39

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Sitemap\ScheduledTask;
  5. use Psr\Log\LoggerInterface;
  6. use Shopware\Core\Content\Sitemap\Exception\AlreadyLockedException;
  7. use Shopware\Core\Content\Sitemap\Service\SitemapExporterInterface;
  8. use Shopware\Core\Framework\Log\Package;
  9. use Shopware\Core\System\SalesChannel\Context\AbstractSalesChannelContextFactory;
  10. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  11. use Shopware\Core\System\SystemConfig\SystemConfigService;
  12. use Symfony\Component\Messenger\Attribute\AsMessageHandler;
  14. /**
  15.  * @internal
  16.  */
  17. #[AsMessageHandler]
  18. #[Package('sales-channel')]
  19. final class SitemapMessageHandler
  20. {
  21.     /**
  22.      * @internal
  23.      */
  24.     public function __construct(
  25.         private readonly AbstractSalesChannelContextFactory $salesChannelContextFactory,
  26.         private readonly SitemapExporterInterface $sitemapExporter,
  27.         private readonly LoggerInterface $logger,
  28.         private readonly SystemConfigService $systemConfigService,
  29.     ) {
  30.     }
  32.     public function __invoke(SitemapMessage $message): void
  33.     {
  34.         $sitemapRefreshStrategy = $this->systemConfigService->getInt('core.sitemap.sitemapRefreshStrategy');
  35.         if ($sitemapRefreshStrategy !== SitemapExporterInterface::STRATEGY_SCHEDULED_TASK) {
  36.             return;
  37.         }
  39.         $this->generate($message);
  40.     }
  42.     private function generate(SitemapMessage $message): void
  43.     {
  44.         if ($message->getLastSalesChannelId() === null || $message->getLastLanguageId() === null) {
  45.             return;
  46.         }
  48.         $context = $this->salesChannelContextFactory->create('', $message->getLastSalesChannelId(), [SalesChannelContextService::LANGUAGE_ID => $message->getLastLanguageId()]);
  50.         try {
  51.             $this->sitemapExporter->generate($context, true, $message->getLastProvider(), $message->getNextOffset());
  52.         } catch (AlreadyLockedException $exception) {
  53.             $this->logger->error(sprintf('ERROR: %s', $exception->getMessage()));
  54.         }
  55.     }
  56. }