diff --git a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java index bbf755f..c118037 100644 --- a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java +++ b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java @@ -200,6 +200,8 @@ public class WechatCalllbackController extends BaseController { openService.getWxOpenConfigStorage(), timestamp, nonce, msgSignature); logger.info("接收微信APP回调,消息解密后内容为:\n{}", inMessage.toString()); + PrintWriter printWriter = response.getWriter(); + if(appinfo.getType().equals(EnumAppType.B.getCode()) || appinfo.getType().equals(EnumAppType.C.getCode())) { // 小程序 审核 消息 @@ -218,29 +220,26 @@ public class WechatCalllbackController extends BaseController { default: break; } - PrintWriter pr = response.getWriter(); - pr.print("success"); - pr.flush(); - pr.close(); + printWriter.print("success"); + printWriter.flush(); + printWriter.close(); return; } case "text": WxMpXmlOutMessage outMessage = openService.getWxOpenMessageRouter().route(inMessage, appId); if (outMessage == null) { - PrintWriter pr = response.getWriter(); - pr.print("success"); - pr.flush(); - pr.close(); + printWriter.print("success"); + printWriter.flush(); + printWriter.close(); return; } out = WxOpenXmlMessage.wxMpOutXmlMessageToEncryptedXml(outMessage, openService.getWxOpenConfigStorage()); logger.info(out); break; default: - PrintWriter pr = response.getWriter(); - pr.print("success"); - pr.flush(); - pr.close(); + printWriter.print("success"); + printWriter.flush(); + printWriter.close(); return; } } else { @@ -250,10 +249,9 @@ public class WechatCalllbackController extends BaseController { WxMpXmlOutMessage outMessage = mpManager.getRouter(mpService).route(inMessage); if (outMessage == null) { 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; } 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) {