微信支付:Native支付 工具类

发布时间:2024年01月18日


import com.wechat.pay.java.core.Config;
import com.wechat.pay.java.core.RSAAutoCertificateConfig;
import com.wechat.pay.java.core.exception.ServiceException;
import com.wechat.pay.java.core.notification.NotificationConfig;
import com.wechat.pay.java.core.notification.NotificationParser;
import com.wechat.pay.java.core.notification.RequestParam;
import com.wechat.pay.java.service.payments.model.Transaction;
import com.wechat.pay.java.service.payments.nativepay.NativePayService;
import com.wechat.pay.java.service.payments.nativepay.model.Amount;
import com.wechat.pay.java.service.payments.nativepay.model.*;
import com.wechat.pay.java.service.refund.RefundService;
import com.wechat.pay.java.service.refund.model.*;
import lombok.extern.slf4j.Slf4j;

import javax.servlet.http.HttpServletRequest;
import java.io.BufferedReader;

/**
 * Native 支付工具类  获取支付地址、解析支付数据
 *
 * @Author: szl
 * @Date: 2024年1月18日 下午15:30:11
 */
@Slf4j
public class PayUtils {
    //商户号
    public static String mchid = "1604711111";
    //商户API私钥路径
    //生产:
    //public static String privateKeyPath = "/hom123/apiclient_key.pem";
    //商户证书序列号
    public static String merchantSerialNumber = "543BA";
    //商户APIV3密钥
    public static String apiV3key = "iK81144423";
    public static String appId = "wx0a281111f7e";
    //退款后的回调地址
    public static final String refundNotifyUrl = "http://47.1711457/pay/refundNotify";
    //支付后的回调地址
    public static final String nativeNotifyUrl = "htt27/pay/notifyNative";

    // 使用自动更新平台证书的RSA配置
    public static Config config = new RSAAutoCertificateConfig.Builder()
            .merchantId(mchid) // 商户号
            .privateKeyFromPath(privateKeyPath)  // API证书地址(此处的路径自己调试一下,能找到就行)
            .merchantSerialNumber(merchantSerialNumber) // API证书序列号
            .apiV3Key(apiV3key) // API密匙
            .build();
    // 初始化 解析器 NotificationParser
    public static NotificationParser parser = new NotificationParser((NotificationConfig) config);
    // 构建支付、查询的service
    public static NativePayService nativePayService = new NativePayService.Builder().config(config).build();
    // 构建退款的service
    public static RefundService refundService = new RefundService.Builder().config(config).build();

    /**
     * 支付解析,解析成订单数据
     */
    public static Transaction parserTransaction(HttpServletRequest request) {
        RequestParam requestParam = parseRequest(request);
        // 解析为 Transaction 对象(解密数据) 解密完成后的数据
        Transaction transaction = parser.parse(requestParam, Transaction.class);
        return transaction;
    }

    /**
     * 退款解析,解析成退款单
     */
    public static RefundNotification parserRefundNotification(HttpServletRequest request) throws Exception {
        RequestParam requestParam = parseRequest(request);
        RefundNotification refundNotification = parser.parse(requestParam, RefundNotification.class);
        return refundNotification;
    }

    public static RequestParam parseRequest(HttpServletRequest request) {
        try {
            // 获取请求体原内容(此时获取的数据是加密的)
            BufferedReader reader = request.getReader();
            StringBuilder requestBody = new StringBuilder();
            String line;
            while ((line = reader.readLine()) != null) {
                requestBody.append(line);
            }
            // 获取请求携带的数据,构造参数
            RequestParam requestParam = new RequestParam.Builder()
                    .serialNumber(request.getHeader("Wechatpay-Serial")) // 微信支付平台证书的序列号
                    .nonce(request.getHeader("Wechatpay-Nonce")) // 签名中的随机数
                    .signature(request.getHeader("Wechatpay-Signature"))  // 应答的微信支付签名
                    .timestamp(request.getHeader("Wechatpay-Timestamp")) // 签名中的时间戳
                    .body(requestBody.toString()) // 请求体内容(原始内容,不要解析)
                    .build();
            //解密完成后的数据
            return requestParam;
        } catch (Exception e) {
            e.printStackTrace();
            log.error("解析失败:{}", e.getMessage());
            return null;
        }
    }

    /**
     * 获取支付地址 设置回调路径
     *
     * @param total     【总金额】 订单总金额,单位为分
     * @param desc      商品描述
     * @param notifyUrl 回调地址(必须是http)   如:"http://47.92.***.2**:80*7/pay/notifyNative"
     * @return
     * @Param orderNo 自己后端的唯一订单号
     */
    public static String nativePayAddr(Integer total, String desc, String notifyUrl, String orderNo, String attach) {
        try {
            PrepayRequest request = new PrepayRequest();
            Amount amount = new Amount();
            amount.setTotal(total); // 【总金额】 订单总金额,单位为分。
            request.setAmount(amount);
            request.setAppid(appId); // 应用ID
            request.setMchid(mchid);  // 商户号
            request.setDescription(desc);  // 商品描述
            request.setNotifyUrl(notifyUrl);  // 支付成功的回调地址 "http://47.92.132.209:8027/pay/notifyNative"
            request.setAttach(attach);
            request.setOutTradeNo(orderNo);  // 自己后端的唯一订单号,此处使用时间模拟
            // 调用下单方法,得到应答,发送请求
            PrepayResponse response = nativePayService.prepay(request);
            // 使用微信扫描 code_url 对应的二维码,即可体验Native支付
            log.info("支付地址:{}", response.getCodeUrl());
            return response.getCodeUrl();
        } catch (Exception e) {
            e.printStackTrace();
            log.info("获取支付的url失败:" + e.getMessage());
            return "获取支付的地址失败";
        }
    }

