Browse Source

[公众号消息][修改]:第三方平台api处理公众号消息

release
Stormeye Wu 7 years ago
parent
commit
5dccfaba9f
1 changed files with 17 additions and 20 deletions
  1. +17
    -20
      mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java

+ 17
- 20
mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java View File

@@ -200,6 +200,8 @@ public class WechatCalllbackController extends BaseController {
openService.getWxOpenConfigStorage(), timestamp, nonce, msgSignature); openService.getWxOpenConfigStorage(), timestamp, nonce, msgSignature);
logger.info("接收微信APP回调,消息解密后内容为:\n{}", inMessage.toString()); logger.info("接收微信APP回调,消息解密后内容为:\n{}", inMessage.toString());


PrintWriter printWriter = response.getWriter();

if(appinfo.getType().equals(EnumAppType.B.getCode()) || if(appinfo.getType().equals(EnumAppType.B.getCode()) ||
appinfo.getType().equals(EnumAppType.C.getCode())) { appinfo.getType().equals(EnumAppType.C.getCode())) {
// 小程序 审核 消息 // 小程序 审核 消息
@@ -218,29 +220,26 @@ public class WechatCalllbackController extends BaseController {
default: default:
break; break;
} }
PrintWriter pr = response.getWriter();
pr.print("success");
pr.flush();
pr.close();
printWriter.print("success");
printWriter.flush();
printWriter.close();
return; return;
} }
case "text": case "text":
WxMpXmlOutMessage outMessage = openService.getWxOpenMessageRouter().route(inMessage, appId); WxMpXmlOutMessage outMessage = openService.getWxOpenMessageRouter().route(inMessage, appId);
if (outMessage == null) { if (outMessage == null) {
PrintWriter pr = response.getWriter();
pr.print("success");
pr.flush();
pr.close();
printWriter.print("success");
printWriter.flush();
printWriter.close();
return; return;
} }
out = WxOpenXmlMessage.wxMpOutXmlMessageToEncryptedXml(outMessage, openService.getWxOpenConfigStorage()); out = WxOpenXmlMessage.wxMpOutXmlMessageToEncryptedXml(outMessage, openService.getWxOpenConfigStorage());
logger.info(out); logger.info(out);
break; break;
default: default:
PrintWriter pr = response.getWriter();
pr.print("success");
pr.flush();
pr.close();
printWriter.print("success");
printWriter.flush();
printWriter.close();
return; return;
} }
} else { } else {
@@ -250,10 +249,9 @@ public class WechatCalllbackController extends BaseController {
WxMpXmlOutMessage outMessage = mpManager.getRouter(mpService).route(inMessage); WxMpXmlOutMessage outMessage = mpManager.getRouter(mpService).route(inMessage);
if (outMessage == null) { if (outMessage == null) {
this.logger.info("2 return: success"); this.logger.info("2 return: success");
PrintWriter pr = response.getWriter();
pr.print("success");
pr.flush();
pr.close();
printWriter.print("success");
printWriter.flush();
printWriter.close();
return; return;
} }
logger.info("组装回复" + outMessage.toXml()); logger.info("组装回复" + outMessage.toXml());
@@ -264,10 +262,9 @@ public class WechatCalllbackController extends BaseController {
} }
} }


PrintWriter pr = response.getWriter();
pr.print("success");
pr.flush();
pr.close();
printWriter.print("success");
printWriter.flush();
printWriter.close();
} }


private void updateAuditStatus(String appId, boolean success, String reason) { private void updateAuditStatus(String appId, boolean success, String reason) {


Loading…
Cancel
Save