vendor/shopware/core/Content/ImportExport/DataAbstractionLayer/SystemDefaultValidator.php line 39

Open in your IDE?
  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.     private Connection $connection;
  22.     public function __construct(Connection $connection)
  23.     {
  24.         $this->connection = $connection;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             PreWriteValidationEvent::class => 'preValidate',
  31.         ];
  32.     }
  34.     /**
  35.      * @internal
  36.      *
  37.      * @throws DeleteDefaultProfileException
  38.      */
  39.     public function preValidate(PreWriteValidationEvent $event): void
  40.     {
  41.         $ids = [];
  42.         $writeCommands = $event->getCommands();
  44.         foreach ($writeCommands as $command) {
  45.             if ($command->getDefinition()->getClass() === ImportExportProfileDefinition::class
  46.                 && $command instanceof DeleteCommand
  47.             ) {
  48.                 $ids[] = $command->getPrimaryKey()['id'];
  49.             }
  50.         }
  52.         $filteredIds = $this->filterSystemDefaults($ids);
  53.         if (!empty($filteredIds)) {
  54.             $event->getExceptions()->add(new DeleteDefaultProfileException($filteredIds));
  55.         }
  56.     }
  58.     private function filterSystemDefaults(array $ids): array
  59.     {
  60.         if (empty($ids)) {
  61.             return [];
  62.         }
  64.         $result = $this->connection->executeQuery(
  65.             'SELECT id FROM import_export_profile WHERE id IN (:idList) AND system_default = 1',
  66.             ['idList' => $ids],
  67.             ['idList' => Connection::PARAM_STR_ARRAY]
  68.         );
  70.         return $result->fetchAll(FetchMode::COLUMN);
  71.     }
  72. }