src/Core/Content/Product/ProductHydrator.php line 182

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Product;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Dbal\EntityHydrator;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Entity;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityDefinition;
  9. use Shopware\Core\Framework\Log\Package;
  10. use Shopware\Core\Framework\Uuid\Uuid;
  12. #[Package('inventory')]
  13. class ProductHydrator extends EntityHydrator
  14. {
  15.     /**
  16.      * @param array<string, string> $row
  17.      *
  18.      * @throws \Exception
  19.      */
  20.     protected function assign(EntityDefinition $definition, Entity $entity, string $root, array $row, Context $context): Entity
  21.     {
  22.         if (isset($row[$root . '.id'])) {
  23.             $entity->id = Uuid::fromBytesToHex($row[$root . '.id']);
  24.         }
  25.         if (isset($row[$root . '.versionId'])) {
  26.             $entity->versionId = Uuid::fromBytesToHex($row[$root . '.versionId']);
  27.         }
  28.         if (isset($row[$root . '.parentId'])) {
  29.             $entity->parentId = Uuid::fromBytesToHex($row[$root . '.parentId']);
  30.         }
  31.         if (isset($row[$root . '.manufacturerId'])) {
  32.             $entity->manufacturerId = Uuid::fromBytesToHex($row[$root . '.manufacturerId']);
  33.         }
  34.         if (isset($row[$root . '.unitId'])) {
  35.             $entity->unitId = Uuid::fromBytesToHex($row[$root . '.unitId']);
  36.         }
  37.         if (isset($row[$root . '.taxId'])) {
  38.             $entity->taxId = Uuid::fromBytesToHex($row[$root . '.taxId']);
  39.         }
  40.         if (isset($row[$root . '.coverId'])) {
  41.             $entity->coverId = Uuid::fromBytesToHex($row[$root . '.coverId']);
  42.         }
  43.         if (isset($row[$root . '.deliveryTimeId'])) {
  44.             $entity->deliveryTimeId = Uuid::fromBytesToHex($row[$root . '.deliveryTimeId']);
  45.         }
  46.         if (isset($row[$root . '.featureSetId'])) {
  47.             $entity->featureSetId = Uuid::fromBytesToHex($row[$root . '.featureSetId']);
  48.         }
  49.         if (isset($row[$root . '.canonicalProductId'])) {
  50.             $entity->canonicalProductId = Uuid::fromBytesToHex($row[$root . '.canonicalProductId']);
  51.         }
  52.         if (isset($row[$root . '.cmsPageId'])) {
  53.             $entity->cmsPageId = Uuid::fromBytesToHex($row[$root . '.cmsPageId']);
  54.         }
  55.         if (\array_key_exists($root . '.price', $row)) {
  56.             $entity->price = $definition->decode('price', self::value($row, $root, 'price'));
  57.         }
  58.         if (isset($row[$root . '.productNumber'])) {
  59.             $entity->productNumber = $row[$root . '.productNumber'];
  60.         }
  61.         if (isset($row[$root . '.stock'])) {
  62.             $entity->stock = (int) $row[$root . '.stock'];
  63.         }
  64.         if (isset($row[$root . '.restockTime'])) {
  65.             $entity->restockTime = (int) $row[$root . '.restockTime'];
  66.         }
  67.         if (isset($row[$root . '.autoIncrement'])) {
  68.             $entity->autoIncrement = (int) $row[$root . '.autoIncrement'];
  69.         }
  70.         if (isset($row[$root . '.active'])) {
  71.             $entity->active = (bool) $row[$root . '.active'];
  72.         }
  73.         if (isset($row[$root . '.availableStock'])) {
  74.             $entity->availableStock = (int) $row[$root . '.availableStock'];
  75.         }
  76.         if (isset($row[$root . '.available'])) {
  77.             $entity->available = (bool) $row[$root . '.available'];
  78.         }
  79.         if (isset($row[$root . '.isCloseout'])) {
  80.             $entity->isCloseout = (bool) $row[$root . '.isCloseout'];
  81.         }
  82.         if (isset($row[$root . '.displayGroup'])) {
  83.             $entity->displayGroup = $row[$root . '.displayGroup'];
  84.         }
  85.         if (isset($row[$root . '.states'])) {
  86.             $entity->states = $definition->decode('states', self::value($row, $root, 'states'));
  87.         }
  88.         if (isset($row[$root . '.variantListingConfig'])) {
  89.             $entity->variantListingConfig = $definition->decode('variantListingConfig', self::value($row, $root, 'variantListingConfig'));
  90.         }
  91.         if (\array_key_exists($root . '.variantRestrictions', $row)) {
  92.             $entity->variantRestrictions = $definition->decode('variantRestrictions', self::value($row, $root, 'variantRestrictions'));
  93.         }
  94.         if (isset($row[$root . '.manufacturerNumber'])) {
  95.             $entity->manufacturerNumber = $row[$root . '.manufacturerNumber'];
  96.         }
  97.         if (isset($row[$root . '.ean'])) {
  98.             $entity->ean = $row[$root . '.ean'];
  99.         }
  100.         if (isset($row[$root . '.purchaseSteps'])) {
  101.             $entity->purchaseSteps = (int) $row[$root . '.purchaseSteps'];
  102.         }
  103.         if (isset($row[$root . '.maxPurchase'])) {
  104.             $entity->maxPurchase = (int) $row[$root . '.maxPurchase'];
  105.         }
  106.         if (isset($row[$root . '.minPurchase'])) {
  107.             $entity->minPurchase = (int) $row[$root . '.minPurchase'];
  108.         }
  109.         if (isset($row[$root . '.purchaseUnit'])) {
  110.             $entity->purchaseUnit = (float) $row[$root . '.purchaseUnit'];
  111.         }
  112.         if (isset($row[$root . '.referenceUnit'])) {
  113.             $entity->referenceUnit = (float) $row[$root . '.referenceUnit'];
  114.         }
  115.         if (isset($row[$root . '.shippingFree'])) {
  116.             $entity->shippingFree = (bool) $row[$root . '.shippingFree'];
  117.         }
  118.         if (\array_key_exists($root . '.purchasePrices', $row)) {
  119.             $entity->purchasePrices = $definition->decode('purchasePrices', self::value($row, $root, 'purchasePrices'));
  120.         }
  121.         if (isset($row[$root . '.markAsTopseller'])) {
  122.             $entity->markAsTopseller = (bool) $row[$root . '.markAsTopseller'];
  123.         }
  124.         if (isset($row[$root . '.weight'])) {
  125.             $entity->weight = (float) $row[$root . '.weight'];
  126.         }
  127.         if (isset($row[$root . '.width'])) {
  128.             $entity->width = (float) $row[$root . '.width'];
  129.         }
  130.         if (isset($row[$root . '.height'])) {
  131.             $entity->height = (float) $row[$root . '.height'];
  132.         }
  133.         if (isset($row[$root . '.length'])) {
  134.             $entity->length = (float) $row[$root . '.length'];
  135.         }
  136.         if (isset($row[$root . '.releaseDate'])) {
  137.             $entity->releaseDate = new \DateTimeImmutable($row[$root . '.releaseDate']);
  138.         }
  139.         if (isset($row[$root . '.ratingAverage'])) {
  140.             $entity->ratingAverage = (float) $row[$root . '.ratingAverage'];
  141.         }
  142.         if (\array_key_exists($root . '.categoryTree', $row)) {
  143.             $entity->categoryTree = $definition->decode('categoryTree', self::value($row, $root, 'categoryTree'));
  144.         }
  145.         if (\array_key_exists($root . '.propertyIds', $row)) {
  146.             $entity->propertyIds = $definition->decode('propertyIds', self::value($row, $root, 'propertyIds'));
  147.         }
  148.         if (\array_key_exists($root . '.optionIds', $row)) {
  149.             $entity->optionIds = $definition->decode('optionIds', self::value($row, $root, 'optionIds'));
  150.         }
  151.         if (\array_key_exists($root . '.streamIds', $row)) {
  152.             $entity->streamIds = $definition->decode('streamIds', self::value($row, $root, 'streamIds'));
  153.         }
  154.         if (\array_key_exists($root . '.tagIds', $row)) {
  155.             $entity->tagIds = $definition->decode('tagIds', self::value($row, $root, 'tagIds'));
  156.         }
  157.         if (\array_key_exists($root . '.categoryIds', $row)) {
  158.             $entity->categoryIds = $definition->decode('categoryIds', self::value($row, $root, 'categoryIds'));
  159.         }
  160.         if (isset($row[$root . '.childCount'])) {
  161.             $entity->childCount = (int) $row[$root . '.childCount'];
  162.         }
  163.         if (isset($row[$root . '.customFieldSetSelectionActive'])) {
  164.             $entity->customFieldSetSelectionActive = (bool) $row[$root . '.customFieldSetSelectionActive'];
  165.         }
  166.         if (isset($row[$root . '.sales'])) {
  167.             $entity->sales = (int) $row[$root . '.sales'];
  168.         }
  169.         if (\array_key_exists($root . '.cheapestPrice', $row)) {
  170.             $entity->cheapestPrice = $definition->decode('cheapestPrice', self::value($row, $root, 'cheapestPrice'));
  171.         }
  172.         if (isset($row[$root . '.createdAt'])) {
  173.             $entity->createdAt = new \DateTimeImmutable($row[$root . '.createdAt']);
  174.         }
  175.         if (isset($row[$root . '.updatedAt'])) {
  176.             $entity->updatedAt = new \DateTimeImmutable($row[$root . '.updatedAt']);
  177.         }
  178.         $entity->deliveryTime = $this->manyToOne($row, $root, $definition->getField('deliveryTime'), $context);
  179.         $entity->tax = $this->manyToOne($row, $root, $definition->getField('tax'), $context);
  180.         $entity->manufacturer = $this->manyToOne($row, $root, $definition->getField('manufacturer'), $context);
  181.         $entity->unit = $this->manyToOne($row, $root, $definition->getField('unit'), $context);
  182.         $entity->cover = $this->manyToOne($row, $root, $definition->getField('cover'), $context);
  183.         $entity->featureSet = $this->manyToOne($row, $root, $definition->getField('featureSet'), $context);
  184.         $entity->cmsPage = $this->manyToOne($row, $root, $definition->getField('cmsPage'), $context);
  185.         $entity->canonicalProduct = $this->manyToOne($row, $root, $definition->getField('canonicalProduct'), $context);
  187.         $this->translate($definition, $entity, $row, $root, $context, $definition->getTranslatedFields());
  188.         $this->hydrateFields($definition, $entity, $root, $row, $context, $definition->getExtensionFields());
  189.         $this->customFields($definition, $row, $root, $entity, $definition->getField('customFields'), $context);
  190.         $this->manyToMany($row, $root, $entity, $definition->getField('options'));
  191.         $this->manyToMany($row, $root, $entity, $definition->getField('properties'));
  192.         $this->manyToMany($row, $root, $entity, $definition->getField('categories'));
  193.         $this->manyToMany($row, $root, $entity, $definition->getField('streams'));
  194.         $this->manyToMany($row, $root, $entity, $definition->getField('categoriesRo'));
  195.         $this->manyToMany($row, $root, $entity, $definition->getField('tags'));
  196.         $this->manyToMany($row, $root, $entity, $definition->getField('customFieldSets'));
  198.         return $entity;
  199.     }
  200. }