MDEE-974: Product Feed index taking long time to execute

Author: le0n4ik

CatalogDataExporter/Model/Provider/Products.php

@@ -137,10 +137,10 @@ public function execute(
                 if ($storeViewItemN[$storeViewCode] % $metadata->getBatchSize() == 0
                     || count($mappedProducts) % $metadata->getBatchSize() == 0) {
                     $this->processProducts(
-                        ['storeViewCode' => $mappedProducts[$storeViewCode]],
-                        ['storeViewCode' => $attributesData[$storeViewCode]],
+                        $mappedProducts,
+                        $attributesData,
                         $dataProcessorCallback,
-                        $metadata
+                        $storeViewCode
                     );
                     unset($mappedProducts[$storeViewCode], $attributesData[$storeViewCode]);
                 }
@@ -158,7 +158,7 @@ public function execute(
                 )
             );
         } else {
-            $this->processProducts($mappedProducts, $attributesData, $dataProcessorCallback, $metadata);
+            $this->processProducts($mappedProducts, $attributesData, $dataProcessorCallback);
         }
     }
 
@@ -179,25 +179,28 @@ public function get(array $values) : array
      * @param array $mappedProducts
      * @param array $attributesData
      * @param callable $dataProcessorCallback
-     * @param FeedIndexMetadata $metadata
+     * @param string|null $storeViewCode
      * @return void
      * @throws UnableRetrieveData
      */
     private function processProducts(
         array $mappedProducts,
         array $attributesData,
         callable $dataProcessorCallback,
-        FeedIndexMetadata $metadata
+        string $storeViewCode = null
     ): void {
         $output = [];
-
-        foreach ($mappedProducts as $storeCode => $products) {
-            $output[] = \array_map(function ($row) {
-                return $this->formatter->format($row);
-            }, \array_replace_recursive(
-                $products,
-                $this->entityEavAttributesResolver->resolve($attributesData[$storeCode], $storeCode)
-            ));
+        if (null === $storeViewCode) {
+            foreach ($mappedProducts as $mappedStoreViewCode => $products) {
+                $this->formatOutput($products, $attributesData[$storeViewCode], $output, $mappedStoreViewCode);
+            }
+        } else {
+            $this->formatOutput(
+                $mappedProducts[$storeViewCode],
+                $attributesData[$storeViewCode],
+                $output,
+                $storeViewCode
+            );
         }
 
         $errorEntityIds = [];
@@ -218,4 +221,28 @@ private function processProducts(
 
         $dataProcessorCallback($this->get(\array_merge(...$output)));
     }
+
+    /**
+     * Format output
+     *
+     * @param array $products
+     * @param array $attributesData
+     * @param array $output
+     * @param string $storeViewCode
+     * @return void
+     * @throws UnableRetrieveData
+     */
+    private function formatOutput(
+        array $products,
+        array $attributesData,
+        array &$output,
+        string $storeViewCode
+    ): void {
+        $output[] = \array_map(function ($row) {
+            return $this->formatter->format($row);
+        }, \array_replace_recursive(
+            $products,
+            $this->entityEavAttributesResolver->resolve($attributesData, $storeViewCode)
+        ));
+    }
 }