当前位置：首页 > news >正文

扩展开发指南：如何为pay-java-parent添加新的支付渠道

news 2026/8/15 2:09:33

扩展开发指南：如何为pay-java-parent添加新的支付渠道

【免费下载链接】pay-java-parentegzosn/pay-java-parent: 是一个基于 Java 的分布式支付系统，支持多种支付渠道和支付方式。该项目提供了一个简单易用的分布式支付系统，可以方便地实现各种支付场景的支付处理和结算，同时支持多种支付渠道和支付方式。项目地址: https://gitcode.com/gh_mirrors/pa/pay-java-parent

pay-java-parent是一个基于Java的分布式支付系统，支持多种支付渠道和支付方式。该框架提供了简单易用的分布式支付解决方案，可以方便地实现各种支付场景的支付处理和结算，同时支持多种支付渠道和支付方式。本文将详细介绍如何为这个强大的支付框架添加新的支付渠道，让你能够轻松扩展支付能力。

🚀 为什么选择pay-java-parent进行支付渠道扩展

pay-java-parent采用高度模块化的设计，将支付核心逻辑与具体支付渠道实现分离。这种架构使得添加新的支付渠道变得非常简单，你只需要关注特定支付渠道的业务逻辑，而不需要重写整个支付流程。

核心优势

统一接口设计：所有支付渠道都遵循相同的接口规范
模块化架构：每个支付渠道独立成模块，互不干扰
丰富的工具支持：内置签名、加密、HTTP请求等工具类
完善的测试支持：提供完整的demo和测试用例

📁 项目结构概览

在开始扩展之前，先了解项目的基本结构：

pay-java-parent/ ├── pay-java-common/ # 公共模块，定义核心接口和抽象类 ├── pay-java-ali/ # 支付宝支付实现 ├── pay-java-wx/ # 微信支付实现 ├── pay-java-union/ # 银联支付实现 ├── pay-java-paypal/ # PayPal支付实现 ├── pay-java-*/ # 其他支付渠道实现 └── pay-java-demo/ # 示例项目

🔧 扩展新支付渠道的5个关键步骤

步骤1：创建新的支付模块

首先，你需要创建一个新的Maven模块。参考现有模块结构，比如支付宝模块pay-java-ali：

pay-java-newpay/ ├── src/main/java/com/egzosn/pay/newpay/ │ ├── api/ │ │ ├── NewPayConfigStorage.java │ │ └── NewPayService.java │ ├── bean/ │ │ ├── NewTransactionType.java │ │ ├── NewRefundResult.java │ │ └── NewPayMessage.java │ └── util/ │ └── NewPayUtil.java └── pom.xml

步骤2：实现配置存储类

配置存储类需要继承BasePayConfigStorage，并添加特定支付渠道的配置项：

// pay-java-newpay/src/main/java/com/egzosn/pay/newpay/api/NewPayConfigStorage.java public class NewPayConfigStorage extends BasePayConfigStorage { // 新支付渠道特有的配置属性 private String merchantId; private String apiKey; private String secretKey; // getter和setter方法 public String getMerchantId() { return merchantId; } public void setMerchantId(String merchantId) { this.merchantId = merchantId; } // 其他配置方法... }

步骤3：实现支付服务类

支付服务类需要继承BasePayService，并实现核心支付方法：

// pay-java-newpay/src/main/java/com/egzosn/pay/newpay/api/NewPayService.java public class NewPayService extends BasePayService<NewPayConfigStorage> { public NewPayService(NewPayConfigStorage payConfigStorage) { super(payConfigStorage); } @Override public String getReqUrl(TransactionType transactionType) { // 根据交易类型返回不同的API地址 return payConfigStorage.isTest() ? "https://sandbox.newpay.com/api" : "https://api.newpay.com/v1"; } @Override public <O extends PayOrder> Map<String, Object> orderInfo(O order) { // 创建订单的具体实现 Map<String, Object> parameters = new TreeMap<>(); parameters.put("merchant_id", payConfigStorage.getMerchantId()); parameters.put("amount", order.getPrice()); parameters.put("order_no", order.getOutTradeNo()); // ... 其他参数 return parameters; } @Override public boolean verify(NoticeParams noticeParams) { // 验证回调签名 Map<String, Object> params = noticeParams.getBody(); String sign = (String) params.get("sign"); String content = buildSignContent(params); return verifySign(content, sign); } // 其他必须实现的方法... }

步骤4：定义交易类型枚举

交易类型枚举需要实现TransactionType接口：

