Parcourir la source

[微信公众号消息接收及处理][修改]

release_toaliyun_real
Stormeye Wu il y a 7 ans
Parent
révision
cda2997a8d
1 fichiers modifiés avec 11 ajouts et 3 suppressions
  1. +11
    -3
      mallinkAdmin/src/main/java/com/iformall/controller/WechatCalllbackController.java

+ 11
- 3
mallinkAdmin/src/main/java/com/iformall/controller/WechatCalllbackController.java Voir le fichier

@@ -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.kefu.WxMpKefuMessage;
import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage; import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage; 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 me.chanjar.weixin.open.bean.message.WxOpenXmlMessage;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
@@ -75,7 +76,7 @@ public class WechatCalllbackController extends BaseController {
return "success"; 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 { public Object callback(@PathVariable("appId") String appId, HttpServletRequest request) throws IOException {
logger.info("[" +getIpAddr() + "]接收微信请求 /{appId}/callback"); logger.info("[" +getIpAddr() + "]接收微信请求 /{appId}/callback");
InputStream inStream = request.getInputStream(); InputStream inStream = request.getInputStream();
@@ -139,14 +140,21 @@ public class WechatCalllbackController extends BaseController {
} else { } else {
/**判断消息类型,调用对应的方法*/ /**判断消息类型,调用对应的方法*/
switch (inMessage.getMsgType()){ switch (inMessage.getMsgType()){
/*
case "event": case "event":
case "text": case "text":
WxMpXmlOutMessage outMessage = wxOpenService.getWxOpenMessageRouter().route(inMessage, appId); WxMpXmlOutMessage outMessage = wxOpenService.getWxOpenMessageRouter().route(inMessage, appId);
if (outMessage != null) { if (outMessage != null) {
out = WxOpenXmlMessage.wxMpOutXmlMessageToEncryptedXml(outMessage, wxOpenService.getWxOpenConfigStorage()); 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: default:
return "success"; return "success";
} }


Chargement…
Annuler
Enregistrer