MDEE-463: inventory exporter warning (#273)

Author: mslabko

InventoryDataExporter/Plugin/BulkSourceUnassign.php

@@ -5,6 +5,7 @@
  */
 namespace Magento\InventoryDataExporter\Plugin;
 
+use Magento\DataExporter\Model\Logging\CommerceDataExportLoggerInterface;
 use Magento\InventoryCatalogApi\Api\BulkSourceUnassignInterface;
 use Magento\InventoryDataExporter\Model\Provider\StockStatusIdBuilder;
 use Magento\InventoryDataExporter\Model\Query\StockStatusDeleteQuery;
@@ -14,18 +15,20 @@
  */
 class BulkSourceUnassign
 {
-    /**
-     * @var StockStatusDeleteQuery
-     */
-    private $stockStatusDeleteQuery;
+    private StockStatusDeleteQuery $stockStatusDeleteQuery;
+
+    private CommerceDataExportLoggerInterface $logger;
 
     /**
      * @param StockStatusDeleteQuery $stockStatusDeleteQuery
+     * @param CommerceDataExportLoggerInterface $logger
      */
     public function __construct(
-        StockStatusDeleteQuery $stockStatusDeleteQuery
+        StockStatusDeleteQuery $stockStatusDeleteQuery,
+        CommerceDataExportLoggerInterface $logger
     ) {
         $this->stockStatusDeleteQuery = $stockStatusDeleteQuery;
+        $this->logger = $logger;
     }
 
     /**
@@ -45,12 +48,16 @@ public function afterExecute(
         array $skus,
         array $sourceCodes
     ): int {
-        $sourcesAssignedToProducts = $this->stockStatusDeleteQuery->getStocksAssignedToSkus($skus);
-        $sourcesByStocks = $this->stockStatusDeleteQuery->getStocksWithSources($sourceCodes);
-        $stocksToDelete = $this->getStocksToDelete($skus, $sourcesByStocks, $sourcesAssignedToProducts);
+        try {
+            $sourcesAssignedToProducts = $this->stockStatusDeleteQuery->getStocksAssignedToSkus($skus);
+            $sourcesByStocks = $this->stockStatusDeleteQuery->getStocksWithSources($sourceCodes);
+            $stocksToDelete = $this->getStocksToDelete($skus, $sourcesByStocks, $sourcesAssignedToProducts);
 
-        if (!empty($stocksToDelete)) {
-            $this->stockStatusDeleteQuery->markStockStatusesAsDeleted($stocksToDelete);
+            if (!empty($stocksToDelete)) {
+                $this->stockStatusDeleteQuery->markStockStatusesAsDeleted($stocksToDelete);
+            }
+        } catch (\Throwable $e) {
+            $this->logger->warning('Bulk source unassign error', ['exception' => $e]);
         }
 
         return $result;

InventoryDataExporter/Plugin/MarkItemsAsDeleted.php

@@ -5,6 +5,7 @@
  */
 namespace Magento\InventoryDataExporter\Plugin;
 
+use Magento\DataExporter\Model\Logging\CommerceDataExportLoggerInterface;
 use Magento\Inventory\Model\ResourceModel\SourceItem\DeleteMultiple;
 use Magento\InventoryApi\Api\Data\SourceItemInterface;
 use Magento\InventoryDataExporter\Model\Provider\StockStatusIdBuilder;
@@ -15,18 +16,19 @@
  */
 class MarkItemsAsDeleted
 {
-    /**
-     * @var StockStatusDeleteQuery
-     */
-    private $stockStatusDeleteQuery;
+    private StockStatusDeleteQuery $stockStatusDeleteQuery;
+    private CommerceDataExportLoggerInterface $logger;
 
     /**
      * @param StockStatusDeleteQuery $stockStatusDeleteQuery
+     * @param CommerceDataExportLoggerInterface $logger
      */
     public function __construct(
-        StockStatusDeleteQuery $stockStatusDeleteQuery
+        StockStatusDeleteQuery $stockStatusDeleteQuery,
+        CommerceDataExportLoggerInterface $logger
     ) {
         $this->stockStatusDeleteQuery = $stockStatusDeleteQuery;
+        $this->logger = $logger;
     }
 
     /**
@@ -42,18 +44,22 @@ public function beforeExecute(
         DeleteMultiple $subject,
         array $sourceItems
     ): void {
-        $deletedSourceItems = [];
-        foreach ($sourceItems as $sourceItem) {
-            $deletedSourceItems[$sourceItem->getSku()][] = $sourceItem->getSourceCode();
-        }
+        try {
+            $deletedSourceItems = [];
+            foreach ($sourceItems as $sourceItem) {
+                $deletedSourceItems[$sourceItem->getSku()][] = $sourceItem->getSourceCode();
+            }
 
-        $fetchedSourceItems = $this->stockStatusDeleteQuery->getStocksAssignedToSkus(array_keys($deletedSourceItems));
+            $fetchedSourceItems = $this->stockStatusDeleteQuery->getStocksAssignedToSkus(array_keys($deletedSourceItems));
 
-        if (!empty($fetchedSourceItems)) {
-            $stocksToDelete = $this->getStocksToDelete($deletedSourceItems, $fetchedSourceItems);
-        }
-        if (!empty($stocksToDelete)) {
-            $this->stockStatusDeleteQuery->markStockStatusesAsDeleted($stocksToDelete);
+            if (!empty($fetchedSourceItems)) {
+                $stocksToDelete = $this->getStocksToDelete($deletedSourceItems, $fetchedSourceItems);
+            }
+            if (!empty($stocksToDelete)) {
+                $this->stockStatusDeleteQuery->markStockStatusesAsDeleted($stocksToDelete);
+            }
+        } catch (\Throwable $e) {
+            $this->logger->warning('Multiple source delete error', ['exception' => $e]);
         }
     }
 
@@ -68,6 +74,9 @@ private function getStocksToDelete(array $deletedSourceItems, array $fetchedSour
     {
         $stocksToDelete = [];
         foreach ($deletedSourceItems as $deletedItemSku => $deletedItemSources) {
+            if (!isset($fetchedSourceItems[$deletedItemSku])) {
+                continue ;
+            }
             foreach ($fetchedSourceItems[$deletedItemSku] as $fetchedItemStockId => $fetchedItemSources) {
                 if ($this->isContainsAllKeys($fetchedItemSources, $deletedItemSources)) {
                     $stockStatusId = StockStatusIdBuilder::build(