微信公众号开发—自定义菜单、被动回复消息

自定义菜单

1. 通过appid和secret获取access_token。
2. 生成按钮数据(JSON)。

被动回复消息

1. 获取用户发送信息(XML格式)
2. 解析XML中的关键字，并使用关键字查询数据库中所对应的回复消息。
3. 重新封装XML，进行响应。

代码如下:

/**
     * 判断签名是否一致
     * @param signature
     * @param timestamp
     * @param nonce
     * @param token
     * @return
     */
    public boolean verifyInfo(String signature, String timestamp, String nonce, String token) {
          
   
        TreeSet<String> set = new TreeSet<String>();
        set.add(token);
        set.add(timestamp);
        set.add(nonce);
        StringBuilder sb = new StringBuilder();
        for (String item : set) {
          
   
            sb.append(item);
        }
        String sign = DigestUtils.sha1Hex(sb.toString());
        return signature.equalsIgnoreCase(sign);
    }

2. 获取用户发送信息并对信息进行解析。

@PostMapping("/verify")
private String sendMessage(HttpServletRequest request, HttpServletResponse response){
          
   
    BufferedReader reader = null;
    String message = "";
    try{
          
   
        reader = request.getReader();
        String str = "";
        while((str=reader.readLine()) != null) {
          
   
            message += str;
        }
    }catch (Exception e){
          
   
        e.printStackTrace();
    }
    return wxService.replyMessage(message);
}

public static Map<String, String> xmlParser(String str){
          
   
Map<String, String> map = new HashMap<>();
try {
          
   
    Document document = DocumentHelper.parseText(str);
    Element e = document.getRootElement();
    map.put("ToUserName",e.elementText("ToUserName"));
    map.put("FromUserName",e.elementText("FromUserName"));
    map.put("Content", e.elementText("Content"));
}catch (Exception e) {
          
   
    e.printStackTrace();
}
return map;
}

3. 数据库中查找回复信息，并封装成XML。

public String replyMessage(String str){
          
   
    Map<String, String> map = XMLUtils.xmlParser(str);
    Date date = new Date();
    String content =  "";
    try {
          
   
        content = replyDao.selectByKeyword(map.get("Content"));
    }catch (Exception e) {
          
   
        e.printStackTrace();
    }
    log.info("返回内容是" + content);
    String message = "<xml>
" +
            "  <ToUserName><![CDATA["+ map.get("FromUserName")+"]]></ToUserName>
" +
            "  <FromUserName><![CDATA["+ map.get("ToUserName")+"]]></FromUserName>
" +
            "  <CreateTime>"+ date.toString() +"</CreateTime>
" +
            "  <MsgType><![CDATA[text]]></MsgType>
" +
            "  <Content><![CDATA[" +content+ "]]></Content>
" +
            "</xml>";

    return message;
}

4. 最后对消息进行返回，最终，我们的效果如图所示:

代码补充:这里对持久层代码进行补充

@Mapper
public interface ReplyDao extends BaseDao<Reply> {
          
   
    String selectByKeyword(String keyword) throws Exception;
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lanou.wechat.dao.ReplyDao">

    <select id="selectByKeyword" parameterType="java.lang.String"  
    resultType="java.lang.String">
        select reply from tb_reply where keyword=#{keyword}
    </select>

</mapper>