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

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