resourceConnection = $resourceConnection; } /** * @inheritdoc */ public function execute(array $salesChannels, int $stockId): void { $connection = $this->resourceConnection->getConnection(); $tableName = $this->resourceConnection->getTableName('inventory_stock_sales_channel'); $connection->delete($tableName, ['stock_id = ?' => $stockId]); if (count($salesChannels)) { $salesChannelsToInsert = []; foreach ($salesChannels as $salesChannel) { $salesChannelsToInsert[] = [ SalesChannelInterface::TYPE => $salesChannel->getType(), SalesChannelInterface::CODE => $salesChannel->getCode(), 'stock_id' => $stockId, ]; } $connection->insertOnDuplicate($tableName, $salesChannelsToInsert); } } }