custom/plugins/AcrisProductCustomerGroupCS/src/Core/Content/Product/SalesChannel/SalesChannelProductRepository.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\ProductCustomerGroup\Core\Content\Product\SalesChannel;
  5. use Acris\ProductCustomerGroup\Components\BlockProductService;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\AggregationResult\AggregationResultCollection;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\IdSearchResult;
  15. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepository;
  16. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  17. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  18. use Shopware\Core\System\SystemConfig\SystemConfigService;
  20. class SalesChannelProductRepository extends SalesChannelRepository
  21. {
  22.     private SalesChannelRepositoryInterface $parent;
  24.     private BlockProductService $blockProductService;
  26.     private SystemConfigService $configService;
  28.     public function __construct(
  29.         SalesChannelRepositoryInterface $parent,
  30.         BlockProductService $blockProductService,
  31.         SystemConfigService $configService
  32.     ) {
  33.         $this->parent = $parent;
  34.         $this->blockProductService = $blockProductService;
  35.         $this->configService = $configService;
  36.     }
  38.     /**
  39.      * @throws InconsistentCriteriaIdsException
  40.      */
  41.     public function search(Criteria $criteria, SalesChannelContext $salesChannelContext): EntitySearchResult
  42.     {
  43.         $this->blockProductsForCustomerGroup($criteria, $salesChannelContext);
  45.         return $this->parent->search($criteria, $salesChannelContext);
  46.     }
  48.     public function aggregate(Criteria $criteria, SalesChannelContext $salesChannelContext): AggregationResultCollection
  49.     {
  50.         return $this->parent->aggregate($criteria, $salesChannelContext);
  51.     }
  53.     public function searchIds(Criteria $criteria, SalesChannelContext $salesChannelContext): IdSearchResult
  54.     {
  55.         $this->blockProductsForCustomerGroup($criteria, $salesChannelContext);
  57.         return $this->parent->searchIds($criteria, $salesChannelContext);
  58.     }
  60.     private function blockProductsForCustomerGroup(Criteria $criteria, SalesChannelContext $salesChannelContext): void
  61.     {
  62.         $blockedProductIds = $this->blockProductService->getBlockedProductIdsForCustomerGroupId($salesChannelContext->getCurrentCustomerGroup()->getId(), $salesChannelContext->getContext());
  63.         $filters = [];
  65.         if($this->configService->get('AcrisProductCustomerGroupCS.config.blockProductsIfNoCustomerGroupAssigned', $salesChannelContext->getSalesChannel()->getId()) === BlockProductService::DEFAULT_PLUGIN_CONFIG_BLOCK_PRODUCT_IF_NO_CUSTOMER_GROUPS_ASSIGNED) {
  66.             $criteria->addAssociation('product.acrisBlockCustomerGroup');
  68.             $filters[] = new NotFilter(NotFilter::CONNECTION_AND, [
  69.                 new EqualsFilter('product.acrisBlockCustomerGroup.id', null)
  70.             ]);
  71.         }
  73.         if (!empty($blockedProductIds)) {
  74.             $filters[] = new NotFilter(NotFilter::CONNECTION_AND, [new EqualsAnyFilter('id', $blockedProductIds)]);
  75.         }
  77.         if (!empty($filters)) {
  78.             $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, $filters));
  79.         }
  80.     }
  81. }