From 4f6f15b818704079ff2e4e4719b798f48d68a335 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期五, 11 九月 2026 13:52:19 +0800
Subject: [PATCH] update
---
backend/src/main/java/com/tourguide/modules/order/service/OrderRefundService.java | 119 ++++++++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 105 insertions(+), 14 deletions(-)
diff --git a/backend/src/main/java/com/tourguide/modules/order/service/OrderRefundService.java b/backend/src/main/java/com/tourguide/modules/order/service/OrderRefundService.java
index 21d2b11..d8b4bd8 100644
--- a/backend/src/main/java/com/tourguide/modules/order/service/OrderRefundService.java
+++ b/backend/src/main/java/com/tourguide/modules/order/service/OrderRefundService.java
@@ -1,11 +1,17 @@
package com.tourguide.modules.order.service;
import com.tourguide.common.huifu.RequestSeqUtil;
+import com.tourguide.modules.order.domain.OrderStatus;
import com.tourguide.modules.order.domain.PaymentMethod;
+import com.tourguide.modules.order.domain.RefundAmountCalculator;
import com.tourguide.modules.order.domain.RefundStatus;
import com.tourguide.modules.order.entity.TourOrder;
+import com.tourguide.modules.order.entity.TourOrderRefund;
import com.tourguide.modules.order.mapper.TourOrderMapper;
+import com.tourguide.modules.order.mapper.TourOrderRefundMapper;
import com.tourguide.modules.order.payment.PaymentRefundGateway;
+import com.tourguide.modules.finance.service.GuideBalanceSettlementService;
+import org.springframework.beans.factory.annotation.Autowired;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@@ -20,42 +26,127 @@
private final TourOrderMapper orderMapper;
private final PaymentRefundGateway paymentRefundGateway;
+ private final TourOrderRefundMapper refundMapper;
+ private final GuideBalanceSettlementService balanceSettlementService;
public OrderRefundService(TourOrderMapper orderMapper, PaymentRefundGateway paymentRefundGateway) {
- this.orderMapper = orderMapper;
- this.paymentRefundGateway = paymentRefundGateway;
+ this(orderMapper, paymentRefundGateway, null, null);
}
- public void requestRefund(TourOrder order) {
- if (order.getPaymentTime() == null || RefundStatus.REFUNDED.matches(order.getRefundStatus())) {
- return;
+ public OrderRefundService(TourOrderMapper orderMapper, PaymentRefundGateway paymentRefundGateway,
+ TourOrderRefundMapper refundMapper) {
+ this(orderMapper, paymentRefundGateway, refundMapper, null);
+ }
+
+ @Autowired
+ public OrderRefundService(TourOrderMapper orderMapper, PaymentRefundGateway paymentRefundGateway,
+ TourOrderRefundMapper refundMapper,
+ GuideBalanceSettlementService balanceSettlementService) {
+ this.orderMapper = orderMapper;
+ this.paymentRefundGateway = paymentRefundGateway;
+ this.refundMapper = refundMapper;
+ this.balanceSettlementService = balanceSettlementService;
+ }
+
+ public boolean requestRefund(TourOrder order) {
+ if (order == null) return false;
+ BigDecimal refundAmount = RefundAmountCalculator.refundableAmount(order);
+ return requestRefund(order, refundAmount);
+ }
+
+ public boolean requestRefund(TourOrder order, BigDecimal refundAmount) {
+ if (order == null || order.getPaymentTime() == null) {
+ return false;
+ }
+ if (RefundStatus.REFUNDED.matches(order.getRefundStatus())
+ || OrderStatus.REFUNDED.matches(order.getStatus())) {
+ return true;
}
if (RefundStatus.REFUNDING.matches(order.getRefundStatus())
&& StringUtils.hasText(order.getRefundOrderNo())) {
- return;
+ return true;
}
- BigDecimal refundAmount = order.getPaymentAmount() == null
- ? order.getAmount() : order.getPaymentAmount();
- if (!StringUtils.hasText(order.getRefundOrderNo())) {
- order.setRefundOrderNo(RequestSeqUtil.generateForBusiness("RF"));
+ if (refundAmount == null || refundAmount.compareTo(BigDecimal.ZERO) <= 0) {
+ return false;
}
+ BigDecimal refundableAmount = RefundAmountCalculator.refundableAmount(order);
+ if (refundAmount.compareTo(refundableAmount) > 0) {
+ return false;
+ }
+ order.setRefundOrderNo(RequestSeqUtil.generateForBusiness("RF"));
order.setRefundStatus(RefundStatus.REFUNDING.getCode());
order.setRefundAmount(refundAmount);
order.setRefundMethod(order.getPaymentMethod());
+ TourOrderRefund refundRecord = createRefundRecord(order, refundAmount);
if (PaymentMethod.TEMPORARY_BYPASS.matches(order.getPaymentMethod())) {
- order.setRefundStatus(RefundStatus.REFUNDED.getCode());
- order.setRefundTime(LocalDateTime.now());
+ if (order.getCancelledAt() == null) order.setCancelledAt(LocalDateTime.now());
+ completeLocalRefund(order, refundAmount);
+ LocalDateTime refundTime = LocalDateTime.now();
+ order.setRefundTime(refundTime);
+ // 明细状态描述当前这一笔退款；订单状态则描述累计退款进度。
+ updateRefundRecord(refundRecord, RefundStatus.REFUNDED.getCode(), refundTime);
orderMapper.updateById(order);
- return;
+ return true;
}
orderMapper.updateById(order);
try {
- paymentRefundGateway.refund(order, refundAmount);
+ String refundRequestNo = paymentRefundGateway.refund(order, refundAmount);
+ if (!StringUtils.hasText(refundRequestNo)) {
+ throw new IllegalStateException("Payment provider did not accept refund request");
+ }
+ if (!OrderStatus.CANCELLED.matches(order.getStatus())) {
+ order.setStatus(OrderStatus.CANCELLED.getCode());
+ }
+ if (order.getCancelledAt() == null) order.setCancelledAt(LocalDateTime.now());
+ orderMapper.updateById(order);
+ return true;
} catch (RuntimeException exception) {
order.setRefundStatus(RefundStatus.REFUND_FAILED.getCode());
+ updateRefundRecord(refundRecord, RefundStatus.REFUND_FAILED.getCode(), null);
orderMapper.updateById(order);
log.error("Order refund request failed, orderId={}, orderNo={}, refundOrderNo={}",
order.getId(), order.getOrderNo(), order.getRefundOrderNo(), exception);
+ return false;
}
}
+
+ private void completeLocalRefund(TourOrder order, BigDecimal refundAmount) {
+ BigDecimal previousRefundedAmount = RefundAmountCalculator.refundedAmount(order);
+ BigDecimal refundedAmount = previousRefundedAmount.add(refundAmount);
+ order.setRefundedAmount(refundedAmount);
+ if (refundedAmount.compareTo(RefundAmountCalculator.paidAmount(order)) >= 0) {
+ order.setRefundStatus(RefundStatus.REFUNDED.getCode());
+ order.setStatus(OrderStatus.REFUNDED.getCode());
+ } else {
+ order.setRefundStatus(RefundStatus.PARTIAL.getCode());
+ order.setStatus(OrderStatus.CANCELLED.getCode());
+ }
+ reverseSettledEarning(order, previousRefundedAmount, refundedAmount);
+ }
+
+ private void reverseSettledEarning(TourOrder order, BigDecimal previousRefundedAmount,
+ BigDecimal currentRefundedAmount) {
+ if (balanceSettlementService != null) {
+ balanceSettlementService.reverseRefund(order, previousRefundedAmount, currentRefundedAmount);
+ }
+ }
+
+ private TourOrderRefund createRefundRecord(TourOrder order, BigDecimal refundAmount) {
+ if (refundMapper == null || order.getId() == null) return null;
+ TourOrderRefund refund = new TourOrderRefund();
+ refund.setOrderId(order.getId());
+ refund.setRefundOrderNo(order.getRefundOrderNo());
+ refund.setRefundAmount(refundAmount);
+ refund.setRefundStatus(RefundStatus.REFUNDING.getCode());
+ refund.setRefundMethod(order.getRefundMethod());
+ refundMapper.insert(refund);
+ return refund;
+ }
+
+ private void updateRefundRecord(TourOrderRefund refund, String status, LocalDateTime refundTime) {
+ if (refundMapper == null || refund == null) return;
+ refund.setRefundStatus(status);
+ refund.setRefundTime(refundTime);
+ refundMapper.updateById(refund);
+ }
}
--
Gitblit v1.7.1