• java版 支付宝和微信 h5支付

    1.支付宝微信支付

    1. <!--引入阿里支付-->
    2.         <dependency>
    3.             <groupId>com.alipay.sdk</groupId>
    4.             <artifactId>alipay-sdk-java</artifactId>
    5.             <version>4.38.60.ALL</version>
    6.         </dependency>
    AliPayment.java
    1. package com.ruoyi.coupon.payment;
    2.  
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.alipay.api.AlipayApiException;
    5. import com.alipay.api.CertAlipayRequest;
    6. import com.alipay.api.DefaultAlipayClient;
    7. import com.alipay.api.domain.AlipayTradeAppPayModel;
    8. import com.alipay.api.domain.AlipayTradeRefundModel;
    9. import com.alipay.api.domain.ExtendParams;
    10. import com.alipay.api.internal.util.AlipaySignature;
    11. import com.alipay.api.request.*;
    12. import com.alipay.api.response.*;
    13. import com.ruoyi.common.core.redis.RedisCache;
    14. import com.ruoyi.common.exception.GlobalException;
    15. import com.ruoyi.common.utils.StringUtils;
    16. import com.ruoyi.coupon.payment.dto.PayParam;
    17. import com.ruoyi.coupon.payment.dto.RefundParam;
    18. import com.ruoyi.coupon.service.ICouponConfigService;
    19. import lombok.extern.slf4j.Slf4j;
    20. import org.apache.commons.io.FileUtils;
    21. import org.springframework.beans.factory.annotation.Autowired;
    22. import org.springframework.stereotype.Service;
    23.  
    24. import javax.servlet.http.HttpServletRequest;
    25. import java.io.File;
    26. import java.io.IOException;
    27. import java.io.InputStream;
    28. import java.io.UnsupportedEncodingException;
    29. import java.util.HashMap;
    30. import java.util.LinkedHashMap;
    31. import java.util.Map;
    32.  
    33. /**
    34.  * 阿里支付类
    35.  */
    36. @Service
    37. @Slf4j
    38. public class AliPayment {
    39.     private static Map<String,DefaultAlipayClient> aliCertClientMap = new HashMap();
    40.  
    41.     /*public static String appid="";
    42.     //应用私钥 参考 https://opendocs.alipay.com/support/01rauw
    43.     public static String privateKey="";
    44.     //服务商的账户pid 参考 https://opendocs.alipay.com/open/194/105190?pathHash=e479c7e4#%E8%BF%94%E4%BD%A3
    45.     public static String sysServiceProviderId="";*/
    46.  
    47.     public static String appid="";
    48.     //应用私钥 参考 https://opendocs.alipay.com/support/01rauw
    49.     public static String privateKey="";
    50.     //服务商的账户pid 参考 https://opendocs.alipay.com/open/194/105190?pathHash=e479c7e4#%E8%BF%94%E4%BD%A3
    51.     public static String sysServiceProviderId="";
    52.  
    53.     @Autowired
    54.     private RedisCache redisCache;
    55.  
    56.     @Autowired
    57.     private ICouponConfigService couponConfigService;
    58.  
    59.     /**
    60.      * 获取客户端
    61.      * @return
    62.      */
    63.     public DefaultAlipayClient getAliCertClient() {
    64.         DefaultAlipayClient aliCertClient = aliCertClientMap.get("aliCertClient");
    65.         if(aliCertClient != null){
    66.             return aliCertClient;
    67.         }
    68.  
    69.         File appCert = new File("aliPayCert/appCertPublicKey_2021004*******.crt");
    70.         File alipayCert = new File("aliPayCert/alipayCertPublicKey_RSA2.crt");
    71.         File alipayRootCert = new File("aliPayCert/alipayRootCert.crt");
    72.  
    73.         try {
    74.             if (!appCert.exists()) {
    75.                 InputStream stream = AliPayment.class.getResourceAsStream("/aliPayCert/appCertPublicKey_2021004*******.crt");
    76.                 FileUtils.copyInputStreamToFile(stream, appCert);
    77.             }
    78.             if (!alipayCert.exists()) {
    79.                 InputStream stream = AliPayment.class.getResourceAsStream("/aliPayCert/alipayCertPublicKey_RSA2.crt");
    80.                 FileUtils.copyInputStreamToFile(stream, alipayCert);
    81.             }
    82.             if (!alipayRootCert.exists()) {
    83.                 InputStream stream = AliPayment.class.getResourceAsStream("/aliPayCert/alipayRootCert.crt");
    84.                 FileUtils.copyInputStreamToFile(stream, alipayRootCert);
    85.             }
    86.         } catch (IOException e) {
    87.             log.error(e.getMessage());
    88.             throw new GlobalException(e.getMessage());
    89.         }
    90.  
    91.         String appCertPath = appCert.getAbsolutePath();
    92.         String alipayCertPath = alipayCert.getAbsolutePath();
    93.         String alipayRootCertPath = alipayRootCert.getAbsolutePath();
    94.  
    95.  
    96.         String privateKey=this.privateKey;
    97.  
    98.         CertAlipayRequest certAlipayRequest = new CertAlipayRequest();
    99.         certAlipayRequest.setServerUrl("https://openapi.alipay.com/gateway.do");
    100.         certAlipayRequest.setAppId(this.appid);
    101.         certAlipayRequest.setPrivateKey(privateKey);
    102.         certAlipayRequest.setFormat("JSON");
    103.         certAlipayRequest.setCharset("utf-8");
    104.         certAlipayRequest.setSignType("RSA2");
    105.         certAlipayRequest.setCertPath(appCertPath);
    106.         certAlipayRequest.setAlipayPublicCertPath(alipayCertPath);
    107.         certAlipayRequest.setRootCertPath(alipayRootCertPath);
    108.  
    109.         DefaultAlipayClient alipayClient = null;
    110.  
    111.         try {
    112.             alipayClient = new DefaultAlipayClient(certAlipayRequest);
    113.             aliCertClientMap.put("aliCertClient",alipayClient);
    114.         } catch (AlipayApiException e) {
    115.             e.printStackTrace();
    116.         }
    117.         return alipayClient;
    118.     }
    119.  
    120.     /**
    121.      * 下单
    122.      * @param payParam
    123.      * @return
    124.      */
    125.     public String pay(PayParam payParam) {
    126.         String apiUrl = couponConfigService.getValue("online_domain");
    127.  
    128.         //证书公钥模式
    129.         DefaultAlipayClient alipayClient = this.getAliCertClient();
    130.         // 创建API对应的request(网页版)
    131.         AlipayTradeWapPayRequest request = new AlipayTradeWapPayRequest();
    132.  
    133.         request.setNotifyUrl(apiUrl + "/api/payment/alipay/notify");
    134.         //request.setNotifyUrl("http://egevdr.natappfree.cc" + "/payment/alipay/notify");
    135.  
    136.         request.setReturnUrl("");
    137.  
    138.         /******必传参数******/
    139.         JSONObject bizContent = new JSONObject();
    140.         //商户订单号，商家自定义，保持唯一性
    141.         bizContent.put("out_trade_no", payParam.getOutTradeNo());
    142.         //支付金额，最小值0.01元
    143.         bizContent.put("total_amount",payParam.getTotalAmount());
    144.         //订单标题，不可使用特殊符号
    145.         bizContent.put("subject", payParam.getSubject());
    146.  
    147.         /******可选参数******/
    148.         //手机网站支付默认传值FAST_INSTANT_TRADE_PAY
    149.         bizContent.put("product_code", "QUICK_WAP_WAY");
    150.         //bizContent.put("time_expire", "2022-08-01 22:00:00");
    151.  
    152.         request.setBizContent(bizContent.toString());
    153.  
    154.         try {
    155.             AlipayTradeWapPayResponse alipayTradeWapPayResponse = alipayClient.pageExecute(request);
    156.             String body = alipayTradeWapPayResponse.getBody();
    157.             return body;
    158.         } catch (AlipayApiException e) {
    159.             e.printStackTrace();
    160.         }
    161.         return null;
    162.     }
    163.  
    164.     /**
    165.      * 退款
    166.      * @param pefundParam
    167.      * @return
    168.      */
    169.     public Boolean refundOrder(RefundParam pefundParam) {
    170.         DefaultAlipayClient alipayClient = this.getAliCertClient();
    171.         String apiUrl = couponConfigService.getValue("online_domain");;
    172.  
    173.         AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
    174.         JSONObject bizContent = new JSONObject();
    175.         bizContent.put("out_trade_no", pefundParam.getOutTradeNo());
    176.         bizContent.put("refund_amount", pefundParam.getRefund());
    177.         bizContent.put("refund_reason",pefundParam.getBody());
    178.  
    179.         request.setBizContent(bizContent.toString());
    180.         //request.setNotifyUrl(apiUrl + "/api/payment/alipay/notify");
    181.         try {
    182.             AlipayTradeRefundResponse response = alipayClient.certificateExecute(request);
    183.             return response.isSuccess();
    184.         } catch (AlipayApiException e) {
    185.             e.printStackTrace();
    186.         }
    187.         return null;
    188.     }
    189.  
    190.     /**
    191.      * 查询订单接口 https://opendocs.alipay.com/open/02ivbt?scene=common&pathHash=8abc6ffe
    192.      * @param orderNum
    193.      * @return
    194.      */
    195.     public Map orderQuery(String  orderNum) {
    196.         DefaultAlipayClient alipayClient = this.getAliCertClient();
    197.         AlipayTradeQueryRequest request = new AlipayTradeQueryRequest();
    198.         JSONObject bizContent = new JSONObject();
    199.         bizContent.put("out_trade_no", orderNum);
    200.         //bizContent.put("trade_no", "2014112611001004680073956707");
    201.         request.setBizContent(bizContent.toString());
    202.  
    203.         try {
    204.             AlipayTradeQueryResponse alipayTradeQueryResponse = alipayClient.certificateExecute(request);
    205.  
    206.             Map map=new HashMap();
    207.             map.put("tradeState",alipayTradeQueryResponse.getTradeStatus());
    208.             /**
    209.              * 交易状态：WAIT_BUYER_PAY（交易创建，等待买家付款）、TRADE_CLOSED（未付款交易超时关闭，或支付完成后全额退款）、TRADE_SUCCESS（交易支付成功）、TRADE_FINISHED（交易结束，不可退款）
    210.              */
    211.             return map;
    212.         } catch (AlipayApiException e) {
    213.             e.printStackTrace();
    214.         }
    215.         return null;
    216.     }
    217.  
    218.     /**
    219.      * 公钥证书模式效验签名
    220.      * @param request
    221.      * @return
    222.      */
    223.     public boolean ZSRsaCheck(HttpServletRequest request){
    224.         /**
    225.          * 支付宝线上的验签需要的支付宝公钥证书
    226.          */
    227.         File alipayCert = new File("aliPayCert/alipayCertPublicKey_RSA2.crt");
    228.         try {
    229.             if (!alipayCert.exists()) {
    230.                 InputStream stream = AliPayment.class.getResourceAsStream("/aliPayCert/alipayCertPublicKey_RSA2.crt");
    231.                 FileUtils.copyInputStreamToFile(stream, alipayCert);
    232.             }
    233.  
    234.         } catch (IOException e) {
    235.             log.error("alipayCertPublicKey 证书文件未找到:{}",e.getMessage());
    236.             throw new GlobalException(e.getMessage());
    237.         }
    238.         //支付宝公钥证书
    239.         String alipayPublicCertPath=alipayCert.getAbsolutePath();
    240.         /**
    241.          * 这种方式效率高一点
    242.          */
    243.         //签名方式
    244.         String sign_type="RSA2";
    245.         //对待签名字符串数据通过&进行拆分
    246.         Map requestParams = request.getParameterMap();
    247.         LinkedHashMap<String, String> map =  new LinkedHashMap<String, String>();
    248.         //把拆分数据放在map集合内
    249.         for (Object o : requestParams.keySet()) {
    250.             String name = (String) o;
    251.             String[] values = (String[]) requestParams.get(name);
    252.             String valueStr = "";
    253.             for (int i = 0; i < values.length; i++) {
    254.                 valueStr = (i == values.length - 1) ? valueStr + values[i]
    255.                         : valueStr + values[i] + ",";
    256.             }
    257.             map.put(name, valueStr);
    258.         }
    259.  
    260.         try {
    261.             return AlipaySignature.rsaCertCheckV1(map, alipayPublicCertPath, "utf-8",sign_type);
    262.         } catch (AlipayApiException e) {
    263.             log.error("支付宝异步验签失败:{}",e.getMessage());
    264.             return false;
    265.         }
    266.     }
    267.  
    268.     /**
    269.      * 支付宝转账
    270.      * @param param
    271.      * @return
    272.      */
    273.     public Map alipayTransfer(Map param){
    274.         //获得公钥证书模式支付宝客户端
    275.         DefaultAlipayClient aliCertClient = getAliCertClient();
    276.  
    277.         AlipayFundTransUniTransferRequest request = new AlipayFundTransUniTransferRequest();
    278.         request.setBizContent("{" +
    279.                 "\"out_biz_no\":\""+param.get("outBizNo")+"\"," +
    280.                 "\"trans_amount\":"+param.get("transAmount")+"," +
    281.                 "\"product_code\":\"TRANS_ACCOUNT_NO_PWD\"," +
    282.                 "\"biz_scene\":\"DIRECT_TRANSFER\"," +
    283.                 "\"order_title\":\""+param.get("orderTitle")+"\"," +
    284.                 "\"payee_info\":{" +
    285.                 "\"identity_type\":\"ALIPAY_LOGON_ID\"," +
    286.                 "\"identity\":\""+param.get("identity")+"\"," +
    287.                 "\"name\":\""+param.get("name")+"\"" +
    288.                 "}," +
    289.                 "\"remark\":\""+param.get("remark")+"\"," +
    290.                 "\"business_params\":{\"payer_show_name_use_alias\":\"true\"}" +
    291.                 "}");
    292.  
    293.         //返回的map
    294.         Map rmap=new HashMap();
    295.         try {
    296.             AlipayFundTransUniTransferResponse response = aliCertClient.certificateExecute(request);
    297.             rmap.put("isSuccess",response.isSuccess());
    298.             rmap.put("subMsg",response.getSubMsg());
    299.             return  rmap;
    300.         } catch (AlipayApiException e) {
    301.             e.printStackTrace();
    302.             return rmap;
    303.         }
    304.     }
    305. }
    AlipayNotify.java
    1. package com.ruoyi.api.controller.coupon.payment.rest;
    2.  
    3. import com.ruoyi.common.utils.StringUtils;
    4. import com.ruoyi.coupon.payment.AliPayment;
    5. import com.ruoyi.coupon.payment.enums.AliPayStatusEnum;
    6. import com.ruoyi.coupon.payment.event.PaymentEvent;
    7. import lombok.RequiredArgsConstructor;
    8. import lombok.extern.slf4j.Slf4j;
    9. import org.springframework.beans.factory.annotation.Autowired;
    10. import org.springframework.context.ApplicationEventPublisher;
    11. import org.springframework.http.HttpStatus;
    12. import org.springframework.http.ResponseEntity;
    13. import org.springframework.web.bind.annotation.RequestMapping;
    14. import org.springframework.web.bind.annotation.RequestMethod;
    15. import org.springframework.web.bind.annotation.RestController;
    16.  
    17. import javax.servlet.http.HttpServletRequest;
    18. import java.io.UnsupportedEncodingException;
    19. import java.nio.charset.StandardCharsets;
    20. import java.util.HashMap;
    21. import java.util.Map;
    22.  
    23. @Slf4j
    24. @RestController
    25. @RequestMapping("/payment/alipay")
    26. public class AlipayNotify {
    27.  
    28.     @Autowired
    29.     private AliPayment aliPayment;
    30.     @Autowired
    31.     private ApplicationEventPublisher publisher;
    32.  
    33.  
    34.     @RequestMapping(value = "/notify", method = {RequestMethod.GET, RequestMethod.POST})
    35.     @SuppressWarnings("all")
    36.     public ResponseEntity<Object> notify(HttpServletRequest request) throws UnsupportedEncodingException {
    37.         Map<String, String[]> parameterMap = request.getParameterMap();
    38.         //内容验签，防止黑客篡改参数
    39.         //if (alipayUtils.rsaCheck(request,alipay)) {
    40.         if(aliPayment.ZSRsaCheck(request)){
    41.             //交易状态
    42.             String tradeStatus = getRequestParameter(request, "trade_status");
    43.             // 商户订单号
    44.             String outTradeNo = getRequestParameter(request, "out_trade_no");
    45.             //支付宝交易号
    46.             String tradeNo = getRequestParameter(request, "trade_no");
    47.             //付款金额
    48.             String totalAmount = getRequestParameter(request, "total_amount");
    49.             //退款金额
    50.             String refundFee = getRequestParameter(request, "refund_fee");
    51.  
    52.             //获取回传参数paymentType
    53.             String passbackParams = getRequestParameter(request, "passback_params");
    54.             Map<String,String> map=new HashMap<>();
    55.             if(StringUtils.isNotBlank(passbackParams)){
    56.                 passbackParams= java.net.URLDecoder.decode(passbackParams,"UTF-8");
    57.                 String[] split = StringUtils.split(passbackParams, ";");
    58.                 for (int i=0;i<split.length;i++){
    59.                     String[] split1 = StringUtils.split(split[i], "=");
    60.                     map.put(split1[0],split1[1]);
    61.                 }
    62.             }
    63.  
    64.  
    65.             //记录日志
    66.             if (StringUtils.isNotEmpty(refundFee)) {
    67.                 log.info(">>>>> 交易状态: {}, 商户订单号: {}, 支付宝交易号: {}, 退款金额: {}", tradeStatus, outTradeNo, tradeNo, refundFee);
    68.                 //验证
    69.                 if (AliPayStatusEnum.CLOSED.getValue().equals(tradeStatus)) {
    70.                     // outTradeNo 退款成功
    71.                     publisher.publishEvent(new PaymentEvent(this, outTradeNo,1,map,refundFee));
    72.                 }
    73.             } else if (StringUtils.isNotEmpty(totalAmount)) {
    74.                 log.info(">>>>> 交易状态: {}, 商户订单号: {}, 支付宝交易号: {}, 付款金额: {}", tradeStatus, outTradeNo, tradeNo, totalAmount);
    75.                 //验证
    76.                 if (AliPayStatusEnum.SUCCESS.getValue().equals(tradeStatus) || AliPayStatusEnum.FINISHED.getValue().equals(tradeStatus)) {
    77.                     // outTradeNo 支付成功
    78.                     publisher.publishEvent(new PaymentEvent(this, outTradeNo,0,map,totalAmount));
    79.                 }
    80.             } else {
    81.                 log.info(">>>>> 交易状态: {}, 商户订单号: {}, 支付宝交易号: {}", tradeStatus, outTradeNo, tradeNo);
    82.             }
    83.             return new ResponseEntity<>("success",HttpStatus.OK);//返回success ,让支付宝不在重复调起回调
    84.         }
    85.         return new ResponseEntity<>(HttpStatus.BAD_REQUEST);
    86.     }
    87.  
    88.     private String getRequestParameter(HttpServletRequest request, String valname) {
    89.         String value = request.getParameter(valname);
    90.         if (value != null) {
    91.             return new String(value.getBytes(StandardCharsets.ISO_8859_1), StandardCharsets.UTF_8);
    92.         }
    93.         return value;
    94.     }
    95. }

    2.微信支付

    1. <dependency>
    2.             <groupId>com.github.wechatpay-apiv3</groupId>
    3.             <artifactId>wechatpay-java</artifactId>
    4.             <version>0.2.11</version>
    5.         </dependency>
    WeChatPayment.java
    1. package com.ruoyi.coupon.payment;
    2.  
    3. import com.fasterxml.jackson.databind.ObjectMapper;
    4. import com.fasterxml.jackson.databind.node.ObjectNode;
    5. import com.google.gson.Gson;
    6. import com.google.gson.GsonBuilder;
    7. import com.ruoyi.common.exception.GlobalException;
    8. import com.ruoyi.coupon.payment.dto.PayParam;
    9. import com.ruoyi.coupon.payment.dto.RefundParam;
    10. import com.ruoyi.coupon.payment.utils.IpUtil;
    11. import com.ruoyi.coupon.service.ICouponConfigService;
    12. import com.wechat.pay.java.core.Config;
    13. import com.wechat.pay.java.core.RSAAutoCertificateConfig;
    14. import com.wechat.pay.java.core.notification.NotificationConfig;
    15. import com.wechat.pay.java.core.notification.NotificationParser;
    16. import com.wechat.pay.java.core.notification.RequestParam;
    17. import com.wechat.pay.java.service.payments.h5.H5Service;
    18. import com.wechat.pay.java.service.payments.h5.model.*;
    19. import com.wechat.pay.java.service.payments.model.Transaction;
    20. import com.wechat.pay.java.service.payments.model.TransactionAmount;
    21. import com.wechat.pay.java.service.refund.RefundService;
    22. import com.wechat.pay.java.service.refund.model.AmountReq;
    23. import com.wechat.pay.java.service.refund.model.CreateRequest;
    24. import com.wechat.pay.java.service.refund.model.Refund;
    25. import com.wechat.pay.java.service.refund.model.RefundNotification;
    26. import lombok.extern.slf4j.Slf4j;
    27. import org.springframework.beans.factory.annotation.Autowired;
    28. import org.springframework.stereotype.Service;
    29.  
    30. import javax.servlet.ServletInputStream;
    31. import javax.servlet.http.HttpServletRequest;
    32. import java.io.*;
    33. import java.math.BigDecimal;
    34. import java.nio.charset.StandardCharsets;
    35. import java.security.PrivateKey;
    36. import java.security.cert.X509Certificate;
    37. import java.util.ArrayList;
    38. import java.util.HashMap;
    39. import java.util.Map;
    40. import java.util.UUID;
    41.  
    42. /**
    43.  * 微信支付服务类
    44.  */
    45. @Service
    46. @Slf4j
    47. public class WeChatPayment {
    48.  
    49.     private static final String mchId = ""; // 商户号
    50.     private static final String mchSerialNo = ""; // 商户证书序列号
    51.     //商户私钥 //https://pay.weixin.qq.com/wiki/doc/apiv3/wechatpay/wechatpay3_1.shtml
    52.     private static final String privateKey = "";
    53.     // 你的微信支付平台证书
    54.     private static final String apiV3Key = "";
    55.  
    56.     private static final String appid="";
    57.  
    58.     /** 商户API私钥路径 */
    59.     public static String privateKeyPath = "C:\\Users\\Administrator\\Desktop\\coupon\\wxpay\\apiclient_key.pem";
    60.  
    61.     @Autowired
    62.     private ICouponConfigService couponConfigService;
    63.  
    64.     /**
    65.      * 获得H5客户端
    66.      * @return
    67.      */
    68.     public H5Service getH5Service () {
    69.         Config config =
    70.                 new RSAAutoCertificateConfig.Builder()
    71.                         .merchantId(mchId)
    72.                         .privateKey(privateKey)
    73.                         //.privateKeyFromPath(privateKeyPath)
    74.                         .merchantSerialNumber(mchSerialNo)
    75.                         .apiV3Key(apiV3Key)
    76.                         .build();
    77.         H5Service build = new H5Service.Builder().config(config).build();
    78.         return build;
    79.     }
    80.  
    81.     public String pay(PayParam payParam) {
    82.         String apiUrl = couponConfigService.getValue("online_domain");
    83.         BigDecimal bigDecimal = new BigDecimal(100);
    84.         int payPrice = bigDecimal.multiply(new BigDecimal(payParam.getTotalAmount())).intValue();
    85.  
    86.         H5Service h5Service = getH5Service();
    87.  
    88.         //获取客户端
    89.         PrepayRequest request = new PrepayRequest();
    90.         Amount amount = new Amount();
    91.         amount.setTotal(payPrice);
    92.  
    93.         H5Info h5Info = new H5Info();
    94.         h5Info.setType("Wap");
    95.  
    96.         //场景信息
    97.         SceneInfo sceneInfo = new SceneInfo();
    98.         sceneInfo.setPayerClientIp("qy.gsjf.cc");
    99.         sceneInfo.setH5Info(h5Info);
    100.  
    101.         request.setAmount(amount);
    102.         request.setAppid(appid);
    103.         request.setMchid(mchId);
    104.         request.setDescription(payParam.getSubject());
    105.         //request.setNotifyUrl("http://egevdr.natappfree.cc" + "/payment/weChatPay/payment/notify");
    106.         request.setNotifyUrl(apiUrl +"api" + "/payment/weChatPay/payment/notify");
    107.         request.setOutTradeNo(payParam.getOutTradeNo());
    108.         request.setAttach(payParam.getPassbackParams());//携带其他参数
    109.         request.setSceneInfo(sceneInfo);
    110.  
    111.         // 调用下单方法，得到应答
    112.         PrepayResponse prepay = h5Service.prepay(request);
    113.         return prepay.getH5Url();
    114.     }
    115.  
    116.     /**
    117.      * 申请退款
    118.      * @param refundParam
    119.      */
    120.     public void refundOrder(RefundParam refundParam) {
    121.         String apiUrl = couponConfigService.getValue("online_domain");
    122.         BigDecimal bigDecimal = new BigDecimal(100);
    123.         int total = bigDecimal.multiply(new BigDecimal(refundParam.getTotal())).intValue();
    124.  
    125.         int refund = bigDecimal.multiply(new BigDecimal(refundParam.getRefund())).intValue();
    126.  
    127.         Config config =
    128.                 new RSAAutoCertificateConfig.Builder()
    129.                         .merchantId(mchId)
    130.                         .privateKey(privateKey)
    131.                         .merchantSerialNumber(mchSerialNo)
    132.                         .apiV3Key(apiV3Key)
    133.                         .build();
    134.         RefundService service = new RefundService.Builder().config(config).build();
    135.  
    136.         //生成随机退款订单号
    137.         String s = UUID.randomUUID().toString().replace("-","");
    138.  
    139.         CreateRequest request = new CreateRequest();
    140.  
    141.         //金额信息
    142.         AmountReq amount = new AmountReq();
    143.         amount.setCurrency("CNY");
    144.         amount.setTotal(Long.valueOf(total));
    145.         amount.setRefund(Long.valueOf(refund));
    146.  
    147.         request.setAmount(amount);
    148.         request.setOutTradeNo(refundParam.getOutTradeNo());
    149.         request.setOutRefundNo(s);
    150.         //request.setNotifyUrl("http://egevdr.natappfree.cc" + "/payment/weChatPay/refund/notify");
    151.         request.setNotifyUrl(apiUrl +"api" + "/payment/weChatPay/refund/notify");
    152.  
    153.         //发送请求
    154.         Refund refund1 = service.create(request);
    155.     }
    156.  
    157.     /**
    158.      * 根据订单号查询订单信息,目前只返回了订单状态 https://pay.weixin.qq.com/wiki/doc/apiv3/apis/chapter3_3_2.shtml
    159.      * @param orderNum
    160.      * @return
    161.      */
    162.     public Map queryOrderByOutTradeNo(String orderNum) {
    163.         H5Service h5Service = getH5Service();
    164.         QueryOrderByOutTradeNoRequest request = new QueryOrderByOutTradeNoRequest();
    165.         request.setMchid(mchId);
    166.         request.setOutTradeNo(orderNum);
    167.  
    168.         Transaction transaction = h5Service.queryOrderByOutTradeNo(request);
    169.  
    170.         Map map=new HashMap();
    171.         map.put("tradeState",transaction.getTradeState());
    172.         /**
    173.          * 交易状态，枚举值：
    174.          * SUCCESS：支付成功
    175.          * REFUND：转入退款
    176.          * NOTPAY：未支付
    177.          * CLOSED：已关闭
    178.          * REVOKED：已撤销（仅付款码支付会返回）
    179.          * USERPAYING：用户支付中（仅付款码支付会返回）
    180.          * PAYERROR：支付失败（仅付款码支付会返回）
    181.          */
    182.         return map;
    183.     }
    184.  
    185.     /**
    186.      * 支付成功验签
    187.      * @param request
    188.      * @return
    189.      */
    190.     public Map paySuccessCheck(HttpServletRequest request) {
    191.         Config config =
    192.                 new RSAAutoCertificateConfig.Builder()
    193.                         .merchantId(mchId)
    194.                         .privateKey(privateKey)
    195.                         .merchantSerialNumber(mchSerialNo)
    196.                         .apiV3Key(apiV3Key)
    197.                         .build();
    198.  
    199.         // 从请求头中获取信息
    200.         String timestamp                        = request.getHeader("Wechatpay-Timestamp");
    201.         String nonce                            = request.getHeader("Wechatpay-Nonce");
    202.         String signature                        = request.getHeader("Wechatpay-Signature");
    203.         String singType                         = request.getHeader("Wechatpay-Signature-Type");
    204.         String wechatPayCertificateSerialNumber = request.getHeader("Wechatpay-Serial");
    205.  
    206.         String requestBody = getRequestBody(request);
    207.  
    208.         // 构造 RequestParam
    209.         RequestParam requestParam = new RequestParam.Builder()
    210.                 .serialNumber(wechatPayCertificateSerialNumber)
    211.                 .nonce(nonce)
    212.                 .signature(signature)
    213.                 .signType(singType)
    214.                 .timestamp(timestamp)
    215.                 .body(requestBody)
    216.                 .build();
    217.  
    218.         // 初始化解析器 NotificationParser
    219.         NotificationParser parser = new NotificationParser((NotificationConfig) config);
    220.  
    221.         // 这个Transaction是微信包里面的
    222.         Transaction decryptObject = parser.parse(requestParam, Transaction.class);
    223.  
    224.         TransactionAmount amount = decryptObject.getAmount();
    225.         String outTradeNo = decryptObject.getOutTradeNo();
    226.         String attach = decryptObject.getAttach();
    227.  
    228.         Map map=new HashMap();
    229.         map.put("amount",amount.getTotal());
    230.         map.put("outTradeNo",outTradeNo);
    231.         map.put("attach",attach);
    232.         return map;
    233.     }
    234.  
    235.     public Map refundSuccessCheck(HttpServletRequest request) {
    236.         Config config =
    237.                 new RSAAutoCertificateConfig.Builder()
    238.                         .merchantId(mchId)
    239.                         .privateKey(privateKey)
    240.                         .merchantSerialNumber(mchSerialNo)
    241.                         .apiV3Key(apiV3Key)
    242.                         .build();
    243.  
    244.         // 从请求头中获取信息
    245.         String timestamp                        = request.getHeader("Wechatpay-Timestamp");
    246.         String nonce                            = request.getHeader("Wechatpay-Nonce");
    247.         String signature                        = request.getHeader("Wechatpay-Signature");
    248.         String singType                         = request.getHeader("Wechatpay-Signature-Type");
    249.         String wechatPayCertificateSerialNumber = request.getHeader("Wechatpay-Serial");
    250.  
    251.         String requestBody = getRequestBody(request);
    252.  
    253.         // 构造 RequestParam
    254.         RequestParam requestParam = new RequestParam.Builder()
    255.                 .serialNumber(wechatPayCertificateSerialNumber)
    256.                 .nonce(nonce)
    257.                 .signature(signature)
    258.                 .signType(singType)
    259.                 .timestamp(timestamp)
    260.                 .body(requestBody)
    261.                 .build();
    262.  
    263.         // 初始化解析器 NotificationParser
    264.         NotificationParser parser = new NotificationParser((NotificationConfig) config);
    265.  
    266.         // 这个Transaction是微信包里面的
    267.         RefundNotification decryptObject = parser.parse(requestParam, RefundNotification.class);
    268.  
    269.         com.wechat.pay.java.service.refund.model.Amount amount = decryptObject.getAmount();
    270.         String outTradeNo = decryptObject.getOutTradeNo();
    271.  
    272.         Map map=new HashMap();
    273.         map.put("amount",amount.getTotal());
    274.         map.put("outTradeNo",outTradeNo);
    275.         return map;
    276.     }
    277.  
    278.     // 获取请求头里的数据
    279.     private String getRequestBody(HttpServletRequest request) {
    280.         StringBuffer sb = new StringBuffer();
    281.         try (
    282.                 ServletInputStream inputStream = request.getInputStream();
    283.                 BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
    284.         ) {
    285.             String line;
    286.             while ((line = reader.readLine()) != null) {
    287.                 sb.append(line);
    288.             }
    289.         } catch (IOException e) {
    290.             System.out.println("读取数据流异常:"+e);
    291.         }
    292.         return sb.toString();
    293.     }
    294. }
    WeChatPayNotify.java
    1. package com.ruoyi.api.controller.coupon.payment.rest;
    2.  
    3. import com.ruoyi.common.utils.StringUtils;
    4. import com.ruoyi.coupon.payment.WeChatPayment;
    5. import com.ruoyi.coupon.payment.event.PaymentEvent;
    6. import lombok.extern.slf4j.Slf4j;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.context.ApplicationEventPublisher;
    9. import org.springframework.http.HttpStatus;
    10.  
    11. import org.springframework.http.ResponseEntity;
    12. import org.springframework.transaction.annotation.Transactional;
    13. import org.springframework.web.bind.annotation.PostMapping;
    14. import org.springframework.web.bind.annotation.RequestBody;
    15. import org.springframework.web.bind.annotation.RequestMapping;
    16. import org.springframework.web.bind.annotation.RestController;
    17.  
    18. import javax.servlet.http.HttpServletRequest;
    19. import javax.servlet.http.HttpServletResponse;
    20. import java.math.BigDecimal;
    21. import java.util.HashMap;
    22. import java.util.Map;
    23.  
    24. /**
    25.  * 商城支付项微信支付的回调接口
    26.  */
    27. @Slf4j
    28. @RestController
    29. @RequestMapping("/payment/weChatPay")
    30. public class WeChatPayNotify {
    31.     @Autowired
    32.     private ApplicationEventPublisher publisher;
    33.  
    34.     @Autowired
    35.     private WeChatPayment weChatPayment;
    36.  
    37.     /**
    38.      * 微信支付/充值回调
    39.      */
    40.     @PostMapping("/payment/notify")
    41.     public ResponseEntity.BodyBuilder  renotify(HttpServletRequest request) {
    42.         Map map = weChatPayment.paySuccessCheck(request);
    43.  
    44.         Integer amount = (Integer)map.get("amount");
    45.         String outTradeNo = (String)map.get("outTradeNo");
    46.  
    47.         String attach = (String)map.get("attach");
    48.         Map<String, Object> map1 = new HashMap<>();
    49.         //将附加信息 attach 解析到 map1 中,因为现在没有传递任何参数,所以没有解析
    50.  
    51.         BigDecimal divide = new BigDecimal(amount).divide(new BigDecimal("100"));
    52.  
    53.         publisher.publishEvent(new PaymentEvent(this, outTradeNo,0,map1,divide.toString()));
    54.  
    55.         return ResponseEntity.status(HttpStatus.OK);
    56.     }
    57.  
    58.     /**
    59.      * 微信退款回调
    60.      */
    61.     @PostMapping("/refund/notify")
    62.     public ResponseEntity.BodyBuilder parseRefundNotifyResult(HttpServletRequest request) {
    63.         Map map = weChatPayment.refundSuccessCheck(request);
    64.  
    65.         Long amount = (Long)map.get("amount");
    66.         String outTradeNo = (String)map.get("outTradeNo");
    67.  
    68.         BigDecimal divide = new BigDecimal(amount).divide(new BigDecimal("100"));
    69.  
    70.         publisher.publishEvent(new PaymentEvent(this, outTradeNo,1,null,divide.toString()));
    71.         return ResponseEntity.status(HttpStatus.OK);
    72.     }
    73. }

     前端 uniapp 的调起方式

    1. <view class="alipaysubmit" v-html="formContent"></view>
    2.  
    3. createOrder(data).then(res=>{
    4. 					uni.hideLoading()
    5. 					this.payType=''
    6. 					if(res.data.payType=="aliPayH5"){
    7. 						this.formContent=res.data.payStrand
    8. 						this.$nextTick(() => {
    9. 							document.forms['punchout_form'].submit(); 
    10. 						})
    11. 					}else if(res.data.payType=="weChatH5"){ 
    12. 						const platform = uni.getSystemInfoSync().platform 
    13. 						let mweb_url = res.data.payStrand 
    14. 						var a=document.createElement('a'); 
    15. 						switch (platform) {
    16. 							case 'android':
    17. 								a.href=mweb_url
    18. 								a.click() 
    19. 								break;
    20. 							case 'ios':
    21. 							a.href=mweb_url
    22. 								a.click() 
    23. 								break;
    24. 							default:
    25. 								break;
    26. 						} 
    27. 					}else if(res.data.payType=="balance"){
    28. 						uni.showToast({
    29. 							title:res.data.payStrand
    30. 						})
    31. 					}
    32. 					uni.navigateTo({
    33. 						url:"/pages/mine/order/order"
    34. 					}) 
    35. 				})

  • 相关阅读:
    常见机器学习算法的优缺点及如何选择1
    承上启下：基于全域漏斗分析的主搜深度统一粗排
    Springboot毕设项目老来福平台682f5（java+VUE+Mybatis+Maven+Mysql）
    String（三）———接口大全
    [H5动画制作系列] Sprite及Text Demo
    Topic太多，RocketMQ炸了！
    金仓数据库KingbaseES客户端编程接口指南-DCI（5. 程序示例）
    DJ 12-3 程序控制指令
    ubuntu挂载共享目录的方法
    20和遍历以及迭代器有关的一些东西
  • 原文地址：https://blog.csdn.net/qq_31683775/article/details/134081306