clunt
/
ghy-all
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

更新加价记录的操作放到回调

This commit is contained in:
clunt 2022-10-17 00:14:50 +08:00
parent 3abc26165d
commit 6cb7271c1b
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
ghy-payment/src/main/java/com/ghy/payment/service/impl/PayCallbackService.java
View File

@ -50,8 +50,14 @@ public class PayCallbackService implements CallBackService {
param.setStatus(payment.getStatus()); param.setStatus(payment.getStatus());
param.setPayTime(LocalDateTime.now()); param.setPayTime(LocalDateTime.now());
financialMasterService.updatePayment(param); financialMasterService.updatePayment(param);
if (AdapayStatusEnum.succeeded.code.equals(payment.getStatus())) { if (AdapayStatusEnum.succeeded.code.equals(payment.getStatus())) {
if(payment.getOrderNo().split("_").length > 2){
FinancialChangeRecord financialChangeRecord = new FinancialChangeRecord();
financialChangeRecord.setId(payment.getOrderNo().split("_")[1]);
financialChangeRecord.setPayStatus(1L);
financialChangeRecordService.updateFinancialChangeRecord(financialChangeRecord);
// TODO 拆分对应的分账流水
}
// 更新主财务单状态 // 更新主财务单状态
financialMasterService.paySucceeded(payment.getId(), payment.getPayChannel()); financialMasterService.paySucceeded(payment.getId(), payment.getPayChannel());
} else { } else {
@ -75,13 +81,6 @@ public class PayCallbackService implements CallBackService {
update.setOrderMasterCode(payment.getOrderNo().split("_")[0]); update.setOrderMasterCode(payment.getOrderNo().split("_")[0]);
update.setPaymentId(payment.getId()); update.setPaymentId(payment.getId());
financialMasterService.updateFinancialMaster(update); financialMasterService.updateFinancialMaster(update);
if(payment.getOrderNo().split("_").length > 2){
FinancialChangeRecord financialChangeRecord = new FinancialChangeRecord();
financialChangeRecord.setId(payment.getOrderNo().split("_")[1]);
financialChangeRecord.setPayStatus(1L);
financialChangeRecordService.updateFinancialChangeRecord(financialChangeRecord);
// TODO 拆分对应的分账流水
}
} else { } else {
logger.warn("发起支付失败 : {}", response.toJSONString()); logger.warn("发起支付失败 : {}", response.toJSONString());
} }