Skip to content

Commit c59e6c0

Browse files
committed
Signed-off-by: vcdemon <345280563@qq.com>
1 parent a8dafe1 commit c59e6c0

File tree

5 files changed

+70
-25
lines changed

5 files changed

+70
-25
lines changed

wechat-web/src/main/java/com/itfvck/wechatframework/web/service/WechatDefaultService.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,12 @@
55

66
import com.itfvck.wechatframework.web.support.WechatSupport;
77

8+
/**
9+
* 微信默认消息处理中心
10+
*
11+
* @author lidong
12+
*
13+
*/
814
public class WechatDefaultService extends WechatSupport {
915
static Logger logger = LoggerFactory.getLogger(WechatDefaultService.class);
1016

wechat-web/src/main/java/com/itfvck/wechatframework/web/servlet/WechatDefaultDispatcherServlet.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,19 @@
1414
import com.itfvck.wechatframework.core.common.WechatParam;
1515
import com.itfvck.wechatframework.core.util.SignatureUtil;
1616

17+
/**
18+
* 默认微信消息请求入口
19+
*
20+
* @author
21+
*
22+
*/
1723
public class WechatDefaultDispatcherServlet extends WechatFrameworkServlet {
1824
private static final long serialVersionUID = -9199915074190263799L;
1925
static Logger logger = LoggerFactory.getLogger(WechatDefaultDispatcherServlet.class);
2026

27+
/**
28+
* 微信接入验证请求入口
29+
*/
2130
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
2231
WechatParam params = new WechatParam(request);
2332
logger.info("GET params:" + params.toString());
@@ -42,6 +51,9 @@ protected void doGet(HttpServletRequest request, HttpServletResponse response) t
4251
}
4352
}
4453

54+
/**
55+
* 微信消息接收入口
56+
*/
4557
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
4658
WechatParam params = new WechatParam(request);
4759
logger.info("POST params:" + params.toString());

wechat-web/src/main/java/com/itfvck/wechatframework/web/servlet/WechatFrameworkServlet.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,12 @@
99
import com.itfvck.wechatframework.web.service.WechatDefaultService;
1010
import com.itfvck.wechatframework.web.support.WechatSupport;
1111

12+
/**
13+
* 默认servlet初始化层
14+
*
15+
* @author
16+
*
17+
*/
1218
public abstract class WechatFrameworkServlet extends HttpServlet {
1319
private static Logger logger = LoggerFactory.getLogger(WechatFrameworkServlet.class);
1420
private static final long serialVersionUID = -3673669864159664378L;
@@ -21,6 +27,9 @@ public void init() throws ServletException {
2127
logger.info("消息处理中心服务器:" + wechat);
2228
}
2329

30+
/**
31+
* 初始化微信消息处理器对象,第一步初始化自定义消息处理器,初始化失败则采用默认消息处理器
32+
*/
2433
private void initWechatServer() {
2534
try {
2635
wechat = (WechatSupport) Class.forName(this.getInitParameter(CLAZZ_NAME), true, Thread.currentThread().getContextClassLoader()).newInstance();
@@ -31,6 +40,11 @@ private void initWechatServer() {
3140
}
3241
}
3342

43+
/**
44+
* 获取消息处理器对象
45+
*
46+
* @return
47+
*/
3448
public WechatSupport getWechatService() {
3549
return wechat;
3650
}

wechat-web/src/main/java/com/itfvck/wechatframework/web/support/WechatDispatcher.java

Lines changed: 32 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,23 @@
1212
import com.itfvck.wechatframework.core.responseMsg.WechatResponse;
1313
import com.itfvck.wechatframework.core.util.XmlHelper;
1414

15+
/**
16+
* 微信服务器与用户消息转发控制中心
17+
*
18+
* @author
19+
*
20+
*/
1521
abstract class WechatDispatcher {
1622

23+
/**
24+
* 微信服务器消息入口
25+
*
26+
* @param request
27+
* @param conf
28+
* @param params
29+
* @return 返回处理后的消息
30+
* @throws Exception
31+
*/
1732
public String service(HttpServletRequest request, WechatConfig conf, WechatParam params) throws Exception {
1833
WechatRequest wechatRequest = XmlHelper.toObj(XmlHelper.parseXml(request, conf, params));
1934
String xml = null;
@@ -31,16 +46,11 @@ public String service(HttpServletRequest request, WechatConfig conf, WechatParam
3146
}
3247

3348
/**
34-
* @Description 普通消息分发
35-
* @param requestMap
36-
* @param baseConf
37-
* @param params
49+
* 普通消息分发中心
50+
*
51+
* @param wechatRequest
3852
* @return
3953
* @throws Exception
40-
* @CreationDate 2016年5月28日 下午1:29:02
41-
* @Author itfvck(itfvck@itfvck.com)
42-
* @UpdateDate
43-
* @UpdateAuthor
4454
*/
4555
private String dispatchMessage(WechatRequest wechatRequest) throws Exception {
4656
// 消息类型
@@ -76,15 +86,11 @@ private String dispatchMessage(WechatRequest wechatRequest) throws Exception {
7686
}
7787

7888
/**
79-
* @Description 事件消息分发
89+
* 事件消息分发中心
90+
*
8091
* @param wechatRequest
81-
* @param baseConf
82-
* @param params
8392
* @return
84-
* @CreationDate 2016年5月28日 下午1:29:14
85-
* @Author itfvck(itfvck@itfvck.com)
86-
* @UpdateDate
87-
* @UpdateAuthor
93+
* @throws Exception
8894
*/
8995
private String dispatchEvent(WechatRequest wechatRequest) throws Exception {
9096
// 事件推送
@@ -148,22 +154,23 @@ private String dispatchEvent(WechatRequest wechatRequest) throws Exception {
148154
}
149155

150156
/**
151-
* @Description 获取微信消息的请求消息对象
157+
* 将返回消息对象格式化为微信服务器所需要的XML格式字符串
158+
*
152159
* @param wechatRequest
153-
* @param baseConf
154-
* @param params
155-
* @return WechatRequest 请求消息对象
156-
* @see WechatRequest 请求消息对象
157-
* @throws Exception
158-
* @CreationDate 2016年5月29日 上午12:49:03
159-
* @Author itfvck(itfvck@itfvck.com)
160-
* @UpdateDate
161-
* @UpdateAuthor
160+
* @param wechatResponse
161+
* @return
162162
*/
163163
protected String formatWechatResponse(WechatRequest wechatRequest, WechatResponse wechatResponse) {
164164
return XmlHelper.toXML(setWechatResponseBase(wechatRequest, wechatResponse));
165165
}
166166

167+
/**
168+
* 设置返回消息对象的基础数据
169+
*
170+
* @param wechatRequest
171+
* @param response
172+
* @return
173+
*/
167174
private WechatResponse setWechatResponseBase(WechatRequest wechatRequest, WechatResponse response) {
168175
// 发送方帐号, 公告号将要向该号发送回复消息
169176
// 开发者微信帐号

wechat-web/src/main/java/com/itfvck/wechatframework/web/support/WechatSupport.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,12 @@
99
import com.itfvck.wechatframework.core.requestMsg.WechatRequest;
1010
import com.itfvck.wechatframework.core.responseMsg.WechatResponse;
1111

12+
/**
13+
* 微信消息处理中心,用户可继承该类以便实现业务定制
14+
*
15+
* @author
16+
*
17+
*/
1218
public abstract class WechatSupport extends WechatDispatcher {
1319
static Logger logger = LoggerFactory.getLogger(WechatSupport.class);
1420

0 commit comments

Comments
 (0)