Java - 微信公众号 - 消息回复

@XStreamAlias("xml")
public class BaseMessage {

    /**
     * 接收方帐号（收到的OpenID）
     */
    private String ToUserName;
    /**
     * 开发者微信号
     */
    private String FromUserName;
    /**
     * 消息创建时间 （整型）
     */
    
    private long CreateTime;

    /**
     * 消息类型
     */
    private String MsgType;

    
    public String getToUserName() {
        return ToUserName;
    }

    
    public void setToUserName(String toUserName) {
        ToUserName = toUserName;
    }

    
    public String getFromUserName() {
        return FromUserName;
    }

    
    public void setFromUserName(String fromUserName) {
        FromUserName = fromUserName;
    }

    
    public long getCreateTime() {
        return CreateTime;
    }

    
    public void setCreateTime(long createTime) {
        CreateTime = createTime;
    }

    
    public String getMsgType() {
        return MsgType;
    }

    
    public void setMsgType(String msgType) {
        MsgType = msgType;
    }

}

/**
 * 文本实体类
 * @author xzl
 *
 */
@XStreamAlias("xml")
public class TextMeaasge extends BaseMessage {
    
    /**
     * 文本消息内容
     */
    private String Content;
    
    public String getContent() {
        return Content;
    }
    
    public void setContent(String content) {
        Content = content;
    }
    
}

public class WeiXinUserInfo {

    private int subscribe;// 用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息。  
    private String openid; // 用户的标识，对当前公众号唯一  
    private String nickname;// 用户的昵称  
    private int sex;// 用户的性别，值为1时是男性，值为2时是女性，值为0时是未知  
    private String city;// 用户所在城市  
    private String country;// 用户所在国家  
    private String province;// 用户所在省份  
    private String language;// 用户的语言，简体中文为zh_CN  
    private String headimgurl;// 用户头像，最后一个数值代表正方形头像大小（有0、46、64、96、132数值可选，0代表640*640正方形头像），用户没有头像时该项为空。若用户更换头像，原有头像URL将失效。  
    private String subscribe_time;// 用户关注时间，为时间戳。如果用户曾多次关注，则取最后关注时间  
    private String unionid;// 只有在用户将公众号绑定到微信开放平台帐号后，才会出现该字段。  
    private String remark;// 公众号运营者对粉丝的备注，公众号运营者可在微信公众平台用户管理界面对粉丝添加备注  
    private int groupid;// 用户所在的分组ID（兼容旧的用户分组接口）  
    private String tagid_list; // 用户被打上的标签ID列表
    
    public int getSubscribe() {
        return subscribe;
    }
    
    public void setSubscribe(int subscribe) {
        this.subscribe = subscribe;
    }
    
    public String getOpenid() {
        return openid;
    }
    
    public void setOpenid(String openid) {
        this.openid = openid;
    }
    
    public String getNickname() {
        return nickname;
    }
    
    public void setNickname(String nickname) {
        this.nickname = nickname;
    }
    
    public int getSex() {
        return sex;
    }
    
    public void setSex(int sex) {
        this.sex = sex;
    }
    
    public String getCity() {
        return city;
    }
    
    public void setCity(String city) {
        this.city = city;
    }
    
    public String getCountry() {
        return country;
    }
    
    public void setCountry(String country) {
        this.country = country;
    }
    
    public String getProvince() {
        return province;
    }
    
    public void setProvince(String province) {
        this.province = province;
    }
    
    public String getLanguage() {
        return language;
    }
    
    public void setLanguage(String language) {
        this.language = language;
    }
    
    public String getHeadimgurl() {
        return headimgurl;
    }
    
    public void setHeadimgurl(String headimgurl) {
        this.headimgurl = headimgurl;
    }
    
    public String getSubscribe_time() {
        return subscribe_time;
    }
    
    public void setSubscribe_time(String subscribe_time) {
        this.subscribe_time = subscribe_time;
    }
    
