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

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\ProductExport\EventListener;
  5. use League\Flysystem\FilesystemOperator;
  6. use Shopware\Core\Content\ProductExport\Service\ProductExportFileHandlerInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  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.  * @internal
  16.  */
  17. #[Package('sales-channel')]
  18. class ProductExportEventListener implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @internal
  22.      */
  23.     public function __construct(
  24.         private readonly EntityRepository $productExportRepository,
  25.         private readonly ProductExportFileHandlerInterface $productExportFileHandler,
  26.         private readonly FilesystemOperator $fileSystem
  27.     ) {
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             'product_export.written' => 'afterWrite',
  34.         ];
  35.     }
  37.     public function afterWrite(EntityWrittenEvent $event): void
  38.     {
  39.         foreach ($event->getWriteResults() as $writeResult) {
  40.             if (!$this->productExportWritten($writeResult)) {
  41.                 continue;
  42.             }
  44.             $primaryKey = $writeResult->getPrimaryKey();
  45.             $primaryKey = \is_array($primaryKey) ? $primaryKey['id'] : $primaryKey;
  47.             $this->productExportRepository->update(
  48.                 [
  49.                     [
  50.                         'id' => $primaryKey,
  51.                         'generatedAt' => null,
  52.                     ],
  53.                 ],
  54.                 $event->getContext()
  55.             );
  56.             $productExportResult = $this->productExportRepository->search(new Criteria([$primaryKey]), $event->getContext());
  57.             if ($productExportResult->getTotal() !== 0) {
  58.                 $productExport = $productExportResult->first();
  60.                 $filePath = $this->productExportFileHandler->getFilePath($productExport);
  61.                 if ($this->fileSystem->fileExists($filePath)) {
  62.                     $this->fileSystem->delete($filePath);
  63.                 }
  64.             }
  65.         }
  66.     }
  68.     private function productExportWritten(EntityWriteResult $writeResult): bool
  69.     {
  70.         return $writeResult->getEntityName() === 'product_export'
  71.             && $writeResult->getOperation() !== EntityWriteResult::OPERATION_DELETE
  72.             && !\array_key_exists('generatedAt', $writeResult->getPayload());
  73.     }
  74. }