java微信登录授权源码java

package org.liufeng.course.util; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.util.ArrayList; import java.util.List; import javax.net.ssl.HttpsURLConnection; import net.sf.json.JSONArray; import net.sf.json.JSONException; import net.sf.json.JSONObject; import org.liufeng.course.message.resp.Article; import org.liufeng.course.message.resp.Music; import org.liufeng.course.pojo.SNSUserInfo; import org.liufeng.course.pojo.WeixinGroup; import org.liufeng.course.pojo.WeixinMedia; import org.liufeng.course.pojo.WeixinOauth2Token; import org.liufeng.course.pojo.WeixinQRCode; import org.liufeng.course.pojo.WeixinUserInfo; import org.liufeng.course.pojo.WeixinUserList; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * 高级接口工具类 * * @author liufeng * @date 2013-11-9 */ public class AdvancedUtil { private static Logger log = LoggerFactory.getLogger(AdvancedUtil.class); /** * 组装文本客服消息 * * @param openId 消息发送对象 * @param content 文本消息内容 * @return */ public static String makeTextCustomMessage(String openId, String content) { // 对消息内容中的双引号进行转义 content = content.replace("\"", "\\\""); String jsonMsg = "{\"touser\":\"%s\",\"msgtype\":\"text\",\"text\":{\"content\":\"%s\"}}"; return String.format(jsonMsg, openId, content); } /** * 组装图片客服消息 * * @param openId 消息发送对象 * @param mediaId 媒体文件id * @return */ public static String makeImageCustomMessage(String openId, String mediaId) { String jsonMsg = "{\"touser\":\"%s\",\"msgtype\":\"image\",\"image\":{\"media_id\":\"%s\"}}"; return String.format(jsonMsg, openId, mediaId); } /** * 组装语音客服消息 * * @param openId 消息发送对象 * @param mediaId 媒体文件id * @return */ public static String makeVoiceCustomMessage(String openId, String mediaId) { String jsonMsg = "{\"touser\":\"%s\",\"msgtype\":\"voice\",\"voice\":{\"media_id\":\"%s\"}}"; return String.format(jsonMsg, openId, mediaId); } /** * 组装视频客服消息 * * @param openId 消息发送对象 * @param mediaId 媒体文件id * @param thumbMediaId 视频消息缩略图的媒体id * @return */ public static String makeVideoCustomMessage(String openId, String mediaId, String thumbMediaId) { String jsonMsg = "{\"touser\":\"%s\",\"msgtype\":\"video\",\"video\":{\"media_id\":\"%s\",\"thumb_media_id\":\"%s\"}}"; return String.format(jsonMsg, openId, mediaId, thumbMediaId); } /** * 组装音乐客服消息 * * @param openId 消息发送对象 * @param music 音乐对象 * @return */ public static String makeMusicCustomMessage(String openId, Music music) { String jsonMsg = "{\"touser\":\"%s\",\"msgtype\":\"music\",\"music\":%s}"; jsonMsg = String.format(jsonMsg, openId, JSONObject.fromObject(music).toString()); // 将jsonMsg中的thumbmediaid替换为thumb_media_id jsonMsg = jsonMsg.replace("thumbmediaid", "thumb_media_id"); return jsonMsg; } /** * 组装图文客服消息 * * @param openId 消息发送对象 * @param articleList 图文消息列表 * @return */ public static String makeNewsCustomMessage(String openId, List<Article> articleList) { String jsonMsg = "{\"touser\":\"%s\",\"msgtype\":\"news\",\"news\":{\"articles\":%s}}"; jsonMsg = String.format(jsonMsg, openId, JSONArray.fromObject(articleList).toString().replaceAll("\"", "\\\"")); // 将jsonMsg中的picUrl替换为picurl jsonMsg = jsonMsg.replace("picUrl", "picurl"); return jsonMsg; } /** * 发送客服消息 * * @param accessToken 接口访问凭证 * @param jsonMsg json格式的客服消息（包括touser、msgtype和消息内容） * @return true | false */ public static boolean sendCustomMessage(String accessToken, String jsonMsg) { log.info("消息内容：{}", jsonMsg); boolean result = false; // 拼接请求地址 String requestUrl = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=ACCESS_TOKEN"; requestUrl = requestUrl.replace("ACCESS_TOKEN", accessToken); // 发送客服消息 JSONObject jsonObject = CommonUtil.httpsRequest(requestUrl, "POST", jsonMsg); if (null != jsonObject) { int errorCode = jsonObject.getInt("errcode"); String errorMsg = jsonObject.getString("errmsg"); if (0 == errorCode) { result = true; log.info("客服消息发送成功 errcode:{} errmsg:{}", errorCode, errorMsg); } else { log.error("客服消息发送失败 errcode:{} errmsg:{}", errorCode, errorMsg); } } return result; } /** * 获取网页授权凭证 * * @param appId 公众账号的唯一标识 * @param appSecret 公众账号的密钥 * @param code * @return WeixinAouth2Token */ public static WeixinOauth2Token getOauth2AccessToken(String appId, String appSecret, String code) { WeixinOauth2Token wat = null; // 拼接请求地址 String requestUrl = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=APPID&secret=SECRET&code=CODE&grant_type=authorization_code"; requestUrl = requestUrl.replace("APPID", appId); requestUrl = requestUrl.replace("SECRET", appSecret); requestUrl = requestUrl.replace("CODE", code); // 获取网页授权凭证 JSONObject jsonObject = CommonUtil.httpsRequest(requestUrl, "GET", null); if (null != jsonObject) { try { wat = new WeixinOauth2Token(); wat.setAccessToken(jsonObject.getString("access_token")); wat.setExpiresIn(jsonObject.getInt("expires_in")); wat.setRefreshToken(jsonObject.getString("refresh_token")); wat.setOpenId(jsonObject.getString("openid")); wat.setScope(jsonObject.getString("scope")); } catch (Exception e) { wat = null; int errorCode = jsonObject.getInt("errcode"); String errorMsg = jsonObject.getString("errmsg"); log.error("获取网页授权凭证失败 errcode:{} errmsg:{}", errorCode, errorMsg); } } return wat; } /** * 刷新网页授权凭证 * * @param appId 公众账号的唯一标识 * @param refreshToken * @return WeixinAouth2Token */ public static WeixinOauth2Token refreshOauth2AccessToken(String appId, String refreshToken) { WeixinOauth2Token wat = null; // 拼接请求地址 String requestUrl = "https://api.weixin.qq.com/sns/oauth2/refresh_token?appid=APPID&grant_type=refresh_token&refresh_token=REFRESH_TOKEN"; requestUrl = requestUrl.replace("APPID", appId); requestUrl = requestUrl.replace("REFRESH_TOKEN", refreshToken); // 刷新网页授权凭证 JSONObject jsonObject = CommonUtil.httpsRequest(requestUrl, "GET", null); if (null != jsonObject) { try { wat = new WeixinOauth2Token(); wat.setAccessToken(jsonObject.getString("access_token")); wat.setExpiresIn(jsonObject.getInt("expires_in")); wat.setRefreshToken(jsonObject.getString("refresh_token")); wat.setOpenId(jsonObject.getString("openid")); wat.setScope(jsonObject.getString("scope")); } catch (Exception e) { wat = null; int errorCode = jsonObject.getInt("errcode"); String errorMsg = jsonObject.getString("errmsg"); log.error("刷新网页授权凭证失败 errcode:{} errmsg:{}", errorCode, errorMsg); } } return wat; } /** * 通过网页授权获取用户信息 * * @param accessToken 网页授权接口调用凭证 * @param openId 用户标识 * @return SNSUserInfo */ @SuppressWarnings( { "deprecation", "unchecked" }) public static SNSUserInfo getSNSUserInfo(String accessToken, String openId) { SNSUserInfo snsUserInfo = null; // 拼接请求地址 String requestUrl = "https://api.weixin.qq.com/sns/userinfo?access_token=ACCESS_TOKEN&openid=OPENID"; requestUrl = requestUrl.replace("ACCESS_TOKEN", accessToken).replace("OPENID", openId); // 通过网页授权获取用户信息 JSONObject jsonObject = CommonUtil.httpsRequest(reque