    public String getUnionid() {
        return unionid;
    }
    
    public void setUnionid(String unionid) {
        this.unionid = unionid;
    }
    
    public String getRemark() {
        return remark;
    }
    
    public void setRemark(String remark) {
        this.remark = remark;
    }
    
    public int getGroupid() {
        return groupid;
    }
    
    public void setGroupid(int groupid) {
        this.groupid = groupid;
    }
    
    public String getTagid_list() {
        return tagid_list;
    }
    
    public void setTagid_list(String tagid_list) {
        this.tagid_list = tagid_list;
    }
    
}

public class MessageUtil {
    
 // 请求消息类型：文本
    public static final String REQ_MESSAGE_TYPE_TEXT = "text";
    // 请求消息类型：图片
    public static final String REQ_MESSAGE_TYPE_IMAGE = "image";
    // 请求消息类型：语音
    public static final String REQ_MESSAGE_TYPE_VOICE = "voice";
    // 请求消息类型：视频
    public static final String REQ_MESSAGE_TYPE_VIDEO = "video";
    // 请求消息类型：小视频
    public static final String REQ_MESSAGE_TYPE_SHORTVIDEO = "shortvideo";
    // 请求消息类型：地理位置
    public static final String REQ_MESSAGE_TYPE_LOCATION = "location";
    // 请求消息类型：链接
    public static final String REQ_MESSAGE_TYPE_LINK = "link";
    // 请求消息类型：事件推送
    public static final String REQ_MESSAGE_TYPE_EVENT = "event";
    // 事件类型：subscribe(订阅)
    public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";
    // 事件类型：unsubscribe(取消订阅)
    public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";
    // 事件类型：scan(用户已关注时的扫描带参数二维码)
    public static final String EVENT_TYPE_SCAN = "scan";
    // 事件类型：LOCATION(上报地理位置)
    public static final String EVENT_TYPE_LOCATION = "LOCATION";
    // 事件类型：CLICK(自定义菜单)
    public static final String EVENT_TYPE_CLICK = "CLICK";
 
    // 响应消息类型：文本
    public static final String RESP_MESSAGE_TYPE_TEXT = "text";
    // 响应消息类型：图片
    public static final String RESP_MESSAGE_TYPE_IMAGE = "image";
    // 响应消息类型：语音
    public static final String RESP_MESSAGE_TYPE_VOICE = "voice";
    // 响应消息类型：视频
    public static final String RESP_MESSAGE_TYPE_VIDEO = "video";
    // 响应消息类型：音乐
    public static final String RESP_MESSAGE_TYPE_MUSIC = "music";
    // 响应消息类型：图文
    public static final String RESP_MESSAGE_TYPE_NEWS = "news";
 
    /**
     * 将XML转换成Map集合
     */
    @SuppressWarnings("unchecked")
    public static Map<String, String>xmlToMap(HttpServletRequest request) throws IOException, DocumentException{
         
        Map<String, String> map = new HashMap<String, String>();
        SAXReader reader = new SAXReader();            // 使用dom4j解析xml
        InputStream ins = request.getInputStream(); // 从request中获取输入流
        Document doc = reader.read(ins);
         
        Element root = doc.getRootElement();         // 获取根元素
        List<Element> list = root.elements();        // 获取所有节点
         
        for (Element e : list) {
            map.put(e.getName(), e.getText()); 
            System.out.println(e.getName() + "--->" + e.getText());
        }
        ins.close();
        return map;
    }
 
    /**
     * 对象到xml的处理
     */
    private static XStream xstream = new XStream(new XppDriver() {
        public HierarchicalStreamWriter createWriter(Writer out) {
            return new PrettyPrintWriter(out) {
                // 对所有xml节点的转换都增加CDATA标记
                boolean cdata = true;
 
                @SuppressWarnings("rawtypes")
                public void startNode(String name, Class clazz) {
                    super.startNode(name, clazz);
                }
 
                protected void writeText(QuickWriter writer, String text) {
                    if (cdata) {
                        writer.write("<![CDATA[");
                        writer.write(text);
                        writer.write("]]>");
                    } else {
                        writer.write(text);
                    }
                }
            };
        }
    });
 
