src/Core/Content/ImportExport/DataAbstractionLayer/SystemDefaultValidator.php line 36

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\ImportExport\DataAbstractionLayer;
  5. use Doctrine\DBAL\Connection;
  6. use Doctrine\DBAL\FetchMode;
  7. use Shopware\Core\Content\ImportExport\Exception\DeleteDefaultProfileException;
  8. use Shopware\Core\Content\ImportExport\ImportExportProfileDefinition;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  11. use Shopware\Core\Framework\Log\Package;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15.  * @internal
  16.  */
  17. #[Package('system-settings')]
  18. class SystemDefaultValidator implements EventSubscriberInterface
  19. {
  20.     public function __construct(private readonly Connection $connection)
  21.     {
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             PreWriteValidationEvent::class => 'preValidate',
  28.         ];
  29.     }
  31.     /**
  32.      * @internal
  33.      *
  34.      * @throws DeleteDefaultProfileException
  35.      */
  36.     public function preValidate(PreWriteValidationEvent $event): void
  37.     {
  38.         $ids = [];
  39.         $writeCommands = $event->getCommands();
  41.         foreach ($writeCommands as $command) {
  42.             if ($command->getDefinition()->getClass() === ImportExportProfileDefinition::class
  43.                 && $command instanceof DeleteCommand
  44.             ) {
  45.                 $ids[] = $command->getPrimaryKey()['id'];
  46.             }
  47.         }
  49.         $filteredIds = $this->filterSystemDefaults($ids);
  50.         if (!empty($filteredIds)) {
  51.             $event->getExceptions()->add(new DeleteDefaultProfileException($filteredIds));
  52.         }
  53.     }
  55.     private function filterSystemDefaults(array $ids): array
  56.     {
  57.         if (empty($ids)) {
  58.             return [];
  59.         }
  61.         $result = $this->connection->executeQuery(
  62.             'SELECT id FROM import_export_profile WHERE id IN (:idList) AND system_default = 1',
  63.             ['idList' => $ids],
  64.             ['idList' => Connection::PARAM_STR_ARRAY]
  65.         );
  67.         return $result->fetchAll(FetchMode::COLUMN);
  68.     }
  69. }