From 29a57ef19ba1a202d5923a9e356ed5863d26602c Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期四, 23 六月 2022 15:08:13 +0800
Subject: [PATCH] bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java |   85 +++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 82 insertions(+), 3 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 ea8de16..388647a 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
@@ -2,15 +2,19 @@
 
 import java.io.IOException;
 import java.io.PrintWriter;
+import java.util.Date;
+import java.util.Map;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 
+import com.panzhihua.applets.umf.UmfPayUtil;
+import com.panzhihua.common.model.vos.R;
+import com.panzhihua.common.utlis.DateUtils;
+import io.swagger.annotations.ApiOperation;
 import org.json.XML;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -32,6 +36,8 @@
 
     @Resource
     private CommunityService communityService;
+    @Resource
+    private UmfPayUtil umfPayUtil;
 
     @PostMapping("wxNotify")
     public void payCallback(HttpServletRequest request, HttpServletResponse response) {
@@ -101,4 +107,77 @@
             e.printStackTrace();
         }
     }
+    @PostMapping("wxNotifyAll")
+    public void payCallbackAll(HttpServletRequest request, HttpServletResponse response) {
+        log.info("微信支付回调start");
+        String inputLine = "";
+        String notityXml = "";
+        try {
+            while ((inputLine = request.getReader().readLine()) != null) {
+                notityXml += inputLine;
+            }
+            // 关闭流
+            request.getReader().close();
+            log.info("微信回调内容信息:" + 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);
+
+
+
+                    // 封装 返回值
+                    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();
+        }
+    }
+    @ApiOperation("uu洗车退款接口")
+    @GetMapping("/uuRepay")
+    public R uuRepay(@RequestParam("orderid") String orderid, @RequestParam("merdate") String merdate, @RequestParam("refundAmount")String refundAmount, @RequestParam("orgAmount")String orgAmount){
+        Map map=umfPayUtil.repay(orderid,merdate, DateUtils.getDateFormatString(new Date(),"yyMMddHHmmss")+"0001",refundAmount,orgAmount);
+        return R.ok(map);
+    }
 }

--
Gitblit v1.7.1