package com.chinaztt.mes.technology.state.bom; import com.chinaztt.mes.technology.entity.Bom; import com.chinaztt.mes.technology.entity.Routing; import com.chinaztt.mes.technology.state.bom.constant.BomEvents; import com.chinaztt.mes.technology.state.bom.constant.BomStates; import com.chinaztt.mes.technology.state.routing.constant.RoutingEvents; import com.chinaztt.mes.technology.state.routing.constant.RoutingStates; 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: zhangxy * @Date: 2020-08-24 17:21 */ @Configuration @EnableStateMachineFactory(name = "bomStateMachineFactory") public class BomStateMachineConfig extends EnumStateMachineConfigurerAdapter { public final static String MACHINE_ID = "bomStateMachine"; @Override public void configure(StateMachineStateConfigurer states) throws Exception { states.withStates() .initial(BomStates.DRAFT) .states(EnumSet.allOf(BomStates.class)); } @Override public void configure(StateMachineTransitionConfigurer transitions) throws Exception { transitions .withExternal() .source(BomStates.DRAFT).target(BomStates.ACCEPTED) .event(BomEvents.ACCEPT) .and() .withExternal() .source(BomStates.ACCEPTED).target(BomStates.DRAFT) .event(BomEvents.REVOKE) .and() .withExternal() .source(BomStates.ACCEPTED).target(BomStates.CANCELLED) .event(BomEvents.CANCEL); } @Override public void configure(StateMachineConfigurationConfigurer config) throws Exception { config.withConfiguration().machineId(MACHINE_ID); } /** * 持久化配置 * * @return */ @Bean(name ="bomPersister") public StateMachinePersister persister() { return new DefaultStateMachinePersister<>(new StateMachinePersist() { @Override public void write(StateMachineContext stateMachineContext, Bom bom) throws Exception { } @Override public StateMachineContext read(Bom bom) throws Exception { StateMachineContext result = new DefaultStateMachineContext(BomStates.getEnum(bom.getState()), null, null, null, null, MACHINE_ID); return result; } }); } }