custom/plugins/EsmPluginOverride/src/Subscriber/ArticleQuestionSubscriber.php line 56

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace EsmPluginOverride\Subscriber;
  5. use Nimbits\NimbitsArticleQuestionsNext\Setting\Service\SettingService;
  6. use Shopware\Core\Content\Mail\Service\AbstractMailService;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\Struct\StructCollection;
  12. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  13. use Shopware\Storefront\Pagelet\Footer\FooterPageletLoadedEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use function array_key_exists;
  16. use function dd;
  19. class ArticleQuestionSubscriber implements EventSubscriberInterface
  20. {
  22.     /** @var EntityRepositoryInterface $articleQuestionsRepository */
  23.     protected $articleQuestionsRepository;
  24.     private $settingsService;
  25.     private $mailService;
  26.     private $salesChannelRepository;
  27.     private $twig;
  29.     public function __construct(
  30.         SettingService            $settingsService,
  31.         EntityRepositoryInterface $articleQuestionsRepository,
  32.         AbstractMailService       $mailService,
  33.         EntityRepositoryInterface $salesChannelRepository,
  34.         \Twig\Environment         $twig,
  35.         EntityRepositoryInterface $productRepository
  36.     )
  37.     {
  38.         $this->settingsService = $settingsService;
  39.         $this->articleQuestionsRepository = $articleQuestionsRepository;
  40.         $this->mailService = $mailService;
  41.         $this->salesChannelRepository = $salesChannelRepository;
  42.         $this->twig = $twig;
  43.         $this->productRepository = $productRepository;
  45.     }
  47.     public static function getSubscribedEvents(): array
  48.     {
  49.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  50.         return [
  51.             ProductPageLoadedEvent::class => 'onProductPageLoaded',
  52.             FooterPageletLoadedEvent::class => 'onFooterLoaded'
  53.         ];
  54.     }
  56.     public function onFooterLoaded(FooterPageletLoadedEvent $event)
  57.     {
  58.         $event->getPagelet()->addExtension('nimbitsArticleQuestionsSettings',
  59.             $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId())
  60.         );
  62.     }
  64.     public function onProductPageLoaded(ProductPageLoadedEvent $event)
  65.     {
  66.         $settingsarr = $this->settingsService->getSettingsAsArray();
  68.         $this->checkSalesChannel($event);
  70.         $productIds = [$event->getPage()->getProduct()->getId()];
  72.         //if we need to display the questions to all variants of a product
  73.         if ($settingsarr['showQuestionsOnAllVariants']) {
  75.             $parentId = $event->getPage()->getProduct()->getParentId();
  76.             //only if we have a parent
  77.             if(!empty($parentId)){
  78.                 $productIds = [];
  79.                 //find all variants ids
  80.                 $criteria = (new Criteria)
  81.                     ->addFilter(new EqualsFilter('parentId', $parentId));
  83.                 $articleIds = $this->productRepository->searchIds(
  84.                     $criteria,
  85.                     $event->getContext()
  86.                 );
  88.                 foreach($articleIds->getData() AS $dataSet){
  89.                     $productIds[] = $dataSet["id"];
  90.                 }
  91.             }
  92.         }
  94.         $parentProduct = $event->getPage()->getProduct();
  95.         if(array_key_exists('custom_product_model', $parentProduct->getCustomFields()) && $model = $parentProduct->getCustomFields()['custom_product_model']) {
  96.             $criteria = new Criteria();
  97.             $criteria->addFilter(new EqualsFilter('customFields.custom_product_model', $model));
  98.             $products = $this->productRepository->search($criteria, $event->getContext());
  100.             foreach($products->getIds() as $id) {
  101.                 $productIds[] = $id;
  102.             }
  103.         }
  105.         $event->getPage()->getProduct()->addExtension('nimbitsArticleQuestionsSettings', $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId()));
  107.         $criteria = (new Criteria)
  108.             ->addFilter(new EqualsAnyFilter('article_id', $productIds))
  109.             ->addFilter(new EqualsFilter('active', 1));
  112.         if(array_key_exists("onlyShowCurrentLanguage", $settingsarr)){
  113.              if ($settingsarr['onlyShowCurrentLanguage']) {
  114.                  $criteria->addFilter(new EqualsFilter('language_id', $event->getContext()->getLanguageId()));
  115.              }
  116.         }
  120.         $questions = $this->articleQuestionsRepository->search(
  121.             $criteria,
  122.             \Shopware\Core\Framework\Context::createDefaultContext()
  123.         );
  125.         $questions = $questions->getElements();
  128.         $event->getPage()->getProduct()->addExtension('nimbitsArticleQuestions', (new StructCollection())->assign(['questions' => $questions]));
  129.     }
  131.     public function checkSalesChannel(ProductPageLoadedEvent $event)
  132.     {
  134.         $productId = $event->getPage()->getProduct()->getId();
  136.         $criteria = (new Criteria)
  137.             ->addFilter(new EqualsFilter('article_id', $productId))
  138.             ->addFilter(new EqualsFilter('active', 1));
  140.         $settingsarr = $this->settingsService->getSettingsAsArray();
  142.         $allowedStorefronts = [];
  143.         if(array_key_exists("defaultQuestionVisibilities", $settingsarr))
  144.         {
  145.             $allowedStorefronts = $settingsarr['defaultQuestionVisibilities'];
  146.         }
  148.         $currentStorefront = $event->getContext()->getSource()->getSalesChannelId();
  149.         $showInSalesChannel = false;
  151.         foreach ($allowedStorefronts as $allowedStorefront) {
  152.             if ($currentStorefront == $allowedStorefront) {
  153.                 $showInSalesChannel = true;
  154.             }
  155.             $event->getPage()->addExtension('nimbitsArticleQuestions', (new StructCollection())->assign(['showInSalesChannel' => $showInSalesChannel]));
  156.         }
  158.     }
  161. }