resourceConnection = $resourceConnection; } /** * Resolve customer group from db * * @param int $customerId * @return int|null */ public function resolve(int $customerId) : ?int { $result = null; $connection = $this->resourceConnection->getConnection(); $tableName = $this->resourceConnection->getTableName('customer_entity'); $query = $connection ->select() ->from( ['main_table' => $tableName], ['main_table.group_id'] ) ->where('main_table.entity_id = ?', $customerId); $groupId = $connection->fetchOne($query); if ($groupId) { $result = (int) $groupId; } return $result; } }