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