package com.chinaztt.mes.warehouse.state.joinstockorder; import com.chinaztt.mes.warehouse.entity.JoinStockOrder; import com.chinaztt.mes.warehouse.state.joinstockorder.constant.JoinStockOrderEvents; import com.chinaztt.mes.warehouse.state.joinstockorder.constant.JoinStockOrderStates; 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: 2020-07-24 17:21 */ @Configuration @EnableStateMachineFactory(name = "joinStockOrderStateMachineFactory") public class JoinStockOrderStateMachineConfig extends EnumStateMachineConfigurerAdapter { public final static String MACHINE_ID = "joinStockOrderStateMachine"; @Override public void configure(StateMachineStateConfigurer states) throws Exception { states.withStates() .initial(JoinStockOrderStates.UNCONFIRMED) .states(EnumSet.allOf(JoinStockOrderStates.class)); } @Override public void configure(StateMachineTransitionConfigurer transitions) throws Exception { transitions .withExternal() .source(JoinStockOrderStates.UNCONFIRMED).target(JoinStockOrderStates.CONFIRMED) .event(JoinStockOrderEvents.CONFIRM) .and() .withExternal() .source(JoinStockOrderStates.CONFIRMED).target(JoinStockOrderStates.UNCONFIRMED) .event(JoinStockOrderEvents.CANCEL); } @Override public void configure(StateMachineConfigurationConfigurer config) throws Exception { config.withConfiguration().machineId(MACHINE_ID); } /** * 持久化配置 * * @return */ @Bean(name = "joinStockOrderPersister") public StateMachinePersister persister() { return new DefaultStateMachinePersister<>(new StateMachinePersist() { @Override public void write(StateMachineContext stateMachineContext, JoinStockOrder joinStockOrder) throws Exception { } @Override public StateMachineContext read(JoinStockOrder joinStockOrder) throws Exception { StateMachineContext result = new DefaultStateMachineContext(JoinStockOrderStates.getEnum(joinStockOrder.getStatus()), null, null, null, null, MACHINE_ID); return result; } }); } }