custom/plugins/CrehlerProductExportScheduler/src/Subscriber/ProductExportSubscriber.php line 42

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Crehler\ProductExportScheduler\Subscriber;
  6. use Crehler\ProductExportScheduler\DataAbstractionLayer\Entity\ProductExportLog\ProductExportLogDefinition;
  7. use Crehler\ProductExportScheduler\Service\ProductExportLogService;
  8. use League\Flysystem\FilesystemInterface;
  9. use Shopware\Core\Content\ProductExport\Service\ProductExportFileHandlerInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class ProductExportSubscriber implements EventSubscriberInterface
  17. {
  18.     protected EntityRepositoryInterface $productExportRepository;
  19.     protected ProductExportFileHandlerInterface $productExportFileHandler;
  20.     protected FilesystemInterface $fileSystem;
  21.     protected ProductExportLogService $productExportLogService;
  23.     public function __construct(
  24.         EntityRepositoryInterface $productExportRepository,
  25.         ProductExportFileHandlerInterface $productExportFileHandler,
  26.         ProductExportLogService $productExportLogService,
  27.         FilesystemInterface $fileSystem
  28.     ) {
  29.         $this->productExportRepository = $productExportRepository;
  30.         $this->productExportFileHandler = $productExportFileHandler;
  31.         $this->productExportLogService = $productExportLogService;
  32.         $this->fileSystem = $fileSystem;
  33.     }
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             'product_export.written' => 'onProductExportWritten',
  39.         ];
  40.     }
  42.     public function onProductExportWritten(EntityWrittenEvent $event)
  43.     {
  44.         foreach ($event->getWriteResults() as $writeResult) {
  45.             if (!$this->productExportWritten($writeResult)) {
  46.                 continue;
  47.             }
  49.             $primaryKey = $writeResult->getPrimaryKey();
  50.             $primaryKey = \is_array($primaryKey) ? $primaryKey['id'] : $primaryKey;
  52.             $productExportResult = $this->productExportRepository->search(new Criteria([$primaryKey]), $event->getContext());
  54.             if ($productExportResult->getTotal() !== 0) {
  55.                 $productExport = $productExportResult->first();
  57.                 $filePath = $this->productExportFileHandler->getFilePath($productExport);
  59.                 try {
  60.                     $size = $this->fileSystem->getSize($filePath);
  61.                 } catch (\Throwable $e) {
  62.                     $size = 0;
  63.                 }
  65.                 $this->productExportLogService->log(
  66.                     $productExport->getId(),
  67.                     ProductExportLogDefinition::DONE_STATUS,
  68.                     $size
  69.                 );
  70.             }
  71.         }
  72.     }
  74.     private function productExportWritten(EntityWriteResult $writeResult): bool
  75.     {
  76.         return $writeResult->getEntityName() === 'product_export'
  77.             && $writeResult->getOperation() !== EntityWriteResult::OPERATION_DELETE
  78.             && \array_key_exists('generatedAt', $writeResult->getPayload())
  79.             && $writeResult->getPayload()['generatedAt'] !== null;
  80.     }
  81. }