MDEE-40:[Commerce Export] Implement stock_item_status feed

- use product id instead of sku: changelog table can work only with integers

Author: mslabko

InventoryDataExporter/Model/Provider/StockStatus.php

@@ -65,20 +65,20 @@ public function __construct(
      */
     public function get(array $values): array
     {
-        $skus = \array_column($values, 'sku');
+        $productIds = \array_column($values, 'productId');
         $connection = $this->resourceConnection->getConnection();
         $output = [];
 
         try {
-            $select = $this->query->getQuery($skus);
+            $select = $this->query->getQuery($productIds);
             $cursor = $connection->query($select);
-            $processedSkus = [];
+            $processedIds = [];
             while ($row = $cursor->fetch()) {
-                $processedSkus[] = $row['sku'];
+                $processedIds[] = $row['productId'];
                 $output[] = $this->fillWithDefaultValues($row);
             }
 
-            $select = $this->query->getQueryForDefaultStock(\array_diff($skus, $processedSkus));
+            $select = $this->query->getQueryForDefaultStock(\array_diff($productIds, $processedIds));
             $cursor = $connection->query($select);
             while ($row = $cursor->fetch()) {
                 $output[] = $this->fillWithDefaultValues($row);

InventoryDataExporter/Model/Query/InventoryStockQuery.php

@@ -51,11 +51,10 @@ private function getTable(string $tableName): string
     /**
      * Get query for provider
      *
-     * @param array $skus
-     * @param bool $defaultStock
+     * @param array $productIds
      * @return Select
      */
-    public function getQuery(array $skus): Select
+    public function getQuery(array $productIds): Select
     {
         $connection = $this->resourceConnection->getConnection();
         foreach ($this->getStocks() as $stockId) {
@@ -65,12 +64,19 @@ public function getQuery(array $skus): Select
             }
             $select = $connection->select()
                 ->from(['isi' => $this->getTable(sprintf('inventory_stock_%s', $stockId))], [])
-                ->where('isi.sku IN (?)', $skus)
+                ->joinInner(
+                    [
+                        'product' => $this->resourceConnection->getTableName('catalog_product_entity'),
+                    ],
+                    'product.sku = isi.sku',
+                    []
+                )->where('product.entity_id IN (?)', $productIds)
                 ->columns(
                     [
+                        'sku' => "isi.sku",
+                        'productId' => "product.entity_id",
                         'qty' => "isi.quantity",
                         'isSalable' => "isi.is_salable",
-                        'sku' => "isi.sku",
                         'stockId' => new Expression($stockId),
                         'manageStock' => new Expression(1),
                         'useConfigManageStock' => new Expression(1),
@@ -87,17 +93,17 @@ public function getQuery(array $skus): Select
     /**
      * Get data for default stock: "inventory_stock_1" is a view used as a fallback
      *
-     * @param array $skus
+     * @param array $productIds
      * @return Select
      * @see \Magento\InventoryCatalog\Setup\Patch\Schema\CreateLegacyStockStatusView
      */
-    public function getQueryForDefaultStock(array $skus): Select
+    public function getQueryForDefaultStock(array $productIds): Select
     {
         $connection = $this->resourceConnection->getConnection();
         $stockId = $this->defaultStockProvider->getId();
         $select = $connection->select()
             ->from(['isi' => $this->getTable(sprintf('inventory_stock_%s', $stockId))], [])
-            ->where('isi.sku IN (?)', $skus)
+            ->where('stock_item.product_id IN (?)', $productIds)
             ->joinInner(
                 [
                     'stock_item' => $this->resourceConnection->getTableName('cataloginventory_stock_item'),
@@ -106,9 +112,10 @@ public function getQueryForDefaultStock(array $skus): Select
                 []
             )->columns(
                 [
+                    'sku' => "isi.sku",
+                    'productId' => "stock_item.product_id",
                     'qty' => "isi.quantity",
                     'isSalable' => "isi.is_salable",
-                    'sku' => "isi.sku",
                     'stockId' => new Expression($stockId),
                     'manageStock' => 'stock_item.manage_stock',
                     'useConfigManageStock' => 'stock_item.use_config_manage_stock',

InventoryDataExporter/etc/di.xml

@@ -24,10 +24,10 @@
     <virtualType name="Magento\InventoryDataExporter\Model\Indexer\StockStatusFeedIndexMetadata" type="Magento\DataExporter\Model\Indexer\FeedIndexMetadata">
         <arguments>
             <argument name="feedName" xsi:type="string">stock_statuses</argument>
-            <argument name="feedIdentity" xsi:type="string">sku</argument>
+            <argument name="feedIdentity" xsi:type="string">productId</argument>
             <!--  source table used only during full reindex -->
             <argument name="sourceTableName" xsi:type="string">catalog_product_entity</argument>
-            <argument name="sourceTableField" xsi:type="string">sku</argument>
+            <argument name="sourceTableField" xsi:type="string">entity_id</argument>
             <argument name="feedTableName" xsi:type="string">inventory_data_exporter_stock_status</argument>
             <argument name="feedTableField" xsi:type="string">id</argument>
             <argument name="feedTableMutableColumns" xsi:type="array">