custom/plugins/AcrisProductTabCS/src/Components/ProductTab/ProductTabGateway.php line 37

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\ProductTab\Components\ProductTab;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\OrFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  15. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  17. class ProductTabGateway
  18. {
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     private $productTabRepository;
  24.     /**
  25.      * @var EntityRepositoryInterface
  26.      */
  27.     private $productStreamMappingRepository;
  29.     public function __construct(
  30.         EntityRepositoryInterface $productTabRepository,
  31.         EntityRepositoryInterface $productStreamMappingRepository
  32.     ) {
  33.         $this->productTabRepository = $productTabRepository;
  34.         $this->productStreamMappingRepository = $productStreamMappingRepository;
  35.     }
  37.     public function getProductDetailProductTab(string $productId, array $productStreamIds, SalesChannelContext $context): EntitySearchResult
  38.     {
  40.         $productFilter = [new EqualsFilter('productId', $productId)];
  41.         if(!empty($productStreamIds)){
  42.             $productFilter[] = new MultiFilter(MultiFilter::CONNECTION_AND, [
  43.                 new EqualsAnyFilter('productStreams.id', $productStreamIds),
  44.                 new NotFilter(NotFilter::CONNECTION_AND, [
  45.                     new EqualsFilter('productStreams.id', null)
  46.                 ])
  47.             ]);
  48.         }
  50.         return $this->productTabRepository->search((new Criteria())
  51.             ->addAssociation('productStreams')
  52.             ->addAssociation('rules')
  53.             ->addAssociation('cmsPage')
  54.             ->addSorting(new FieldSorting('priority',FieldSorting::DESCENDING, true))
  55.             ->addFilter(new EqualsFilter('active', true))
  56.             ->addFilter(new OrFilter([new EqualsFilter('rules.id', null), new EqualsAnyFilter('rules.id', $context->getRuleIds())]))
  57.             ->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, $productFilter)),
  59.         $context->getContext());
  60.     }
  62.     public function getProductStreamIds(array $productIds, Context $context): array
  63.     {
  64.         $productStreamIds = [];
  66.         $idSearchResult = $this->productStreamMappingRepository->searchIds((new Criteria())->addFilter(new EqualsAnyFilter('productId', $productIds)), $context);
  68.         if ($idSearchResult->getTotal() > 0) {
  69.             foreach ($idSearchResult->getIds() as $ids) {
  70.                 if (!empty($ids) && is_array($ids) && array_key_exists('productStreamId', $ids) && !empty($ids['productStreamId'])) {
  71.                     $productStreamIds[] = $ids['productStreamId'];
  72.                 }
  73.             }
  74.         }
  76.         return $productStreamIds;
  77.     }
  78. }