三、微信公众号开发--阐述消息的处理与接收流程

1
2
3
4
5
6
7
8
9
10
11
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// 调用核心业务类接收消息、处理消息
String respXml = MessageControl.getControl().processMessageRequest(request);
//System.out.println("respxml"+respXml);
// 响应消息
PrintWriter out = response.getWriter();
out.print(respXml);
out.close();
return;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package com.wx.control;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import com.wx.service.ImageMsgService;
import com.wx.service.LinkMsgService;
import com.wx.service.LocationMsgService;
import com.wx.service.MenuService;
import com.wx.service.TextMsgService;
import com.wx.service.VideoMsgService;
import com.wx.service.VoiceMsgService;
import com.wx.service.impl.ImageMsgServiceImpl;
import com.wx.service.impl.LinkMsgServiceImpl;
import com.wx.service.impl.LocationMsgServiceImpl;
import com.wx.service.impl.MenuServiceImpl;
import com.wx.service.impl.TextMsgServiceImpl;
import com.wx.service.impl.VideoMsgServiceImpl;
import com.wx.service.impl.VoiceMsgServiceImpl;
import com.wx.util.MessageUtil;
import life.book.util.LogPersist;
import life.book.util.LogPersist.Path;
import life.book.util.Utils;
/**
* User:Jiahengfei --> 17515250730@163.com
* create by 2018年4月29日 from Eclipse.
* describe:消息接收与回应控制器
*/
public class MessageControl implements Path{
private static MessageControl control;
private MessageControl(){}
public static MessageControl getControl(){if(control==null){control=new MessageControl();}return control;}
private TextMsgService text = new TextMsgServiceImpl();
private VideoMsgService video = new VideoMsgServiceImpl();
private ImageMsgService image = new ImageMsgServiceImpl();
private VoiceMsgService link = new VoiceMsgServiceImpl();
private LocationMsgService location = new LocationMsgServiceImpl();
private LinkMsgService voice = new LinkMsgServiceImpl();
private MenuService menu = new MenuServiceImpl();
/**
* 处理微信发来的请求
* @param request
* @return xml
*/
public String processMessageRequest(HttpServletRequest request) {
// xml格式的消息数据
String respXml = null;
try {
// 调用parseXml方法解析请求消息
Map<String, String> map = MessageUtil.parseXml(request);
// 消息类型
String msgType = map.get("MsgType");
//持久化日志
String[] params = {Utils.getTime(),map.get("MsgType"),map.get("FromUserName"),map.get("Content")};
LogPersist.getOperation().log().csv(this, params);
System.out.println("AE:"+map.get("MsgType"));
// 文本消息
if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
respXml = text.dispose(map);
}
// 图片消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {
respXml = image.dispose(map);
}
// 语音消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {
respXml = voice.dispose(map);
}
// 视频消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VIDEO)) {
respXml = video.dispose(map);
}
// 视频消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_SHORTVIDEO)) {
respXml = video.dispose(map);
}
// 地理位置消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {
respXml = location.dispose(map);
}
// 链接消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {
respXml = link.dispose(map);
}
// 事件推送
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {
// 事件类型
String eventType = map.get("Event");
// 关注
if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
respXml = MessageUtil.Default.text(map, "谢谢你那么有才华还关注我

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
}
// 取消关注
else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {
// TODO 取消订阅后用户不会再收到公众账号发送的消息，因此不需要回复
}
// 扫描带参数二维码
else if (eventType.equals(MessageUtil.EVENT_TYPE_SCAN)) {
// TODO 处理扫描带参数二维码事件
}
// 上报地理位置
else if (eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)) {
// TODO 处理上报地理位置事件
}
// 自定义菜单
else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
// TODO 处理菜单点击事件
String key = map.get("EventKey");
if (key!=null) {
respXml = menu.rstOnclickMenu(key, map);
}
}
}
if (respXml==null) {respXml = MessageUtil.Default.text(map, "您当前发送的信息暂无法自动识别,已移交客服处理,请等待客服回复,感谢您对我们的支持和理解!");}
} catch (Exception e) {
e.printStackTrace();
}
return respXml;
}
@Override
public String gainPath() {
return LogPersist.getOperation().path("wx/textmsg");
}
}