From 5c69299991ee84d14f8c040eb51eec13498efe71 Mon Sep 17 00:00:00 2001 From: wangpengfei <1928057482@qq.com> Date: Tue, 17 Dec 2024 10:35:05 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=80=E6=AC=BE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/yxt/pay/api/refund/RefundOrder.java | 5 +- .../com/yxt/pay/biz/order/OrderService.java | 1 + .../com/yxt/pay/biz/refund/WxRefundRest.java | 7 +- .../yxt/pay/biz/refund/WxRefundService.java | 159 ++++++++++++------ .../java/com/yxt/pay/utils/TrustEveryone.java | 39 +++++ 5 files changed, 153 insertions(+), 58 deletions(-) create mode 100644 src/main/java/com/yxt/pay/utils/TrustEveryone.java diff --git a/src/main/java/com/yxt/pay/api/refund/RefundOrder.java b/src/main/java/com/yxt/pay/api/refund/RefundOrder.java index 4f77e48..a330004 100644 --- a/src/main/java/com/yxt/pay/api/refund/RefundOrder.java +++ b/src/main/java/com/yxt/pay/api/refund/RefundOrder.java @@ -4,6 +4,7 @@ import com.yxt.common.base.utils.StringRandom; import com.yxt.common.core.domain.BaseEntity; import lombok.Data; +import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.Date; @@ -17,7 +18,7 @@ public class RefundOrder extends BaseEntity { private String outRefundNo;//订单编号 private int source;//来源 0云菜窖 private String name;//商品名 - private String amount;//金额 + private BigDecimal amount;//金额 private String openId;// private String returnUrl;//业务回调 private String orderSid;//支付订单sid @@ -31,7 +32,7 @@ public class RefundOrder extends BaseEntity { public RefundOrder(int source) { String Randomstr = StringRandom.getRandomString(15); if (source == 0) {//云菜窖 - outTradeNo = "YCJ" + getTime() + Randomstr; + outRefundNo = "YCJ" + getTime() + Randomstr; } else if (source == 1) { diff --git a/src/main/java/com/yxt/pay/biz/order/OrderService.java b/src/main/java/com/yxt/pay/biz/order/OrderService.java index 788d8dd..a51d5fb 100644 --- a/src/main/java/com/yxt/pay/biz/order/OrderService.java +++ b/src/main/java/com/yxt/pay/biz/order/OrderService.java @@ -151,6 +151,7 @@ public class OrderService extends MybatisBaseService { Map map = new HashMap<>(); map.put("mainSid", payOrder.getSid()); map.put("payTime", date); + TrustEveryone.trustEveryone(); ResponseEntity postForEntity = new RestTemplate().postForEntity(payOrder.getPayUrl(), map, ResultBean.class); return rb.success().setData(resultObj); } diff --git a/src/main/java/com/yxt/pay/biz/refund/WxRefundRest.java b/src/main/java/com/yxt/pay/biz/refund/WxRefundRest.java index f90cb3b..b851963 100644 --- a/src/main/java/com/yxt/pay/biz/refund/WxRefundRest.java +++ b/src/main/java/com/yxt/pay/biz/refund/WxRefundRest.java @@ -9,6 +9,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; /** * @author wangpengfei @@ -39,10 +40,10 @@ public class WxRefundRest { */ // @Operation(summary = "微信退款回调" , description = "微信退款回调" ) // @SysLog("微信退款回调" ) - @PostMapping("/payNotify") - public ResultBean refundPayNotify(HttpServletRequest request) throws Exception { + @PostMapping("/refundNotify") + public ResultBean refundPayNotify(HttpServletRequest request, HttpServletResponse response) throws Exception { ResultBean rb=new ResultBean(); - refundService.refundNotify(request);//注意：回调接口需要暴露到公网上，且要放开token验证 + refundService.refundNotify(request,response);//注意：回调接口需要暴露到公网上，且要放开token验证 return rb.success(); } diff --git a/src/main/java/com/yxt/pay/biz/refund/WxRefundService.java b/src/main/java/com/yxt/pay/biz/refund/WxRefundService.java index 8612c5a..a370664 100644 --- a/src/main/java/com/yxt/pay/biz/refund/WxRefundService.java +++ b/src/main/java/com/yxt/pay/biz/refund/WxRefundService.java @@ -19,7 +19,11 @@ import com.yxt.pay.api.order.PayOrder; import com.yxt.pay.api.refund.*; import com.yxt.pay.api.wxpay.WxPayVo; import com.yxt.pay.biz.order.OrderService; +import com.yxt.pay.utils.TrustEveryone; import com.yxt.pay.utils.UrlComponent; +import com.yxt.pay.utils.wx.HttpKit; +import com.yxt.pay.utils.wx.SignType; +import com.yxt.pay.utils.wx.WxPayKit; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; @@ -30,9 +34,12 @@ import org.springframework.web.client.RestTemplate; import javax.servlet.ServletInputStream; import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; import java.io.BufferedReader; +import java.io.InputStream; import java.io.InputStreamReader; import java.math.BigDecimal; +import java.util.Date; import java.util.HashMap; import java.util.Map; @@ -68,7 +75,9 @@ public class WxRefundService extends MybatisBaseService().eq("sid",refundOrderDto.getOrderSid())); + BeanUtil.copyProperties(refundOrderDto,refundOrder,"id","sid"); + refundOrder.setOutTradeNo(payOrder.getOutTradeNo()); baseMapper.insert(refundOrder); return rb.success().setData(refundOrder); @@ -84,9 +93,9 @@ public class WxRefundService extends MybatisBaseService().eq("sid",orderSid)); + RefundOrder refundOrder=baseMapper.selectOne(new QueryWrapper().eq("orderSid",payOrder.getSid()).eq("state","1")); try { - PayOrder payOrder=orderService.getOne(new QueryWrapper().eq("sid",orderSid)); - WxPayVo wxPayVo=new WxPayVo(payOrder.getSource()); source=payOrder.getSource(); // 使用自动更新平台证书的RSA配置 // 一个商户号只能初始化一个配置，否则会因为重复的下载任务报错 @@ -101,58 +110,48 @@ public class WxRefundService extends MybatisBaseService().eq("sid",orderSid)); - RefundOrder refundOrder=baseMapper.selectOne(new QueryWrapper().eq("orderSid",payOrder.getSid())); - BigDecimal b=new BigDecimal(refundOrder.getAmount()); BigDecimal a =new BigDecimal(100); - String aoum=String.valueOf(b.multiply(a).setScale(0,ROUND_DOWN)); + String aoum=String.valueOf(refundOrder.getAmount().multiply(a).setScale(0,ROUND_DOWN)); //退款金额 amountReq.setRefund(Long.valueOf(aoum)); -// amountReq.setRefund(Long.valueOf("1")); //原订单金额 amountReq.setTotal(Long.valueOf(aoum)); -// amountReq.setTotal(Long.valueOf("1")); //货币类型(默认人民币) amountReq.setCurrency("CNY"); request.setAmount(amountReq); //商户退款单号 request.setOutRefundNo(refundOrder.getOutTradeNo()); -// request.setOutRefundNo(String.valueOf("ceshi")); request.setOutTradeNo(payOrder.getOutTradeNo()); -// request.setOutTradeNo("ceshi"); request.setReason(refundOrder.getReason()); -// request.setReason("ceshi"); //退款通知回调地址 // request.setNotifyUrl(wxPayV3Bean.getRefundNotifyUrl()); - request.setNotifyUrl(urlComponent.getDoMainUrl() + "order/payNotify"); + request.setNotifyUrl(urlComponent.getDoMainUrl() + "refund/refundNotify"); // 调用退款方法，得到应答 // 调用微信sdk接口 Refund refund = service.create(request); + System.out.println(refund); //接收退款返回参数 Refund refundResponse = new Refund(); refundResponse.setStatus(refund.getStatus()); - System.out.println(refund);; if (refundResponse.getStatus().equals(Status.SUCCESS)){ - //说明退款成功，开始接下来的业务操作 -// WXRefundOrderRespVo refundOrderRespVO = new WXRefundOrderRespVo(); - payOrder.setState(2); - orderService.updateById(payOrder); - refundOrder.setState(2); - baseMapper.updateById(refundOrder); //你的业务代码 return rb.success().setData(refund); + }else if(refundResponse.getStatus().equals(Status.PROCESSING)){ + return rb.success().setMsg("退款申请处理中,请稍等").setData(refund); }else{ - payOrder.setState(3); + payOrder.setState(4); orderService.updateById(payOrder); - return rb.setMsg("申请退款失败").setData(refund); + refundOrder.setState(3); + baseMapper.updateById(refundOrder); + return rb.setCode("500").setMsg("申请退款失败").setData(refund); } }catch (Exception e){ - e.printStackTrace(); + refundOrder.setState(3); + baseMapper.updateById(refundOrder); return rb.setMsg("退款失败,error=" + e.getMessage()); // throw new ResultException(ResultEnum.ERROR,e.toString()); } @@ -166,25 +165,20 @@ public class WxRefundService extends MybatisBaseService().eq("outRefundNo",parse.getOutRefundNo())); System.out.println("退款回调结果： " + parse); + RefundOrder refundOrder=baseMapper.selectOne(new QueryWrapper().eq("outTradeNo",parse.getOutTradeNo())); + PayOrder payOrder=orderService.getOne(new QueryWrapper().eq("sid",refundOrder.getOrderSid())); //parse.getRefundStatus().equals("SUCCESS");说明退款成功 RefundBusinessQuery query=new RefundBusinessQuery(); Map map = new HashMap<>(); - if (parse.getRefundStatus().equals(Transaction.TradeStateEnum.SUCCESS)){ + if (parse.getRefundStatus().toString().equals(Transaction.TradeStateEnum.SUCCESS.toString())){ //你的业务代码 map.put("mainSid",refundOrder.getOrderSid()); - map.put("aBoolean",true); - System.out.println("退款回调结果： " + parse); + map.put("code",true); + refundOrder.setState(2); + baseMapper.updateById(refundOrder); + payOrder.setState(6); + orderService.updateById(payOrder); + System.out.println(parse.getRefundStatus()); }else{ map.put("mainSid",refundOrder.getOrderSid()); - map.put("aBoolean",false); - System.out.println("退款回调结果： " + parse); + map.put("code",false); + refundOrder.setState(3); + baseMapper.updateById(refundOrder); + payOrder.setState(5); + orderService.updateById(payOrder); + System.out.println(parse.getRefundStatus()); } + TrustEveryone.trustEveryone(); ResponseEntity postForEntity = new RestTemplate().postForEntity(refundOrder.getReturnUrl(),map, ResultBean.class); - } catch (Exception e) { e.printStackTrace(); } } +// public void weixinRefundNotify(String body, HttpServletRequest request, HttpServletResponse response) throws Exception { +// //获取报文 +// //随机串 +// String nonceStr = request.getHeader("Wechatpay-Nonce"); +// //微信传递过来的签名 +// String signature = request.getHeader("Wechatpay-Signature"); +// //证书序列号（微信平台） +// String serialNo = request.getHeader("Wechatpay-Serial"); +// //时间戳 +// String timestamp = request.getHeader("Wechatpay-Timestamp"); +// InputStream is = null; +// try { +// is = request.getInputStream(); +// // 构造 RequestParam +// com.wechat.pay.java.core.notification.RequestParam requestParam = new com.wechat.pay.java.core.notification.RequestParam.Builder() +// .serialNumber(serialNo) +// .nonce(nonceStr) +// .signature(signature) +// .timestamp(timestamp) +// .body(body) +// .build(); +// // 如果已经初始化了 RSAAutoCertificateConfig，可以直接使用 config +// // 初始化 NotificationParser +// // 验签、解密并转换成 Transaction +// RefundNotification refundNotification = notificationParser.parse(requestParam, RefundNotification.class); +// String orderNo = refundNotification.getOutTradeNo(); +// //记录日志信息 +// System.out.println("订单号：" + orderNo); +// if (SUCCESS.equals(refundNotification.getRefundStatus().SUCCESS)) { +// System.out.println("退款成功"); +// //TODO------ +// //根据自己的需求处理相应的业务逻辑,异步 +// JSONObject jsonObject = JSONObject.parseObject(refundNotification.toString()); +// System.out.println("微信退款回调信息：" + jsonObject); +// JSONObject resultJson = new JSONObject(); +// resultJson.put("out_trade_no", jsonObject.getString("out_trade_no")); +// resultJson.put("refund_status", jsonObject.getString("refund_status")); +// //业务处理 +// //通知微信回调成功 +// response.getWriter().write(""); +// } else { +// System.out.println("微信回调失败,JsapiPayController.payNotify.transaction：" + refundNotification.toString()); +// //通知微信回调失败 +// response.getWriter().write(""); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } finally { +// is.close(); +// } +// } + // //url 微信退款请求地址 data 请求参数 diff --git a/src/main/java/com/yxt/pay/utils/TrustEveryone.java b/src/main/java/com/yxt/pay/utils/TrustEveryone.java new file mode 100644 index 0000000..2c462ec --- /dev/null +++ b/src/main/java/com/yxt/pay/utils/TrustEveryone.java @@ -0,0 +1,39 @@ +package com.yxt.pay.utils; + +import javax.net.ssl.*; +import java.security.SecureRandom; +import java.security.cert.CertificateException; +import java.security.cert.X509Certificate; + +/** + * @author wangpengfei + * @date 2024/12/16 15:27 + */ +public class TrustEveryone { + public static void trustEveryone() { + + try { + HttpsURLConnection.setDefaultHostnameVerifier(new HostnameVerifier() { + public boolean verify(String hostname, SSLSession session) { + return true; + } + }); + + SSLContext context = SSLContext.getInstance("TLS"); + context.init(null, new X509TrustManager[]{new X509TrustManager() { + public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { + } + + public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { + } + + public X509Certificate[] getAcceptedIssuers() { + return new X509Certificate[0]; + } + }}, new SecureRandom()); + HttpsURLConnection.setDefaultSSLSocketFactory(context.getSocketFactory()); + } catch (Exception e) { + e.printStackTrace(); + } + } +}