yexuejc007/wechat4j
2
0
Fork 0
mirror of https://gitee.com/hotlcc/wechat4j.git synced 2025-06-28 21:22:46 +08:00
Code Issues Releases Wiki Activity

提交代码

Browse Source
This commit is contained in:
hotlcc 2018-08-17 15:55:00 +08:00
parent c5010d4a22
commit 002bdf3d9c
1 changed files with 18 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/main/java/com/hotlcc/wechat4j/Wechat.java
View File

@ -815,36 +815,24 @@ public class Wechat {
*/ */
private void processNewMsg(JSONArray AddMsgList) { private void processNewMsg(JSONArray AddMsgList) {
try { try {
if (AddMsgList != null && !AddMsgList.isEmpty()) { if (AddMsgList == null || AddMsgList.isEmpty()) {
int len = AddMsgList.size();
logger.debug("收到{}条新消息", len);
for (int i = 0; i < len; i++) {
JSONObject AddMsg = AddMsgList.getJSONObject(i);
processNewMsg(AddMsg);
}
}
} catch (Exception e) {
logger.error("Execute processNewMsg error.", e);
}
}
private void processNewMsg(JSONObject AddMsg) {
try {
ReceivedMsg msg = ReceivedMsg.valueOf(AddMsg);
processNewMsg(msg);
} catch (Exception e) {
logger.error("Execute processNewMsg error.", e);
}
}
private void processNewMsg(ReceivedMsg msg) {
try {
if (receivedMsgHandlers == null) {
return; return;
} }
int len = AddMsgList.size();
logger.debug("收到{}条新消息", len);
if (receivedMsgHandlers == null || receivedMsgHandlers.isEmpty()) {
logger.warn("收到{}条新消息，但没有配置消息处理器", len);
return;
}
List<ReceivedMsg> receivedMsgList = ReceivedMsg.valueOf(AddMsgList);
for (ReceivedMsg receivedMsg : receivedMsgList) {
for (ReceivedMsgHandler handler : receivedMsgHandlers) { for (ReceivedMsgHandler handler : receivedMsgHandlers) {
if (handler != null) { if (handler != null) {
processNewMsg(msg, handler); processNewMsg(receivedMsg, handler);
}
} }
} }
} catch (Exception e) { } catch (Exception e) {
@ -854,11 +842,9 @@ public class Wechat {
private void processNewMsg(ReceivedMsg msg, ReceivedMsgHandler handler) { private void processNewMsg(ReceivedMsg msg, ReceivedMsgHandler handler) {
try { try {
if (handler != null) {
handler.handleAllType(wechat, msg); handler.handleAllType(wechat, msg);
}
} catch (Exception e) { } catch (Exception e) {
logger.error("Execute processNewMsg error.", e);
} }
} }
} }