resourceConnection = $resourceConnection; $this->getProductIdsBySkus = $getProductIdsBySkus; } /** * @param string $sku * @param float $quantity * @param int $status * @return void */ public function execute(string $sku, float $quantity, int $status) { $productIds = $this->getProductIdsBySkus->execute([$sku]); if (isset($productIds[$sku])) { $productId = $productIds[$sku]; $connection = $this->resourceConnection->getConnection(); $connection->update( $this->resourceConnection->getTableName('cataloginventory_stock_item'), [ StockItemInterface::QTY => $quantity, StockItemInterface::IS_IN_STOCK => $status, ], [ StockItemInterface::PRODUCT_ID . ' = ?' => $productId, 'website_id = ?' => 0, ] ); } } }