platform/src/Core/System/CustomField/CustomFieldService.php line 78

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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class CustomFieldService implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var string[]|null
  22.      */
  23.     private $customFields;
  25.     /**
  26.      * @var Connection
  27.      */
  28.     private $connection;
  30.     public function __construct(Connection $connection)
  31.     {
  32.         $this->connection = $connection;
  33.     }
  35.     public function getCustomField(string $attributeName): ?Field
  36.     {
  37.         $type = $this->getCustomFields()[$attributeName] ?? null;
  38.         if (!$type) {
  39.             return null;
  40.         }
  42.         switch ($type) {
  43.             case CustomFieldTypes::INT:
  44.                 return (new IntField($attributeName, $attributeName))->addFlags(new ApiAware());
  46.             case CustomFieldTypes::FLOAT:
  47.                 return (new FloatField($attributeName, $attributeName))->addFlags(new ApiAware());
  49.             case CustomFieldTypes::BOOL:
  50.                 return (new BoolField($attributeName, $attributeName))->addFlags(new ApiAware());
  52.             case CustomFieldTypes::DATETIME:
  53.                 return (new DateTimeField($attributeName, $attributeName))->addFlags(new ApiAware());
  55.             case CustomFieldTypes::TEXT:
  56.                 return (new LongTextField($attributeName, $attributeName))->addFlags(new ApiAware());
  58.             case CustomFieldTypes::HTML:
  59.                 return (new LongTextField($attributeName, $attributeName))->addFlags(new ApiAware(), new AllowHtml());
  61.             case CustomFieldTypes::JSON:
  62.             default:
  63.                 return (new JsonField($attributeName, $attributeName))->addFlags(new ApiAware());
  64.         }
  65.     }
  67.     public static function getSubscribedEvents(): array
  68.     {
  69.         return [
  70.             CustomFieldEvents::CUSTOM_FIELD_DELETED_EVENT => 'invalidateCache',
  71.             CustomFieldEvents::CUSTOM_FIELD_WRITTEN_EVENT => 'invalidateCache',
  72.         ];
  73.     }
  75.     /**
  76.      * @internal
  77.      */
  78.     public function invalidateCache(): void
  79.     {
  80.         $this->customFields = null;
  81.     }
  83.     /**
  84.      * @return string[]
  85.      */
  86.     private function getCustomFields(): array
  87.     {
  88.         if ($this->customFields !== null) {
  89.             return $this->customFields;
  90.         }
  92.         $fields = $this->connection->fetchAll('SELECT `name`, `type` FROM `custom_field` WHERE `active` = 1');
  94.         $this->customFields = FetchModeHelper::keyPair($fields);
  96.         return $this->customFields;
  97.     }
  98. }