update

liujie

2026-08-21 ad5db85e540947e82c7a4d5612879b3b3ecdf459

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
package com.tourguide.modules.order.service;
 
import com.tourguide.common.huifu.RequestSeqUtil;
import com.tourguide.modules.order.domain.RefundStatus;
import com.tourguide.modules.order.entity.TourOrder;
import com.tourguide.modules.order.mapper.TourOrderMapper;
import com.tourguide.modules.order.payment.PaymentRefundGateway;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
 
import java.math.BigDecimal;
 
@Service
public class OrderRefundService {
    private static final Logger log = LoggerFactory.getLogger(OrderRefundService.class);
 
    private final TourOrderMapper orderMapper;
    private final PaymentRefundGateway paymentRefundGateway;
 
    public OrderRefundService(TourOrderMapper orderMapper, PaymentRefundGateway paymentRefundGateway) {
        this.orderMapper = orderMapper;
        this.paymentRefundGateway = paymentRefundGateway;
    }
 
    public void requestRefund(TourOrder order) {
        if (order.getPaymentTime() == null || RefundStatus.REFUNDED.matches(order.getRefundStatus())) {
            return;
        }
        if (RefundStatus.REFUNDING.matches(order.getRefundStatus())
                && StringUtils.hasText(order.getRefundOrderNo())) {
            return;
        }
        BigDecimal refundAmount = order.getPaymentAmount() == null
                ? order.getAmount() : order.getPaymentAmount();
        if (!StringUtils.hasText(order.getRefundOrderNo())) {
            order.setRefundOrderNo(RequestSeqUtil.generateForBusiness("RF"));
        }
        order.setRefundStatus(RefundStatus.REFUNDING.getCode());
        order.setRefundAmount(refundAmount);
        order.setRefundMethod(order.getPaymentMethod());
        orderMapper.updateById(order);
        try {
            paymentRefundGateway.refund(order, refundAmount);
        } catch (RuntimeException exception) {
            order.setRefundStatus(RefundStatus.REFUND_FAILED.getCode());
            orderMapper.updateById(order);
            log.error("Order refund request failed, orderId={}, orderNo={}, refundOrderNo={}",
                    order.getId(), order.getOrderNo(), order.getRefundOrderNo(), exception);
        }
    }
}