From ad34ae1f10c509866ff45e9b19a522996fcaaa9d Mon Sep 17 00:00:00 2001
From: jkcdev <dingchao@jkcchina.com>
Date: Wed, 30 Apr 2025 16:28:43 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=94=AF=E4=BB=98=E3=80=81?=
 =?UTF-8?q?=E9=80=80=E6=AC=BE=E7=8A=B6=E6=80=81=E6=9F=A5=E8=AF=A2=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3=EF=BC=88=E5=90=8E=E9=9D=A2=E8=80=83=E8=99=91=E6=98=AF?=
 =?UTF-8?q?=E5=90=A6=E4=BF=9D=E7=95=99=E6=9F=A5=E8=AF=A2=E5=BE=AE=E4=BF=A1?=
 =?UTF-8?q?=E6=94=AF=E4=BB=98=E8=8E=B7=E5=8F=96=E6=94=AF=E4=BB=98=E3=80=81?=
 =?UTF-8?q?=E9=80=80=E6=AC=BE=E8=AF=A6=E6=83=85=E7=9A=84=E6=8E=A5=E5=8F=A3?=
 =?UTF-8?q?=EF=BC=89=E8=BF=94=E5=9B=9E=E6=98=AF=E5=90=A6=E6=88=90=E5=8A=9F?=
 =?UTF-8?q?=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/EbikeWxPaymentController.java  |  16 +-
 .../payment/service/EbikePaymentService.java  |   7 +
 .../cdzy/payment/service/WxPayService.java    |  18 ++
 .../service/impl/EbikePaymentServiceImpl.java |   9 +-
 .../service/impl/WxPayServiceImpl.java        | 160 +++++++++++-------
 5 files changed, 144 insertions(+), 66 deletions(-)

diff --git a/ebike-payment/src/main/java/com/cdzy/payment/controller/EbikeWxPaymentController.java b/ebike-payment/src/main/java/com/cdzy/payment/controller/EbikeWxPaymentController.java
index 50d79def..cd9dd9ed 100644
--- a/ebike-payment/src/main/java/com/cdzy/payment/controller/EbikeWxPaymentController.java
+++ b/ebike-payment/src/main/java/com/cdzy/payment/controller/EbikeWxPaymentController.java
@@ -70,6 +70,18 @@ public class EbikeWxPaymentController {
         return r == null?JsonResult.failed(String.format("骑行订单号{%s}查询支付订单失败", outTradeNo)):JsonResult.success(r);
     }
 
+    /**
+     * 通过交易订单号查询支付订单状态
+     *
+     * @param transactionId 微信支付订单号
+     * @return 支付订单信息
+     */
+    @GetMapping("/queryOrderStatusById/{transactionId}")
+    public JsonResult<?> queryOrderStatusById(@PathVariable String transactionId) {
+        HandleNotifyResult r = wxPayService.queryOrderStatusById(transactionId);
+        return JsonResult.success(r);
+    }
+
     /**
      * 退款申请
      *
@@ -88,12 +100,14 @@ public class EbikeWxPaymentController {
      * @param outRefundNo 商户(骑行)退款单号
      * @return 退款信息
      */
-    @GetMapping("/refundQuery/{outRefundNo}")
+    @GetMapping("/queryRefund/{outRefundNo}")
     public JsonResult<?> refundQuery(@PathVariable String outRefundNo) {
         Refund r = wxPayService.queryRefundByOutNo(outRefundNo);
         return r == null?JsonResult.failed(String.format("退款单号{%s}查询退款失败", outRefundNo)):JsonResult.success(r);
     }
 
+
+
     // ================通知回调接口===============
     // TODO 通知接口不能鉴权
     /**
diff --git a/ebike-payment/src/main/java/com/cdzy/payment/service/EbikePaymentService.java b/ebike-payment/src/main/java/com/cdzy/payment/service/EbikePaymentService.java
index 1067bb83..287cf606 100644
--- a/ebike-payment/src/main/java/com/cdzy/payment/service/EbikePaymentService.java
+++ b/ebike-payment/src/main/java/com/cdzy/payment/service/EbikePaymentService.java
@@ -37,4 +37,11 @@ public interface EbikePaymentService extends IService<EbikePayment> {
      */
     Boolean updatePaymentStatus(Transaction transaction);
 
+    /**
+     * 根据支付订单id查询支付记录
+     *
+     * @param paymentId 支付订单id
+     * @return
+     */
+    EbikePayment getByPaymentId(String paymentId);
 }
