resourceConnection = $resourceConnection; } /** * @param string[] $sourceCodes * @return int[] */ public function execute(array $sourceCodes): array { $connection = $this->resourceConnection->getConnection(); $sourceStockLinkTable = $this->resourceConnection->getTableName( StockSourceLinkResourceModel::TABLE_NAME_STOCK_SOURCE_LINK ); $select = $connection ->select() ->from($sourceStockLinkTable, StockSourceLink::STOCK_ID) ->where(StockSourceLink::SOURCE_CODE . ' IN (?)', $sourceCodes) ->group(StockSourceLink::STOCK_ID); $stockIds = $connection->fetchCol($select); $stockIds = array_map('intval', $stockIds); return $stockIds; } }