vendor/store.shopware.com/h1webblog/src/Provider/BlogProvider.php line 49

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace H1web\Blog\Provider;
  6. use Doctrine\DBAL\Connection;
  7. use H1web\Blog\Blog\BlogCollection;
  8. use H1web\Blog\Blog\BlogEntity;
  9. use H1web\Blog\Blog\SalesChannel\BlogAvailableFilter;
  10. use Shopware\Core\Content\Seo\SeoUrlPlaceholderHandlerInterface;
  11. use Shopware\Core\Content\Sitemap\Provider\AbstractUrlProvider;
  12. use Shopware\Core\Content\Sitemap\Struct\Url;
  13. use Shopware\Core\Content\Sitemap\Struct\UrlResult;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\FetchModeHelper;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  19. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  20. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  21. use Symfony\Component\Routing\RouterInterface;
  23. class BlogProvider extends AbstractUrlProvider
  24. {
  25.     public const CHANGE_FREQ = 'monthly';
  27.     private EntityRepositoryInterface $blogRepository;
  28.     private SeoUrlPlaceholderHandlerInterface $seoUrlPlaceholderHandler;
  29.     private Connection $connection;
  30.     private RouterInterface $router;
  32.     public function __construct(
  33.         EntityRepositoryInterface $blogRepository,
  34.         SeoUrlPlaceholderHandlerInterface $seoUrlPlaceholderHandler,
  35.         RouterInterface $router,
  36.         Connection $connection
  37.     ) {
  38.         $this->blogRepository = $blogRepository;
  39.         $this->seoUrlPlaceholderHandler = $seoUrlPlaceholderHandler;
  40.         $this->router = $router;
  41.         $this->connection = $connection;
  42.     }
  44.     public function getName(): string
  45.     {
  46.         return 'blog';
  47.     }
  49.     public function getUrls(SalesChannelContext $context, int $limit, ?int $offset = null): UrlResult
  50.     {
  51.         $blogs = $this->getBlogposts($context, $limit, $offset);
  53.         if (empty($blogs)) {
  54.             return new UrlResult([], null);
  55.         }
  57.         $seoUrls = $this->getSeoUrls($blogs->getIds(), 'frontend.h1webblog.blog', $context, $this->connection);
  58.         $seoUrls = FetchModeHelper::groupUnique($seoUrls);
  60.         $tagUrls = [];
  61.         $urls = [];
  62.         $url = new Url();
  63.         /** @var BlogEntity $blog */
  64.         foreach ($blogs as $blog) {
  65.             /** @var \DateTimeInterface $lastmod */
  66.             $lastmod = $blog->getUpdatedAt() ?: $blog->getCreatedAt();
  68.             $newUrl = clone $url;
  69.             if (isset($seoUrls[$blog->getId()])) {
  70.                 $newUrl->setLoc($seoUrls[$blog->getId()]['seo_path_info']);
  71.             } else {
  72.                 $newUrl->setLoc($this->router->generate('frontend.h1webblog.blog', ['id' => $blog->getId()], UrlGeneratorInterface::ABSOLUTE_PATH));
  73.             }
  75.             $newUrl->setLastmod($lastmod);
  76.             $newUrl->setChangefreq(self::CHANGE_FREQ);
  77.             $newUrl->setResource(BlogEntity::class);
  78.             $newUrl->setIdentifier($blog->getId());
  79.             $newUrl->setPriority(0.2);
  81.             $urls[] = $newUrl;
  83.             if ($blog->getTags() === null) {
  84.                 continue;
  85.             }
  87.             $tagSeoUrls = $this->getSeoUrls($blog->getTags()->getIds(), 'frontend.h1webblog.tag_overview', $context, $this->connection);
  88.             $tagSeoUrls = FetchModeHelper::groupUnique($tagSeoUrls);
  90.             foreach ($blog->getTags() as $tag) {
  91.                 if (array_key_exists($tag->getId(), $tagUrls)) {
  92.                     continue;
  93.                 }
  95.                 $tagUrl = new Url();
  96.                 $tagUrl->setLoc($tagSeoUrls[$tag->getId()]['seo_path_info']);
  97.                 $tagUrl->setLastmod(new \DateTime());
  98.                 $tagUrl->setChangefreq(self::CHANGE_FREQ);
  99.                 $tagUrl->setResource('tag');
  100.                 $tagUrl->setIdentifier($tag->getId());
  101.                 $tagUrl->setPriority(0.2);
  103.                 $tagUrls[$tag->getId()] = $tagUrl;
  104.             }
  105.         }
  107.         if (\count($urls) < $limit) { // last run
  108.             $nextOffset = null;
  109.         } elseif ($offset === null) { // first run
  110.             $nextOffset = $limit;
  111.         } else { // 1+n run
  112.             $nextOffset = $offset + $limit;
  113.         }
  115.         $urls = array_merge($urls, array_values($tagUrls));
  117.         return new UrlResult($urls, $nextOffset);
  118.     }
  120.     private function getBlogposts(SalesChannelContext $salesChannelContext, int $limit, ?int $offset): BlogCollection
  121.     {
  122.         $blogCriteria = new Criteria();
  123.         $blogCriteria->setLimit($limit);
  124.         $blogCriteria->addFilter(new BlogAvailableFilter($salesChannelContext->getSalesChannelId()))
  125.             ->addFilter(new EqualsFilter('isActive', 1))
  126.             ->addAssociation('visibilities')->addAssociation('tags');
  128.         if ($offset !== null) {
  129.             $blogCriteria->setOffset($offset);
  130.         }
  132.         return $this->blogRepository->search($blogCriteria, $salesChannelContext->getContext())->getEntities();
  133.     }
  135.     public function getDecorated(): AbstractUrlProvider
  136.     {
  137.         throw new DecorationPatternException(self::class);
  138.     }
  139. }