    /**
     * 文本消息对象转换成xml
     * 
     * @param textMessage 文本消息对象
     * @return xml
     */
    public static String messageToXml(TextMeaasge textMessage) {
        xstream.alias("xml", textMessage.getClass());
        return xstream.toXML(textMessage);
    }
    
    /**
     * 图文消息对象转换成xml
     * 
     * @param newsMessage 图文消息对象
     * @return xml
     */
    public static String messageToXml(NewsMessage newsMessage) {
        xstream.alias("xml", newsMessage.getClass());
        xstream.alias("item", new Article().getClass());
        return xstream.toXML(newsMessage);
    }
 
    /**
     * 图片消息对象转换成xml
     * 
     * @param imageMessage 图片消息对象
     * @return xml
     */
    public static String messageToXml(ImageMessage imageMessage) {
        xstream.alias("xml", imageMessage.getClass());
        return xstream.toXML(imageMessage);
    }
 
    /**
     * 语音消息对象转换成xml
     * 
     * @param voiceMessage 语音消息对象
     * @return xml
     */
    public static String messageToXml(VoiceMessage voiceMessage) {
        xstream.alias("xml", voiceMessage.getClass());
        return xstream.toXML(voiceMessage);
    }
 
    /**
     * 视频消息对象转换成xml
     * 
     * @param videoMessage 视频消息对象
     * @return xml
     */
    public static String messageToXml(VideoMessage videoMessage) {
        xstream.alias("xml", videoMessage.getClass());
        return xstream.toXML(videoMessage);
    }
 
    /**
     * 音乐消息对象转换成xml
     * 
     * @param musicMessage 音乐消息对象
     * @return xml
     */
    public static String messageToXml(MusicMessage musicMessage) {
        xstream.alias("xml", musicMessage.getClass());
        return xstream.toXML(musicMessage);
    }

}

/**
 * 列表图文信息
 * @author xzl
 *
 */
@XStreamAlias("xml")
public class NewsMessage extends BaseMessage {
    
    /** 
     * 图文消息个数，限制为10条以内 
     */  
    private int ArticleCount;  
    
    /** 
     * 多条图文消息信息，默认第一个item为大图 
     */  
    private List<Article> Articles;  
  
    public int getArticleCount() {  
        return ArticleCount;  
    }  
  
    public void setArticleCount(int articleCount) {  
        ArticleCount = articleCount;  
    }  
  
    public List<Article> getArticles() {  
        return Articles;  
    }  
  
    public void setArticles(List<Article> articles) {  
        Articles = articles;  
    }

}

/**
 * 图片消息
 * @author xzl
 *
 */
@XStreamAlias("xml")
public class ImageMessage extends BaseMessage {

    // 图片链接  
    private String PicUrl;
    //图片消息媒体id
    private String MediaId;

    
    public String getPicUrl() {
        return PicUrl;
    }

    
    public void setPicUrl(String picUrl) {
        PicUrl = picUrl;
    }


    
    public String getMediaId() {
        return MediaId;
    }


    
    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }
}

/**
 * 音频消息
 * @author xzl
 *
 */
@XStreamAlias("xml")
public class VoiceMessage extends BaseMessage {

    // 媒体ID  
    private String MediaId;  
    // 语音格式  
    private String Format;
    
    public String getMediaId() {
        return MediaId;
    }
    
    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }
    
    public String getFormat() {
        return Format;
    }
    
    public void setFormat(String format) {
        Format = format;
    }
}

/**
 * 视频消息
 * @author xzl
 *
 */
@XStreamAlias("xml")
public class VideoMessage extends BaseMessage {
    