diff --git a/ebike-payment/src/main/java/com/cdzy/payment/service/WxPayService.java b/ebike-payment/src/main/java/com/cdzy/payment/service/WxPayService.java
index bcba35cf..a68cf42a 100644
--- a/ebike-payment/src/main/java/com/cdzy/payment/service/WxPayService.java
+++ b/ebike-payment/src/main/java/com/cdzy/payment/service/WxPayService.java
@@ -26,6 +26,7 @@ public interface WxPayService {
      * @return
      */
     boolean closeOrder(String outTradeNo);
+
     /**
      * JSAPI支付下单
      *
@@ -46,6 +47,7 @@ public interface WxPayService {
      * @return 支付订单信息
      */
     Transaction queryOrderById(String transactionId);
+
     /**
      * 通过商户(骑行)订单号查询支付订单
      *
@@ -54,6 +56,14 @@ public interface WxPayService {
      */
     Transaction queryOrderByOutTradeNo(String outTradeNo);
 
+    /**
+     * 通过交易订单号查询支付订单状态
+     *
+     * @param transactionId 微信支付订单号
+     * @return 支付订单信息
+     */
+    HandleNotifyResult queryOrderStatusById(String transactionId);
+
     /**
      * 处理支付回调
      *
@@ -82,6 +92,14 @@ public interface WxPayService {
      */
     Refund queryRefundByOutNo(String outRefundNo);
 
+    /**
+     * 通过商户退款单号查询退款信息状态
+     *
+     * @param outRefundNo 商户退款订单号
+     * @return 退款信息
+     */
+    HandleNotifyResult queryRefundStatusByOutNo(String outRefundNo);
+
     /**
      * 处理支退款回调
      *
diff --git a/ebike-payment/src/main/java/com/cdzy/payment/service/impl/EbikePaymentServiceImpl.java b/ebike-payment/src/main/java/com/cdzy/payment/service/impl/EbikePaymentServiceImpl.java
index a55879ca..3f171cdb 100644
--- a/ebike-payment/src/main/java/com/cdzy/payment/service/impl/EbikePaymentServiceImpl.java
+++ b/ebike-payment/src/main/java/com/cdzy/payment/service/impl/EbikePaymentServiceImpl.java
@@ -58,7 +58,7 @@ public class EbikePaymentServiceImpl extends ServiceImpl<EbikePaymentMapper, Ebi
         ebikePayment.setTradeState(String.valueOf(transaction.getTradeState().ordinal()));
         if (Transaction.TradeStateEnum.SUCCESS.equals(transaction.getTradeState())) {
             // 支付成功， 更新订单状态
-            double v = transaction.getAmount().getTotal().doubleValue() / 100.0;
+            double v = transaction.getAmount().getPayerTotal().doubleValue() / 100.0;
             ebikePayment.setTotal(v);
             String paymentTime = transaction.getSuccessTime();
             ebikePayment.setPaymentTime(StringUtils.toLocalDatetime(paymentTime));
@@ -73,4 +73,11 @@ public class EbikePaymentServiceImpl extends ServiceImpl<EbikePaymentMapper, Ebi
                .where(EBIKE_PAYMENT.PAYMENT_ID.eq(transaction.getTransactionId()));
         return update(ebikePayment, query);
     }
+
+    @Override
+    public EbikePayment getByPaymentId(String paymentId) {
+        QueryWrapper query = QueryWrapper.create()
+              .where(EBIKE_PAYMENT.PAYMENT_ID.eq(paymentId));
+        return this.getOne(query);
+    }
 }
diff --git a/ebike-payment/src/main/java/com/cdzy/payment/service/impl/WxPayServiceImpl.java b/ebike-payment/src/main/java/com/cdzy/payment/service/impl/WxPayServiceImpl.java
index 9e6c8b0d..501fd507 100644
--- a/ebike-payment/src/main/java/com/cdzy/payment/service/impl/WxPayServiceImpl.java
+++ b/ebike-payment/src/main/java/com/cdzy/payment/service/impl/WxPayServiceImpl.java
@@ -147,26 +147,44 @@ public class WxPayServiceImpl implements WxPayService {
 
     @Override
     public Transaction queryOrderById(String transactionId) {
-        try {
-            QueryOrderByIdRequest request = new QueryOrderByIdRequest();
-            request.setTransactionId(transactionId);
-            return wxJsapiService.queryOrderById(request);
-        }catch (Exception e) {
-            logError("通过交易订单号查询支付订单queryOrderById", e);
-        }
-        return null;
+        QueryOrderByIdRequest request = new QueryOrderByIdRequest();
+        request.setTransactionId(transactionId);
+        return wxJsapiService.queryOrderById(request);
     }
 
     @Override
     public Transaction queryOrderByOutTradeNo(String outTradeNo) {
-        try {
-            QueryOrderByOutTradeNoRequest request = new QueryOrderByOutTradeNoRequest();
-            request.setOutTradeNo(outTradeNo);
-            return wxJsapiService.queryOrderByOutTradeNo(request);
-        }catch (Exception e) {
-            logError("通过商户(骑行)订单号查询支付订单queryOrderByOutTradeNo", e);
-            return null;
+        QueryOrderByOutTradeNoRequest request = new QueryOrderByOutTradeNoRequest();
+        request.setOutTradeNo(outTradeNo);
+        return wxJsapiService.queryOrderByOutTradeNo(request);
+    }
+
+    @Override
+    public HandleNotifyResult queryOrderStatusById(String transactionId) {
+        // 先查本地数据库，如果退款状态不为SUCCESS，需要查询微信支付
+        HandleNotifyResult result = new HandleNotifyResult();
+        EbikePayment ebikePayment = ebikePaymentService.getByPaymentId(transactionId);
+        if (ebikePayment==null){
+            log.error("{}支付订单不存在", transactionId);
+            result.setMessage(String.format("{%s}支付订单不存在", transactionId));
+            return result;
         }
+        result.setSuccess(String.valueOf(Transaction.TradeStateEnum.SUCCESS.ordinal()).equals(ebikePayment.getTradeState()));
+        if (result.isSuccess()){
+            result.setMessage(String.format("订单%s支付成功", ebikePayment.getOrderId()));
+            return result;
+        }
+        QueryOrderByIdRequest request = new QueryOrderByIdRequest();
+        request.setTransactionId(transactionId);
+        Transaction r = wxJsapiService.queryOrderById(request);
+        if(r!=null&& r.getTradeState().equals(Transaction.TradeStateEnum.SUCCESS)) {
+            result.setMessage(String.format("订单%s支付成功", ebikePayment.getOrderId()));
+            result.setSuccess(true);
+            // 更新支付状态
+            ebikePaymentService.updatePaymentStatus(r);
+            return result;
+        }
+        return result;
     }
 
     @Override
@@ -177,14 +195,12 @@ public class WxPayServiceImpl implements WxPayService {
         String nonce = request.getHeader(WECHAT_PAY_NONCE);
         String serialNo = request.getHeader(WECHAT_PAY_SERIAL);
         String signature = request.getHeader(WECHAT_PAY_SIGNATURE);
-        String signatureType = request.getHeader(WECHAT_PAY_SIGNATURE+"-Type");
         String timestamp = request.getHeader(WECHAT_PAY_TIMESTAMP);
 
         try {
             RequestParam requestParam = new RequestParam.Builder()
                     .serialNumber(serialNo)
                     .signature(signature)
-                    .signType(signatureType)
                     .timestamp(timestamp)
                     .body(HttpServletUtils.getRequestBody(request))
                     .nonce(nonce)
@@ -208,58 +224,76 @@ public class WxPayServiceImpl implements WxPayService {
 
     @Override
     public String refund(String transactionId, String outTradeNo, String reason, AmountRefundDto amount) {
-        try {
-            // 雪花算法生成退款单号
-            String outRefundNo = StringUtils.generateSnowflakeId("refundId");
-            EbikeRefund ebikeRefund = new EbikeRefund();
-            ebikeRefund.setCreateTime(LocalDateTime.now());
-            // 发起退款
-            CreateRequest request = new CreateRequest();
-            request.setTransactionId(transactionId);
-            request.setOutTradeNo(outTradeNo);
-            request.setOutRefundNo(outRefundNo);
-            request.setReason(reason);
-            request.setNotifyUrl(wxPayConfig.getRefundNotifyUrl());
-            AmountReq amountReq = new AmountReq();
-            amountReq.setRefund(BigDecimal.valueOf(amount.getRefund() * 100.0).longValue());
-            amountReq.setTotal(BigDecimal.valueOf(amount.getTotal() * 100.0).longValue());
-            amountReq.setCurrency(amount.getCurrency());
-            request.setAmount(amountReq);
-            Refund result = wxRefundService.create(request);
-            // 入库
-            if (result != null) {
-                ebikeRefund.setRefundId(outRefundNo);
-                ebikeRefund.setOrderId(outTradeNo);
-                ebikeRefund.setPaymentId(transactionId);
-                ebikeRefund.setTotal(amount.getTotal());
-                ebikeRefund.setReason(reason);
-                ebikeRefund.setStatus(String.valueOf(result.getStatus().ordinal()));
-                ebikeRefund.setCurrency(amount.getCurrency());
-                if(Status.SUCCESS.equals(result.getStatus())){
-                    ebikeRefund.setRefund(result.getAmount().getRefund().doubleValue() / 100.0);
-                    ebikeRefund.setRefundTime(LocalDateTime.now());
-                }
-                ebikeRefundService.saveRefundResult(ebikeRefund);
-                return outRefundNo;
+        // 雪花算法生成退款单号
+        String outRefundNo = StringUtils.generateSnowflakeId("refundId");
+        EbikeRefund ebikeRefund = new EbikeRefund();
+        ebikeRefund.setCreateTime(LocalDateTime.now());
+        // 发起退款
+        CreateRequest request = new CreateRequest();
+        request.setTransactionId(transactionId);
+        request.setOutTradeNo(outTradeNo);
+        request.setOutRefundNo(outRefundNo);
+        request.setReason(reason);
+        request.setNotifyUrl(wxPayConfig.getRefundNotifyUrl());
+        AmountReq amountReq = new AmountReq();
+        amountReq.setRefund(BigDecimal.valueOf(amount.getRefund() * 100.0).longValue());
+        amountReq.setTotal(BigDecimal.valueOf(amount.getTotal() * 100.0).longValue());
+        amountReq.setCurrency(amount.getCurrency());
+        request.setAmount(amountReq);
+        Refund result = wxRefundService.create(request);
+        // 入库
+        if (result != null) {
+            ebikeRefund.setRefundId(outRefundNo);
+            ebikeRefund.setOrderId(outTradeNo);
+            ebikeRefund.setPaymentId(transactionId);
+            ebikeRefund.setTotal(amount.getTotal());
+            ebikeRefund.setReason(reason);
+            ebikeRefund.setStatus(String.valueOf(result.getStatus().ordinal()));
+            ebikeRefund.setCurrency(amount.getCurrency());
+            if(Status.SUCCESS.equals(result.getStatus())){
+                ebikeRefund.setRefund(result.getAmount().getRefund().doubleValue() / 100.0);
+                ebikeRefund.setRefundTime(LocalDateTime.now());
             }
-            log.error("退款申请refund失败，订单号：{}", outTradeNo);
-            return null;
-        }catch (Exception e) {
-            logError("退款申请refund", e);
-            return null;
+            ebikeRefundService.saveRefundResult(ebikeRefund);
+            return outRefundNo;
         }
+        log.error("退款申请refund失败，订单号：{}", outTradeNo);
+        return null;
     }
 
     @Override
     public Refund queryRefundByOutNo(String outRefundNo) {
-        try {
-            QueryByOutRefundNoRequest request = new QueryByOutRefundNoRequest();
-            request.setOutRefundNo(outRefundNo);
-            return wxRefundService.queryByOutRefundNo(request);
-        }catch (Exception e) {
-            logError("通过商户退款单号查询退款queryByOutRefundNo", e);
-            return null;
+        QueryByOutRefundNoRequest request = new QueryByOutRefundNoRequest();
+        request.setOutRefundNo(outRefundNo);
+        return wxRefundService.queryByOutRefundNo(request);
+    }
+
+    @Override
+    public HandleNotifyResult queryRefundStatusByOutNo(String outRefundNo) {
+        HandleNotifyResult result = new HandleNotifyResult();
+        // 先查本地数据库，如果退款状态不为SUCCESS，需要查询微信支付
+        EbikeRefund ebikeRefund = ebikeRefundService.getById(outRefundNo);
+        if (ebikeRefund==null){
+            log.error("{}退款订单不存在", outRefundNo);
+            result.setMessage(String.format("{%s}退款订单不存在", outRefundNo));
+            return result;
         }
+        result.setSuccess(String.valueOf(Status.SUCCESS.ordinal()).equals(ebikeRefund.getStatus()));
+        if (result.isSuccess()){
+            result.setMessage(String.format("退款%s成功", ebikeRefund.getRefundId()));
+            return result;
+        }
+        QueryByOutRefundNoRequest request = new QueryByOutRefundNoRequest();
+        request.setOutRefundNo(outRefundNo);
+        Refund r = wxRefundService.queryByOutRefundNo(request);
+        if(r!=null&& r.getStatus().equals(Status.SUCCESS)) {
+            result.setMessage(String.format("退款%s成功", ebikeRefund.getRefundId()));
+            result.setSuccess(true);
+            // 更新退款状态
+            ebikeRefundService.updateRefundStatus(r);
+            return result;
+        }
+        return result;
     }
 
     @Override
@@ -270,14 +304,12 @@ public class WxPayServiceImpl implements WxPayService {
         String nonce = request.getHeader(WECHAT_PAY_NONCE);
         String serialNo = request.getHeader(WECHAT_PAY_SERIAL);
         String signature = request.getHeader(WECHAT_PAY_SIGNATURE);
-        String signatureType = request.getHeader(WECHAT_PAY_SIGNATURE+"-Type");
         String timestamp = request.getHeader(WECHAT_PAY_TIMESTAMP);
 
         try {
             RequestParam requestParam = new RequestParam.Builder()
                     .serialNumber(serialNo)
                     .signature(signature)
-                    .signType(signatureType)
                     .timestamp(timestamp)
                     .body(HttpServletUtils.getRequestBody(request))
                     .nonce(nonce)