基本上复制粘贴，稍加修改即可使用。
接上一篇处理用户关注，当后台接收到关注信息后，应当给用户返回一条信息。
除关注之外，用户发送信息，我们也需要做出相应的回复。
获取用户发送的信息
首先简单介绍一下，获取用户发送的信息。
与关注一样，当用户输入信息后点击发送后，微信会Post数据到后台。
接收方法也是一样，将XML数据存入Map。
代码如下。
所需Jar包(Maven)
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>com.thoughtworks.xstream</groupId>
<artifactId>xstream</artifactId>
<version>1.4.11.1</version>
</dependency>
代码-解析用户发送的数据
req.setCharacterEncoding("UTF-8"); // 接收请求时的编码。
resp.setCharacterEncoding("UTF-8"); // 响应给浏览器的编码。
// 个人理解设置编码的原因是 由于 xml解析时编码要一致。
SAXReader saxReader = new SAXReader();
BasicInfo backInfo = null;//这个是我自定义的返回信息的超类。(可略)
XStream xStream = new XStream();
Map<String, String> map = new HashMap<>();
Document read = saxReader.read(req.getInputStream());
//得到根节点
Element rootElement = read.getRootElement();
//获得子节点
List<Element> elements = rootElement.elements();
for (Element e:
elements) {
//将数据存进map
map.put(e.getName(), e.getStringValue());
}
执行完到这里已经在map中存了这些信息。【文本信息为例】
其他类型见官方文档
image.png
判别发送类型及获得消息内容
已知我们判别用户关注是根据这个关键字。
if (map.containsKey("Event") && map.get("Event").equals("subscribe"))
判别发送的是文字（text）、图片（image）、语音（voice）为的关键字为MsgType
image.png
else if (map.containsKey("MsgType") && map.get("MsgType").equals("text"))
以文本为例，获取用户发送的消息为
map.get("Content")
至此已经得到了关键字、关注信息。
回复消息
前置准备
由于可以给用户回复文本、图片、图文消息等。
提取其中各类型回复所需的相同数据，设计为一个父类。
建议加上无参构造器和所有属性的set-get方法。
@XStreamAlias("xml")
public class BasicInfo {
private String ToUserName;
private String FromUserName;
private String CreateTime;
private String MsgType;
public BasicInfo(String toUserName, String fromUserName, String createTime, String msgType) {
this.ToUserName = toUserName;
FromUserName = fromUserName;
CreateTime = createTime;
MsgType = msgType;
}
//建议加上无参构造器和所有属性的set-get方法。
}
文本信息子类
然后设计一个子类，用于存储回复文本信息所需的属性。
建议加上无参构造器和所有属性的set-get方法。
@XStreamAlias("xml")
public class BackTextInfo extends BasicInfo{
private String Content;
public BackTextInfo(String ToUserName, String FromUserName, String CreateTime, String MsgType, String Content){
super(ToUserName, FromUserName, CreateTime, MsgType);
this.Content = Content;
}
//建议加上无参构造器和所有属性的set-get方法。
}
图文信息[需要两个类]
继承基础信息的子类
建议加上无参构造器和所有属性的set-get方法。
public class BackArticlesInfo extends BasicInfo{
private Integer ArticleCount;
private List<ArticleItem> Articles;
public BackArticlesInfo(String toUserName, String fromUserName, String createTime, String msgType, Integer articleCount, List<ArticleItem> articles) {
super(toUserName, fromUserName, createTime, msgType);
ArticleCount = articleCount;
Articles = articles;
}
}
ArticleItem类
建议加上无参构造器和所有属性的set-get方法。
public class ArticleItem{
private String Title;
private String Description;
private String PicUrl;
private String Url;
public ArticleItem(String title, String description, String picUrl, String url) {
Title = title;
Description = description;
PicUrl = picUrl;
Url = url;
}
//建议加上无参构造器和所有属性的set-get方法。
}
其他类型类似
回复文本
比如说，我们接收到用户发送的信息中心包含 ："网站"两个字，就把网站链接返回给用户。
// 返回网站信息
else if (map.containsKey("Content") && map.get("Content").contains("网站")){
System.out.println("wangzhan");
backInfo = wxService.setWebInfo(map);//这里的代码见下
xStream.alias("xml", BackTextInfo.class);
}
注意
这里的FromUserName[公众号], ToUserName[用户]
而map中存的是 FromUserName[用户]， ToUserName[公众号]
需要调转。
还有，一定要设置这一句，xStream.alias("xml", BackTextInfo.class);
第二个参数是你设计的类的Class对象。
backInfo = wxService.setWebInfo(map);//这里的代码见下
public BasicInfo setWebInfo(Map<String, String> map) {
String Content = "www.baidu.com";
return new BackTextInfo(map.get("FromUserName"), (String)map.get("ToUserName"),
System.currentTimeMillis() / 1000 + "", "text", Content);
}
将数据给用户
String s = xStream.toXML(backInfo);
System.out.println(s);
PrintWriter writer = resp.getWriter();
writer.write(s);
writer.flush();
writer.close();
回复图文
类似回复文本
else if (map.containsKey("Content") && map.get("Content").equalsIgnoreCase("tuwen")){
backInfo = wxService.setHelpInfo(map);
xStream.alias("xml", BackArticlesInfo.class);
xStream.alias("item", ArticleItem.class);
}
public BasicInfo setHelpInfo(Map<String, String> map) {
String title1 = "【图文】";
String description1 = "点我查看图文";
String picUrl1 = "https://123.jpg";
String url1 = "https://微信发布的图文链接";
ArticleItem articleItem1 = new ArticleItem(title1, description1, picUrl1, url1);
List<ArticleItem> articleItems = new ArrayList<>();
articleItems.add(articleItem1);
return new BackArticlesInfo(map.get("FromUserName"), map.get("ToUserName")
,System.currentTimeMillis() / 1000 + "", "news", 1, articleItems);
}
将数据给用户
String s = xStream.toXML(backInfo);
System.out.println(s);
PrintWriter writer = resp.getWriter();
writer.write(s);
writer.flush();
writer.close();
完整代码
Controller
因为我做的只有图文和文本，所以对于MsgType没有判定。
大家可以自己加。
@PostMapping(value = "/connect")
public void getXml(HttpServletRequest req, HttpServletResponse resp) throws IOException, DocumentException {
req.setCharacterEncoding("UTF-8"); // 接收请求时的编码。
resp.setCharacterEncoding("UTF-8"); // 响应给浏览器的编码。
// 个人理解设置编码的原因是 由于 xml解析时编码要一致。
SAXReader saxReader = new SAXReader();
BasicInfo backInfo = null;//这个是我自定义的返回信息的超类。
XStream xStream = new XStream();
Map<String, String> map = new HashMap<>();
Document read = saxReader.read(req.getInputStream());
//得到根节点
Element rootElement = read.getRootElement();
//获得子节点
List<Element> elements = rootElement.elements();
for (Element e:
elements) {
//将数据存进map
map.put(e.getName(), e.getStringValue());
}
// 判断用户是否为关注
if (map.containsKey("Event") && map.get("Event").equals("subscribe")) {
// 处理关注
backInfo = wxService.setSubscribe(map);
System.out.println("关注");
xStream.alias("xml", BackArticlesInfo.class);
xStream.alias("item", ArticleItem.class);
}
// 处理返回图文信息
else if (map.containsKey("Content") && map.get("Content").equalsIgnoreCase("tuwen")){
backInfo = wxService.setHelpInfo(map);
xStream.alias("xml", BackArticlesInfo.class);
xStream.alias("item", ArticleItem.class);
}
// 返回文本信息
else if (map.containsKey("Content") && map.get("Content").contains("网站")){
System.out.println("wangzhan");
backInfo = wxService.setWebInfo(map);
xStream.alias("xml", BackTextInfo.class);
}
String s = xStream.toXML(backInfo);
System.out.println(s);
PrintWriter writer = resp.getWriter();
writer.write(s);
writer.flush();
writer.close();
}
Service
@Service
public class WxService {
public BackArticlesInfo setSubscribe(Map<String, String> map) {
String title1 = "【欢迎关注】";
String description1 = "点我看图文。";
String picUrl1 = "https://123.jpg";
String url1 = "https://发布的图文";
ArticleItem articleItem1 = new ArticleItem(title1, description1, picUrl1, url1);
List<ArticleItem> articleItems = new ArrayList<>();
articleItems.add(articleItem1);
return new BackArticlesInfo(map.get("FromUserName"), map.get("ToUserName")
,System.currentTimeMillis() / 1000 + "", "news", 1, articleItems);
}
public BasicInfo setHelpInfo(Map<String, String> map) {
String title1 = "【图文】";
String description1 = "点我查看图文";
String picUrl1 = "https://123.jpg";
String url1 = "https://发布的图文";
ArticleItem articleItem1 = new ArticleItem(title1, description1, picUrl1, url1);
List<ArticleItem> articleItems = new ArrayList<>();
articleItems.add(articleItem1);
return new BackArticlesInfo(map.get("FromUserName"), map.get("ToUserName")
,System.currentTimeMillis() / 1000 + "", "news", 1, articleItems);
}
public BasicInfo setWebInfo(Map<String, String> map) {
String Content = "www.baidu.com";
return new BackTextInfo(map.get("FromUserName"), (String)map.get("ToUserName"),
System.currentTimeMillis() / 1000 + "", "text", Content);
}
下面也是这个Service中的是连接数据库了。
@Resource
private BookMapper bookMapper;
public BasicInfo getBook(Map<String, String> map) {
PayLink payLink = ;
String Content;
if (payLink != null) {
System.out.println(payLink);
Content = "";
}
else {
System.out.println("不存在");
Content = "";
}
return new BackTextInfo(map.get("FromUserName"), map.get("ToUserName"), System.currentTimeMillis()/1000+"",
"text", Content);
}
public BasicInfo backError(Map<String, String> map) {
String Content = "抱歉";
return new BackTextInfo(map.get("FromUserName"), map.get("ToUserName"), System.currentTimeMillis()/1000+"",
"text", Content);
}
public BasicInfo search(String content, Map<String, String> map) {
List<PayLink>payLinks = bookMapper.searchBooks(content);
if (payLinks.size() == 0){
String Content = "[未找到输入的信息] ";
return new BackTextInfo(map.get("FromUserName"), map.get("ToUserName"), System.currentTimeMillis()/1000+"",
"text", Content);}
StringBuilder sb = new StringBuilder();
String head = content + "\n" +
"\n";
sb.append(head);
for (PayLink p:
payLinks) {
sb.append("回复：").append(p.getRuleId()).append(",");
sb.append(p.getRuleKey()).append("\n");
}
return new BackTextInfo(map.get("FromUserName"), map.get("ToUserName"), System.currentTimeMillis()/1000+"",
"text", sb.toString());
}
}
```
网友评论