vendor/crehler/arrangements/src/Service/ArrangementService.php line 60

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * @copyright 2020 Crehler Sp. z o. o. <https://crehler.com>
  4.  *
  5.  * @author    Jakub Medyński <jme@crehler.com>
  6.  * @support   Crehler <support@crehler.com>
  7.  * @created   10 sie 2020
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  13. namespace Crehler\Arrangements\Service;
  16. use Crehler\Arrangements\Entity\Arrangement\Aggregate\ArrangementMedia\Aggregate\ArrangementMediaDot\ArrangementMediaDotCollection;
  17. use Crehler\Arrangements\Entity\Arrangement\Aggregate\ArrangementMedia\Aggregate\ArrangementMediaDot\ArrangementMediaDotEntity;
  18. use Crehler\Arrangements\Entity\Arrangement\Aggregate\ArrangementMedia\ArrangementMediaEntity;
  19. use Crehler\Arrangements\Entity\Arrangement\Aggregate\ArrangementProduct\ArrangementProductEntity;
  20. use Crehler\Arrangements\Entity\Arrangement\ArrangementEntity;
  21. use Crehler\Tools\Enum\LoaderFlags;
  22. use Crehler\Tools\Product\ProductLoaderInterface;
  23. use Monolog\Logger;
  24. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  25. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  26. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  27. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  28. use Symfony\Component\HttpFoundation\Request;
  30. class ArrangementService
  31. {
  33.     public function __construct(
  34.         private readonly EntityRepository       $arrangementRepository,
  35.         private readonly ProductLoaderInterface $productLoader,
  36.         private readonly Logger $logger
  37.     )
  38.     {
  40.     }
  42.     public function getArrangementById(string $arrangementId, SalesChannelContext $salesChannelContext, Request $request): ?ArrangementEntity
  43.     {
  44.         $criteria = new Criteria([$arrangementId]);
  46.         $criteria->addAssociation('arrangementProducts');
  48.         $criteria->addAssociation('media')
  49.             ->addAssociation('cover.arrangementMediaDots.arrangementProduct')
  50.             ->addAssociation('cover.arrangementMediaDots.arrangementProduct');
  52.         $criteria->getAssociation('media')
  53.             ->addAssociation('arrangementMediaDots.arrangementProduct')
  54.             ->addAssociation('arrangementMediaDots.arrangementProduct')
  55.             ->addSorting(new FieldSorting('position'));
  57.         /** @var ArrangementEntity $arrangement */
  58.         $arrangement = $this->arrangementRepository->search($criteria, $salesChannelContext->getContext())->first();
  60.         $this->filterDotCollection($arrangement->getCover()->getArrangementMediaDots(), $salesChannelContext);
  62.         /** @var ArrangementMediaEntity $media */
  63.         foreach ($arrangement->getMedia() as $media) {
  64.             $this->filterDotCollection($media->getArrangementMediaDots(), $salesChannelContext);
  65.         }
  67.         /** @var ArrangementProductEntity $arrangementProduct */
  68.         foreach ($arrangement->getArrangementProducts() as $arrangementProduct) {
  69.             $salesChannelProduct = $this->productLoader->load(
  70.                 $arrangementProduct->getProductId(),
  71.                 $salesChannelContext,
  72.                 LoaderFlags::SkipPageLoading,
  73.                 LoaderFlags::SkipSeoCategory,
  74.                 LoaderFlags::IgnoreHideCloseoutProductsWhenOutOfStock)
  75.                 ->first();
  76.             if ($salesChannelProduct === null) {
  77.                 $this->logger->warning("Remove " . $arrangementProduct->getProductId() . " from arrangement " . $arrangement->getId());
  78.                 $arrangement->getArrangementProducts()->remove($arrangementProduct->getId());
  79.                 continue;
  80.             }
  81.             $arrangementProduct->setProduct($salesChannelProduct);
  82.         }
  84.         return $arrangement;
  85.     }
  87.     private function filterDotCollection(ArrangementMediaDotCollection $arrangementMediaDotCollection, SalesChannelContext $salesChannelContext): void
  88.     {
  89.         /** @var ArrangementMediaDotEntity $arrangementMediaDot */
  90.         foreach ($arrangementMediaDotCollection as $arrangementMediaDot) {
  91.             $productId = $arrangementMediaDot->getArrangementProduct()->getProductId();
  92.             $salesChannelProduct = $this->productLoader->load(
  93.                 $productId,
  94.                 $salesChannelContext,
  95.                 LoaderFlags::SkipPageLoading,
  96.                 LoaderFlags::SkipSeoCategory,
  97.                 LoaderFlags::IgnoreHideCloseoutProductsWhenOutOfStock)
  98.                 ->first();
  100.             if ($salesChannelProduct === null) {
  101.                 $arrangementMediaDotCollection->remove($arrangementMediaDot->getId());
  102.                 $this->logger->warning("Remove " . $productId . " from arrangement media dot " . $arrangementMediaDot->getId());
  103.                 continue;
  104.             }
  105.             $arrangementMediaDot->getArrangementProduct()->setProduct($salesChannelProduct);
  106.         }
  107.     }
  110. }