vendor/shopware/core/Content/Product/ProductHydrator.php line 20

Open in your IDE?
  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 (\array_key_exists($root . '.configuratorGroupConfig', $row)) {
  89. $entity->configuratorGroupConfig = $definition->decode('configuratorGroupConfig', self::value($row, $root, 'configuratorGroupConfig'));
  90. }
  91. if (isset($row[$root . '.mainVariantId'])) {
  92. $entity->mainVariantId = Uuid::fromBytesToHex($row[$root . '.mainVariantId']);
  93. }
  94. if (isset($row[$root . '.displayParent'])) {
  95. $entity->displayParent = (bool) $row[$root . '.displayParent'];
  96. }
  97. if (isset($row[$root . '.variantListingConfig'])) {
  98. $entity->variantListingConfig = $definition->decode('variantListingConfig', self::value($row, $root, 'variantListingConfig'));
  99. }
  100. if (\array_key_exists($root . '.variantRestrictions', $row)) {
  101. $entity->variantRestrictions = $definition->decode('variantRestrictions', self::value($row, $root, 'variantRestrictions'));
  102. }
  103. if (isset($row[$root . '.manufacturerNumber'])) {
  104. $entity->manufacturerNumber = $row[$root . '.manufacturerNumber'];
  105. }
  106. if (isset($row[$root . '.ean'])) {
  107. $entity->ean = $row[$root . '.ean'];
  108. }
  109. if (isset($row[$root . '.purchaseSteps'])) {
  110. $entity->purchaseSteps = (int) $row[$root . '.purchaseSteps'];
  111. }
  112. if (isset($row[$root . '.maxPurchase'])) {
  113. $entity->maxPurchase = (int) $row[$root . '.maxPurchase'];
  114. }
  115. if (isset($row[$root . '.minPurchase'])) {
  116. $entity->minPurchase = (int) $row[$root . '.minPurchase'];
  117. }
  118. if (isset($row[$root . '.purchaseUnit'])) {
  119. $entity->purchaseUnit = (float) $row[$root . '.purchaseUnit'];
  120. }
  121. if (isset($row[$root . '.referenceUnit'])) {
  122. $entity->referenceUnit = (float) $row[$root . '.referenceUnit'];
  123. }
  124. if (isset($row[$root . '.shippingFree'])) {
  125. $entity->shippingFree = (bool) $row[$root . '.shippingFree'];
  126. }
  127. if (\array_key_exists($root . '.purchasePrices', $row)) {
  128. $entity->purchasePrices = $definition->decode('purchasePrices', self::value($row, $root, 'purchasePrices'));
  129. }
  130. if (isset($row[$root . '.markAsTopseller'])) {
  131. $entity->markAsTopseller = (bool) $row[$root . '.markAsTopseller'];
  132. }
  133. if (isset($row[$root . '.weight'])) {
  134. $entity->weight = (float) $row[$root . '.weight'];
  135. }
  136. if (isset($row[$root . '.width'])) {
  137. $entity->width = (float) $row[$root . '.width'];
  138. }
  139. if (isset($row[$root . '.height'])) {
  140. $entity->height = (float) $row[$root . '.height'];
  141. }
  142. if (isset($row[$root . '.length'])) {
  143. $entity->length = (float) $row[$root . '.length'];
  144. }
  145. if (isset($row[$root . '.releaseDate'])) {
  146. $entity->releaseDate = new \DateTimeImmutable($row[$root . '.releaseDate']);
  147. }
  148. if (isset($row[$root . '.ratingAverage'])) {
  149. $entity->ratingAverage = (float) $row[$root . '.ratingAverage'];
  150. }
  151. if (\array_key_exists($root . '.categoryTree', $row)) {
  152. $entity->categoryTree = $definition->decode('categoryTree', self::value($row, $root, 'categoryTree'));
  153. }
  154. if (\array_key_exists($root . '.propertyIds', $row)) {
  155. $entity->propertyIds = $definition->decode('propertyIds', self::value($row, $root, 'propertyIds'));
  156. }
  157. if (\array_key_exists($root . '.optionIds', $row)) {
  158. $entity->optionIds = $definition->decode('optionIds', self::value($row, $root, 'optionIds'));
  159. }
  160. if (\array_key_exists($root . '.streamIds', $row)) {
  161. $entity->streamIds = $definition->decode('streamIds', self::value($row, $root, 'streamIds'));
  162. }
  163. if (\array_key_exists($root . '.tagIds', $row)) {
  164. $entity->tagIds = $definition->decode('tagIds', self::value($row, $root, 'tagIds'));
  165. }
  166. if (\array_key_exists($root . '.categoryIds', $row)) {
  167. $entity->categoryIds = $definition->decode('categoryIds', self::value($row, $root, 'categoryIds'));
  168. }
  169. if (isset($row[$root . '.childCount'])) {
  170. $entity->childCount = (int) $row[$root . '.childCount'];
  171. }
  172. if (isset($row[$root . '.customFieldSetSelectionActive'])) {
  173. $entity->customFieldSetSelectionActive = (bool) $row[$root . '.customFieldSetSelectionActive'];
  174. }
  175. if (isset($row[$root . '.sales'])) {
  176. $entity->sales = (int) $row[$root . '.sales'];
  177. }
  178. if (\array_key_exists($root . '.cheapestPrice', $row)) {
  179. $entity->cheapestPrice = $definition->decode('cheapestPrice', self::value($row, $root, 'cheapestPrice'));
  180. }
  181. if (isset($row[$root . '.createdAt'])) {
  182. $entity->createdAt = new \DateTimeImmutable($row[$root . '.createdAt']);
  183. }
  184. if (isset($row[$root . '.updatedAt'])) {
  185. $entity->updatedAt = new \DateTimeImmutable($row[$root . '.updatedAt']);
  186. }
  187. $entity->deliveryTime = $this->manyToOne($row, $root, $definition->getField('deliveryTime'), $context);
  188. $entity->tax = $this->manyToOne($row, $root, $definition->getField('tax'), $context);
  189. $entity->manufacturer = $this->manyToOne($row, $root, $definition->getField('manufacturer'), $context);
  190. $entity->unit = $this->manyToOne($row, $root, $definition->getField('unit'), $context);
  191. $entity->cover = $this->manyToOne($row, $root, $definition->getField('cover'), $context);
  192. $entity->featureSet = $this->manyToOne($row, $root, $definition->getField('featureSet'), $context);
  193. $entity->cmsPage = $this->manyToOne($row, $root, $definition->getField('cmsPage'), $context);
  194. $entity->canonicalProduct = $this->manyToOne($row, $root, $definition->getField('canonicalProduct'), $context);
  196. $this->translate($definition, $entity, $row, $root, $context, $definition->getTranslatedFields());
  197. $this->hydrateFields($definition, $entity, $root, $row, $context, $definition->getExtensionFields());
  198. $this->customFields($definition, $row, $root, $entity, $definition->getField('customFields'), $context);
  199. $this->manyToMany($row, $root, $entity, $definition->getField('options'));
  200. $this->manyToMany($row, $root, $entity, $definition->getField('properties'));
  201. $this->manyToMany($row, $root, $entity, $definition->getField('categories'));
  202. $this->manyToMany($row, $root, $entity, $definition->getField('streams'));
  203. $this->manyToMany($row, $root, $entity, $definition->getField('categoriesRo'));
  204. $this->manyToMany($row, $root, $entity, $definition->getField('tags'));
  205. $this->manyToMany($row, $root, $entity, $definition->getField('customFieldSets'));
  207. return $entity;
  208. }
  209. }