145 lines
6.9 KiB
Java
145 lines
6.9 KiB
Java
package com.ghy.callback;
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.ghy.common.adapay.model.AdapayStatusEnum;
|
|
import com.ghy.common.adapay.model.Event;
|
|
import com.ghy.common.adapay.model.PayCallback;
|
|
import com.ghy.common.adapay.model.PaymentDTO;
|
|
import com.ghy.common.enums.PayStatus;
|
|
import com.ghy.payment.domain.FinancialChangeRecord;
|
|
import com.ghy.payment.domain.FinancialDetail;
|
|
import com.ghy.payment.domain.FinancialMaster;
|
|
import com.ghy.payment.service.CallBackService;
|
|
import com.ghy.payment.service.FinancialChangeRecordService;
|
|
import com.ghy.payment.service.FinancialDetailService;
|
|
import com.ghy.payment.service.FinancialMasterService;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
import javax.annotation.Resource;
|
|
import java.math.BigDecimal;
|
|
import java.time.LocalDateTime;
|
|
import java.util.List;
|
|
import java.util.concurrent.CompletableFuture;
|
|
|
|
/**
|
|
* 支付回调
|
|
*
|
|
* @author HH 2022/5/31
|
|
*/
|
|
@Service("payCallbackService")
|
|
public class PayCallbackService implements CallBackService {
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(PayCallbackService.class);
|
|
|
|
@Resource
|
|
FinancialMasterService financialMasterService;
|
|
|
|
@Resource
|
|
FinancialDetailService financialDetailService;
|
|
|
|
@Resource
|
|
FinancialChangeRecordService financialChangeRecordService;
|
|
|
|
@Override
|
|
@Transactional(rollbackFor = Exception.class)
|
|
public void onCallback(Event event) {
|
|
logger.info("支付回调: {}", event);
|
|
String data = event.getData();
|
|
PayCallback payment = JSON.parseObject(data, PayCallback.class);
|
|
PaymentDTO dto = financialMasterService.selectPaymentById(payment.getId());
|
|
// 校验是否是本系统发出去的支付请求
|
|
if (dto != null) {
|
|
CompletableFuture.runAsync(() -> {
|
|
// 异步更新交易记录 避免被回滚
|
|
PaymentDTO param = new PaymentDTO();
|
|
param.setId(payment.getId());
|
|
param.setFeeAmt(payment.getFeeAmt());
|
|
param.setStatus(payment.getStatus());
|
|
param.setPayTime(LocalDateTime.now());
|
|
financialMasterService.updatePayment(param);
|
|
});
|
|
if (AdapayStatusEnum.succeeded.code.equals(payment.getStatus())) {
|
|
if (payment.getOrderNo().split("_").length > 2) {
|
|
// 支付回调中的加价记录ID
|
|
String fcrIdStr = payment.getOrderNo().split("_")[1];
|
|
String[] fcrIds = fcrIdStr.split(",");
|
|
|
|
BigDecimal totalChangeMoney = BigDecimal.ZERO;
|
|
Long financialMasterId = null;
|
|
for (String fcrId : fcrIds) {
|
|
FinancialChangeRecord financialChangeRecord = new FinancialChangeRecord();
|
|
financialChangeRecord.setId(Long.valueOf(fcrId));
|
|
financialChangeRecord.setPayStatus(1);
|
|
// 加价的支付paymentId回填到remark
|
|
financialChangeRecord.setRemark(payment.getId());
|
|
financialChangeRecord.setRemark(payment.getId());
|
|
financialChangeRecord.setPaymentId(payment.getId());
|
|
financialChangeRecordService.update(financialChangeRecord);
|
|
|
|
// 修改子订单的payMoney
|
|
FinancialChangeRecord fc = financialChangeRecordService.selectFinancialChangeRecordById(financialChangeRecord.getId());
|
|
FinancialDetail financialDetail = financialDetailService.selectByOrderDetailId(fc.getOrderDetailId());
|
|
FinancialDetail financialDetail2Update = new FinancialDetail();
|
|
financialDetail2Update.setId(financialDetail.getId());
|
|
financialDetail2Update.setPayMoney(financialDetail.getPayMoney().add(fc.getChangeMoney()));
|
|
financialDetail2Update.setPayStatus(PayStatus.PAID.getCode());
|
|
financialDetailService.updateFinancialDetail(financialDetail2Update);
|
|
totalChangeMoney = totalChangeMoney.add(fc.getChangeMoney());
|
|
if (financialMasterId == null) {
|
|
financialMasterId = financialDetail.getFinancialMasterId();
|
|
}
|
|
}
|
|
// 修改主单的payMoney
|
|
FinancialMaster financialMaster = financialMasterService.selectById(financialMasterId);
|
|
FinancialMaster financialMaster2Update = new FinancialMaster();
|
|
financialMaster2Update.setId(financialMaster.getId());
|
|
financialMaster2Update.setPayMoney(financialMaster.getPayMoney().add(totalChangeMoney));
|
|
financialMaster2Update.setPayStatus(PayStatus.PAID.getCode());
|
|
financialMasterService.updateFinancialMaster(financialMaster2Update);
|
|
// TODO 拆分对应的分账流水
|
|
}else {
|
|
// 主单的付款
|
|
String masterOrderNo = payment.getOrderNo().split("_")[0];
|
|
|
|
// 找到主单记录
|
|
FinancialMaster param = new FinancialMaster();
|
|
param.setOrderMasterCode(masterOrderNo);
|
|
List<FinancialMaster> financialMasters = financialMasterService.selectFinancialMasterList(param);
|
|
FinancialMaster source = financialMasters.get(0);
|
|
// 更新主单paymentId 以及主单状态
|
|
FinancialMaster financialMaster2Update = new FinancialMaster();
|
|
financialMaster2Update.setId(source.getId());
|
|
financialMaster2Update.setPayStatus(PayStatus.PAID.getCode());
|
|
financialMaster2Update.setPaymentId(payment.getId());
|
|
financialMasterService.updateFinancialMaster(financialMaster2Update);
|
|
}
|
|
// 更新主财务单状态
|
|
financialMasterService.paySucceeded(payment.getId(), payment.getPayChannel());
|
|
} else {
|
|
logger.warn("支付失败 : {}", data);
|
|
}
|
|
} else {
|
|
logger.warn("系统中不存在这条交易记录: {}", event);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onResponse(JSONObject response) {
|
|
logger.info("发起支付 Response: {}", response.toJSONString());
|
|
// 保存一条支付记录
|
|
PaymentDTO payment = response.toJavaObject(PaymentDTO.class);
|
|
String status = payment.getStatus();
|
|
|
|
financialMasterService.insertPayment(payment);
|
|
|
|
if (!AdapayStatusEnum.succeeded.code.equals(status)) {
|
|
logger.warn("发起支付失败 : {}", response.toJSONString());
|
|
}
|
|
}
|
|
|
|
}
|