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

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Iwv\IwvDatevV6\Subscriber;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  14. use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskDefinition;
  15. use Iwv\IwvDatevV6\Service\ScheduledTask\ScheduledExportTask;
  16. use Iwv\IwvDatevV6\Core\Content\IwvDatev\ScheduledExportEvents;
  17. use Iwv\IwvDatevV6\Core\Content\IwvDatev\ScheduledExportDefinition;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use League\Flysystem\FilesystemInterface;
  21. class ScheduledExportSubscriber implements EventSubscriberInterface
  22. {
  23.     /** @var EntityRepositoryInterface */
  24.     protected $scheduledTaskRepository;
  26.     /** @var FilesystemInterface $filesystemPrivate */
  27.     private $filesystemPrivate;
  29.     /**
  30.      * @param EntityRepositoryInterface $scheduledTaskRepository
  31.      * @param FilesystemInterface $filesystemPrivate
  32.      */
  33.     public function __construct(
  34.         EntityRepositoryInterface $scheduledTaskRepository,
  35.         FilesystemInterface $filesystemPrivate
  36.     ) {
  37.         $this->scheduledTaskRepository = $scheduledTaskRepository;
  38.         $this->filesystemPrivate = $filesystemPrivate;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             PreWriteValidationEvent::class => 'onPreWriteValidationEvent',
  45.             ScheduledExportEvents::ENTITY_DELETED_EVENT => 'onEntityDeleted',
  46.             ScheduledExportEvents::ENTITY_WRITTEN_EVENT => 'onEntityWritten',
  47.         ];
  48.     }
  50.     public function onPreWriteValidationEvent(PreWriteValidationEvent $event): void
  51.     {
  52.         foreach ($event->getCommands() as $command) {
  54.             if ($command->getDefinition()->getEntityName() !== ScheduledExportDefinition::ENTITY_NAME) {
  55.                 continue;
  56.             }
  58.             if (!$command instanceof DeleteCommand) {
  59.                 continue;
  60.             }
  61.             $command->requestChangeSet();
  62.         }
  63.     }
  65.     public function onEntityDeleted(EntityDeletedEvent $event): void
  66.     {
  67.         foreach ($event->getIds() as $id) {
  68.             if ($this->filesystemPrivate->has($id)) {
  69.                 $this->filesystemPrivate->delete($id);
  70.             }
  71.         }
  72.     }
  74.     public function onEntityWritten(EntityWrittenEvent $event): void
  75.     {
  77.         $context = $event->getContext();
  78.         /** @var \Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskEntity $taskDB */
  79.         if ($taskDB = $this->scheduledTaskRepository
  80.             ->search((new Criteria)
  81.                 ->addFilter(new EqualsFilter('name', ScheduledExportTask::getTaskName()))
  82.                 ->addFilter(new EqualsFilter('status', ScheduledTaskDefinition::STATUS_QUEUED))
  83.                 , $context)
  84.             ->first()) {
  85.             $this->scheduledTaskRepository->update([
  86.                 [
  87.                     'id' => $taskDB->getId(),
  88.                     'status' => ScheduledTaskDefinition::STATUS_SCHEDULED,
  89.                 ]
  90.                 ]
  91.                 , $context);
  92.         }
  93.     }
  94. }