custom/static-plugins/GlobusSW6/src/Subscriber/StoreLocator/CurrentStoreStockSubscriber.php line 47

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber\StoreLocator;
  5. use GlobusSW6\Service\App\AppFromRequestIdentifier;
  6. use GlobusSW6\Service\App\AppIdentifier;
  7. use GlobusSW6\Service\App\AppService;
  8. use Shopware\Core\Content\Product\ProductEntity;
  9. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  12. use Shopware\Core\Content\Product\ProductCollection;
  13. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  14. use GlobusSW6\Service\IaneoBusinessExtension;
  16. class CurrentStoreStockSubscriber implements EventSubscriberInterface
  17. {
  19.     /** @var SessionInterface */
  20.     private $session;
  22.     /** @var IaneoBusinessExtension */
  23.     private $ianeoBusinessExtensionService;
  25.     /** @var AppService */
  26.     private $appService;
  28.     /**
  29.      * @param SessionInterface $session
  30.      * @param IaneoBusinessExtension $ianeoBusinessExtensionService
  31.      * @param AppService $appService
  32.      */
  33.     public function __construct(SessionInterface $session, IaneoBusinessExtension $ianeoBusinessExtensionService, AppService $appService)
  34.     {
  35.         $this->session = $session;
  36.         $this->ianeoBusinessExtensionService = $ianeoBusinessExtensionService;
  37.         $this->appService = $appService;
  38.     }
  40.     public static function getSubscribedEvents()
  41.     {
  42.         return [
  43.             'product.search.result.loaded' => 'appendCurrentStoreStock'
  44.         ];
  45.     }
  47.     public function appendCurrentStoreStock(EntitySearchResultLoadedEvent $event)
  48.     {
  49.         // do not fire event in backend context
  50.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  51.             if ($event->getContext()->getSource()->isAdmin()) {
  52.                 return;
  53.             }
  54.         }
  56.         // get products
  57.         /** @var ProductCollection $products */
  58.         $products = $event->getResult()->getEntities();
  60.         if ($products === null) {
  61.             return;
  62.         }
  64.         // get current store
  65.         $currentStore = $this->session->get('ianeoCurrentStore');
  67.         $currentStores = $this->createFakeArray($products->getIds(), $currentStore);
  69.         // Take max quantity in store from checkoutInfos, as it's already calculated there
  70.         // TODO-NGS: having the $maxQuantityInStore information in two places is redundant
  71.         $stocks = [];
  72.         /** @var ProductEntity $product */
  73.         foreach ($products as $product){
  74.             if(array_key_exists('ianeoExtensions', $product->getExtensions())){
  75.                 if($product->getExtensions()['ianeoExtensions']->has('checkoutInfos')){
  76.                     $maxQuantityInStore = $product->getExtensions()['ianeoExtensions']['checkoutInfos']->getMaxQuantityInStore();
  77.                     $stocks[$product->getId()] = (is_null($maxQuantityInStore)) ? null : $maxQuantityInStore ;
  78.                 }
  79.             }
  80.         }
  82.         // insert stock in ianeoExtension
  83.         $this->ianeoBusinessExtensionService->addAttributes($products, $currentStores, 'currentStore');
  85.         $this->ianeoBusinessExtensionService->addAttributes($products, $stocks, 'storeStock');
  87.     }
  89.     // TODO-NGS: Just for testing, remove this later on
  90.     private function createFakeArray(array $ids, $value)
  91.     {
  92.         $arr = [];
  93.         foreach ($ids as $id) {
  94.             $arr[$id] = $value;
  95.         }
  96.         return $arr;
  97.     }
  98. }