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

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\EntityWrittenEvent;
  9. use Shopware\Core\Framework\Uuid\Uuid;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class CustomFieldSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var Connection
  16.      */
  17.     private $connection;
  19.     public function __construct(Connection $connection)
  20.     {
  21.         $this->connection = $connection;
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             'custom_field.written' => 'customFieldIsWritten',
  28.         ];
  29.     }
  31.     public function customFieldIsWritten(EntityWrittenEvent $event): void
  32.     {
  33.         $snippets = [];
  34.         $snippetSets = null;
  35.         foreach ($event->getWriteResults() as $writeResult) {
  36.             if (!isset($writeResult->getPayload()['config']['label']) || empty($writeResult->getPayload()['config']['label'])) {
  37.                 continue;
  38.             }
  40.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT) {
  41.                 if ($snippetSets === null) {
  42.                     $snippetSets = $this->connection->fetchAll('SELECT id, iso FROM snippet_set');
  43.                 }
  45.                 if (empty($snippetSets)) {
  46.                     return;
  47.                 }
  49.                 $this->setInsertSnippets($writeResult, $snippetSets, $snippets);
  50.             }
  51.         }
  53.         if (empty($snippets)) {
  54.             return;
  55.         }
  57.         foreach ($snippets as $snippet) {
  58.             $this->connection->executeUpdate(
  59.                 'INSERT INTO snippet (`id`, `snippet_set_id`, `translation_key`, `value`, `author`, `created_at`) VALUES(:id, :setId, :translationKey, :value, :author, :createdAt)',
  60.                 $snippet
  61.             );
  62.         }
  63.     }
  65.     private function setInsertSnippets(EntityWriteResult $writeResult, array $snippetSets, array &$snippets): void
  66.     {
  67.         $name = $writeResult->getPayload()['name'];
  68.         $labels = $writeResult->getPayload()['config']['label'];
  70.         foreach ($snippetSets as $snippetSet) {
  71.             $label = $name;
  72.             $iso = $snippetSet['iso'];
  74.             if (isset($labels[$iso])) {
  75.                 $label = $labels[$iso];
  76.             }
  78.             $snippets[] = [
  79.                 'id' => Uuid::randomBytes(),
  80.                 'setId' => $snippetSet['id'],
  81.                 'translationKey' => 'customFields.' . $name,
  82.                 'value' => $label,
  83.                 'author' => 'System',
  84.                 'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  85.             ];
  86.         }
  87.     }
  88. }