vendor/shopware/core/System/Snippet/Subscriber/CustomFieldSubscriber.php line 76

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\System\Snippet\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Defaults;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\Log\Package;
  11. use Shopware\Core\Framework\Uuid\Uuid;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  16. */
  17. #[Package('system-settings')]
  18. class CustomFieldSubscriber implements EventSubscriberInterface
  19. {
  20. private const CUSTOM_FIELD_ID_FIELD = 'custom_field_id';
  22. private Connection $connection;
  24. /**
  25. * @internal
  26. */
  27. public function __construct(Connection $connection)
  28. {
  29. $this->connection = $connection;
  30. }
  32. public static function getSubscribedEvents(): array
  33. {
  34. return [
  35. 'custom_field.written' => 'customFieldIsWritten',
  36. 'custom_field.deleted' => 'customFieldIsDeleted',
  37. ];
  38. }
  40. public function customFieldIsWritten(EntityWrittenEvent $event): void
  41. {
  42. $snippets = [];
  43. $snippetSets = null;
  44. foreach ($event->getWriteResults() as $writeResult) {
  45. if (!isset($writeResult->getPayload()['config']['label']) || empty($writeResult->getPayload()['config']['label'])) {
  46. continue;
  47. }
  49. if ($writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT) {
  50. if ($snippetSets === null) {
  51. $snippetSets = $this->connection->fetchAllAssociative('SELECT id, iso FROM snippet_set');
  52. }
  54. if (empty($snippetSets)) {
  55. return;
  56. }
  58. $this->setInsertSnippets($writeResult, $snippetSets, $snippets);
  59. }
  60. }
  62. if (empty($snippets)) {
  63. return;
  64. }
  66. foreach ($snippets as $snippet) {
  67. $this->connection->executeStatement(
  68. 'INSERT INTO snippet (`id`, `snippet_set_id`, `translation_key`, `value`, `author`, `custom_fields`, `created_at`)
  69. VALUES (:id, :setId, :translationKey, :value, :author, :customFields, :createdAt)
  70. ON DUPLICATE KEY UPDATE `value` = :value',
  71. $snippet
  72. );
  73. }
  74. }
  76. public function customFieldIsDeleted(EntityDeletedEvent $event): void
  77. {
  78. $this->connection->executeStatement(
  79. 'DELETE FROM `snippet`
  80. WHERE JSON_EXTRACT(`custom_fields`, "$.custom_field_id") IN (:customFieldIds)',
  81. ['customFieldIds' => $event->getIds()],
  82. ['customFieldIds' => Connection::PARAM_STR_ARRAY]
  83. );
  84. }
  86. /**
  87. * @param list<array<string, string>> $snippetSets
  88. * @param array<string, mixed> $snippets
  89. */
  90. private function setInsertSnippets(EntityWriteResult $writeResult, array $snippetSets, array &$snippets): void
  91. {
  92. $name = $writeResult->getPayload()['name'];
  93. $labels = $writeResult->getPayload()['config']['label'];
  95. foreach ($snippetSets as $snippetSet) {
  96. $label = $name;
  97. $iso = $snippetSet['iso'];
  99. if (isset($labels[$iso])) {
  100. $label = $labels[$iso];
  101. }
  103. $snippets[] = [
  104. 'id' => Uuid::randomBytes(),
  105. 'setId' => $snippetSet['id'],
  106. 'translationKey' => 'customFields.' . $name,
  107. 'value' => $label,
  108. 'author' => 'System',
  109. 'customFields' => json_encode([
  110. self::CUSTOM_FIELD_ID_FIELD => $writeResult->getPrimaryKey(),
  111. ]),
  112. 'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  113. ];
  114. }
  115. }
  116. }