MSI-2733: Improve performance of re-indexation after SourceItem saved.

Fix static tests.
Stepa4man · Dec 2, 2019 · 85d5e0a · 85d5e0a
1 parent 0f9578a
commit 85d5e0a
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/InventoryIndexer/Indexer/SourceItem/GetSourceItemIds.php b/InventoryIndexer/Indexer/SourceItem/GetSourceItemIds.php
@@ -30,14 +30,16 @@ public function __construct(ResourceConnection $resourceConnection)
     }
 
     /**
+     * Retrieve source items ids.
+     *
      * @param SourceItemInterface[] $sourceItems
      * @return array
      */
     public function execute(array $sourceItems): array
     {
         $connection = $this->resourceConnection->getConnection();
         $skusBySourceCode = [];
-        $sourceItemIds = [];
+        $sourceItemIds = [[]];
         foreach ($sourceItems as $sourceItem) {
             $skusBySourceCode[$sourceItem->getSourceCode()][] = $sourceItem->getSku();
         }
@@ -47,8 +49,9 @@ public function execute(array $sourceItems): array
                     $this->resourceConnection->getTableName(SourceItemResourceModel::TABLE_NAME_SOURCE_ITEM),
                     [SourceItemResourceModel::ID_FIELD_NAME]
                 )->where('sku IN (?)', $skus)->where('source_code = ?', $sourceCode);
-            $sourceItemIds = array_merge($sourceItemIds, $connection->fetchCol($select));
+            $sourceItemIds[] = $connection->fetchCol($select);
         }
+        $sourceItemIds = array_merge(...$sourceItemIds);
 
         return $sourceItemIds;
     }