custom/plugins/CioProductDownloadsTab/src/Subscriber/ProductListingSubscriber.php line 35

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace CioProductDownloadsTab\Subscriber;
  5. use CioProductDownloadsTab\Entity\ProductDownloadDefinition;
  6. use Shopware\Core\Content\Media\MediaEntity;
  7. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  8. use Shopware\Core\Content\Product\Events\ProductSearchResultEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\Framework\Struct\ArrayStruct;
  14. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. final class ProductListingSubscriber implements EventSubscriberInterface
  18. {
  19.     private EntityRepository $productDownloadRepository;
  21.     public function __construct(EntityRepository $productDownloadRepository)
  22.     {
  23.         $this->productDownloadRepository = $productDownloadRepository;
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             // CIO-AI-Driven: make downloads available in listing/search templates via product.extensions.productDownloads
  30.             ProductListingResultEvent::class => 'onProductListingResult',
  31.             ProductSearchResultEvent::class => 'onProductListingResult',
  32.         ];
  33.     }
  35.     public function onProductListingResult(ProductListingResultEvent $event): void
  36.     {
  37.         $products = $event->getResult()->getEntities();
  39.         if ($products->count() <= 0) {
  40.             return;
  41.         }
  43.         $productIds = [];
  44.         foreach ($products as $product) {
  45.             $productIds[] = $product->getId();
  46.         }
  48.         $downloadsByProductId = $this->getDownloadsByProductIdAndType($productIds, $event->getSalesChannelContext(), ProductDownloadDefinition::TYPE_DOWNLOAD);
  49.         foreach ($products as $product) {
  50.             $downloads = $downloadsByProductId[$product->getId()] ?? [];
  52.             if ($downloads !== []) {
  53.                 $product->addExtension('productDownloads', new ArrayStruct([
  54.                     'downloads' => $downloads,
  55.                 ]));
  56.             }
  57.         }
  59.         $cadDownloadsByProductId = $this->getDownloadsByProductIdAndType($productIds, $event->getSalesChannelContext(), ProductDownloadDefinition::TYPE_CAD);
  60.         foreach ($products as $product) {
  61.             $downloads = $cadDownloadsByProductId[$product->getId()] ?? [];
  63.             if ($downloads !== []) {
  64.                 $product->addExtension('productCadDownloads', new ArrayStruct([
  65.                     'downloads' => $downloads,
  66.                 ]));
  67.             }
  68.         }
  69.     }
  71.     /**
  72.      * @param array<int, string> $productIds
  73.      *
  74.      * @return array<string, array<int, array{displayName: string, fileName: string, url: string|null}>>
  75.      */
  76.     private function getDownloadsByProductIdAndType(array $productIds, SalesChannelContext $context, string $type): array
  77.     {
  78.         if ($productIds === []) {
  79.             return [];
  80.         }
  82.         $criteria = new Criteria();
  83.         $criteria->addFilter(new EqualsAnyFilter('productId', $productIds));
  84.         $criteria->addFilter(new EqualsFilter('languageId', $context->getContext()->getLanguageId()));
  86.         // CIO-AI-Driven: discriminator
  87.         $criteria->addFilter(new EqualsFilter('type', $type));
  89.         $criteria->addAssociation('media');
  91.         $result = $this->productDownloadRepository->search($criteria, $context->getContext());
  92.         if ($result->getTotal() <= 0) {
  93.             return [];
  94.         }
  96.         $downloadsByProductId = [];
  98.         foreach ($result->getEntities() as $download) {
  99.             $productId = (string) $download->get('productId');
  100.             if ($productId === '') {
  101.                 continue;
  102.             }
  104.             $displayName = (string) $download->get('displayName');
  105.             $fileName = (string) $download->get('fileName');
  107.             $media = $download->get('media');
  108.             $url = null;
  110.             if ($media instanceof MediaEntity) {
  111.                 $url = $media->getUrl();
  112.                 $fileName = $fileName !== '' ? $fileName : $this->buildFileNameFromMedia($media);
  113.                 $displayName = $displayName !== '' ? $displayName : $fileName;
  114.             }
  116.             // Backward compatibility (old implementations could have filePath)
  117.             if ($url === null) {
  118.                 $url = $download->get('filePath') ? (string) $download->get('filePath') : null;
  119.             }
  121.             $downloadsByProductId[$productId] ??= [];
  122.             $downloadsByProductId[$productId][] = [
  123.                 'displayName' => $displayName,
  124.                 'fileName' => $fileName,
  125.                 'url' => $url,
  126.             ];
  127.         }
  129.         return $downloadsByProductId;
  130.     }
  132.     private function buildFileNameFromMedia(MediaEntity $media): string
  133.     {
  134.         $baseName = (string) ($media->getFileName() ?? '');
  135.         $extension = (string) ($media->getFileExtension() ?? '');
  137.         if ($baseName === '') {
  138.             return '';
  139.         }
  141.         return $extension !== '' ? "{$baseName}.{$extension}" : $baseName;
  142.     }
  143. }