vendor/store.shopware.com/watodigitecgalaxusexport/src/Subscriber/ProductExportWrittenSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wato\DigitecGalaxusExport\Subscriber;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  11. use Symfony\Component\Filesystem\Filesystem;
  12. use Wato\DigitecGalaxusExport\Helper\SFTPFileHelper;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Psr\Log\LoggerInterface;
  16. use Shopware\Core\System\SystemConfig\SystemConfigService;
  18. class ProductExportWrittenSubscriber implements EventSubscriberInterface {
  20.     public function __construct(EntityRepositoryInterface $productExportRepo, SFTPFileHelper $sftp, LoggerInterface $logger, SystemConfigService $systemConfigService)
  21.     {
  22.         $this->productExportRepo = $productExportRepo;
  23.         $this->sftp = $sftp;
  24.         $this->logger = $logger;
  25.         $this->systemConfigService = $systemConfigService;
  26.     }
  28.     public static function getSubscribedEvents()
  29.     {
  30.         return [
  31.             'product_export.written' => 'afterWrite',
  32.         ];
  33.     }
  35.     public function afterWrite(EntityWrittenEvent $event): void
  36.     {
  37.         $context = $event->getContext();
  38.         $user = $this->systemConfigService->get('DigitecGalaxusExport.config.ftpUser');
  39.         $pw = $this->systemConfigService->get('DigitecGalaxusExport.config.ftpPassword');
  40.         $server = $this->systemConfigService->get('DigitecGalaxusExport.config.ftpServer');
  41.         $directory = $this->systemConfigService->get('DigitecGalaxusExport.config.articleDataDirectory');
  42.         foreach ($event->getPayloads() as $payload)
  43.         {
  44.             $id = $payload['id'];
  45.             $filename = $this->productExportRepo->search(new Criteria([$id]), $context)->first()->fileName;
  46.             if (str_starts_with($filename, 'Product'))
  47.             {
  48.                 try {
  49.                     $this->sftp->deployFile($filename, $user, $pw, $server, $directory);
  50.                 } catch (\Throwable $t){
  51.                     $this->logger->error(date('D M d, Y G:i') . ': ' . $t->getMessage() . ' Line: ' . $t->getLine() . ' File: ' . $t->getFile() . PHP_EOL);
  52.                     continue;
  53.                 }
  54.             } 
  55.         }
  56.     }
  58.     private function productExportWritten(EntityWriteResult $writeResult): bool
  59.     {
  60.         return $writeResult->getEntityName() === 'product_export'
  61.             && $writeResult->getOperation() !== EntityWriteResult::OPERATION_DELETE
  62.             && !\array_key_exists('generatedAt', $writeResult->getPayload());
  63.     }
  64. }