vendor/shopware/core/System/CustomField/CustomFieldService.php line 82

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\System\CustomField;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\FetchModeHelper;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Field\BoolField;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Field\DateTimeField;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Field\Field;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Field\Flag\AllowHtml;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Field\Flag\ApiAware;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Field\FloatField;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Field\IntField;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Field\JsonField;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Field\LongTextField;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Field\PriceField;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class CustomFieldService implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var string[]|null
  23.      */
  24.     private $customFields;
  26.     /**
  27.      * @var Connection
  28.      */
  29.     private $connection;
  31.     public function __construct(Connection $connection)
  32.     {
  33.         $this->connection = $connection;
  34.     }
  36.     public function getCustomField(string $attributeName): ?Field
  37.     {
  38.         $type = $this->getCustomFields()[$attributeName] ?? null;
  39.         if (!$type) {
  40.             return null;
  41.         }
  43.         switch ($type) {
  44.             case CustomFieldTypes::INT:
  45.                 return (new IntField($attributeName, $attributeName))->addFlags(new ApiAware());
  47.             case CustomFieldTypes::FLOAT:
  48.                 return (new FloatField($attributeName, $attributeName))->addFlags(new ApiAware());
  50.             case CustomFieldTypes::BOOL:
  51.                 return (new BoolField($attributeName, $attributeName))->addFlags(new ApiAware());
  53.             case CustomFieldTypes::DATETIME:
  54.                 return (new DateTimeField($attributeName, $attributeName))->addFlags(new ApiAware());
  56.             case CustomFieldTypes::TEXT:
  57.                 return (new LongTextField($attributeName, $attributeName))->addFlags(new ApiAware());
  59.             case CustomFieldTypes::HTML:
  60.                 return (new LongTextField($attributeName, $attributeName))->addFlags(new ApiAware(), new AllowHtml());
  62.             case CustomFieldTypes::PRICE:
  63.                 return (new PriceField($attributeName, $attributeName))->addFlags(new ApiAware());
  65.             case CustomFieldTypes::JSON:
  66.             default:
  67.                 return (new JsonField($attributeName, $attributeName))->addFlags(new ApiAware());
  68.         }
  69.     }
  71.     public static function getSubscribedEvents(): array
  72.     {
  73.         return [
  74.             CustomFieldEvents::CUSTOM_FIELD_DELETED_EVENT => 'invalidateCache',
  75.             CustomFieldEvents::CUSTOM_FIELD_WRITTEN_EVENT => 'invalidateCache',
  76.         ];
  77.     }
  79.     /**
  80.      * @internal
  81.      */
  82.     public function invalidateCache(): void
  83.     {
  84.         $this->customFields = null;
  85.     }
  87.     /**
  88.      * @return string[]
  89.      */
  90.     private function getCustomFields(): array
  91.     {
  92.         if ($this->customFields !== null) {
  93.             return $this->customFields;
  94.         }
  96.         $fields = $this->connection->fetchAll('SELECT `name`, `type` FROM `custom_field` WHERE `active` = 1');
  98.         $this->customFields = FetchModeHelper::keyPair($fields);
  100.         return $this->customFields;
  101.     }
  102. }