czg_team
/
video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

支付订单处理

This commit is contained in:
GYJ 2025-08-19 16:40:58 +08:00
parent 944d1b953b
commit 70046aacbc
1 changed files with 36 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java
View File

@ -120,27 +120,44 @@ public class WuyouController {
return Result.success().put("data", data); return Result.success().put("data", data);
} }
try {
BaseResp baseResp = wuyouPay.payOrder(payDetails.getTradeNo(), order.getUserId(), order.getPayMoney().toString(), BaseResp baseResp = wuyouPay.payOrder(payDetails.getTradeNo(), order.getUserId(), order.getPayMoney().toString(),
request.getHeader("User-Agent"), String.format("%d-%d", order.getCourseId(), order.getCourseDetailsId()), request.getHeader("User-Agent"), String.format("%d-%d", order.getCourseId(), order.getCourseDetailsId()),
payType); payType);
if (baseResp.getCode() == null) { if (baseResp.getCode() == null) {
if (baseResp.getErrorMsg().contains("通道拥挤")) { log.error("无忧支付失败：{}", JSONObject.toJSONString(baseResp));
String errMsg = "系统繁忙，请稍后再尝试购买";
order.setStatus(3); order.setStatus(3);
payDetails.setState(2);
if (baseResp.getErrorMsg().contains("通道拥挤")) {
payDetails.setRemark("通道拥挤");
} else {
errMsg = baseResp.getErrorMsg();
payDetails.setRemark(errMsg);
}
ordersService.update(order, new LambdaQueryWrapper<Orders>() ordersService.update(order, new LambdaQueryWrapper<Orders>()
.eq(Orders::getOrdersId, order.getOrdersId()).eq(Orders::getUserId, order.getUserId())); .eq(Orders::getOrdersId, order.getOrdersId()).eq(Orders::getUserId, order.getUserId()));
payDetails.setState(2);
payDetailsDao.update(payDetails, new LambdaQueryWrapper<PayDetails>() payDetailsDao.update(payDetails, new LambdaQueryWrapper<PayDetails>()
.eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId())); .eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId()));
return Result.error("系统繁忙，请稍后再尝试购买"); return Result.error(errMsg);
}
return Result.error(baseResp.getErrorMsg());
} }
if (baseResp.getCode() != 200) { if (baseResp.getCode() != 200) {
return Result.error(baseResp.getMsg()); return Result.error(baseResp.getMsg());
} }
return Result.success().put("data", baseResp.getData()); return Result.success().put("data", baseResp.getData());
} catch (Exception e) {
log.error("无忧支付异常：{}", e.getMessage());
order.setStatus(3);
payDetails.setState(2);
payDetails.setRemark(e.getMessage());
ordersService.update(order, new LambdaQueryWrapper<Orders>()
.eq(Orders::getOrdersId, order.getOrdersId()).eq(Orders::getUserId, order.getUserId()));
payDetailsDao.update(payDetails, new LambdaQueryWrapper<PayDetails>()
.eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId()));
return Result.error("支付失败请稍后再试");
}
} }
@ApiOperation("查询订单支付结果") @ApiOperation("查询订单支付结果")