From b30e1a48f2bc5f65a0efd2e69e090fed2d7a627c Mon Sep 17 00:00:00 2001 From: yanghui <2536613402@qq.com> Date: 星期四, 17 十一月 2022 15:56:43 +0800 Subject: [PATCH] #feat 订单退款和查询 --- springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java | 70 +++++++++++++++++++++++++++++++++++ 1 files changed, 70 insertions(+), 0 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java index edb9839..25ee016 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java @@ -348,4 +348,74 @@ public R settle(String settleDate){ return R.ok(umfPayUtil.settle(settleDate)); } + + + @PostMapping("flowerWxNotify") + public void flowerWxNotify(HttpServletRequest request, HttpServletResponse response) { + log.error("微信支付回调start"); + String inputLine = ""; + String notityXml = ""; + try { + while ((inputLine = request.getReader().readLine()) != null) { + notityXml += inputLine; + } + // 关闭流 + request.getReader().close(); + log.error("微信回调内容信息:" + notityXml); + // 解析成Json + org.json.JSONObject xmlJson = XML.toJSONObject(notityXml); + if (StringUtils.isNotEmpty(xmlJson.toString())) { + JSONObject resultData = JSON.parseObject(xmlJson.get("xml").toString()); + // 成功支付订单 + if (resultData.getString("result_code").equals("SUCCESS") + && resultData.getString("return_code").equals("SUCCESS")) { + WxPayNotifyOrderDTO notifyOrderDTO = new WxPayNotifyOrderDTO(); + // 订单号 + String orderTradeNo = resultData.getString("out_trade_no"); + notifyOrderDTO.setOrderTradeNo(orderTradeNo); + // 微信支付订单号 + String wxTradeNo = resultData.getString("transaction_id"); + notifyOrderDTO.setWxTradeNo(wxTradeNo); + // 订单金额 + String totalFee = resultData.getString("total_fee"); + notifyOrderDTO.setTotalFee(totalFee); + // 支付完成时间 + String payTime = resultData.getString("time_end"); + notifyOrderDTO.setPayTime(payTime); + // 现金支付金额 + String cashFee = resultData.getString("cash_fee"); + notifyOrderDTO.setCashFee(cashFee); + + // 根据订单号修改订单信息 + communityService.wxOrderPayNotify(notifyOrderDTO); + + // 封装 返回值 + StringBuffer buffer = new StringBuffer(); + buffer.append("<xml>"); + buffer.append("<return_code>SUCCESS</return_code>"); + buffer.append("<return_msg>OK</return_msg>"); + buffer.append("</xml>"); + + // 给微信服务器返回 成功标示 否则会一直询问 咱们服务器 是否回调成功 + PrintWriter writer = response.getWriter(); + // 返回 + writer.print(buffer.toString()); + } else {// 未成功支付订单 + // 封装 返回值 + StringBuffer buffer = new StringBuffer(); + buffer.append("<xml>"); + buffer.append("<return_code>FAIL</return_code>"); + buffer.append("<return_msg>FAIL</return_msg>"); + buffer.append("</xml>"); + + // 给微信服务器返回 成功标示 否则会一直询问 咱们服务器 是否回调成功 + PrintWriter writer = response.getWriter(); + // 返回 + writer.print(buffer.toString()); + } + } + } catch (IOException e) { + e.printStackTrace(); + } + } } -- Gitblit v1.7.1