package com.chinaztt.mes.plan.state.outsourcing; import com.chinaztt.mes.plan.entity.OutsourcingOrder; import com.chinaztt.mes.plan.state.outsourcing.constant.OutsourcingOrderEvents; import com.chinaztt.mes.plan.state.outsourcing.constant.OutsourcingOrderStates; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.statemachine.StateMachineContext; import org.springframework.statemachine.StateMachinePersist; import org.springframework.statemachine.config.EnableStateMachineFactory; import org.springframework.statemachine.config.EnumStateMachineConfigurerAdapter; import org.springframework.statemachine.config.builders.StateMachineConfigurationConfigurer; import org.springframework.statemachine.config.builders.StateMachineStateConfigurer; import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer; import org.springframework.statemachine.persist.DefaultStateMachinePersister; import org.springframework.statemachine.persist.StateMachinePersister; import org.springframework.statemachine.support.DefaultStateMachineContext; import java.util.EnumSet; /** * @Author: cxf * @Date: 2021-08-17 17:21 */ @Configuration @EnableStateMachineFactory(name = "outsourcingOrderStateMachineFactory") public class OutsourcingOrderStateMachineConfig extends EnumStateMachineConfigurerAdapter { public final static String MACHINE_ID = "outsourcingOrderStateMachine"; @Override public void configure(StateMachineStateConfigurer states) throws Exception { states.withStates() .initial(OutsourcingOrderStates.PLANNED) .states(EnumSet.allOf(OutsourcingOrderStates.class)); } @Override public void configure(StateMachineTransitionConfigurer transitions) throws Exception { transitions .withExternal() .source(OutsourcingOrderStates.PLANNED).target(OutsourcingOrderStates.ISSUED) .event(OutsourcingOrderEvents.COMMAND) .and() .withExternal() .source(OutsourcingOrderStates.PLANNED).target(OutsourcingOrderStates.COMPLETED) .event(OutsourcingOrderEvents.COMPLETE) .and() .withExternal() .source(OutsourcingOrderStates.PLANNED).target(OutsourcingOrderStates.CANCELED) .event(OutsourcingOrderEvents.CANCEL) .and() .withExternal() .source(OutsourcingOrderStates.ISSUED).target(OutsourcingOrderStates.COMPLETED) .event(OutsourcingOrderEvents.COMPLETE) .and() .withExternal() .source(OutsourcingOrderStates.ISSUED).target(OutsourcingOrderStates.CANCELED) .event(OutsourcingOrderEvents.CANCEL) .and() .withExternal() .source(OutsourcingOrderStates.ISSUED).target(OutsourcingOrderStates.PLANNED) .event(OutsourcingOrderEvents.PLAN) .and() .withExternal() .source(OutsourcingOrderStates.CANCELED).target(OutsourcingOrderStates.COMPLETED) .event(OutsourcingOrderEvents.COMPLETE) .and() .withExternal() .source(OutsourcingOrderStates.CANCELED).target(OutsourcingOrderStates.ISSUED) .event(OutsourcingOrderEvents.COMMAND) .and() .withExternal() .source(OutsourcingOrderStates.CANCELED).target(OutsourcingOrderStates.PLANNED) .event(OutsourcingOrderEvents.PLAN) .and() .withExternal() .source(OutsourcingOrderStates.COMPLETED).target(OutsourcingOrderStates.ISSUED) .event(OutsourcingOrderEvents.COMMAND) .and() .withExternal() .source(OutsourcingOrderStates.COMPLETED).target(OutsourcingOrderStates.PLANNED) .event(OutsourcingOrderEvents.PLAN) .and() .withExternal() .source(OutsourcingOrderStates.COMPLETED).target(OutsourcingOrderStates.CANCELED) .event(OutsourcingOrderEvents.CANCEL); } @Override public void configure(StateMachineConfigurationConfigurer config) throws Exception { config.withConfiguration().machineId(MACHINE_ID); } /** * 持久化配置 * * @return */ @Bean(name = "outsourcingOrderPersister") public StateMachinePersister persister() { return new DefaultStateMachinePersister<>(new StateMachinePersist() { @Override public void write(StateMachineContext stateMachineContext, OutsourcingOrder outsourcingOrder) throws Exception { } @Override public StateMachineContext read(OutsourcingOrder outsourcingOrder) throws Exception { StateMachineContext result = new DefaultStateMachineContext(OutsourcingOrderStates.getEnum(outsourcingOrder.getState()), null, null, null, null, MACHINE_ID); return result; } }); } }