hzero:
  oauth:
    social:
      # 如果三方用户未绑定系统用户，是否跳转到绑定账号页面
      attempt-bind: true

public class QQUser implements SocialUser {

    private String ret;

    private String msg;

    private String openId;

    private String nickname;

    private String figureurl;

    private String gender;

    private String unionId;

    // getter/setter...
}

public interface QQApi extends SocialApi {

}

public class DefaultQQApi extends AbstractSocialApi implements QQApi {

    private static final Logger LOGGER = LoggerFactory.getLogger(DefaultQQApi.class);

    private String userInfoUrl;
    private String openIdUrl;

    /**
     * 客户端 appId
     */
    private String appId;
    /**
     * openId
     */
    private String openId;
    /**
     * openId
     */
    private String unionId;

    private static final ObjectMapper mapper = new ObjectMapper();

    public DefaultQQApi(String accessToken, Provider provider) {
        super(accessToken);
        this.appId = provider.getAppId();
        this.userInfoUrl = provider.getUserInfoUrl() + "?oauth_consumer_key={appId}&openid={openId}";
        this.openIdUrl = provider.getOpenIdUrl();
        if (isGetUnionId()) {
            this.openIdUrl += "?unionid=1";
        }
    }

    @Override
    public synchronized QQUser getUser() {
        if (!isAuthorized()) {
            throw new CommonSocialException(SocialErrorCode.SOCIAL_USER_NOT_AUTHORIZED);
        }
        if (StringUtils.isBlank(openId)) {
            QQMe me = getMe();
            this.openId = me.getOpenId();
            this.unionId = me.getUnionId();
        }

        String result = getRestTemplate().getForObject(userInfoUrl, String.class, this.appId, this.openId);

        QQUser user = null;
        try {
            user = mapper.readValue(result, QQUser.class);
        } catch (Exception e) {
            LOGGER.error("parse qq UserInfo error. result : {}", result);
        }
        if (user == null || StringUtils.isBlank(user.getNickname())) {
            LOGGER.info("not found provider user, result user={}", user);
            throw new ProviderUserNotFoundException(SocialErrorCode.PROVIDER_USER_NOT_FOUND);
        }
        user.setOpenId(openId);
        user.setUnionId(unionId);
        return user;
    }

    /**
     * 获取用户 OpenId
     */
    private QQMe getMe() {
        // 返回结构：callback( {"client_id":"YOUR_APPID","openid":"YOUR_OPENID","unionid":"YOUR_UNIONID"} );
        String openIdResult = getRestTemplate().getForObject(openIdUrl, String.class);
        if (StringUtils.isBlank(openIdResult) || openIdResult.contains("error")) {
            LOGGER.warn("request social user's openId return error, result={}", openIdResult);
            throw new CommonSocialException(SocialErrorCode.OPEN_ID_NOT_FOUND);
        }
        // 解析 openId
        String[] arr = StringUtils.substringBetween(openIdResult, "{", "}").replace("\"", "").split(",");

        String openid = null;
        String unionid = null;
        for (String s : arr) {
            if (s.contains("openid")) {
                openid = s.split(":")[1];
            } else if (s.contains("unionid")) {
                unionid = s.split(":")[1];
            }
        }
        return new QQMe(openid, unionid);
    }

    private boolean isGetUnionId() {
        SocialProperties socialProperties = ApplicationContextHelper.getContext().getBean(SocialProperties.class);
        return socialProperties.getQq().isGetUnionId();
    }

    private class QQMe {
        private String openId;
        private String unionId;

        public QQMe(String openId, String unionId) {
            this.openId = openId;
            this.unionId = unionId;
        }

        public String getOpenId() {
            return openId;
        }

        public String getUnionId() {
            return unionId;
        }
    }
}

