custom/plugins/XioniXconfig/src/Storefront/Page/Product/Subscriber/ProductPageSubscriber.php line 31

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Xioni\Xconfig\Storefront\Page\Product\Subscriber;
  5. use Shopware\Core\Framework\Struct\ArrayEntity;
  6. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\Context;
  13. class ProductPageSubscriber implements EventSubscriberInterface
  14. {
  15.     /**
  16.      * @var EntityRepositoryInterface
  17.      */
  18.     private $productRepository;
  19.     
  20.     public function __construct(EntityRepositoryInterface $productRepository)
  21.     {
  22.         $this->productRepository = $productRepository;
  23.     }      
  24.     public static function getSubscribedEvents()
  25.     {
  26.         return [
  27.             ProductPageLoadedEvent::class => 'onProductPageLoaded'
  28.         ];
  29.     }
  31.     public function onProductPageLoaded(ProductPageLoadedEvent $event): void
  32.     {
  33.         $page = $event->getPage();
  34.         $product = $page->getProduct();
  35.         $product_number = $product->getProductNumber();
  36.         $x_product = $this->getConfigurationProduct($product_number);
  37.         $x_product = json_decode($x_product, true);
  38.         
  39.         $xconfig = false;
  40.         if($x_product['data']) {
  41.             $x_variants_accessories = $this->getVariantsAccessoriesByProductId($x_product['data']['base']['id']);
  42.             $x_variants_accessories = json_decode($x_variants_accessories, true);
  43.             $xconfig = true;
  44.             $accessory_products = array();
  45.             if (isset($x_product['data']['product_accessories'])) {
  46.                 foreach($x_product['data']['product_accessories'] as $index => $item) {
  47.                     $item = $item['product'];
  48.                     $criteria = new Criteria();
  49.                     // var_dump($item);
  50.                     // $criteria->addPostFilter(new EqualsFilter('productNumber', $item['base']['product_number']));             
  51.                     // $newContext = Context::createDefaultContext();
  52.                     // $accessory_products[] = $this->productRepository->search($criteria, $newContext)->getElements();
  53.                 }            
  54.             }
  56.             if (isset($x_variants_accessories['data'])) {
  57.                 foreach($x_variants_accessories['data'] as $index => $item) {
  58.                     $criteria = new Criteria();
  59.                     // var_dump($item);
  60.                     // $criteria->addPostFilter(new EqualsFilter('productNumber', $item['base']['product_number']))->addAssociation('cover');              
  61.                     // $newContext = Context::createDefaultContext();
  62.                     // $accessory_products[] = $this->productRepository->search($criteria, $newContext)->getElements();
  63.                 }            
  64.             }            
  65.             $accessory_products = array_filter($accessory_products);
  66.             $page->addExtension('xconfig', new ArrayEntity(['product' => $x_product]));        
  67.             $page->addExtension('xconfig_accessories', new ArrayEntity(['accessories' => $accessory_products]));               
  68.         }
  69.         $page->addExtension('is_xconfig', new ArrayEntity(['has_configuration' => $xconfig])); 
  70.     }
  71.     
  72.     public function getConfigurationProduct($product_number)
  73.     {
  74.         $url        = 'http://151.252.50.234:8086/api/cim/products/getbyproductnumber/'.$product_number;
  75.         $product  = file_get_contents($url);
  76.         
  77.         return $product;
  78.     }
  80.     public function getVariantsAccessoriesByProductId($id)
  81.     {
  82.         $url        = 'http://151.252.50.234:8086/api/cim/matrix/getaccessoriesbyproduct/'.$id;
  83.         $variants  = file_get_contents($url);
  84.         
  85.         return $variants;
  86.     }
  87.     
  88.     public function getProduct($id)
  89.     {
  90.         $url        = 'http://151.252.50.234:8086/api/pim/article/get/'.$id;
  91.         $product    = file_get_contents($url);
  93.         return $product;
  94.     }
  95.     
  96. }