// pay-java-newpay/src/main/java/com/egzosn/pay/newpay/bean/NewTransactionType.java public enum NewTransactionType implements TransactionType { // 支付类型 APP_PAY("payment.create"), WEB_PAY("payment.web.create"), QR_PAY("payment.qr.create"), // 查询类型 QUERY("payment.query"), REFUND("refund.create"), REFUND_QUERY("refund.query"); private String method; NewTransactionType(String method) { this.method = method; } @Override public String getType() { return this.name(); } @Override public String getMethod() { return this.method; } }

步骤5：添加Maven依赖配置

在模块的pom.xml中添加必要的依赖：

<!-- pay-java-newpay/pom.xml --> <dependency> <groupId>com.egzosn</groupId> <artifactId>pay-java-common</artifactId> <version>${project.version}</version> </dependency>

🎯 关键接口实现详解

1. 支付订单创建

每个支付渠道都需要实现orderInfo()方法，该方法负责构建支付请求参数：

@Override public <O extends PayOrder> Map<String, Object> orderInfo(O order) { Map<String, Object> orderInfo = new TreeMap<>(); // 必填参数 orderInfo.put("app_id", payConfigStorage.getAppId()); orderInfo.put("merchant_id", payConfigStorage.getMerchantId()); orderInfo.put("out_trade_no", order.getOutTradeNo()); orderInfo.put("total_amount", order.getPrice()); orderInfo.put("subject", order.getSubject()); orderInfo.put("body", order.getBody()); // 可选参数 if (StringUtils.isNotEmpty(order.getExpirationTime())) { orderInfo.put("time_expire", order.getExpirationTime()); } // 生成签名 String sign = createSign(buildSignString(orderInfo), payConfigStorage.getInputCharset()); orderInfo.put("sign", sign); return orderInfo; }

2. 回调验证

回调验证是支付安全的关键，需要正确实现签名验证：

@Override public boolean verify(NoticeParams noticeParams) { Map<String, Object> params = noticeParams.getBody(); // 获取签名 String sign = (String) params.remove("sign"); if (StringUtils.isEmpty(sign)) { return false; } // 构建待签名字符串 String content = buildSignContent(params); // 验证签名 try { return verifySign(content, sign, payConfigStorage.getKeyPublic()); } catch (Exception e) { LOG.error("签名验证失败", e); return false; } }

3. 退款处理

退款功能是支付渠道必须支持的核心功能：

@Override public RefundResult refund(RefundOrder refundOrder) { Map<String, Object> parameters = new HashMap<>(); parameters.put("refund_no", refundOrder.getRefundNo()); parameters.put("out_trade_no", refundOrder.getOutTradeNo()); parameters.put("refund_amount", refundOrder.getRefundAmount()); parameters.put("reason", refundOrder.getDescription()); // 调用支付渠道API String response = requestTemplate.postForObject( getReqUrl(NewTransactionType.REFUND), parameters, String.class ); // 解析响应 JSONObject json = JSON.parseObject(response); NewRefundResult result = new NewRefundResult(); result.setRefundNo(json.getString("refund_id")); result.setRefundAmount(json.getBigDecimal("refund_amount")); result.setRefundStatus(json.getString("status")); return result; }

📊 支付渠道架构对比

组件	支付宝实现	微信支付实现	新支付渠道实现
配置类	`AliPayConfigStorage`	`WxPayConfigStorage`	`NewPayConfigStorage`
服务类	`AliPayService`	`WxPayService`	`NewPayService`
交易类型	`AliTransactionType`	`WxTransactionType`	`NewTransactionType`
退款结果	`AliRefundResult`	`WxRefundResult`	`NewRefundResult`

🔍 调试与测试技巧

1. 使用Demo项目进行测试

参考pay-java-demo项目中的控制器实现，创建你的测试控制器：

@RestController @RequestMapping("newpay") public class NewPayController { private NewPayService service; @PostConstruct public void init() { NewPayConfigStorage config = new NewPayConfigStorage(); config.setAppId("your_app_id"); config.setMerchantId("your_merchant_id"); config.setKeyPrivate("your_private_key"); config.setKeyPublic("your_public_key"); config.setNotifyUrl("http://your-domain.com/payBack.json"); config.setReturnUrl("http://your-domain.com/payBack.html"); service = new NewPayService(config); } @RequestMapping("pay") public Map<String, Object> pay() { PayOrder order = new PayOrder(); order.setOutTradeNo(UUID.randomUUID().toString()); order.setPrice(new BigDecimal("0.01")); order.setSubject("测试支付"); order.setBody("测试支付描述"); order.setTransactionType(NewTransactionType.APP_PAY); return service.orderInfo(order); } }