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. }