代码提交

This commit is contained in:
张家训
2026-05-01 09:55:23 +08:00
parent 7eec0e5b32
commit fce4f29a64
5 changed files with 72 additions and 294 deletions
@@ -1,58 +1,59 @@
package com.example.workutils.demo.disburse.bo; package com.example.workutils.demo.disburse.bo;
import com.example.workutils.demo.disburse.enums.DisburseRevokeStatusEnum;
import com.example.workutils.demo.disburse.enums.DisburseStateEnum; import com.example.workutils.demo.disburse.enums.DisburseStateEnum;
import lombok.Data; import lombok.Getter;
/** /**
* @desc: 状态机流转结果 * @desc: 状态机流转结果
* @author: zhaoyuhang * @author: zhaoyuhang
* @date: 2026-04-28 10:01:13 * @date: 2026-04-28 10:01:13
*/ */
@Data @Getter
public class StateTransitionResult { public class StateTransitionResult {
/** /**
* 状态流转是否成功 * 状态流转是否成功
*/ */
public final boolean success; private final boolean success;
/** /**
* 流转后的放款状态 * 流转后的放款状态
*/ */
public final DisburseStateEnum transitionAfterState; private final DisburseStateEnum transitionAfterState;
/** /**
* 挂起标识 * 挂起标识
* false:未挂起,true:已挂起 * false:未挂起,true:已挂起
*/ */
public final Boolean suspendedFlag; private final Boolean suspendedFlag;
/** /**
* 撤销标识 * 撤销状态
* false:未撤销,true:已撤销
*/ */
public final Boolean revokeFlag; private final DisburseRevokeStatusEnum revokeStatus;
/** /**
* 操作拒绝原因 * 操作拒绝原因
*/ */
public final String failReason; private final String failReason;
private StateTransitionResult(boolean success, DisburseStateEnum transitionAfterState, private StateTransitionResult(boolean success, DisburseStateEnum transitionAfterState,
Boolean suspendedFlag, Boolean revokeFlag, String failReason) { Boolean suspendedFlag, DisburseRevokeStatusEnum revokeStatus,
String failReason) {
this.success = success; this.success = success;
this.transitionAfterState = transitionAfterState; this.transitionAfterState = transitionAfterState;
this.suspendedFlag = suspendedFlag; this.suspendedFlag = suspendedFlag;
this.revokeFlag = revokeFlag; this.revokeStatus = revokeStatus;
this.failReason = failReason; this.failReason = failReason;
} }
public static StateTransitionResult allow(DisburseStateEnum transitionAfterState, public static StateTransitionResult allow(DisburseStateEnum transitionAfterState,
Boolean suspended, Boolean suspended,
Boolean canceled) { DisburseRevokeStatusEnum revokeStatus) {
return new StateTransitionResult(true, transitionAfterState, suspended, canceled, null); return new StateTransitionResult(true, transitionAfterState, suspended, revokeStatus, null);
} }
public static StateTransitionResult deny(String reason) { public static StateTransitionResult deny(String reason) {
@@ -1,64 +1,48 @@
package com.example.workutils.demo.disburse.context; package com.example.workutils.demo.disburse.context;
import com.example.workutils.demo.disburse.enums.DisburseRevokeStatusEnum;
import com.example.workutils.demo.disburse.enums.DisburseStateEnum; import com.example.workutils.demo.disburse.enums.DisburseStateEnum;
import lombok.Data; import lombok.Getter;
/** /**
* @desc: 放款状态流转上下文类 * @desc: 放款状态流转上下文类
* @author: zhaoyuhang * @author: zhaoyuhang
* @date: 2026-04-28 10:06:37 * @date: 2026-04-28 10:06:37
*/ */
@Data @Getter
public class DisburseStatusTransitionContext { public class DisburseStatusTransitionContext {
/** /**
* 放款状态枚举 * 放款状态枚举
*/ */
public DisburseStateEnum currentDisburseState; private final DisburseStateEnum currentDisburseState;
/** /**
* 挂起标识 * 挂起标识
* false:未挂起,true:已挂起 * false:未挂起,true:已挂起
*/ */
public boolean suspendedFlag; private final boolean suspendedFlag;
/** /**
* 撤销标识 * 撤销状态
* false:未撤销,true:已撤销
*/ */
public boolean revokeFlag; private final DisburseRevokeStatusEnum revokeStatus;
/** /**
* 达到冷静期标识 * 达到冷静期标识
* false:未达到冷静期,true:已达到冷静期 * false:未达到冷静期,true:已达到冷静期
*/ */
public boolean coolingReachedFlag; private final boolean coolingReachedFlag;
/**
* 自动确认标识
* false:不自动确认,true:自动确认
*/
public boolean autoConfirmFlag;
/**
* 自动审核标识
* false:不自动审核,true:自动审核
*/
public boolean autoAuditFlag;
public DisburseStatusTransitionContext(DisburseStateEnum currentDisburseState, public DisburseStatusTransitionContext(DisburseStateEnum currentDisburseState,
boolean suspendedFlag, boolean suspendedFlag,
boolean revokeFlag, DisburseRevokeStatusEnum revokeStatus,
boolean coolingReachedFlag, boolean coolingReachedFlag) {
boolean autoConfirmFlag,
boolean autoAuditFlag) {
this.currentDisburseState = currentDisburseState; this.currentDisburseState = currentDisburseState;
this.suspendedFlag = suspendedFlag; this.suspendedFlag = suspendedFlag;
this.revokeFlag = revokeFlag; this.revokeStatus = revokeStatus;
this.coolingReachedFlag = coolingReachedFlag; this.coolingReachedFlag = coolingReachedFlag;
this.autoConfirmFlag = autoConfirmFlag;
this.autoAuditFlag = autoAuditFlag;
} }
} }
@@ -50,7 +50,17 @@ public enum DisburseActionEnum {
/** /**
* 撤销 * 撤销
*/ */
REVOKE("撤销"); REVOKE("撤销"),
/**
* 撤销成功
*/
REVOKE_SUCCESS("撤销成功"),
/**
* 撤销失败
*/
REVOKE_FAIL("撤销失败");
/** /**
* 描述 * 描述
@@ -1,172 +0,0 @@
package com.example.workutils.demo.disburse.enums;
import lombok.AllArgsConstructor;
import lombok.Getter;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
/**
* @Description: 放款操作规则枚举(决策表)
* @Author:zhaoyuhang
* @Date: 2026/4/28
**/
@Getter
@AllArgsConstructor
public enum DisburseActionRuleEnum {
/**
* 挂起:初始化/待确认/待审核 + 未挂起 → 挂起标识置true,状态不变
*
* 操作:挂起
* 允许操作的放款状态:初始化、待确认、
*/
SUSPEND(DisburseActionEnum.SUSPEND,
Arrays.asList(DisburseStateEnum.INIT,
DisburseStateEnum.PENDING_CONFIRM,
DisburseStateEnum.PENDING_AUDIT),
false,
null,
null,
null,
"初始化/待确认/待审核可挂起"),
/**
* 挂起恢复:已挂起 → 挂起标识置false,状态不变
*/
SUSPEND_RESUME(DisburseActionEnum.SUSPEND_RESUME,
null,
true,
null,
null,
null,
"已挂起可恢复"),
/**
* 提交:初始化 + 未挂起 + 未撤销 + 已达到冷静期 → 待确认
*/
COMMIT(DisburseActionEnum.COMMIT,
Arrays.asList(DisburseStateEnum.INIT),
false,
false,
true,
DisburseStateEnum.PENDING_CONFIRM,
"全部条件必须满足"),
/**
* 确认:待确认 + 未挂起 + 未撤销 → 待审核
*/
CONFIRM(DisburseActionEnum.CONFIRM,
Arrays.asList(DisburseStateEnum.PENDING_CONFIRM),
false,
false,
null,
DisburseStateEnum.PENDING_AUDIT,
"全部条件必须满足"),
/**
* 审核:待审核 + 未挂起 + 未撤销 → 放款中
*/
AUDIT(DisburseActionEnum.AUDIT,
Arrays.asList(DisburseStateEnum.PENDING_AUDIT),
false,
false,
null,
DisburseStateEnum.DISBURSING,
"全部条件必须匹配"),
/**
* 放款成功:放款中 → 放款成功
*/
DISBURSE_SUCCESS(DisburseActionEnum.DISBURSE_SUCCESS,
Arrays.asList(DisburseStateEnum.DISBURSING),
null,
null,
null,
DisburseStateEnum.DISBURSE_SUCCESS,
"放款中→放款成功"),
/**
* 放款失败:放款中 → 放款失败
*/
DISBURSE_FAIL(DisburseActionEnum.DISBURSE_FAIL,
Arrays.asList(DisburseStateEnum.DISBURSING),
null,
null,
null,
DisburseStateEnum.DISBURSE_FAILED,
"放款中→放款失败"),
/**
* 撤销(放款前):初始化/待确认/待审核 + 未撤销 → 放款失败
*/
REVOKE_BEFORE_DISBURSE(DisburseActionEnum.REVOKE,
Arrays.asList(DisburseStateEnum.INIT, DisburseStateEnum.PENDING_CONFIRM, DisburseStateEnum.PENDING_AUDIT),
null,
false,
null,
DisburseStateEnum.DISBURSE_FAILED,
"未发起交易前撤销直接阻止放款"),
/**
* 撤销(放款后):放款中/放款成功 + 未撤销 → 状态不变
*/
REVOKE_AFTER_DISBURSE(DisburseActionEnum.REVOKE,
Arrays.asList(DisburseStateEnum.DISBURSING, DisburseStateEnum.DISBURSE_SUCCESS),
null,
false,
null,
null,
"发起结算后轧差处理"),
;
/**
* 放款操作枚举
*/
private final DisburseActionEnum disburseActionEnum;
/**
* 允许的当前放款状态列表,null表示任意状态
*/
private final List<DisburseStateEnum> allowDisburseStates;
/**
* 期望挂起状态
* false:未挂起,true:已挂起,null:不检查
*/
private final Boolean expectSuspended;
/**
* 期望撤销状态
* false:未撤销,true:已撤销,null:不检查
*/
private final Boolean expectRevoked;
/**
* 期望达到冷静期
* false:未达到冷静期,true:已达到冷静期,null:不检查
*/
private final Boolean expectCoolingReached;
/**
* 目标放款状态,null表示保持当前状态不变
*/
private final DisburseStateEnum targetDisburseState;
/**
* 约束说明
*/
private final String constraintDesc;
/**
* 根据操作枚举获取匹配的规则列表(同一操作可能有多条规则)
*/
public static List<DisburseActionRuleEnum> getRulesByAction(DisburseActionEnum action) {
return Arrays.stream(values())
.filter(rule -> rule.getDisburseActionEnum() == action)
.collect(Collectors.toList());
}
}
@@ -2,8 +2,10 @@ package com.example.workutils.demo.disburse.executor;
import com.example.workutils.demo.disburse.bo.StateTransitionResult; import com.example.workutils.demo.disburse.bo.StateTransitionResult;
import com.example.workutils.demo.disburse.context.DisburseStatusTransitionContext; import com.example.workutils.demo.disburse.context.DisburseStatusTransitionContext;
import com.example.workutils.demo.disburse.enums.DisburseActionAllowRuleEnum;
import com.example.workutils.demo.disburse.enums.DisburseActionEnum; import com.example.workutils.demo.disburse.enums.DisburseActionEnum;
import com.example.workutils.demo.disburse.enums.DisburseActionRuleEnum; import com.example.workutils.demo.disburse.enums.DisburseDenyReasonEnum;
import com.example.workutils.demo.disburse.enums.DisburseRevokeStatusEnum;
import com.example.workutils.demo.disburse.enums.DisburseStateEnum; import com.example.workutils.demo.disburse.enums.DisburseStateEnum;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@@ -21,122 +23,75 @@ public class StateTransitionExecutor {
public StateTransitionResult transitionState(DisburseStatusTransitionContext context, DisburseActionEnum action) { public StateTransitionResult transitionState(DisburseStatusTransitionContext context, DisburseActionEnum action) {
// 1. 查找该操作的所有规则 // 1. 查找该操作的所有允许规则
List<DisburseActionRuleEnum> rules = DisburseActionRuleEnum.getRulesByAction(action); List<DisburseActionAllowRuleEnum> rules = DisburseActionAllowRuleEnum.getRulesByAction(action);
if (rules.isEmpty()) { if (rules.isEmpty()) {
log.error("放款操作未命中任何决策规则,放款操作:{}不合法!", action.name()); log.error("放款操作未命中任何决策规则,放款操作:{}不合法!", action.name());
return StateTransitionResult.deny("放款操作未命中任何决策规则!"); return StateTransitionResult.deny(DisburseDenyReasonEnum.NO_RULE_MATCHED.getReason());
} }
// 2. 前置条件检查(挂起/撤销/冷静期),同一操作的所有规则前置条件一致,取第一条校验即可 // 2. 根据上下文参数匹配唯一规则:放款状态 + 挂起 + 撤销 + 冷静期
DisburseActionRuleEnum referenceRule = rules.get(0); for (DisburseActionAllowRuleEnum rule : rules) {
StateTransitionResult preCheckResult = checkPreConditions(context, referenceRule); if (isConditionMatched(rule, context)) {
if (preCheckResult != null) {
return preCheckResult;
}
// 3. 状态匹配:遍历规则,找到allowDisburseStates匹配的规则
for (DisburseActionRuleEnum rule : rules) {
if (isStateAllowed(rule, context.getCurrentDisburseState())) {
return executeRule(context, rule); return executeRule(context, rule);
} }
} }
// 4. 无匹配规则 → 拒绝 // 3. 无匹配规则 → 拼接允许规则说明
return handleNoMatchedRule(context, action); String reason = "当前状态不允许执行" + action.getDesc()
+ ",允许的放款状态:" + DisburseActionAllowRuleEnum.buildAllowedStatesDesc(rules);
log.info(reason);
return StateTransitionResult.deny(reason);
} }
/** /**
* 前置条件检查:挂起/撤销/冷静期 * 检查规则的所有条件是否与上下文匹配
*/ */
private StateTransitionResult checkPreConditions(DisburseStatusTransitionContext context, private boolean isConditionMatched(DisburseActionAllowRuleEnum rule,
DisburseActionRuleEnum rule) { DisburseStatusTransitionContext context) {
// 挂起状态检查 if (!isStateAllowed(rule, context.getCurrentDisburseState())) {
return false;
}
if (rule.getExpectSuspended() != null if (rule.getExpectSuspended() != null
&& !rule.getExpectSuspended().equals(context.isSuspendedFlag())) { && !rule.getExpectSuspended().equals(context.isSuspendedFlag())) {
log.info("期望挂起状态:{},实际挂起状态:{},状态不可推进!", return false;
rule.getExpectSuspended(), context.isSuspendedFlag());
return context.isSuspendedFlag()
? StateTransitionResult.deny("挂起时不可推进")
: StateTransitionResult.deny("未挂起不可执行该操作");
} }
if (rule.getExpectRevokeStatus() != null
// 撤销状态检查 && !rule.getExpectRevokeStatus().equals(context.getRevokeStatus())) {
if (rule.getExpectRevoked() != null return false;
&& !rule.getExpectRevoked().equals(context.isRevokeFlag())) {
log.info("期望撤销状态:{},实际撤销状态:{},状态不可推进!",
rule.getExpectRevoked(), context.isRevokeFlag());
return context.isRevokeFlag()
? StateTransitionResult.deny("撤销后不可推进")
: StateTransitionResult.deny("未撤销不可执行该操作");
} }
// 冷静期检查
if (rule.getExpectCoolingReached() != null if (rule.getExpectCoolingReached() != null
&& !rule.getExpectCoolingReached().equals(context.isCoolingReachedFlag())) { && !rule.getExpectCoolingReached().equals(context.isCoolingReachedFlag())) {
log.info("期望达到冷静期:{},实际达到冷静期状态:{},冷静期未到!", return false;
rule.getExpectCoolingReached(), context.isCoolingReachedFlag());
return StateTransitionResult.deny("冷静期未到");
} }
return true;
return null;
} }
/** /**
* 判断当前状态是否在规则的允许状态列表中 * 判断当前状态是否在规则的允许状态列表中
*/ */
private boolean isStateAllowed(DisburseActionRuleEnum rule, DisburseStateEnum currentState) { private boolean isStateAllowed(DisburseActionAllowRuleEnum rule, DisburseStateEnum currentState) {
return rule.getAllowDisburseStates() == null return rule.getAllowDisburseStates() == null
|| rule.getAllowDisburseStates().contains(currentState); || rule.getAllowDisburseStates().contains(currentState);
} }
/** /**
* 执行匹配的规则,计算目标状态 * 执行匹配的允许规则,计算目标状态
*/ */
private StateTransitionResult executeRule(DisburseStatusTransitionContext context, private StateTransitionResult executeRule(DisburseStatusTransitionContext context,
DisburseActionRuleEnum rule) { DisburseActionAllowRuleEnum rule) {
DisburseStateEnum targetState = rule.getTargetDisburseState() != null DisburseStateEnum targetState = rule.getTargetDisburseState() != null
? rule.getTargetDisburseState() ? rule.getTargetDisburseState()
: context.getCurrentDisburseState(); : context.getCurrentDisburseState();
// 目标挂起标识从操作类型推导:SUSPEND→true,SUSPEND_RESUME→false,其余保持当前 Boolean targetSuspended = rule.getTargetSuspended() != null
Boolean targetSuspended = resolveTargetSuspended(context, rule.getDisburseActionEnum()); ? rule.getTargetSuspended()
: context.isSuspendedFlag();
// 目标撤销标识从操作类型推导:REVOKE→true,其余保持当前 DisburseRevokeStatusEnum targetRevokeStatus = rule.getTargetRevokeStatus() != null
Boolean targetRevoke = rule.getDisburseActionEnum() == DisburseActionEnum.REVOKE ? rule.getTargetRevokeStatus()
? true : context.getRevokeStatus();
: context.isRevokeFlag();
return StateTransitionResult.allow(targetState, targetSuspended, targetRevoke); return StateTransitionResult.allow(targetState, targetSuspended, targetRevokeStatus);
}
/**
* 根据操作类型推导目标挂起标识
*/
private Boolean resolveTargetSuspended(DisburseStatusTransitionContext context,
DisburseActionEnum action) {
if (action == DisburseActionEnum.SUSPEND) {
return true;
}
if (action == DisburseActionEnum.SUSPEND_RESUME) {
return false;
}
return context.isSuspendedFlag();
}
/**
* 无匹配规则时的拒绝处理
*/
private StateTransitionResult handleNoMatchedRule(DisburseStatusTransitionContext context,
DisburseActionEnum action) {
// 撤销 + 放款失败 → 特殊提示
if (action == DisburseActionEnum.REVOKE
&& context.getCurrentDisburseState() == DisburseStateEnum.DISBURSE_FAILED) {
log.info("放款状态:{}已经放款失败,无需撤销!", context.getCurrentDisburseState());
return StateTransitionResult.deny("放款单据已经放款失败,无需撤销");
}
log.info("当前放款状态:{}不允许执行操作:{}", context.getCurrentDisburseState(), action.getDesc());
return StateTransitionResult.deny("当前状态不允许该操作");
} }
} }