Batch size proccess of affected products after category update (#811)

Author: bsuravech

Model/Indexer/Category.php

@@ -101,18 +101,23 @@ public function executeRow($id)
      */
     private function rebuildAffectedProducts($storeId)
     {
-        $affectedProductsCount = count(self::$affectedProductIds);
+        $affectedProducts = self::$affectedProductIds;
+        $affectedProductsCount = count($affectedProducts);
+
         if ($affectedProductsCount > 0 && $this->configHelper->indexProductOnCategoryProductsUpdate($storeId)) {
-            /** @uses Data::rebuildStoreProductIndex() */
-            $this->queue->addToQueue(
-                Data::class,
-                'rebuildStoreProductIndex',
-                [
-                    'store_id' => $storeId,
-                    'product_ids' => self::$affectedProductIds,
-                ],
-                $affectedProductsCount
-            );
+            $productsPerPage = $this->configHelper->getNumberOfElementByPage();
+            foreach (array_chunk($affectedProducts, $productsPerPage) as $chunk) {
+                /** @uses Data::rebuildStoreProductIndex() */
+                $this->queue->addToQueue(
+                    Data::class,
+                    'rebuildStoreProductIndex',
+                    [
+                        'store_id' => $storeId,
+                        'product_ids' => $chunk,
+                    ],
+                    count($chunk)
+                );
+            }
         }
     }