    /**
     * 手动根据微信订单号查询订单
     *
     * @throws Exception
     */
    public static Transaction queryOrderById(String transactionId) {
        try {
            QueryOrderByIdRequest queryRequest = new QueryOrderByIdRequest();
            queryRequest.setMchid(mchid);
            queryRequest.setTransactionId(transactionId);
            Transaction result = nativePayService.queryOrderById(queryRequest);
            log.info("订单状态: {}", result.getTradeState());
            return result;
        } catch (ServiceException e) {
            e.printStackTrace();
            System.out.printf("code=[%s], message=[%s]\n", e.getErrorCode(), e.getErrorMessage());
            System.out.printf("reponse body=[%s]\n", e.getResponseBody());
            return null;
        }
    }

    /**
     * 手动根据 商 户 订单号查询订单
     *
     * @throws Exception
     */
    public static Transaction queryOutTradeNoByOrderNO(String outTradeNo) {
        try {
            QueryOrderByOutTradeNoRequest queryRequest = new QueryOrderByOutTradeNoRequest();
            queryRequest.setMchid(mchid);
            queryRequest.setOutTradeNo(outTradeNo);
            Transaction transaction = nativePayService.queryOrderByOutTradeNo(queryRequest);
            log.info("订单状态: {}", transaction);
            return transaction;
        } catch (ServiceException e) {
            e.printStackTrace();
            log.info("code=[%s], message=[%s]\n", e.getErrorCode(), e.getErrorMessage());
            log.info("reponse body=[%s]\n", e.getResponseBody());
            return null;
        }
    }

    /**
     * 根据商户订单号进行退款申请
     *
     * @param refundNo
     * @param refuntMoney
     * @param orderTotal
     * @throws Exception
     */
    public static Refund refundByNo(String refundNo, Long refuntMoney, Long orderTotal) {
        try {
            CreateRequest request = new CreateRequest();
            AmountReq amountReq = new AmountReq();
            //退款金额
            amountReq.setRefund(refuntMoney);
            //原订单金额
            amountReq.setTotal(orderTotal);
            //货币类型(默认人民币)
            amountReq.setCurrency("CNY");
            request.setAmount(amountReq);
            //商户单号 微信支付订单号 二选一
            //request.setTransactionId("");
            request.setOutTradeNo(refundNo);
            //商户退款单号
            request.setOutRefundNo(refundNo);
            request.setNotifyUrl(refundNotifyUrl);
            Refund refundOrder = refundService.create(request);
            log.info("退款订单: {}", refundOrder.toString());
            log.info("订单状态:{}", refundOrder.getStatus(), refundOrder.toString());
            return refundOrder;
        } catch (ServiceException e) {
            e.printStackTrace();
            // API返回失败, 例如ORDER_NOT_EXISTS
            log.info("code=[%s], message=[%s]\n", e.getErrorCode(), e.getErrorMessage());
            log.info("reponse body=[%s]\n", e.getResponseBody());
            return null;
        }
    }

    /**
     * 查询退款
     *
     * @throws Exception
     */
    public static Refund queryByOutRefundNo(String outTradeNo) {
        try {
            QueryByOutRefundNoRequest request = new QueryByOutRefundNoRequest();
            request.setOutRefundNo(outTradeNo);
            Refund refund = refundService.queryByOutRefundNo(request);
            log.info("订单状态: {}", refund);
            return refund;
        } catch (ServiceException e) {
            e.printStackTrace();
            // API返回失败, 例如ORDER_NOT_EXISTS
            log.info("code=[%s], message=[%s]\n", e.getErrorCode(), e.getErrorMessage());
            log.info("reponse body=[%s]\n", e.getResponseBody());
            return null;
        }
    }
}
<!--微信支付依赖-->
        <dependency>
            <groupId>com.github.wechatpay-apiv3</groupId>
            <artifactId>wechatpay-java</artifactId>
            <version>0.2.5</version>
        </dependency>

把工具类中各种key? 路径 等关键信息换成自己的就可以用了,记得做好日志和订单

建议:

1、拉起支付时,创建订单。支付成功后被回调时,修改订单

2、申请退款时,创建退款单。退款成功后被回调时,修改退款单 并且修改自己的订单

文章来源:https://blog.csdn.net/weixin_40863853/article/details/135675488
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。