custom/plugins/IwvDatevV6/src/Subscriber/ScheduledExportSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Iwv\IwvDatevV6\Subscriber;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  11. use Iwv\IwvDatevV6\Core\Content\IwvDatev\ScheduledExportEvents;
  12. use Iwv\IwvDatevV6\Core\Content\IwvDatev\ScheduledExportDefinition;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use League\Flysystem\FilesystemInterface;
  16. class ScheduledExportSubscriber implements EventSubscriberInterface
  17. {
  18.     /** @var FilesystemInterface $filesystemPrivate */
  19.     private $filesystemPrivate;
  21.     /**
  22.      * @param FilesystemInterface $filesystemPrivate
  23.      */
  24.     public function __construct(FilesystemInterface $filesystemPrivate)
  25.     {
  26.         $this->filesystemPrivate = $filesystemPrivate;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             PreWriteValidationEvent::class => 'onPreWriteValidationEvent',
  33.             ScheduledExportEvents::ENTITY_DELETED_EVENT => 'onEntityDeleted',
  34.         ];
  35.     }
  37.     public function onPreWriteValidationEvent(PreWriteValidationEvent $event): void
  38.     {
  39.         foreach ($event->getCommands() as $command) {
  41.             if ($command->getDefinition()->getEntityName() !== ScheduledExportDefinition::ENTITY_NAME) {
  42.                 continue;
  43.             }
  45.             if (!$command instanceof DeleteCommand) {
  46.                 continue;
  47.             }
  48.             $command->requestChangeSet();
  49.         }
  50.     }
  52.     public function onEntityDeleted(EntityDeletedEvent $event): void
  53.     {
  54.         foreach ($event->getIds() as $id) {
  55.             if ($this->filesystemPrivate->has($id)) {
  56.                 $this->filesystemPrivate->delete($id);
  57.             }
  58.         }
  59.     }
  60. }