custom/plugins/AcrisSuppliesUpsellingCS/src/Storefront/Subscriber/ProductQuantitySubscriber.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\SuppliesUpselling\Storefront\Subscriber;
  5. use Shopware\Core\Content\Product\Aggregate\ProductCrossSelling\ProductCrossSellingEntity;
  6. use Shopware\Core\Content\Product\Events\ProductCrossSellingsLoadedEvent;
  7. use Shopware\Core\Content\Product\SalesChannel\CrossSelling\CrossSellingElement;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\Struct\ArrayEntity;
  10. use Shopware\Core\System\SystemConfig\SystemConfigService;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. class ProductQuantitySubscriber implements EventSubscriberInterface
  16. {
  17.     const DEFAULT_CROSS_SELLING_PRODUCT_LIST_TYPE = 'productList';
  18.     /**
  19.      * @var SystemConfigService
  20.      */
  21.     private $systemConfigService;
  23.     /**
  24.      * @var EntityRepositoryInterface
  25.      */
  26.     private $repository;
  28.     public function __construct(SystemConfigService $systemConfigService, EntityRepositoryInterface $repository)
  29.     {
  30.         $this->systemConfigService = $systemConfigService;
  31.         $this->repository = $repository;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductCrossSellingsLoadedEvent::class => 'onCrossSellingLoaded',
  38.         ];
  39.     }
  41.     public function onCrossSellingLoaded(ProductCrossSellingsLoadedEvent $event)
  42.     {
  43.         $crossSellings = $event->getCrossSellings()->getElements();
  44.         $productStreamArray = [];
  45.         $customQuantityArray = [];
  46.         $assignedProducts = [];
  48.         if ($crossSellings) {
  49.             /** @var CrossSellingElement $crossSelling */
  50.             foreach ($crossSellings as $crossSelling) {
  51.                 if ($crossSelling->getCrossSelling()->getType() === self::DEFAULT_CROSS_SELLING_PRODUCT_LIST_TYPE) {
  52.                     if (!empty($crossSelling->getCrossSelling()) && !empty($crossSelling->getCrossSelling()->getAssignedProducts()) && $crossSelling->getCrossSelling()->getAssignedProducts()->count() > 0) {
  53.                         foreach ($crossSelling->getCrossSelling()->getAssignedProducts()->getElements() as $assignedProduct) {
  54.                             if (!empty($assignedProduct) && !empty($assignedProduct->getExtensions()) && $assignedProduct->hasExtension('acrisProductCrossSellingAssignedProduct') && !empty($assignedProduct->getExtension('acrisProductCrossSellingAssignedProduct')) && !empty($assignedProduct->getExtension('acrisProductCrossSellingAssignedProduct')->getQuantity())) {
  55.                                 $customQuantityArray[$assignedProduct->getProductId()] = $assignedProduct->getExtension('acrisProductCrossSellingAssignedProduct')->getQuantity();
  56.                             } else {
  57.                                 $customQuantityArray[$assignedProduct->getProductId()] = 1;
  58.                             }
  59.                         }
  60.                     }
  61.                 } else {
  62.                     $productStreamId = $crossSelling->getCrossSelling()->getProductStreamId();
  63.                     if ($productStreamId) {
  64.                         $productStreamFilterRepository = $this->repository->search((new Criteria())->addFilter(new EqualsFilter('productStreamId', $productStreamId))->addFilter(new EqualsFilter('field', 'productNumber'))->addFilter(new EqualsFilter('type', 'equals')), $event->getContext());
  65.                         if ($productStreamFilterRepository){
  66.                             foreach($productStreamFilterRepository as $productStream){
  67.                                 if($productStream){
  68.                                     $productStreamArray[] = $productStream;
  69.                                 }
  70.                             }
  71.                         }
  72.                     }
  73.                 }
  75.             }
  76.         }
  78.         if($productStreamArray){
  79.             foreach ($productStreamArray as $product) {
  80.                 if (!empty($product->getCustomFields())) {
  81.                     if ($product->getCustomFields()["acris_accessory_quantity"] != 0) {
  82.                         $customQuantityArray[$product->getValue()] = $product->getCustomFields()["acris_accessory_quantity"];
  83.                     } else {
  84.                         $customQuantityArray[$product->getValue()] = 1;
  85.                     }
  86.                 } else {
  87.                     $customQuantityArray[$product->getValue()] = 1;
  88.                 }
  89.             }
  90.         }
  92.         if (!empty($customQuantityArray)) {
  93.             $event->getCrossSellings()->addExtension('acris_accessory_quantity', new ArrayEntity([
  94.                 $customQuantityArray
  95.             ]));
  96.         }
  97.     }
  98. }