suninformation / ymate-module-oauth-connector Goto Github PK

               if (StringUtils.equals(_gender, "m")) {
                        _connectUser.setGender(OAuthConnectUser.Gender.FAMALE);
                    } else if (StringUtils.equals(_gender, "f")) {
                        _connectUser.setGender(OAuthConnectUser.Gender.MALE);
                    }

 @Override
    protected JSONObject doParseConnectResponseBody(Response response) throws Exception {
        if (response != null && response.isSuccessful()) {
            JSONObject result;
            String body = response.body().string();
            if (StringUtils.startsWith(body, "callback")) {
                result = JSON.parseObject(StringUtils.substringBetween(body, "callback(", ");"));
            } else {
                //access_token=DA63BF6EB946DFD8D428ECFF8CE424E6&expires_in=7776000&refresh_token=786729E3D4001CA99D4881DF94BFA9B1
                Map<String, String> queryPairs = splitQuery(body);
                result = new JSONObject();
                for (Map.Entry<String, String> entry : queryPairs.entrySet()) {
                    result.put(entry.getKey(), entry.getValue());
                }
            }
            if (result.containsKey("error")) {
                throw new RuntimeException(result.toJSONString());
            }
            return result;
        }
        return null;
    }

    public static Map<String, String> splitQuery(String query) throws UnsupportedEncodingException {
        System.out.println("body:" + query);
        Map<String, String> query_pairs = new LinkedHashMap<>();
        String[] pairs = query.split("&");
        for (String pair : pairs) {
            int idx = pair.indexOf("=");
            query_pairs.put(URLDecoder.decode(pair.substring(0, idx), "UTF-8"), URLDecoder.decode(pair.substring(idx + 1), "UTF-8"));
        }
        return query_pairs;
    }