custom/plugins/Neon6Configurator/src/Services/ConfigurationLoader.php line 125

Open in your IDE?
  1. <?php
  3. namespace Neon\Configurator\Services;
  5. use Neon\Configurator\Core\Content\Calculation\CalculationEntity;
  6. use Neon\Configurator\Core\Content\Configuration\ConfigurationEntity;
  7. use Neon\Configurator\Core\Content\Field\FieldEntity;
  8. use Neon\Configurator\Core\Content\Fieldgroup\FieldgroupEntity;
  9. use Neon\Configurator\Core\Content\Fieldvalidation\FieldvalidationEntity;
  10. use Neon\Configurator\Core\Content\Fieldvalue\FieldvalueCollection;
  11. use Neon\Configurator\Core\Content\Fieldvalue\FieldvalueEntity;
  12. use Neon\Configurator\Core\Content\Info\InfoEntity;
  13. use Neon\Configurator\Neon6Configurator;
  14. use Neon\Configurator\Services\Calculators\CalculationContextFactory;
  15. use Neon\Configurator\Services\Calculators\CalculatorService;
  16. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent;
  17. use Shopware\Core\Content\Category\Service\CategoryBreadcrumbBuilder;
  18. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  19. use Shopware\Core\Content\Property\PropertyGroupEntity;
  20. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  22. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  23. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  24. use Shopware\Core\Framework\DataAbstractionLayer\Search\Grouping\FieldGrouping;
  25. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  26. use Shopware\Core\Framework\Struct\ArrayStruct;
  27. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  29. class ConfigurationLoader
  30. {
  32.     private EntityRepository $configurationRepository;
  34.     private EntityRepository $commoncalculationRepository;
  36.     private EntityRepository $fieldRepository;
  38.     private TwigRenderer $twigRenderer;
  40.     private CategoryBreadcrumbBuilder $breadcrumbBuilder;
  42.     private ProductMediaService $productMediaService;
  43.     private $productRepository;
  44.     private $productStreamBuilder;
  45.     private CalculatorService $calculationService;
  46.     private CalculationContextFactory $calculationContextFactory;
  48.     public function __construct($configurationRepository,
  49.                                 $fieldRepository,
  50.                                 $commoncalculationRepository,
  51.                                 $twigRenderer,
  52.                                 $breadcrumbBuilder,
  53.                                 $productMediaService,
  54.                                 $productRepository,
  55.                                 $productStreamBuilder,
  56.                                 $calculationService,
  57.                                 Calculators\CalculationContextFactory $calculationContextFactory)
  58.     {
  59.         $this->configurationRepository = $configurationRepository;
  60.         $this->fieldRepository = $fieldRepository;
  61.         $this->commoncalculationRepository = $commoncalculationRepository;
  62.         $this->twigRenderer = $twigRenderer;
  63.         $this->breadcrumbBuilder = $breadcrumbBuilder;
  64.         $this->productMediaService = $productMediaService;
  65.         $this->productRepository = $productRepository;
  66.         $this->productStreamBuilder = $productStreamBuilder;
  67.         $this->calculationService = $calculationService;
  68.         $this->calculationContextFactory = $calculationContextFactory;
  69.     }
  72.     /**
  73.      * @param SalesChannelProductEntity $product
  74.      * @param SalesChannelContext $context
  75.      * @return ConfigurationEntity|null
  76.      * @throws \Twig\Error\LoaderError
  77.      * @throws \Twig\Error\SyntaxError
  78.      */
  79.     public function loadFullConfigurationByProduct(SalesChannelProductEntity $product, SalesChannelContext $context, $skipMedia = false)
  80.     {
  81.         return $this->load(function ($configId, $product, $context, $skipMedia) {
  82.             return $this->loadFullConfiguration($configId, $product, $context, $skipMedia);
  83.         }, $product, $context, $skipMedia);
  84.     }
  88.     public function loadFullConfigurationByProductId(string $productId, $context)
  89.     {
  90.         $product = $this->productRepository->search(new Criteria([$productId]), $context)->first();
  91.         return $this->loadFullConfigurationByProduct($product, $context);
  92.     }
  94.     /**
  95.      * @param SalesChannelProductEntity $product
  96.      * @param BeforeLineItemAddedEvent $event
  97.      * @return ConfigurationEntity
  98.      */
  99.     public function loadWithFields(SalesChannelProductEntity $product, SalesChannelContext $context)
  100.     {
  101.         $this->setExtensions($product);
  103.         return $this->load(function ($configId, $product, $context) {
  104.             $criteria = new Criteria([$configId]);
  105.             $criteria->addAssociations(['commoncalculations.calculation']);
  106.             $criteria->addAssociations(['fieldgroups']);
  107.             $criteria->addAssociations(['fieldgroups.fields']);
  108.             $criteria->addAssociations(['fieldgroups.fields.values']);
  109.             $criteria->addAssociations(['fieldgroups.fields.validations']);
  111.             $configuration = $this->configurationRepository->search($criteria, $context->getContext())->first();
  112.             if($configuration !== null) {
  113.                 $this->manuallyAddOneToOneRelationships($configuration, $context);
  114.             }
  115.             return $configuration;
  116.         }, $product, $context);
  118.     }
  120.     public function loadWithoutAssociations(SalesChannelProductEntity $product, SalesChannelContext $context)
  121.     {
  122.         return $this->load(function ($configId, $product, $context) {
  123.             $criteria = new Criteria([$configId]);
  125.             return $this->configurationRepository->search($criteria, $context->getContext())->first();
  126.         }, $product, $context);
  127.     }
  130.     /**
  131.      * @param $configId
  132.      * @param SalesChannelProductEntity $product
  133.      * @param $context
  134.      * @return mixed
  135.      * @throws \Twig\Error\LoaderError
  136.      * @throws \Twig\Error\SyntaxError
  137.      */
  138.     public function loadFullConfiguration($configId, $product, SalesChannelContext $context, $skipMedia = false)
  139.     {
  140.         $this->setExtensions($product);
  142.         $configuration = null;
  143.         if ($configId !== null) {
  145.             $criteria = new Criteria([$configId]);
  146.             $criteria->addAssociations([
  147.                 'commoncalculations'
  148.                 , 'commoncalculations.calculation'
  149.                 , 'fieldgroups.fields'
  150.                 , 'fieldgroups.fields.calculations'
  151.                 , 'fieldgroups.fields.calculations.calculation'
  152.                 , 'fieldgroups.fields.children'
  153.                 , 'fieldgroups.fields.children.validations'
  154.                 , 'fieldgroups.fields.children.values'
  155.                 , 'fieldgroups.fields.children.values.media'
  156.                 , 'fieldgroups.fields.children.visibilities'
  157.                 , 'fieldgroups.fields.validations'
  158.                 , 'fieldgroups.fields.values'
  159.                 , 'fieldgroups.fields.values.product'
  160.                 , 'fieldgroups.fields.values.media'
  161.                 , 'fieldgroups.fields.values.fieldvalueInfos'
  162.                 , 'fieldgroups.fields.visibilities'
  163.                 , 'fieldgroups.fields.productStream'
  164.                 , 'fieldgroups.fields.fieldInfos'
  165.                 , 'medias'
  166.                 , 'medias.media'
  167.                 , 'medias.visibilityCalculation'
  168.             ]);
  169.             $criteria->getAssociation('commoncalculations')
  170.                 ->addSorting(new FieldSorting('position', FieldSorting::ASCENDING));
  171.             $criteria->getAssociation('fieldgroups')
  172.                 ->addSorting(new FieldSorting('position', FieldSorting::ASCENDING));
  173.             $criteria->getAssociation('fieldgroups.fields.children')
  174.                 ->addSorting(new FieldSorting('position', FieldSorting::ASCENDING
  175.                 ));
  177.             $criteria->getAssociation('fieldgroups.fields')
  178.                 ->addFilter(new EqualsFilter('parentId', null))
  179.                 ->addFilter(new EqualsFilter('isActive', 1))
  180.                 ->addSorting(new FieldSorting('position', FieldSorting::ASCENDING));
  181.             $criteria->getAssociation('fieldgroups.fields.values')
  182.                 ->addSorting(new FieldSorting('position', FieldSorting::ASCENDING));
  183.             $criteria->getAssociation('medias')
  184.                 ->addSorting(new FieldSorting('position', FieldSorting::ASCENDING));
  186.             /** @var ConfigurationEntity $configuration */
  187.             $configuration = $this->configurationRepository->search($criteria, $context->getContext())->get($configId);
  189.             if ($configuration != null) {
  190.                 $this->manuallyAddOneToOneRelationships($configuration, $context);
  192.                 $configuration->setCheapestPrice($this->calculationService->calculate($configuration->getCheapestPriceCalculation(), $this->calculationContextFactory->createDefault($product, $configuration, $context)));
  193.                 if (!$skipMedia) {
  194.                     $initialVisibleMedias = $this->productMediaService->getVisibleMediasByDefaultFieldvalues($product, $configuration, $context);
  195.                     $initialVisibleMedias = array_map(function ($media) {
  196.                         return $media->getMedia();
  197.                     }, $initialVisibleMedias);
  199.                     $configuration->setInitialVisibleMedias($initialVisibleMedias);
  200.                 }
  202.                 foreach ($configuration->getFields() as $field) {
  203.                     if ($field->getSelectValueMode() == 'productStream') {
  204.                         $field->setValues($this->getValuesFromProductStream($field, $context));
  205.                     }
  206.                     if ($field->getSelectValueMode() == 'csv') {
  207.                         $field->setValues($this->getValuesFromCsv($field, $context));
  208.                     }
  209.                 }
  211.                 $this->renderTwigTemplates($configuration, $product, $context);
  213.             }
  214.         }
  215.         return $configuration;
  216.     }
  219.     private function load($loader, SalesChannelProductEntity $product, SalesChannelContext $context, $skipMedia = false)
  220.     {
  221.         $config = $this->getAlreadyLoadedConfig($product, $context);
  223.         if ($config == null) {
  224.             $configId = $this->getConfigId($product, $context);
  225.             if ($configId != null) {
  226.                 $config = $loader($configId, $product, $context, $skipMedia);
  227.             }
  228.         }
  229.         return $config;
  230.     }
  232.     protected function renderTwigTemplates(ConfigurationEntity $configuration, SalesChannelProductEntity $product, $context)
  233.     {
  235.         foreach (ConfigurationEntity::TRANSLATABLE_FIELDS as $fieldName) {
  236.             $configuration->$fieldName = $this->twigRenderer->render($configuration->$fieldName, $product);
  237.         }
  239.         foreach ($configuration->getFieldgroups() as $fieldgroup) {
  240.             foreach (FieldgroupEntity::TRANSLATABLE_FIELDS as $fieldName) {
  241.                 $fieldgroup->$fieldName = $this->twigRenderer->render($fieldgroup->$fieldName, $product);
  242.             }
  243.             foreach ($fieldgroup->getFields() as $field) {
  244.                 if (array_key_exists('commoncalculation', $field->getOptions())) {
  245.                     $commoncalculationId = $field->getOptions()['commoncalculation'];
  246.                     $c = new Criteria([$commoncalculationId]);
  247.                     $c->addAssociation('calculation');
  248.                     $options = $field->getOptions();
  249.                     $options['commoncalculation'] = $this->commoncalculationRepository->search($c, $context->getContext())->get($commoncalculationId);
  250.                     $field->setOptions($options);
  251.                 }
  253.                 foreach ($field->getValidations() as $validation) {
  254.                     foreach (FieldvalidationEntity::TRANSLATABLE_FIELDS as $fieldName) {
  255.                         $renderedResult = $this->twigRenderer->render($validation->$fieldName, $product);
  256.                         $validation->$fieldName = $renderedResult;
  257.                     }
  258.                 }
  260.                 foreach ($field->getFieldInfos() as $fieldInfo) {
  261.                     foreach (InfoEntity::TRANSLATABLE_FIELDS as $fieldName) {
  262.                         $renderedResult = $this->twigRenderer->render($fieldInfo->getInfo()->$fieldName, $product);
  263.                         $fieldInfo->getInfo()->$fieldName = $renderedResult;
  264.                     }
  265.                 }
  266.                 foreach (FieldEntity::TRANSLATABLE_FIELDS as $fieldName) {
  267.                     $field->$fieldName = $this->twigRenderer->render($field->$fieldName, $product);
  268.                 }
  269.                 /** @var FieldvalueEntity $value */
  270.                 foreach ($field->getValues() as $value) {
  271.                     $linkedProduct = $value->getHasProduct()
  272.                         ? $this->productRepository->search(new Criteria([$value->getProduct()->getId()]), $context)->first()
  273.                         : null;
  274.                     if ($linkedProduct != null) {
  275.                         $additional = [
  276.                             'linkedProduct' => [
  277.                                 'name' => $linkedProduct->getTranslation('name'),
  278.                                 'price' => $linkedProduct->getCalculatedPrice()->getUnitPrice()
  279.                             ]];
  281.                         if ($linkedProduct->getIsCloseout() && $linkedProduct->getStock() <= 0) {
  282.                             if($value->getVisibilityCalculation() == null) {
  283.                                 $value->setVisibilityCalculation(new CalculationEntity());
  284.                             }
  286.                             $value->getVisibilityCalculation()->setType('simple');
  287.                             $value->getVisibilityCalculation()->setStringFormula('false');
  288.                         }
  289.                     }
  291.                     foreach (FieldvalueEntity::TRANSLATABLE_FIELDS as $fieldName) {
  292.                         $value->$fieldName = $this->twigRenderer->render($value->$fieldName, $product, $additional ?? []);
  293.                     }
  294.                     $options = $value->options;
  295.                     if ($options != null && array_key_exists('priceFormat', $options)) {
  296.                         $options['priceFormat'] = $this->twigRenderer->render($options['priceFormat'], $product, ['price' => $value->getPrice()]);
  297.                         $value->options = $options;
  298.                     }
  299.                 }
  300.             }
  301.         }
  302.     }
  304.     /**
  305.      * @param SalesChannelProductEntity $product
  306.      * @return mixed|null
  307.      */
  308.     private function getConfigId(SalesChannelProductEntity $product, $context)
  309.     {
  310.         $configId = null;
  312.         if (array_key_exists('customFields', $product->getTranslated())
  313.             && array_key_exists(Neon6Configurator::CUSTOMFIELD_PRODUCTS_CONFIG, $product->getTranslated()['customFields'])){
  314.             $configId = $product->getTranslated()['customFields'][Neon6Configurator::CUSTOMFIELD_PRODUCTS_CONFIG];
  315.         }else {
  317.             if ($product->getSeoCategory() == null) {
  318.                 try {
  319.                     $productSeoCategory = $this->breadcrumbBuilder->getProductSeoCategory($product, $context);
  320.                     $product->setSeoCategory($productSeoCategory);
  321.                 } catch (\Exception $e) {
  322.                 }
  323.             }
  324.             if ($product->getSeoCategory() !== null && $product->getSeoCategory()->getCustomFields() != null && array_key_exists(Neon6Configurator::CUSTOMFIELD_CATEGORIES_CONFIG, $product->getSeoCategory()->getCustomFields())) {
  325.                 $configId = $product->getSeoCategory()->getCustomFields()[Neon6Configurator::CUSTOMFIELD_CATEGORIES_CONFIG];
  326.             }
  327.         }
  328.         return $configId;
  329.     }
  331.     private function getAlreadyLoadedConfig(SalesChannelProductEntity $product, $context)
  332.     {
  333.         if (array_key_exists('customFields', $product->getTranslated())
  334.             && array_key_exists(Neon6Configurator::CUSTOMFIELD_PRODUCTS_CONFIG, $product->getTranslated()['customFields'])){
  335.             $config = $product->getTranslated()['customFields'][Neon6Configurator::CUSTOMFIELD_PRODUCTS_CONFIG];
  336.             if ($config instanceof ConfigurationEntity) {
  337.                 return $config;
  338.             }
  339.         }
  340.         return null;
  341.     }
  344.     private function setExtensions(SalesChannelProductEntity $product)
  345.     {
  346.         $product->addExtension('neon_configurator', new ArrayStruct(['properties' => $this->getProperties($product)]));
  347.     }
  349.     /**
  350.      * @param SalesChannelProductEntity $product
  351.      * @return array
  352.      */
  353.     private function getProperties(SalesChannelProductEntity $product): array
  354.     {
  355.         $properties = [];
  356.         if ($product->getSortedProperties() != null) {
  357.             /** @var PropertyGroupEntity $property */
  358.             foreach ($product->getSortedProperties() as $property) {
  359.                 $properties[$property->getName()] = $property->getOptions()->first()->getName();
  360.             }
  361.         }
  362.         return $properties;
  363.     }
  365.     /**
  366.      * @param ConfigurationEntity $configuration
  367.      * @param SalesChannelContext $context
  368.      * @return void
  369.      */
  370.     private function manuallyAddOneToOneRelationships(ConfigurationEntity $configuration, SalesChannelContext $context): void
  371.     {
  372. //        if (Feature::isActive('FEATURE_NEXT_22262')) {
  373. //            return;
  374. //        }
  376.         if ($configuration->getQuantityFieldId()) {
  377.             $configuration->setQuantityField($this->fieldRepository->search(new Criteria([$configuration->getQuantityFieldId()]), $context->getContext())->get($configuration->getQuantityFieldId()));
  378.         }
  379.         if ($configuration->getBlockpriceQuantityFieldId()) {
  380.             $configuration->setBlockpriceQuantityField($this->fieldRepository->search(new Criteria([$configuration->getBlockpriceQuantityFieldId()]), $context->getContext())->get($configuration->getBlockpriceQuantityField()));
  381.         }
  382.     }
  384.     /**
  385.      * @param FieldEntity $field
  386.      * @param SalesChannelContext $context
  387.      * @return FieldvalueCollection
  388.      */
  389.     private function getValuesFromProductStream(FieldEntity $field, SalesChannelContext $context): FieldvalueCollection
  390.     {
  391.         $filters = $this->productStreamBuilder->buildFilters(
  392.             $field->getProductStreamId(),
  393.             $context->getContext()
  394.         );
  395.         $criteria = new Criteria();
  396.         $criteria->addFilter(...$filters);
  397.         $criteria->addAssociation('options.group');
  399.         // Ensure storefront presentation settings of product variants
  400.         $criteria->addGroupField(new FieldGrouping('displayGroup'));
  401.         $criteria->addFilter(
  402.             new NotFilter(
  403.                 NotFilter::CONNECTION_AND,
  404.                 [new EqualsFilter('displayGroup', null)]
  405.             )
  406.         );
  407.         $productsOfStream = $this->productRepository->search($criteria, $context);
  409.         $values = new FieldvalueCollection();
  411.         foreach ($productsOfStream as $productOfStream) {
  412.             $value = new FieldvalueEntity();
  413.             $value->setId($productOfStream->getId());
  414.             $value->setIsDefault(false);
  415.             $value->setHasProduct(true);
  416.             $value->setProductId($productOfStream->getId());
  417.             $value->setProduct($productOfStream);
  418.             $value->setUniqueIdentifier($productOfStream->getId());
  419.             $value->setLabel($productOfStream->getTranslation('name'));
  420.             $value->setValue($productOfStream->getId());
  421.             $value->setPrice('{{linkedProduct.price}}');
  422.             if ($productOfStream->getCover() !== null) {
  423.                 $value->setMedia($productOfStream->getCover()->getMedia());
  424.             }
  425.             $value->setOptions([
  426.                 'productCartMode' => $field->getProductCartMode(),
  427.                 'priceDisplay' => $field->getOptions()['priceDisplay'] ?? 'absolute',
  428.                 'imageSourceType' => 'media',
  429.                 'priceFormat' => $field->getOptions()['priceFormat'],
  430.             ]);
  431.             $values->add($value);
  432.         }
  433.         return $values;
  434.     }
  436.     private function getValuesFromCsv(FieldEntity $field, SalesChannelContext $context)
  437.     {
  438.         $values = new FieldvalueCollection();
  439.         $rows = explode(PHP_EOL,$field->getCsvValues());
  441.         $headerColumns = $field->getCsvColumns();
  443.         foreach($rows as $row) {
  444.             $columns = explode(";", $row);
  445.             $value = new FieldvalueEntity();
  446.             $value->setId(sha1($row));
  447.             $value->setUniqueIdentifier(sha1($row));
  448.             $value->setIsDefault(false);
  449.             $value->setHasProduct(false);
  451.             if(array_search('value', $headerColumns) !== false) {
  452.                 dump(array_search('value', $headerColumns));
  453.                 $value->setValue($columns[array_search('value', $headerColumns)]);
  454.             }
  456.             if(array_search('label', $headerColumns) !== false) {
  457.                 $value->setLabel($columns[array_search('label', $headerColumns)]);
  458.             }
  460.             if(array_search('price', $headerColumns) !== false) {
  461.                 $value->setPrice($columns[array_search('price', $headerColumns)]);
  462.             }
  463.             if(array_search('isDefault', $headerColumns) !== false) {
  464.                 $value->setIsDefault($columns[array_search('isDefault', $headerColumns)]);
  465.             }
  466.             $options = [
  467.                 'imageSourceType' => 'media'
  468.             ];
  470.             if(array_search('priceDisplay', $headerColumns) !== false) {
  471.                 $options['priceDisplay'] = $columns[array_search('priceDisplay', $headerColumns)];
  472.             }
  474.             $value->setOptions($options);
  476.             $values->add($value);
  477.         }
  478.         return $values;
  479.     }
  481. }