From 2d8e102ae5849d54e385490db57ab68f920f0829 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Thu, 25 Apr 2019 16:02:00 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=BA=BF=E7=A8=8B][=E4=BF=AE=E6=94=B9]:handle?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/mp/handler/SubscribeHandler.java | 4 +-- .../mp/handler/UnsubscribeHandler.java | 4 +-- .../com/iformall/mp/manager/WxMpManager.java | 31 ++++++++++++------- 3 files changed, 24 insertions(+), 15 deletions(-) diff --git a/mlWechatOpen/src/main/java/com/iformall/mp/handler/SubscribeHandler.java b/mlWechatOpen/src/main/java/com/iformall/mp/handler/SubscribeHandler.java index 03105dd..b763d4f 100644 --- a/mlWechatOpen/src/main/java/com/iformall/mp/handler/SubscribeHandler.java +++ b/mlWechatOpen/src/main/java/com/iformall/mp/handler/SubscribeHandler.java @@ -11,14 +11,14 @@ import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; import me.chanjar.weixin.mp.bean.result.WxMpUser; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; import java.util.Map; /** * @author Binary Wang(https://github.com/binarywang) */ -@Service +@Component public class SubscribeHandler extends AbstractHandler { @Autowired diff --git a/mlWechatOpen/src/main/java/com/iformall/mp/handler/UnsubscribeHandler.java b/mlWechatOpen/src/main/java/com/iformall/mp/handler/UnsubscribeHandler.java index 2393847..b9202e9 100644 --- a/mlWechatOpen/src/main/java/com/iformall/mp/handler/UnsubscribeHandler.java +++ b/mlWechatOpen/src/main/java/com/iformall/mp/handler/UnsubscribeHandler.java @@ -9,14 +9,14 @@ import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; import me.chanjar.weixin.mp.bean.result.WxMpUser; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; import java.util.Map; /** * @author Binary Wang(https://github.com/binarywang) */ -@Service +@Component public class UnsubscribeHandler extends AbstractHandler { @Autowired diff --git a/mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java b/mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java index d4a1752..eaef619 100644 --- a/mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java +++ b/mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java @@ -31,22 +31,30 @@ public class WxMpManager { @Autowired protected FmOpenService openService; - private LogHandler logHandler = new LogHandler(); - private NullHandler nullHandler = new NullHandler(); - private KfSessionHandler kfSessionHandler = new KfSessionHandler(); - private StoreCheckNotifyHandler storeCheckNotifyHandler = new StoreCheckNotifyHandler(); - private LocationHandler locationHandler = new LocationHandler(); - private MenuHandler menuHandler = new MenuHandler(); - private MsgHandler msgHandler = new MsgHandler(); - private UnsubscribeHandler unsubscribeHandler = new UnsubscribeHandler(); - private SubscribeHandler subscribeHandler = new SubscribeHandler(); + @Autowired + protected LogHandler logHandler; + @Autowired + protected NullHandler nullHandler; + @Autowired + protected KfSessionHandler kfSessionHandler; + @Autowired + protected StoreCheckNotifyHandler storeCheckNotifyHandler; + @Autowired + protected LocationHandler locationHandler; + @Autowired + protected MenuHandler menuHandler; + @Autowired + protected MsgHandler msgHandler; + @Autowired + protected UnsubscribeHandler unsubscribeHandler; + @Autowired + protected SubscribeHandler subscribeHandler; public WxMpService getMpService(String appId) { return openService.getWxOpenComponentService().getWxMpServiceByAppid(appId); } public WxMpMessageRouter getRouter(String appId) { - if (myRouterMap.containsKey(appId)) { logger.info("found appId : " + appId); return myRouterMap.get(appId); @@ -64,6 +72,7 @@ public class WxMpManager { // 记录所有事件的日志 (异步执行) newRouter.rule().handler(this.logHandler).next(); + /* // 接收客服会话管理事件 newRouter.rule().async(false) @@ -128,7 +137,7 @@ public class WxMpManager { // 默认 newRouter.rule().async(false).handler(this.msgHandler).end(); - + */ return newRouter; }