custom/plugins/ChespackTheme/src/Subscriber/ProductSubscriber.php line 33

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ChespackTheme\Subscriber;
  5. use Shopware\Core\Content\Category\CategoryEntity;
  6. use Shopware\Core\Content\Product\ProductEntity;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Shopware\Core\Content\Product\ProductEvents;
  13. class ProductSubscriber implements EventSubscriberInterface
  14. {
  15.     private EntityRepositoryInterface $categoryRepository;
  16.     private EntityRepositoryInterface $mediaRepository;
  18.     public function __construct(
  19.         EntityRepositoryInterface $categoryRepository,
  20.         EntityRepositoryInterface $mediaRepository
  21.     ) {
  22.         $this->categoryRepository = $categoryRepository;
  23.         $this->mediaRepository = $mediaRepository;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductLoaded'
  30.         ];
  31.     }
  33.     public function onProductLoaded(EntityLoadedEvent $event): void
  34.     {
  35.         // loop through all loaded product
  36.         /** @var ProductEntity $productEntity */
  37.         foreach ($event->getEntities() as $productEntity) {
  38.             $customFields = $productEntity->getCustomFields();
  40.             // loop through each product's custom fields
  41.             if($customFields) {
  42.                 foreach ($customFields as $name => $value) {
  43.                     if ($name !== 'related_resource_categories' || empty($value)) {
  44.                         continue;
  45.                     }
  47.                     $context = $event->getContext();
  49.                     $relatedCategories = [];
  51.                     foreach ($value as $key => $categoryID) {
  53.                         // search the entity via the repository here
  54.                         /** @var CategoryEntity $categoryEntity */
  55.                     
  56.                         /*value may come in as a String, Array or an Object type */
  57.                         $categoryid = $categoryID;
  58.                         $objectType = gettype($categoryID);
  59.                         if ($objectType=="array"){
  60.                             $categoryid = $categoryID['id'];
  61.                         } elseif ($objectType == 'object'){
  62.                             $categoryid = $categoryID->getId();
  63.                         }
  64.                     
  65.                         $category = $this->categoryRepository
  66.                             ->search(new Criteria([$categoryid]), $context)->first();
  68.                         if ($category) {
  69.                             //Now get the media associated with the category
  71.                             $media = $this->mediaRepository
  72.                                ->search(new Criteria([$category->getMediaId()]), $context)->first();
  74.                             $category->setMedia($media);
  75.                             $relatedCategories[] = $category;
  76.                         }
  77.                     }
  78.                     $customFields[$name] = $relatedCategories;
  79.                 }
  81.                 $productEntity->setCustomFields($customFields);
  82.             }
  83.         }
  84.     }
  85. }