From cda2997a8d43285372db908a512acab47b52d674 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Tue, 4 Dec 2018 11:49:34 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=BE=AE=E4=BF=A1=E5=85=AC=E4=BC=97=E5=8F=B7?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8E=A5=E6=94=B6=E5=8F=8A=E5=A4=84=E7=90=86?= =?UTF-8?q?][=E4=BF=AE=E6=94=B9]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WechatCalllbackController.java | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/WechatCalllbackController.java b/mallinkAdmin/src/main/java/com/iformall/controller/WechatCalllbackController.java index 5d39d2009..bb2ce1f13 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/WechatCalllbackController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/WechatCalllbackController.java @@ -5,6 +5,7 @@ import me.chanjar.weixin.common.error.WxErrorException; import me.chanjar.weixin.mp.bean.kefu.WxMpKefuMessage; import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; +import me.chanjar.weixin.mp.bean.message.WxMpXmlOutTextMessage; import me.chanjar.weixin.open.bean.message.WxOpenXmlMessage; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; @@ -75,7 +76,7 @@ public class WechatCalllbackController extends BaseController { return "success"; } - @RequestMapping(value = "/{appId}/callback", method = RequestMethod.POST, produces = MediaType.TEXT_XML_VALUE) + @RequestMapping(value = "/{appId}/callback") public Object callback(@PathVariable("appId") String appId, HttpServletRequest request) throws IOException { logger.info("[" +getIpAddr() + "]接收微信请求 /{appId}/callback"); InputStream inStream = request.getInputStream(); @@ -139,14 +140,21 @@ public class WechatCalllbackController extends BaseController { } else { /**判断消息类型,调用对应的方法*/ switch (inMessage.getMsgType()){ - /* case "event": case "text": WxMpXmlOutMessage outMessage = wxOpenService.getWxOpenMessageRouter().route(inMessage, appId); if (outMessage != null) { out = WxOpenXmlMessage.wxMpOutXmlMessageToEncryptedXml(outMessage, wxOpenService.getWxOpenConfigStorage()); + } else { + WxMpXmlOutMessage outMsg = new WxMpXmlOutTextMessage(); + outMsg.setCreateTime(System.currentTimeMillis()); + outMsg.setToUserName(inMessage.getFromUser()); + outMsg.setFromUserName(inMessage.getToUser()); + outMsg.setMsgType("text"); + ((WxMpXmlOutTextMessage) outMsg).setContent(inMessage.getContent()); + out = WxOpenXmlMessage.wxMpOutXmlMessageToEncryptedXml(outMsg, wxOpenService.getWxOpenConfigStorage()); } - */ + break; default: return "success"; }