add handler package and move message handler to here

Author: FirenzesEagle

.idea/compiler.xml

@@ -2,29 +2,21 @@
 
 import com.github.service.CoreService;
 import com.github.util.ReturnModel;
-import me.chanjar.weixin.common.api.WxConsts;
 import me.chanjar.weixin.common.exception.WxErrorException;
-import me.chanjar.weixin.common.session.WxSessionManager;
 import me.chanjar.weixin.common.util.StringUtils;
 import me.chanjar.weixin.mp.api.WxMpConfigStorage;
-import me.chanjar.weixin.mp.api.WxMpMessageHandler;
-import me.chanjar.weixin.mp.api.WxMpMessageRouter;
 import me.chanjar.weixin.mp.api.WxMpService;
 import me.chanjar.weixin.mp.bean.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.WxMpXmlOutMessage;
-import me.chanjar.weixin.mp.bean.WxMpXmlOutTextMessage;
 import me.chanjar.weixin.mp.bean.result.WxMpOAuth2AccessToken;
 import me.chanjar.weixin.mp.bean.result.WxMpUser;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
-import java.util.Map;
 
 /**
  * Created by FirenzesEagle on 2016/5/30 0030.
@@ -40,12 +32,6 @@ public class CoreController extends GenericController {
  @Autowired
  protected CoreService coreService;
 
- protected WxMpMessageRouter wxMpMessageRouter;
- private static final String CREATE_USER_URL = "http://111.207.243.66:8886/SZBProject/wxinfo/insert";
- private static final String CREATE_SHOP_URL = "http://111.207.243.66:8886/SZBProject/shop/create?openId=";
-
- private static final Logger log = LoggerFactory.getLogger(CoreController.class);
-
  @RequestMapping(value = "index")
  public String index() {
  return "index";
@@ -67,30 +53,6 @@ public void wechatCore(HttpServletRequest request, HttpServletResponse response)
  String nonce = request.getParameter("nonce");
  String timestamp = request.getParameter("timestamp");
 
- //订阅事件消息处理
- WxMpMessageHandler subscribeHandler = new WxMpMessageHandler() {
- @Override
- public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {
- WxMpUser wxMpUser = getUserInfo(wxMessage.getFromUserName(), "zh_CN");
- WxMpXmlOutTextMessage m
- = WxMpXmlOutMessage.TEXT()
- .content("尊敬的" + wxMpUser.getNickname() + "，您好 ！")
- .fromUser(wxMessage.getToUserName())
- .toUser(wxMessage.getFromUserName())
- .build();
- log.info("subscribeMessageHandler: " + m.getContent());
- return m;
- }
- };
-
- wxMpMessageRouter = new WxMpMessageRouter(wxMpService);
- wxMpMessageRouter
- .rule()
- .async(false)
- .event(WxConsts.EVT_SUBSCRIBE)
- .handler(subscribeHandler)
- .end();
-
  if (!wxMpService.checkSignature(timestamp, nonce, signature)) {
  // 消息签名不正确，说明不是公众平台发过来的消息
  response.getWriter().println("非法请求");
@@ -111,7 +73,7 @@ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> co
  if ("raw".equals(encryptType)) {
  // 明文传输的消息
  WxMpXmlMessage inMessage = WxMpXmlMessage.fromXml(request.getInputStream());
- WxMpXmlOutMessage outMessage = wxMpMessageRouter.route(inMessage);
+ WxMpXmlOutMessage outMessage = coreService.route(inMessage);
  response.getWriter().write(outMessage.toXml());
  return;
  }
@@ -120,8 +82,9 @@ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> co
  // 是aes加密的消息
  String msgSignature = request.getParameter("msg_signature");
  WxMpXmlMessage inMessage = WxMpXmlMessage.fromEncryptedXml(request.getInputStream(), configStorage, timestamp, nonce, msgSignature);
- WxMpXmlOutMessage outMessage = wxMpMessageRouter.route(inMessage);
- log.info(response.toString());
+ logger.debug("\n消息解密后内容为：\n{} ", inMessage.toString());
+ WxMpXmlOutMessage outMessage = coreService.route(inMessage);
+ logger.info(response.toString());
  response.getWriter().write(outMessage.toEncryptedXml(configStorage));
  return;
  }
@@ -151,24 +114,7 @@ public WxMpUser getUserInfo(HttpServletResponse response, @RequestParam(value =
  returnModel.setResult(false);
  returnModel.setReason(e.getError().toString());
  renderString(response, returnModel);
- log.error(e.getError().toString());
- }
- return wxMpUser;
- }
-
- /**
- * 通过openid获得基本用户信息的重载方法，去除HttpServletResponse对象，否则会空指针
- *
- * @param openid
- * @param lang
- * @return
- */
- public WxMpUser getUserInfo(String openid, String lang) {
- WxMpUser wxMpUser = null;
- try {
- wxMpUser = wxMpService.userInfo(openid, lang);
- } catch (WxErrorException e) {
- log.error(e.getError().toString());
+ logger.error(e.getError().toString());
  }
  return wxMpUser;
  }
@@ -196,7 +142,7 @@ public void getOAuth2UserInfo(HttpServletResponse response, @RequestParam(value
  returnModel.setResult(false);
  returnModel.setReason(e.getError().toString());
  renderString(response, returnModel);
- log.error(e.getError().toString());
+ logger.error(e.getError().toString());
  }
  }
 