public class QQApiAdapter extends SocialApiAdapter {
    /**
     * QQApi 与 Connection 做适配
     * @param api QQApi
     * @param values Connection
     */
    @Override
    public void setConnectionValues(SocialApi api, ConnectionValues values) {
        // 调用三方接口获取用户信息
        QQUser user = (QQUser) api.getUser();
        // 设置昵称
        values.setDisplayName(user.getNickname());
        values.setImageUrl(user.getFigureurl());
        // 设置 open_id
        values.setProviderUserId(user.getOpenId());
    }
}

public class QQServiceProvider extends SocialServiceProvider {

    private Provider provider;

    public QQServiceProvider(Provider provider, SocialTemplate template) {
        super(provider, template);
        this.provider = provider;
    }

    @Override
    public QQApi getSocialApi(String accessToken) {
        // 构造服务提供商API
        return new DefaultQQApi(accessToken, provider);
    }
}

public class QQTemplate extends SocialTemplate {

    private static final Logger LOGGER = LoggerFactory.getLogger(QQTemplate.class);

    public QQTemplate(Provider provider) {
        super(provider);
        // 设置带上 client_id、client_secret
        setUseParametersForClientAuthentication(true);
    }

    /**
     * 解析 QQ 返回的令牌
     */
    @Override
    protected AccessGrant postForAccessGrant(String accessTokenUrl, MultiValueMap<String, String> parameters) {
        // 返回格式：access_token=FE04********CCE2&expires_in=7776000&refresh_token=88E4***********BE14
        String result = getRestTemplate().postForObject(accessTokenUrl, parameters, String.class);
        if (StringUtils.isBlank(result)) {
            throw new RestClientException("access token endpoint returned empty result");
        }
        LOGGER.debug("==> get qq access_token: " + result);
        String[] arr = StringUtils.split(result, "&");
        String accessToken = "", expireIn = "", refreshToken = "";
        for (String s : arr) {
            if (s.contains("access_token")) {
                accessToken = s.split("=")[1];
            } else if (s.contains("expires_in")) {
                expireIn = s.split("=")[1];
            } else if (s.contains("refresh_token")) {
                refreshToken = s.split("=")[1];
            }
        }
        return createAccessGrant(accessToken, null, refreshToken, Long.valueOf(expireIn), null);
    }

    /**
     * QQ 响应 ContentType=text/html;因此需要加入 text/html; 的处理器
     */
    @Override
    protected RestTemplate createRestTemplate() {
        RestTemplate restTemplate = super.createRestTemplate();
        restTemplate.getMessageConverters().add(new StringHttpMessageConverter(Charsets.UTF_8));
        return restTemplate;
    }
}

@Configuration
public class QQSocialBuilder implements SocialConnectionFactoryBuilder {

    @Override
    public String getProviderId() {
        return ProviderEnum.qq.name();
    }

    @Override
    public SocialConnectionFactory buildConnectionFactory(Provider provider) {
        // 获取授权码地址
        final String URL_AUTHORIZE = "https://graph.qq.com/oauth2.0/authorize";
        // 获取令牌地址
        final String URL_GET_ACCESS_TOKEN = "https://graph.qq.com/oauth2.0/token";
        // 获取 openId 的地址
        final String URL_GET_OPEN_ID = "https://graph.qq.com/oauth2.0/me";
        // 获取用户信息的地址
        final String URL_GET_USER_INFO = "https://graph.qq.com/user/get_user_info";

        provider.setAuthorizeUrl(URL_AUTHORIZE);
        provider.setAccessTokenUrl(URL_GET_ACCESS_TOKEN);
        provider.setOpenIdUrl(URL_GET_OPEN_ID);
        provider.setUserInfoUrl(URL_GET_USER_INFO);
        // 创建适配器
        QQApiAdapter apiAdapter = new QQApiAdapter();
        // 创建三方模板
        QQTemplate template = new QQTemplate(provider);
        // 创建服务提供商
        QQServiceProvider serviceProvider = new QQServiceProvider(provider, template);
        // 创建连接工厂
        return new QQConnectionFactory(provider, serviceProvider, apiAdapter);
    }
}

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
org.hzero.starter.social.qq.config.QQSocialBuilder