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

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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class ProductExportEventListener implements EventSubscriberInterface
  14. {
  15.     /**
  16.      * @var EntityRepositoryInterface
  17.      */
  18.     private $productExportRepository;
  20.     /**
  21.      * @var ProductExportFileHandlerInterface
  22.      */
  23.     private $productExportFileHandler;
  25.     /**
  26.      * @var FilesystemInterface
  27.      */
  28.     private $fileSystem;
  30.     /**
  31.      * @internal
  32.      */
  33.     public function __construct(
  34.         EntityRepositoryInterface $productExportRepository,
  35.         ProductExportFileHandlerInterface $productExportFileHandler,
  36.         FilesystemInterface $fileSystem
  37.     ) {
  38.         $this->productExportRepository = $productExportRepository;
  39.         $this->productExportFileHandler = $productExportFileHandler;
  40.         $this->fileSystem = $fileSystem;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             'product_export.written' => 'afterWrite',
  47.         ];
  48.     }
  50.     public function afterWrite(EntityWrittenEvent $event): void
  51.     {
  52.         foreach ($event->getWriteResults() as $writeResult) {
  53.             if (!$this->productExportWritten($writeResult)) {
  54.                 continue;
  55.             }
  57.             $primaryKey = $writeResult->getPrimaryKey();
  58.             $primaryKey = \is_array($primaryKey) ? $primaryKey['id'] : $primaryKey;
  60.             $this->productExportRepository->update(
  61.                 [
  62.                     [
  63.                         'id' => $primaryKey,
  64.                         'generatedAt' => null,
  65.                     ],
  66.                 ],
  67.                 $event->getContext()
  68.             );
  69.             $productExportResult = $this->productExportRepository->search(new Criteria([$primaryKey]), $event->getContext());
  70.             if ($productExportResult->getTotal() !== 0) {
  71.                 $productExport = $productExportResult->first();
  73.                 $filePath = $this->productExportFileHandler->getFilePath($productExport);
  74.                 if ($this->fileSystem->has($filePath)) {
  75.                     $this->fileSystem->delete($filePath);
  76.                 }
  77.             }
  78.         }
  79.     }
  81.     private function productExportWritten(EntityWriteResult $writeResult): bool
  82.     {
  83.         return $writeResult->getEntityName() === 'product_export'
  84.             && $writeResult->getOperation() !== EntityWriteResult::OPERATION_DELETE
  85.             && !\array_key_exists('generatedAt', $writeResult->getPayload());
  86.     }
  87. }