custom/static-plugins/GlobusSW6/src/Subscriber/TextilData/ProductTextilDataExtensionSubscriber.php line 52

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber\TextilData;
  5. use GlobusSW6\Service\TextilApi\TextilApiService;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\Content\Product\ProductCollection;
  8. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  9. use Shopware\Core\Framework\Adapter\Translation\Translator;
  10. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use GlobusSW6\Service\IaneoBusinessExtension;
  15. class ProductTextilDataExtensionSubscriber implements EventSubscriberInterface
  16. {
  18.     /** @var LoggerInterface  */
  19.     private $logger;
  21.     /** @var IaneoBusinessExtension */
  22.     private $ianeoBusinessExtension;
  24.     /** @var TextilApiService */
  25.     private $textilApiService;
  27.     /** @var Translator */
  28.     private $translator;
  30.     /**
  31.      * ProductTextilDataExtensionSubscriber constructor.
  32.      * @param LoggerInterface $logger
  33.      * @param IaneoBusinessExtension $ianeoBusinessExtension
  34.      * @param TextilApiService $textilApiService
  35.      * @param Translator $translator
  36.      */
  37.     public function __construct(LoggerInterface $logger, IaneoBusinessExtension $ianeoBusinessExtension, TextilApiService $textilApiService,Translator $translator)
  38.     {
  39.         $this->logger = $logger;
  40.         $this->ianeoBusinessExtension = $ianeoBusinessExtension;
  41.         $this->textilApiService = $textilApiService;
  42.         $this->translator = $translator;
  43.     }
  45.     public static function getSubscribedEvents(): array
  46.     {
  47.         return [
  48.             'product.search.result.loaded' => 'onProductLoaded'
  49.         ];
  50.     }
  52.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  53.     {
  54.         /** @var ProductCollection $products */
  55.         $products = $event->getResult()->getEntities();
  57.         if ($products === null) {
  58.             return;
  59.         }
  61.         if ($event->getContext()->getSource() instanceOf SalesChannelApiSource) {
  63.             try {
  64.                 $salesChannelId = $event->getContext()->getSource()->getSalesChannelId();
  65.                 $languageId = '2fbb5fe2e29a4d70aa5854ce7ce3e20b';
  67.                 $this->translator->injectSettings(
  68.                     $salesChannelId,
  69.                     $languageId,
  70.                     'de-DE',// TODO-NGS: currently hardcoded
  71.                     $event->getContext()
  72.                 );
  73.             } catch (\Throwable $t) {
  74.                 $this->logger->info('Unable to translate snippets for api calls using the following params: saleschannelId: ' . $salesChannelId  . ' ; languageId: ' . $languageId . ' ; context: ' . json_encode($event->getContext())
  75.                 );
  76.             }
  78.             $hinweisAnimalParts = $this->translator->trans("textil.animalParts");
  79.             $containsAnimalParts = false;
  80.             foreach ($products as $product) {
  82.                 /** @var SalesChannelProductEntity $product */
  84.                 try {
  85.                     $textildata = $this->textilApiService->getTextilByProductId($product->getId(), $event->getContext());
  87.                     if ($textildata) {
  88.                         foreach ($textildata->getProductCompositionData() as $component)
  89.                         {
  90.                             if($component['other_animal_parts'] === '1')
  91.                             {
  92.                                 $containsAnimalParts = true;
  93.                             }
  94.                         }
  95.                         if ($containsAnimalParts){
  96.                             $textildata->setHinweisContainsAnimalPartsFlag($containsAnimalParts);
  97.                             $textildata->setHinweisContainsAnimalParts($hinweisAnimalParts);
  98.                         }
  100.                         $this->ianeoBusinessExtension->addSingleAttributeToProduct($product, $textildata, 'textilData');
  101.                     }
  102.                 } catch (\Exception $exception) {
  103.                     $this->logger->error(__CLASS__ . ":" . __FUNCTION__ . ":" . __LINE__ . ":\$exception->getMessage(): " . $exception->getMessage());
  104.                 }
  105.             }
  106.         }
  107.     }
  108. }