lsm/weixin-java-tools
1
0
Fork 0
mirror of https://gitee.com/binary/weixin-java-tools.git synced 2026-03-10 00:13:40 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix unqualified access

Browse Source
This commit is contained in:
BinaryWang
2016-08-31 19:05:03 +08:00
parent 76e1da564a
commit b9919297d5
50 changed files with 421 additions and 421 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/WxMpMessageRouter.java
View File

@@ -141,7 +141,7 @@ public class WxMpMessageRouter {
final List<WxMpMessageRouterRule> matchRules = new ArrayList<WxMpMessageRouterRule>();
// 收集匹配的规则
for (final WxMpMessageRouterRule rule : rules) {
for (final WxMpMessageRouterRule rule : this.rules) {
if (rule.test(wxMessage)) {
matchRules.add(rule);
if(!rule.isReEnter()) {
@@ -160,35 +160,35 @@ public class WxMpMessageRouter {
// 返回最后一个非异步的rule的执行结果
if(rule.isAsync()) {
futures.add(
executorService.submit(new Runnable() {
this.executorService.submit(new Runnable() {
@Override
public void run() {
rule.service(wxMessage, wxMpService, sessionManager, exceptionHandler);
rule.service(wxMessage, WxMpMessageRouter.this.wxMpService, WxMpMessageRouter.this.sessionManager, WxMpMessageRouter.this.exceptionHandler);
}
})
);
} else {
res = rule.service(wxMessage, wxMpService, sessionManager, exceptionHandler);
res = rule.service(wxMessage, this.wxMpService, this.sessionManager, this.exceptionHandler);
// 在同步操作结束，session访问结束
log.debug("End session access: async=false, sessionId={}", wxMessage.getFromUserName());
this.log.debug("End session access: async=false, sessionId={}", wxMessage.getFromUserName());
sessionEndAccess(wxMessage);
}
}
if (futures.size() > 0) {
executorService.submit(new Runnable() {
this.executorService.submit(new Runnable() {
@Override
public void run() {
for (Future future : futures) {
try {
future.get();
log.debug("End session access: async=true, sessionId={}", wxMessage.getFromUserName());
WxMpMessageRouter.this.log.debug("End session access: async=true, sessionId={}", wxMessage.getFromUserName());
// 异步操作结束，session访问结束
sessionEndAccess(wxMessage);
} catch (InterruptedException e) {
log.error("Error happened when wait task finish", e);
WxMpMessageRouter.this.log.error("Error happened when wait task finish", e);
} catch (ExecutionException e) {
log.error("Error happened when wait task finish", e);
WxMpMessageRouter.this.log.error("Error happened when wait task finish", e);
}
}
}
@@ -210,7 +210,7 @@ public class WxMpMessageRouter {
messageId.append(wxMessage.getMsgId());
}
return messageDuplicateChecker.isDuplicate(messageId.toString());
return this.messageDuplicateChecker.isDuplicate(messageId.toString());
}
@@ -220,7 +220,7 @@ public class WxMpMessageRouter {
*/
protected void sessionEndAccess(WxMpXmlMessage wxMessage) {
InternalSession session = ((InternalSessionManager)sessionManager).findSession(wxMessage.getFromUserName());
InternalSession session = ((InternalSessionManager)this.sessionManager).findSession(wxMessage.getFromUserName());
if (session != null) {
session.endAccess();
}