package com.talentcard.server.business.order;
|
|
import java.util.List;
|
import java.util.Map;
|
|
import com.talentcard.server.common.BusinessException;
|
import com.talentcard.server.common.ErrorCode;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
/**
|
* 订单资金边界。
|
*
|
* <p>一个订单的核销、退款和提现锁定都会先锁定 {@code benefit_order} 的同一行，因此它们按订单串行化：
|
* 不会出现「退了款又核销」「核销后被退款」「已经进了提现记录又撤销核销」。
|
*
|
* <p>{@code refund_status} 由本服务的退款三个方法维护。出款已改由斗拱按结算周期自动完成，
|
* 平台不再生成提现记录，因此订单上不再有「已进入提现记录」这一状态。
|
* 核销、退款、提现锁定与解锁的业务规则都收敛在这里，调用方只负责在拿到 {@link LockedOrder} 后调用
|
* 对应断言。
|
*
|
* <p>{@link #lock(long)} 要求已经存在数据库事务：行锁只在事务内有效，脱离事务调用会直接失败，
|
* 而不是静默地失去串行化能力。其它方法都是单条条件更新，本身就是原子的。
|
*/
|
@Service
|
public class OrderFundBoundaryService {
|
|
/** 订单退款状态：没有生效中的退款。 */
|
public static final long REFUND_NONE = 0;
|
/** 订单退款状态：退款已受理、结果未定。 */
|
public static final long REFUND_IN_PROGRESS = 1;
|
/** 订单退款状态：退款成功（部分退款也算整单退出结算）。 */
|
public static final long REFUNDED = 2;
|
|
private final JdbcTemplate jdbc;
|
|
public OrderFundBoundaryService(JdbcTemplate jdbc) {
|
this.jdbc = jdbc;
|
}
|
|
/**
|
* 锁定订单行并返回它的资金状态。拿到的状态在整个事务内不会被子资金状态变更改动，
|
* 因此所有判断都必须基于本方法的返回值。
|
*/
|
@Transactional(propagation = Propagation.MANDATORY)
|
public LockedOrder lock(long orderId) {
|
List<Map<String, Object>> rows = jdbc.queryForList("""
|
select id, order_status, verify_status, refund_status
|
from benefit_order
|
where id = ? and deleted = 0
|
limit 1 for update
|
""", orderId);
|
if (rows.isEmpty()) {
|
throw new BusinessException(ErrorCode.NOT_FOUND, "订单不存在");
|
}
|
return LockedOrder.fromRow(rows.get(0));
|
}
|
|
/** 退款受理成功：本笔退款结清前订单不可核销，也不参与提现汇总。 */
|
public void markRefundInProgress(long orderId) {
|
int updated = jdbc.update("""
|
update benefit_order set refund_status = 1
|
where id = ? and deleted = 0 and refund_status = 0
|
""", orderId);
|
if (updated != 1) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单已提交退款申请");
|
}
|
}
|
|
/** 退款成功：整单退出可核销与可提现范围，部分退款同样按整单处理。 */
|
public void markRefunded(long orderId) {
|
jdbc.update("update benefit_order set refund_status = 2 where id = ? and deleted = 0 and refund_status <> 2", orderId);
|
}
|
|
/** 退款失败：没有资金变动，订单回到未退款状态。已有成功退款的订单不会被退回。 */
|
public void markRefundFailed(long orderId) {
|
jdbc.update("""
|
update benefit_order o
|
set o.refund_status = 0
|
where o.id = ? and o.deleted = 0 and o.refund_status = 1
|
and not exists (select 1 from order_refund r
|
where r.order_id = o.id and r.deleted = 0 and r.refund_status = 2)
|
""", orderId);
|
}
|
|
/** 一条已被行锁固定的订单资金状态。 */
|
public record LockedOrder(long orderId, long orderStatus, long verifyStatus, long refundStatus) {
|
|
static LockedOrder fromRow(Map<String, Object> row) {
|
return new LockedOrder(
|
number(row.get("id")),
|
number(row.get("order_status")),
|
number(row.get("verify_status")),
|
number(row.get("refund_status")));
|
}
|
|
/** 未支付、已核销、已退款或退款中的订单都不能再核销。 */
|
public void requireVerifiable() {
|
if (orderStatus != 1) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单未支付，不能核销");
|
}
|
if (verifyStatus == 1) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单已核销");
|
}
|
if (refundStatus != REFUND_NONE) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单已退款或退款中，不能核销");
|
}
|
}
|
|
/** 未支付、已退款或退款中的订单都不能再退款。 */
|
public void requireRefundable() {
|
if (orderStatus != 1) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单当前状态不可退款");
|
}
|
if (refundStatus == REFUND_IN_PROGRESS) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单退款处理中，不能重复退款");
|
}
|
if (refundStatus == REFUNDED) {
|
throw new BusinessException(ErrorCode.CONFLICT, "订单已退款");
|
}
|
}
|
|
private static long number(Object value) {
|
return value instanceof Number number ? number.longValue() : 0L;
|
}
|
}
|
}
|