    // 媒体ID
    private String MediaId;
    // 语音格式
    private String ThumbMediaId;
    
    public String getMediaId() {
        return MediaId;
    }
    
    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }
    
    public String getThumbMediaId() {
        return ThumbMediaId;
    }
    
    public void setThumbMediaId(String thumbMediaId) {
        ThumbMediaId = thumbMediaId;
    }

}

/**
 * 音乐消息
 * @author xzl
 *
 */
@XStreamAlias("xml")
public class MusicMessage extends BaseMessage {

    // 音乐  
    private Music Music;
    
    public Music getMusic() {
        return Music;
    }

    
    public void setMusic(Music music) {
        Music = music;
    }
}

@XStreamAlias("xml")
public class Music extends BaseMessage {

    // 音乐名称  
    private String Title;  
    // 音乐描述  
    private String Description;  
    // 音乐链接  
    private String MusicUrl;  
    // 高质量音乐链接，WIFI环境优先使用该链接播放音乐  
    private String HQMusicUrl;
    // 缩略图的媒体id，通过上传多媒体文件得到的id
    private String ThumbMediaId;
    
    public String getTitle() {
        return Title;
    }
    
    public void setTitle(String title) {
        Title = title;
    }
    
    public String getDescription() {
        return Description;
    }
    
    public void setDescription(String description) {
        Description = description;
    }
    
    public String getMusicUrl() {
        return MusicUrl;
    }
    
    public void setMusicUrl(String musicUrl) {
        MusicUrl = musicUrl;
    }
    
    public String getHQMusicUrl() {
        return HQMusicUrl;
    }
    
    public void setHQMusicUrl(String hQMusicUrl) {
        HQMusicUrl = hQMusicUrl;
    }

    
    public String getThumbMediaId() {
        return ThumbMediaId;
    }

    
    public void setThumbMediaId(String thumbMediaId) {
        ThumbMediaId = thumbMediaId;
    }
}

@XStreamAlias("xml")
public class Article extends BaseMessage {
    
    /** 
     * 消息名称 
     */  
    private String Title;  
    /** 
     * 消息描述 
     */  
    private String Description;  
  
    /** 
     * 图片链接，支持JPG、PNG格式，较好的效果为大图640*320，小图80*80
     */  
    private String PicUrl;  
  
    /** 
     * 点击图文消息跳转链接 
     */  
    private String Url;

    
    public String getTitle() {
        return Title;
    }

    
    public void setTitle(String title) {
        Title = title;
    }

    
    public String getDescription() {
        return Description;
    }

    
    public void setDescription(String description) {
        Description = description;
    }

    
    public String getPicUrl() {
        return PicUrl;
    }

    
    public void setPicUrl(String picUrl) {
        PicUrl = picUrl;
    }

    
    public String getUrl() {
        return null == Url ? "" : Url;
    }

    
    public void setUrl(String url) {
        Url = url;
    }

}

/**
 * 微信通用接口凭证
 * @author xzl
 *
 */
public class AccessToken {
    
    // 获取到的凭证
    private String accessToken;

    // 凭证有效时间，单位：秒
    private int expiresin;

    public String getAccessToken() {
        return accessToken;
    }

    public void setAccessToken(String accessToken) {
        this.accessToken = accessToken;
    }

    public int getExpiresin() {
        return expiresin;
    }

    public void setExpiresin(int expiresin) {
        this.expiresin = expiresin;
    }
}

/**
 * 公众平台通用接口工具类
 * @author xzl
 *
 */
public class WeixinUtil {
    
    private static Logger log = LoggerFactory.getLogger(WeixinUtil.class);
    
