Преглед изворни кода

[线程][修改]:handle修改

release
Stormeye Wu пре 7 година
родитељ
комит
2d8e102ae5
3 измењених фајлова са 24 додато и 15 уклоњено
  1. +2
    -2
      mlWechatOpen/src/main/java/com/iformall/mp/handler/SubscribeHandler.java
  2. +2
    -2
      mlWechatOpen/src/main/java/com/iformall/mp/handler/UnsubscribeHandler.java
  3. +20
    -11
      mlWechatOpen/src/main/java/com/iformall/mp/manager/WxMpManager.java

+ 2
- 2
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


+ 2
- 2
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


+ 20
- 11
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;
}



Loading…
Откажи
Сачувај