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

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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. /**
  14.  * @internal
  15.  */
  16. class SystemDefaultValidator implements EventSubscriberInterface
  17. {
  18.     private Connection $connection;
  20.     public function __construct(Connection $connection)
  21.     {
  22.         $this->connection = $connection;
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             PreWriteValidationEvent::class => 'preValidate',
  29.         ];
  30.     }
  32.     /**
  33.      * @internal
  34.      *
  35.      * @throws DeleteDefaultProfileException
  36.      */
  37.     public function preValidate(PreWriteValidationEvent $event): void
  38.     {
  39.         $ids = [];
  40.         $writeCommands = $event->getCommands();
  42.         foreach ($writeCommands as $command) {
  43.             if ($command->getDefinition()->getClass() === ImportExportProfileDefinition::class
  44.                 && $command instanceof DeleteCommand
  45.             ) {
  46.                 $ids[] = $command->getPrimaryKey()['id'];
  47.             }
  48.         }
  50.         $filteredIds = $this->filterSystemDefaults($ids);
  51.         if (!empty($filteredIds)) {
  52.             $event->getExceptions()->add(new DeleteDefaultProfileException($filteredIds));
  53.         }
  54.     }
  56.     private function filterSystemDefaults(array $ids): array
  57.     {
  58.         if (empty($ids)) {
  59.             return [];
  60.         }
  62.         $result = $this->connection->executeQuery(
  63.             'SELECT id FROM import_export_profile WHERE id IN (:idList) AND system_default = 1',
  64.             ['idList' => $ids],
  65.             ['idList' => Connection::PARAM_STR_ARRAY]
  66.         );
  68.         return $result->fetchAll(FetchMode::COLUMN);
  69.     }
  70. }