From 24f7f046f8854d63839ad52d0cff34ea45a0f449 Mon Sep 17 00:00:00 2001
From: gongzuming <gongzuming>
Date: 星期二, 12 十一月 2024 13:10:17 +0800
Subject: [PATCH] 优化

---
 src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java |   54 ++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 44 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java b/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java
index bf4fbf7..e756717 100644
--- a/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java
+++ b/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java
@@ -343,10 +343,16 @@
         SybPayService service = new SybPayService();
 
         Map<String,String> params = service.query(orderId, up.getTransactionId());
+        String retcode = params.get("retcode");
+        if(!"SUCCESS".equals(retcode)){
+            throw new ValidationException("查询订单交易状态失败: " + params.get("retmsg"));
+        }
         String trxstatus = params.get("trxstatus");//支付状态
 
-        if("1001".equals(trxstatus)){
-            //空单 直接取消
+        if("1001".equals(trxstatus) || "3088".equals(trxstatus)){
+            //3088-交易未支付(在查询时间区间内未成功支付,如已影响资金24小时内会做差错退款处理)
+            //1001:交易不存在
+            //直接取消
         } else if (StringUtils.isEmpty(trxstatus)
                 || "2008".equals(trxstatus)
                 || "2000".equals(trxstatus)) {
@@ -355,10 +361,15 @@
             Map<String,String> map = service.close(trxid, orderId);
             log.info("======关闭订单结果" + toJSONString(map));
 
-            String retcode = map.get("retcode");
+            retcode = map.get("retcode");
             if(!"SUCCESS".equals(retcode)){
-                throw new ValidationException("取消订单失败: " + map.get("retmsg"));
+                throw new ValidationException("调用通联关闭订单失败: " + map.get("retmsg"));
             }
+            trxstatus = map.get("trxstatus");
+            if(!"0000".equals(trxstatus)){
+                throw new ValidationException("取消订单失败: " + map.get("errmsg"));
+            }
+
         } else {
             throw new ValidationException("订单不可取消");
         }
@@ -440,7 +451,7 @@
             throw new ValidationException("订单不可退款");
         }
 
-        long trxamt = up.getPaymentAmount().longValue();
+        long trxamt = prepareAmount(up.getPaymentAmount());
         String reqsn = orderId;
         String oldtrxid = up.getTransactionId();
         String oldreqsn = orderId;
@@ -449,7 +460,14 @@
         Map<String,String> map = service.cancel(trxamt, reqsn, oldtrxid, oldreqsn);
         String retcode = map.get("retcode");
         if(!"SUCCESS".equals(retcode)){
-            throw new ValidationException("订单退款失败: " + map.get("retmsg"));
+            throw new ValidationException("调用通联撤销接口失败: " + map.get("retmsg"));
+        }
+
+        //这个不是订单状态,是通用的,如果是支付查询,代表就是订单状态,如果是退款代表的是退款状态
+        String trxstatus = map.get("trxstatus");
+        if(!"0000".equals(trxstatus)){
+            log.error("通联撤销交易失败:" + map.get("errmsg"));
+            throw new ValidationException("订单退款交易失败:" + map.get("errmsg"));
         }
 
         updateOrderRefund(orderId, oldtrxid);
@@ -467,7 +485,7 @@
             throw new ValidationException("订单不可退款");
         }
 
-        long trxamt = up.getPaymentAmount().longValue();
+        long trxamt = prepareAmount(up.getPaymentAmount());
         String reqsn = orderId;
         String oldtrxid = up.getTransactionId();
         String oldreqsn = orderId;
@@ -476,7 +494,13 @@
         Map<String,String> map = service.refund(trxamt, reqsn, oldtrxid, oldreqsn);
         String retcode = map.get("retcode");
         if(!"SUCCESS".equals(retcode)){
-            throw new ValidationException("订单退款失败: " + map.get("retmsg"));
+            throw new ValidationException("调用通联退款失败: " + map.get("retmsg"));
+        }
+
+        //这个不是订单状态,是通用的,如果是支付查询,代表就是订单状态,如果是退款代表的是退款状态
+        String trxstatus = map.get("trxstatus");
+        if(!"0000".equals(trxstatus)){
+            throw new ValidationException("订单退款交易失败:" + map.get("errmsg"));
         }
 
         updateOrderRefund(orderId, oldtrxid);
@@ -544,7 +568,7 @@
                 new QueryWrapper<UserPayment>().eq("order_id", o.getId()));
 
         long trxamt = refund;
-        String reqsn = o.getId();
+        String reqsn = re.getId();//退款单的id
         String oldtrxid = up.getTransactionId();
         String oldreqsn = null;
 
@@ -552,12 +576,22 @@
         Map<String,String> map = service.refund(trxamt, reqsn, oldtrxid, oldreqsn);
         String retcode = map.get("retcode");
         if(!"SUCCESS".equals(retcode)){
-            throw new ValidationException("订单退款失败: " + map.get("retmsg"));
+            throw new ValidationException("调用通联退款失败: " + map.get("retmsg"));
+        }
+
+        //这个不是订单状态,是通用的,如果是支付查询,代表就是订单状态,如果是退款代表的是退款状态
+        String trxstatus = map.get("trxstatus");
+        if(!"0000".equals(trxstatus)){
+            throw new ValidationException("订单退款交易失败:" + map.get("errmsg"));
         }
 
         re.setRequest(toJSONString(map));
         re.create(SecurityUtils.getUserId());
 
+        re.setStatus(retcode);
+        re.setNotification(retcode);
+        re.setNotifyTime(LocalDateTime.now());
+
         orderRefundMapper.insert(re);
 
         return re.getId();

--
Gitblit v1.9.3