dromara/dax-pay
1
0
Fork 0
mirror of https://gitee.com/dromara/dax-pay.git synced 2025-09-01 18:27:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix 异步支付失败数据保存不全

Browse Source
This commit is contained in:
喵呀
2024-03-26 09:15:27 +00:00
parent ef0398ebe2
commit f69ca550b1
5 changed files with 50 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
README.md
View File

@@ -22,7 +22,7 @@
## 🧭 特色功能
- 封装各类支付通道的接口为统一的接口，方便业务系统进行调用，简化对接多种支付方式的复杂度
- 已对接`微信支付`和`支付宝`相关的接口，目前已经支持`V2`版本的接口，后续版本将支持`V3`版本的接口
- 已对接`微信支付`、`支付宝`和云闪付相关的接口，后续版本将支持`V3`版本的接口
- 支持组合支付，满足用户系统需要多种方式同时进行支付的场景。
- 提供`HTTP`方式接口调用能力，和`Java`版本的`SDK`，方便业务系统进行对接
- 接口请求和响应数据支持启用签名机制，可根据实际需要进行开关，保证交易安全可靠
@@ -150,16 +150,14 @@ public class SimplePayOrderTest {
```
## 🍎 系统截图
### H5收银台演示
![h5.png](https://s11.ax1x.com/2024/02/12/pF8nPMV.png)
### 支付演示
![pay.png](https://s11.ax1x.com/2024/02/12/pF8np2q.png)
### 收银台演示
![pc.jpg](https://s11.ax1x.com/2024/02/12/pF8n9x0.jpg)
![微信截图_20240326141126](https://jsd.cdn.zzko.cn/gh/xxm1995/picx-images-hosting@master/daxpay/微信截图_20240326141126.es9yupxd3.webp)
### 驾驶舱
![QQ截图20240326141912](https://jsd.cdn.zzko.cn/gh/xxm1995/picx-images-hosting@master/daxpay/QQ截图20240326141912.60u0cpvjg5.webp)
### H5收银台演示
![h5](https://jsd.cdn.zzko.cn/gh/xxm1995/picx-images-hosting@master/daxpay/h5.839t0s61xr.webp)
### 支付通道配置
![](https://s11.ax1x.com/2024/02/13/pF8s2VS.jpg)
![微信截图_20240326142208](https://jsd.cdn.zzko.cn/gh/xxm1995/picx-images-hosting@master/daxpay/微信截图_20240326142208.6bgu5vdv60.webp)
## 🛣️ 路线图
> 当前处于功能开发阶段，部分功能可能会有调整，`V2.1.0`时将作为正式生产可用版本进行发布，之后会保证系统版本非大版本升级时，API接口和数据接口向前兼容

25
_doc/Task.md
View File

@@ -1,21 +1,16 @@
2.0.4:
- [x] 支付流程也改为先落库后支付情况, 避免极端情况导致掉单
- [x] 首页驾驶舱功能: 各通道收入和支付情况
- [x] 第一排: (数字格式)显示今日收入、支出金额，支付总订单数量、退款总订单数， 时间分支分为: 今日金额/昨日金额/七天内金额
- [x] 第二排: (饼图)显示各通道各支付方式数量和占比, 时间分为: 今日金额/昨日金额/七天内金额
- [x] 第三排: (折线图)显示各通道支付分为支付金额和退款,时间分为: 今日金额/昨日金额/七天内金额
- [x] 云闪付支持对账功能
- [x] 对账文件支持手动导入
- [x] 结算台DEMO增加云闪付示例
- [x] 增加支付限额
- [x] 各通道(异步支付)支持单独的限额
- [x] 整个订单支持整体的限额
2.0.5:
- [ ] 资金流水优化
- [ ] 支持分账
- [ ] 增加撤销功能，用于处理线下支付订单的情况
- [ ] 统计报表功能
- [ ] 修复创建支付订单报错时, 订单保存数据不完整
- [ ] 针对同步/对账等出现脏数据导致阻塞的问题, 进行优化
- [ ] 同步接口
- [ ] 对账接口
2.0.x 版本内容
- [ ] 微信新增V3版本接口
- [ ] 付款码支付自动路由到V2接口
- [ ] 资金流水优化
- [ ] 统一关闭接口增加使用撤销关闭订单
- [ ] 支持分账
- [ ] 增加各类日志记录,例如钱包的各项操作
- [ ] 增加撤销功能，用于处理线下支付订单的情况
- [ ] 数据库表进行规则, 字段设置长度, 增加索引

2
daxpay-single/daxpay-single-service/src/main/java/cn/bootx/platform/daxpay/service/core/order/pay/entity/PayOrderExtra.java
View File

@@ -72,10 +72,12 @@ public class PayOrderExtra extends MpBaseEntity implements EntityBaseFunction<Pa
/** 错误码 */
@DbColumn(comment = "错误码")
@TableField(updateStrategy = FieldStrategy.ALWAYS)
private String errorCode;
/** 错误信息 */
@DbColumn(comment = "错误信息")
@TableField(updateStrategy = FieldStrategy.ALWAYS)
private String errorMsg;
/**

38
daxpay-single/daxpay-single-service/src/main/java/cn/bootx/platform/daxpay/service/core/payment/pay/service/PayService.java
View File

@@ -81,7 +81,7 @@ public class PayService {
payParam.setPayChannels(Collections.singletonList(payChannelParam));
// 复用支付下单接口
return this.pay(payParam);
}
}
/**
@@ -206,7 +206,7 @@ public class PayService {
PayLocal payInfo = PaymentContextLocal.get().getPayInfo();
// 获取支付方式，通过工厂生成对应的策略组
List<AbsPayStrategy> strategies = PayStrategyFactory.createAsyncLast(payParam.getPayChannels());
List<AbsPayStrategy> strategies = PayStrategyFactory.createAsyncLast(payParam.getPayChannels());
if (CollectionUtil.isEmpty(strategies)) {
throw new PayUnsupportedMethodException();
}
@@ -219,9 +219,8 @@ public class PayService {
// 执行支付前处理动作, 进行各种校验
asyncPayStrategy.doBeforePayHandler();
// 创建支付订单和扩展记录并返回支付订单对象
PayOrder payOrder = payAssistService.createPayOrder(payParam);
asyncPayStrategy.setOrder(payOrder);
// 执行支付前的保存动作, 保持订单和通道订单的原子性
PayOrder payOrder = SpringUtil.getBean(this.getClass()).firstPreAsyncPay(asyncPayStrategy, payParam);
// 支付操作
try {
@@ -238,6 +237,19 @@ public class PayService {
}
/**
* 异步单通道支付的订单预保存, 保存订单和通道订单
*/
@Transactional(rollbackFor = Exception.class)
public PayOrder firstPreAsyncPay(AbsPayStrategy asyncPayStrategy, PayParam payParam){
// 创建支付订单和扩展记录并返回支付订单对象
PayOrder payOrder = payAssistService.createPayOrder(payParam);
asyncPayStrategy.setOrder(payOrder);
// 生成通道支付订单
asyncPayStrategy.generateChannelOrder();
return payOrder;
}
/**
* 首次单通道异步支付成功后操作, 更新订单和扥爱松
*/
@@ -254,9 +266,13 @@ public class PayService {
.setPayTime(LocalDateTime.now());
}
payOrderService.updateById(payOrder);
// 扩展记录更新
PayOrderExtra payOrderExtra = payInfo.getPayOrderExtra();
payOrderExtra.setErrorMsg(null);
payOrderExtraManager.update(payOrderExtra);
// 如果支付完成 发送通知
if (Objects.equals(payOrder.getStatus(), SUCCESS.getCode())){
clientNoticeService.registerPayNotice(payOrder, payInfo.getPayOrderExtra(), payInfo.getPayChannelOrders());
clientNoticeService.registerPayNotice(payOrder, payOrderExtra, payInfo.getPayChannelOrders());
}
return PayBuilder.buildPayResultByPayOrder(payOrder);
}
@@ -348,10 +364,13 @@ public class PayService {
.setPayTime(LocalDateTime.now());
}
payOrderService.updateById(payOrder);
payOrderService.updateById(payOrder);
// 扩展记录更新
PayOrderExtra payOrderExtra = payInfo.getPayOrderExtra();
payOrderExtra.setErrorMsg(null);
payOrderExtraManager.update(payOrderExtra);
// 如果支付完成 发送通知
if (Objects.equals(payOrder.getStatus(), SUCCESS.getCode())){
clientNoticeService.registerPayNotice(payOrder, payInfo.getPayOrderExtra(), payInfo.getPayChannelOrders());
clientNoticeService.registerPayNotice(payOrder, payOrderExtra, payInfo.getPayChannelOrders());
}
return PayBuilder.buildPayResultByPayOrder(payOrder);
}
@@ -428,6 +447,9 @@ public class PayService {
.setPayTime(LocalDateTime.now());
}
payOrderService.updateById(payOrder);
// 扩展记录更新
payOrderExtra.setErrorMsg(null);
payOrderExtraManager.update(payOrderExtra);
// 如果支付完成 发送通知
if (Objects.equals(payOrder.getStatus(), SUCCESS.getCode())){
// 查询通道订单

2
daxpay-single/daxpay-single-start/src/main/resources/application-dev.yml
View File

@@ -165,7 +165,7 @@ dax-pay:
# 演示模块
demo:
# 网关地址
server-url: http://localhost:9000/server
server-url: http://localhost:9000
# 前端h5地址
front-h5-url: http://localhost:5173/#
# 签名秘钥