    /**
     * 获取access_token
     * 
     * @param appid 凭证
     * @param appsecret 密钥
     * @return
     */
    public static AccessToken getAccessToken(String appid, String appsecret) {

    // 获取access_token的接口地址（GET） 限200（次/天）
        final String access_token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";

        AccessToken accessToken = null;

        String requestUrl = access_token_url.replace("APPID", appid).replace("APPSECRET", appsecret);
        JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
        // 如果请求成功
        if (null != jsonObject) {
            try {
                accessToken = new AccessToken();
                accessToken.setAccessToken(jsonObject.getString("access_token"));
                accessToken.setExpiresin(jsonObject.getInt("expires_in"));
            } catch (JSONException e) {
                accessToken = null;
                // 获取token失败
                log.error("获取token失败 errcode:{} errmsg:{}", jsonObject.getInt("errcode"), jsonObject.getString("errmsg"));
            }
        }
        return accessToken;
    }
    
    /**
     * URL编码（utf-8）
     * 
     * @param source
     * @return
     */
    public static String urlEncodeUTF8(String source) {
      String result = source;
      try {
        result = java.net.URLEncoder.encode(source, "utf-8");
      } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
      }
      return result;
    }
    
    /**
     * 根据内容类型判断文件扩展名
     * 
     * @param contentType 内容类型
     * @return
     */
    public static String getFileExt(String contentType) {
      String fileExt = "";
      if ("image/jpeg".equals(contentType))
        fileExt = ".jpg";
      else if ("audio/mpeg".equals(contentType))
        fileExt = ".mp3";
      else if ("audio/amr".equals(contentType))
        fileExt = ".amr";
      else if ("video/mp4".equals(contentType))
        fileExt = ".mp4";
      else if ("video/mpeg4".equals(contentType))
        fileExt = ".mp4";
      return fileExt;
    }
    

    /**
     * 获取用户信息
     * 
     * @param accessToken 接口访问凭证
     * @param openId 用户标识
     * @return WeixinUserInfo
     */
    public static WeiXinUserInfo getUserInfo(String accessToken, String openId) {
        WeiXinUserInfo weixinUserInfo = null;
      // 拼接请求地址
      String requestUrl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=ACCESS_TOKEN&openid=OPENID";
      requestUrl = requestUrl.replace("ACCESS_TOKEN", accessToken).replace("OPENID", openId);
      // 获取用户信息
      JSONObject jsonObject = WeixinUtil.httpRequest(requestUrl, "GET", null);
      if (null != jsonObject) {
        try {
          weixinUserInfo = new WeiXinUserInfo();
          // 用户的标识
          weixinUserInfo.setOpenid(jsonObject.getString("openid"));
          // 关注状态（1是关注，0是未关注），未关注时获取不到其余信息
          weixinUserInfo.setSubscribe(jsonObject.getInt("subscribe"));
          // 用户关注时间
          weixinUserInfo.setSubscribe_time(jsonObject.getString("subscribe_time"));
          // 昵称
          weixinUserInfo.setNickname(jsonObject.getString("nickname"));
          // 用户的性别（1是男性，2是女性，0是未知）
          weixinUserInfo.setSex(jsonObject.getInt("sex"));
          // 用户所在国家
          weixinUserInfo.setCountry(jsonObject.getString("country"));
          // 用户所在省份
          weixinUserInfo.setProvince(jsonObject.getString("province"));
          // 用户所在城市
          weixinUserInfo.setCity(jsonObject.getString("city"));
          // 用户的语言，简体中文为zh_CN
          weixinUserInfo.setLanguage(jsonObject.getString("language"));
          // 用户头像
          weixinUserInfo.setHeadimgurl(jsonObject.getString("headimgurl"));
        } catch (Exception e) {
          if (0 == weixinUserInfo.getSubscribe()) {
            log.error("用户{}已取消关注", weixinUserInfo.getOpenid());
          } else {
            int errorCode = jsonObject.getInt("errcode");
            String errorMsg = jsonObject.getString("errmsg");
            log.error("获取用户信息失败 errcode:{} errmsg:{}", errorCode, errorMsg);
          }
        }
      }
      return weixinUserInfo;
    }

}