vendor/shopware/platform/src/Core/Content/ImportExport/DataAbstractionLayer/SystemDefaultValidator.php line 40

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