@@ -220,7 +166,7 @@ public void getOpenid(HttpServletResponse response, @RequestParam(value = "code"
  returnModel.setResult(false);
  returnModel.setReason(e.getError().toString());
  renderString(response, returnModel);
- log.error(e.getError().toString());
+ logger.error(e.getError().toString());
  }
  }
 

src/main/java/com/github/controller/CoreController.java

@@ -0,0 +1,17 @@
+package com.github.handler;
+
+import com.google.gson.Gson;
+import me.chanjar.weixin.mp.api.WxMpMessageHandler;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * 消息处理Handler的父类
+ *
+ * Created by FirenzesEagle on 2016/7/27 0027.
+ * Email:liumingbo2008@gmail.com
+ */
+public abstract class AbstractHandler implements WxMpMessageHandler {
+ protected Logger logger = LoggerFactory.getLogger(getClass());
+ protected final Gson gson = new Gson();
+}

src/main/java/com/github/handler/AbstractHandler.java

@@ -0,0 +1,26 @@
+package com.github.handler;
+
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * 对所有接收到的消息输出日志，也可进行持久化处理
+ *
+ * Created by FirenzesEagle on 2016/7/27 0027.
+ * Email:liumingbo2008@gmail.com
+ */
+@Component
+public class LogHandler extends AbstractHandler {
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage,
+ Map<String, Object> context, WxMpService wxMpService,
+ WxSessionManager sessionManager) {
+ this.logger.info("\n接收到请求消息，内容：【{}】", wxMessage.toString());
+ return null;
+ }
+}

src/main/java/com/github/handler/LogHandler.java

@@ -0,0 +1,26 @@
+package com.github.handler;
+
+import me.chanjar.weixin.common.exception.WxErrorException;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.WxMpXmlOutMessage;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+/**
+ * 转发客户消息Handler
+ *
+ * Created by FirenzesEagle on 2016/7/27 0027.
+ * Email:liumingbo2008@gmail.com
+ */
+@Component
+public class MsgHandler extends AbstractHandler {
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {
+ return WxMpXmlOutMessage
+ .TRANSFER_CUSTOMER_SERVICE().fromUser(wxMessage.getToUserName())
+ .toUser(wxMessage.getFromUserName()).build();
+ }
+}

src/main/java/com/github/handler/MsgHandler.java

@@ -0,0 +1,57 @@
+package com.github.handler;
+
+import com.github.service.CoreService;
+import me.chanjar.weixin.common.exception.WxErrorException;
+import me.chanjar.weixin.common.session.WxSessionManager;
+import me.chanjar.weixin.mp.api.WxMpConfigStorage;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.WxMpXmlOutTextMessage;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.apache.http.NameValuePair;
+import org.apache.http.message.BasicNameValuePair;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 用户关注公众号Handler
+ *
+ * Created by FirenzesEagle on 2016/7/27 0027.
+ * Email:liumingbo2008@gmail.com
+ */
+@Component
+public class SubscribeHandler extends AbstractHandler {
+
+ @Autowired
+ protected WxMpConfigStorage configStorage;
+ @Autowired
+ protected WxMpService wxMpService;
+ @Autowired
+ protected CoreService coreService;
+
+
+ @Override
+ public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {
+ WxMpUser wxMpUser = coreService.getUserInfo(wxMessage.getFromUserName(), "zh_CN");
+ List<NameValuePair> params = new ArrayList<>();
+ params.add(new BasicNameValuePair("openId", wxMpUser.getOpenId()));
+ params.add(new BasicNameValuePair("nickname", wxMpUser.getNickname()));
+ params.add(new BasicNameValuePair("headImgUrl", wxMpUser.getHeadImgUrl()));
+
+ //TODO 在这里可以进行用户关注时对业务系统的相关操作（比如新增用户）
+
+ WxMpXmlOutTextMessage m
+ = WxMpXmlOutMessage.TEXT()
+ .content("尊敬的" + wxMpUser.getNickname() + "，您好！")
+ .fromUser(wxMessage.getToUserName())
+ .toUser(wxMessage.getFromUserName())
+ .build();
+ logger.info("subscribeMessageHandler" + m.getContent());
+ return m;
+ }
+};

src/main/java/com/github/handler/SubscribeHandler.java

@@ -1,5 +1,8 @@
 package com.github.service;
 
+import me.chanjar.weixin.mp.bean.WxMpXmlMessage;
+import me.chanjar.weixin.mp.bean.WxMpXmlOutMessage;
+import me.chanjar.weixin.mp.bean.result.WxMpUser;
 import org.apache.http.NameValuePair;
 import org.apache.http.client.ClientProtocolException;
 
@@ -30,4 +33,26 @@ public interface CoreService {
  */
  public void requestPost(String url, List<NameValuePair> params) throws ClientProtocolException, IOException;
 
+ /**
+ * 刷新消息路由器
+ */
+ public void refreshRouter();
+
+ /**
+ * 路由消息
+ *
+ * @param inMessage
+ * @return
+ */
+ public WxMpXmlOutMessage route(WxMpXmlMessage inMessage);
+
+ /**
+ * 通过openid获得基本用户信息
+ *
+ * @param openid
+ * @param lang
+ * @return
+ */
+ public WxMpUser getUserInfo(String openid, String lang);
+
 }