vendor/shopware/core/Content/ProductExport/EventListener/ProductExportEventListener.php line 46

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\ProductExport\EventListener;
  5. use League\Flysystem\FilesystemInterface;
  6. use Shopware\Core\Content\ProductExport\Service\ProductExportFileHandlerInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\Log\Package;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  16.  */
  17. #[Package('inventory')]
  18. class ProductExportEventListener implements EventSubscriberInterface
  19. {
  20.     private EntityRepositoryInterface $productExportRepository;
  22.     private ProductExportFileHandlerInterface $productExportFileHandler;
  24.     private FilesystemInterface $fileSystem;
  26.     /**
  27.      * @internal
  28.      */
  29.     public function __construct(
  30.         EntityRepositoryInterface $productExportRepository,
  31.         ProductExportFileHandlerInterface $productExportFileHandler,
  32.         FilesystemInterface $fileSystem
  33.     ) {
  34.         $this->productExportRepository = $productExportRepository;
  35.         $this->productExportFileHandler = $productExportFileHandler;
  36.         $this->fileSystem = $fileSystem;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             'product_export.written' => 'afterWrite',
  43.         ];
  44.     }
  46.     public function afterWrite(EntityWrittenEvent $event): void
  47.     {
  48.         foreach ($event->getWriteResults() as $writeResult) {
  49.             if (!$this->productExportWritten($writeResult)) {
  50.                 continue;
  51.             }
  53.             $primaryKey = $writeResult->getPrimaryKey();
  54.             $primaryKey = \is_array($primaryKey) ? $primaryKey['id'] : $primaryKey;
  56.             $this->productExportRepository->update(
  57.                 [
  58.                     [
  59.                         'id' => $primaryKey,
  60.                         'generatedAt' => null,
  61.                     ],
  62.                 ],
  63.                 $event->getContext()
  64.             );
  65.             $productExportResult = $this->productExportRepository->search(new Criteria([$primaryKey]), $event->getContext());
  66.             if ($productExportResult->getTotal() !== 0) {
  67.                 $productExport = $productExportResult->first();
  69.                 $filePath = $this->productExportFileHandler->getFilePath($productExport);
  70.                 if ($this->fileSystem->has($filePath)) {
  71.                     $this->fileSystem->delete($filePath);
  72.                 }
  73.             }
  74.         }
  75.     }
  77.     private function productExportWritten(EntityWriteResult $writeResult): bool
  78.     {
  79.         return $writeResult->getEntityName() === 'product_export'
  80.             && $writeResult->getOperation() !== EntityWriteResult::OPERATION_DELETE
  81.             && !\array_key_exists('generatedAt', $writeResult->getPayload());
  82.     }
  83. }