From 5f4dd407eeeb340c95bd3a3d397cbf1d0cc14c08 Mon Sep 17 00:00:00 2001 From: luofu Date: Fri, 1 Dec 2023 09:35:18 +0800 Subject: [PATCH] fsm bug modify --- fsm/pom.xml | 23 +++- .../fsm/config/OrderPersistHandlerConfig.java | 43 -------- .../OrderStateMachineFactoryConfig.java | 49 +++++++++ .../fsm/config/OrderStatePersistConfig.java | 36 ++++++ .../fsm/config/StateMachineConfig.java | 74 ------------- .../fsm/controller/OrderController.java | 57 ++++++---- .../handler/PersistStateMachineHandler.java | 104 ------------------ .../OrderPersistStateChangeListener.java | 31 ------ .../fsm/listener/OrderStateListener.java | 52 --------- .../OrderStatePersistChangeListener.java | 41 +++++++ .../fsm/service/impl/OrderServiceImpl.java | 10 -- 11 files changed, 181 insertions(+), 339 deletions(-) delete mode 100644 fsm/src/main/java/top/atluofu/fsm/config/OrderPersistHandlerConfig.java create mode 100644 fsm/src/main/java/top/atluofu/fsm/config/OrderStateMachineFactoryConfig.java create mode 100644 fsm/src/main/java/top/atluofu/fsm/config/OrderStatePersistConfig.java delete mode 100644 fsm/src/main/java/top/atluofu/fsm/config/StateMachineConfig.java delete mode 100644 fsm/src/main/java/top/atluofu/fsm/handler/PersistStateMachineHandler.java delete mode 100644 fsm/src/main/java/top/atluofu/fsm/listener/OrderPersistStateChangeListener.java delete mode 100644 fsm/src/main/java/top/atluofu/fsm/listener/OrderStateListener.java create mode 100644 fsm/src/main/java/top/atluofu/fsm/listener/OrderStatePersistChangeListener.java diff --git a/fsm/pom.xml b/fsm/pom.xml index 6a61aa1..5a3a7db 100644 --- a/fsm/pom.xml +++ b/fsm/pom.xml @@ -17,12 +17,33 @@ 17 + + + + org.springframework.statemachine + spring-statemachine-bom + 2.1.3.RELEASE + pom + import + + + + org.springframework.statemachine spring-statemachine-starter - 3.2.1 + + org.springframework.statemachine + spring-statemachine-recipes-common + + + org.springframework.boot + spring-boot-starter-test + test + + cn.hutool hutool-all diff --git a/fsm/src/main/java/top/atluofu/fsm/config/OrderPersistHandlerConfig.java b/fsm/src/main/java/top/atluofu/fsm/config/OrderPersistHandlerConfig.java deleted file mode 100644 index beae735..0000000 --- a/fsm/src/main/java/top/atluofu/fsm/config/OrderPersistHandlerConfig.java +++ /dev/null @@ -1,43 +0,0 @@ -package top.atluofu.fsm.config; - -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.statemachine.StateMachine; -import top.atluofu.fsm.handler.PersistStateMachineHandler; -import top.atluofu.fsm.listener.OrderPersistStateChangeListener; -import top.atluofu.fsm.model.Events; -import top.atluofu.fsm.model.States; -import top.atluofu.fsm.service.impl.OrderServiceImpl; - -/** - * @ClassName: OrderPersistHandlerConfig - * @description: TODO - * @author: 有罗敷的马同学 - * @datetime: 2023Year-11Month-28Day-12:46 - * @Version: 1.0 - */ -@Configuration -public class OrderPersistHandlerConfig { - - @Autowired - private StateMachine stateMachine; - - @Bean - public OrderServiceImpl persist() { - PersistStateMachineHandler handler = persistStateMachineHandler(); - handler.addPersistStateChangeListener(persistStateChangeListener()); - return new OrderServiceImpl(handler); - } - - @Bean - public PersistStateMachineHandler persistStateMachineHandler() { - return new PersistStateMachineHandler(stateMachine); - } - - @Bean - public OrderPersistStateChangeListener persistStateChangeListener() { - return new OrderPersistStateChangeListener(); - } - -} \ No newline at end of file diff --git a/fsm/src/main/java/top/atluofu/fsm/config/OrderStateMachineFactoryConfig.java b/fsm/src/main/java/top/atluofu/fsm/config/OrderStateMachineFactoryConfig.java new file mode 100644 index 0000000..5addfd7 --- /dev/null +++ b/fsm/src/main/java/top/atluofu/fsm/config/OrderStateMachineFactoryConfig.java @@ -0,0 +1,49 @@ +package top.atluofu.fsm.config; + +import org.springframework.context.annotation.Configuration; +import org.springframework.statemachine.config.EnableStateMachineFactory; +import org.springframework.statemachine.config.StateMachineConfigurerAdapter; +import org.springframework.statemachine.config.builders.StateMachineStateConfigurer; +import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer; +import top.atluofu.fsm.model.Events; +import top.atluofu.fsm.model.States; + +/** + * @ClassName: OrderStateMachineFactoryConfig + * @description: OrderStateMachineFactoryConfig + * @author: 有罗敷的马同学 + * @datetime: 2023Year-12Month-01Day-8:36 + * @Version: 1.0 + */ +@Configuration +@EnableStateMachineFactory(name = "orderStateMachineFactory") +public class OrderStateMachineFactoryConfig extends StateMachineConfigurerAdapter { + @Override + public void configure(StateMachineStateConfigurer states) + throws Exception { + states.withStates() + .initial(States.ORDER_WAIT_PAY.toString()) + .state(States.ORDER_WAIT_SEND.toString()) + .state(States.ORDER_WAIT_RECEIVE.toString()) + .end(States.ORDER_FINISH.toString()); + } + + @Override + public void configure(StateMachineTransitionConfigurer transitions) + throws Exception { + transitions.withExternal() + .source(States.ORDER_WAIT_PAY.toString()) + .target(States.ORDER_WAIT_SEND.toString()) + .event(Events.PAY_ORDER.toString()) + .and() + .withExternal() + .source(States.ORDER_WAIT_SEND.toString()) + .target(States.ORDER_WAIT_RECEIVE.toString()) + .event(Events.SEND_ORDER.toString()) + .and() + .withExternal() + .source(States.ORDER_WAIT_RECEIVE.toString()) + .target(States.ORDER_FINISH.toString()) + .event(Events.RECEIVE_ORDER.toString()); + } +} diff --git a/fsm/src/main/java/top/atluofu/fsm/config/OrderStatePersistConfig.java b/fsm/src/main/java/top/atluofu/fsm/config/OrderStatePersistConfig.java new file mode 100644 index 0000000..5fdf87c --- /dev/null +++ b/fsm/src/main/java/top/atluofu/fsm/config/OrderStatePersistConfig.java @@ -0,0 +1,36 @@ +package top.atluofu.fsm.config; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.config.ConfigurableBeanFactory; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.Scope; +import org.springframework.statemachine.StateMachine; +import org.springframework.statemachine.config.StateMachineFactory; +import org.springframework.statemachine.recipes.persist.PersistStateMachineHandler; +import top.atluofu.fsm.listener.OrderStatePersistChangeListener; + +/** + * @ClassName: OrderStatePersistConfig + * @description: OrderStatePersistConfig + * @author: 有罗敷的马同学 + * @datetime: 2023Year-12Month-01Day-8:53 + * @Version: 1.0 + */ +@Configuration +public class OrderStatePersistConfig { + @Autowired + private StateMachineFactory orderStateMachineFactory; + @Autowired + private OrderStatePersistChangeListener persistStateChangeListener; + + @Bean + @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) + public PersistStateMachineHandler getPersistStateMachineHandler() { + StateMachine orderStateMachine = orderStateMachineFactory.getStateMachine(); + PersistStateMachineHandler handler = new PersistStateMachineHandler(orderStateMachine); + handler.addPersistStateChangeListener(persistStateChangeListener); + return handler; + } + +} diff --git a/fsm/src/main/java/top/atluofu/fsm/config/StateMachineConfig.java b/fsm/src/main/java/top/atluofu/fsm/config/StateMachineConfig.java deleted file mode 100644 index f04d8d9..0000000 --- a/fsm/src/main/java/top/atluofu/fsm/config/StateMachineConfig.java +++ /dev/null @@ -1,74 +0,0 @@ -package top.atluofu.fsm.config; - -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.EnableStateMachine; -import org.springframework.statemachine.config.EnumStateMachineConfigurerAdapter; -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 top.atluofu.fsm.listener.OrderStateListener; -import top.atluofu.fsm.model.Events; -import top.atluofu.fsm.model.States; -import top.atluofu.fsm.po.OrderPO; - -import java.util.EnumSet; - -/** - * @ClassName: StateMachineConfig - * @description: fsm配置类 - * @author: 有罗敷的马同学 - * @datetime: 2023Year-11Month-28Day-8:35 - * @Version: 1.0 - */ -@Configuration -@EnableStateMachine -public class StateMachineConfig extends EnumStateMachineConfigurerAdapter { - final OrderStateListener orderStateListener; - - public StateMachineConfig(OrderStateListener orderStateListener) { - this.orderStateListener = orderStateListener; - } - - @Override - public void configure(StateMachineStateConfigurer states) - throws Exception { - states - .withStates() - .initial(States.ORDER_WAIT_PAY) - .states(EnumSet.allOf(States.class)); - } - - @Override - public void configure(StateMachineTransitionConfigurer transitions) - throws Exception { - transitions - .withExternal() - .source(States.ORDER_WAIT_PAY).target(States.ORDER_WAIT_SEND).event(Events.PAY_ORDER) - .and() - .withExternal() - .source(States.ORDER_WAIT_SEND).target(States.ORDER_WAIT_RECEIVE).event(Events.SEND_ORDER) - .and() - .withExternal() - .source(States.ORDER_WAIT_RECEIVE).target(States.ORDER_FINISH).event(Events.RECEIVE_ORDER); - } - - @Bean - public StateMachinePersister persister() { - return new DefaultStateMachinePersister<>(new StateMachinePersist() { - - @Override - public void write(StateMachineContext stateMachineContext, OrderPO orderPO) throws Exception { - - } - - @Override - public StateMachineContext read(OrderPO orderPO) throws Exception { - return null; - } - }); - } -} diff --git a/fsm/src/main/java/top/atluofu/fsm/controller/OrderController.java b/fsm/src/main/java/top/atluofu/fsm/controller/OrderController.java index 39e08be..f42dfac 100644 --- a/fsm/src/main/java/top/atluofu/fsm/controller/OrderController.java +++ b/fsm/src/main/java/top/atluofu/fsm/controller/OrderController.java @@ -1,11 +1,13 @@ package top.atluofu.fsm.controller; +import cn.hutool.core.exceptions.ValidateException; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.ObjectFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.Message; import org.springframework.messaging.support.MessageBuilder; -import org.springframework.statemachine.StateMachine; +import org.springframework.statemachine.recipes.persist.PersistStateMachineHandler; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; @@ -37,8 +39,8 @@ public class OrderController { this.orderService = orderService; } - @GetMapping("test/{name}") - public ResultUtils demo(@PathVariable String name) { + @GetMapping("test1/{name}") + public ResultUtils demo1(@PathVariable String name) { OrderPO build = OrderPO.builder() .orderName(name) .state(States.ORDER_WAIT_PAY.toString()) @@ -47,39 +49,46 @@ public ResultUtils demo(@PathVariable String name) { System.out.println(save); System.out.println(build); System.out.println("---------------------"); - Message orderId = MessageBuilder.withPayload(Events.PAY_ORDER).setHeader("orderId", build.getId()).build(); - changeStateAction(orderId, build); + Message orderId1 = MessageBuilder.withPayload(Events.PAY_ORDER.toString()).setHeader("orderId", build.getId()).build(); + changeStateAction(orderId1, build); OrderPO byId = orderService.getById(build.getId()); System.out.println(byId); + return ResultUtils.success(byId); + } + + @GetMapping("test2/{name}/{id}") + public ResultUtils demo2(@PathVariable String name, @PathVariable Integer id) { + OrderPO build = orderService.getById(id); System.out.println("---------------------"); - orderId = MessageBuilder.withPayload(Events.SEND_ORDER).setHeader("orderId", build.getId()).build(); - changeStateAction(orderId, build); - byId = orderService.getById(build.getId()); + Message orderId2 = MessageBuilder.withPayload(Events.SEND_ORDER.toString()).setHeader("orderId", build.getId()).build(); + changeStateAction(orderId2, build); + OrderPO byId = orderService.getById(build.getId()); System.out.println(byId); System.out.println("---------------------"); - orderId = MessageBuilder.withPayload(Events.RECEIVE_ORDER).setHeader("orderId", build.getId()).build(); - changeStateAction(orderId, build); - byId = orderService.getById(build.getId()); + return ResultUtils.success(byId); + } + + @GetMapping("test3/{name}/{id}") + public ResultUtils demo3(@PathVariable String name, @PathVariable Integer id) { + OrderPO build = orderService.getById(id); + System.out.println("---------------------"); + Message orderId3 = MessageBuilder.withPayload(Events.RECEIVE_ORDER.toString()).setHeader("orderId", build.getId()).build(); + changeStateAction(orderId3, build); + OrderPO byId = orderService.getById(build.getId()); System.out.println(byId); System.out.println("---------------------"); return ResultUtils.success(byId); } - @Autowired - private StateMachine orderStateMachine; - private boolean changeStateAction(Message message, OrderPO order) { - try { - //启动状态机 - orderStateMachine.start(); - //将Message发送给OrderStateListener - boolean res = orderStateMachine.sendEvent(message); + @Autowired + private ObjectFactory stateMachineHandlerObjectFactory; - return res; - } catch (Exception e) { - e.printStackTrace(); - } finally { - orderStateMachine.stop(); + private boolean changeStateAction(Message message, OrderPO order) { + PersistStateMachineHandler persistStateMachineHandler = stateMachineHandlerObjectFactory.getObject(); + boolean b = persistStateMachineHandler.handleEventWithState(message, message.getPayload()); + if(!b){ + throw new ValidateException("失败"); } return false; } diff --git a/fsm/src/main/java/top/atluofu/fsm/handler/PersistStateMachineHandler.java b/fsm/src/main/java/top/atluofu/fsm/handler/PersistStateMachineHandler.java deleted file mode 100644 index 2078a19..0000000 --- a/fsm/src/main/java/top/atluofu/fsm/handler/PersistStateMachineHandler.java +++ /dev/null @@ -1,104 +0,0 @@ -package top.atluofu.fsm.handler; - - -import org.springframework.messaging.Message; -import org.springframework.statemachine.StateMachine; -import org.springframework.statemachine.access.StateMachineAccess; -import org.springframework.statemachine.listener.AbstractCompositeListener; -import org.springframework.statemachine.state.State; -import org.springframework.statemachine.support.DefaultStateMachineContext; -import org.springframework.statemachine.support.LifecycleObjectSupport; -import org.springframework.statemachine.support.StateMachineInterceptorAdapter; -import org.springframework.statemachine.transition.Transition; -import org.springframework.util.Assert; -import top.atluofu.fsm.model.Events; -import top.atluofu.fsm.model.States; - -import java.util.Iterator; -import java.util.List; - -/** - * @author ：luoqi/02216 - * @date ：Created in 2020/6/4 4:03 下午 - * @description：监听器的Handler以及接口定义 - */ -public class PersistStateMachineHandler extends LifecycleObjectSupport { - - private final StateMachine stateMachine; - private final PersistingStateChangeInterceptor interceptor = new PersistingStateChangeInterceptor(); - private final CompositePersistStateChangeListener listeners = new CompositePersistStateChangeListener(); - - /** - * 实例化一个新的持久化状态机Handler - * - * @param stateMachine - */ - public PersistStateMachineHandler(StateMachine stateMachine) { - Assert.notNull(stateMachine, "State machine must be set"); - this.stateMachine = stateMachine; - } - - @Override - protected void onInit() throws Exception { - stateMachine.getStateMachineAccessor().doWithAllRegions(function -> function.addStateMachineInterceptor(interceptor)); - } - - /** - * 处理entity的事件 - * - * @param event - * @param state - * @return - */ - public boolean handleEventWithState(Message event, States state) { - stateMachine.stop(); - List> withAllRegions = stateMachine.getStateMachineAccessor() - .withAllRegions(); - for (StateMachineAccess access : withAllRegions) { - access.resetStateMachine(new DefaultStateMachineContext<>(state, null, null, null)); - } - stateMachine.start(); - return stateMachine.sendEvent(event); - } - - /** - * 添加listener - * - * @param listener - */ - public void addPersistStateChangeListener(PersistStateChangeListener listener) { - listeners.register(listener); - } - - /** - * 可以通过addPersistStateChangeListener，增加当前Handler的PersistStateChangeListener。 - * 在状态变化的持久化触发时，会调用相应的实现了PersistStateChangeListener的Listener实例。 - */ - public interface PersistStateChangeListener { - void onPersist(State state, Message message, - Transition transition, StateMachine stateMachine); - } - - private class PersistingStateChangeInterceptor extends StateMachineInterceptorAdapter { - - // 状态预处理的拦截器方法 -// @Override -// public void preStateChange(State state, Message message, -// Transition transition, StateMachine stateMachine) { -// listeners.onPersist(state, message, transition, stateMachine); -// } - } - - private class CompositePersistStateChangeListener extends AbstractCompositeListener implements PersistStateChangeListener { - - @Override - public void onPersist(State state, Message message, - Transition transition, StateMachine stateMachine) { - for (Iterator iterator = getListeners().reverse(); iterator.hasNext(); ) { - PersistStateChangeListener listener = iterator.next(); - listener.onPersist(state, message, transition, stateMachine); - } - } - } - -} diff --git a/fsm/src/main/java/top/atluofu/fsm/listener/OrderPersistStateChangeListener.java b/fsm/src/main/java/top/atluofu/fsm/listener/OrderPersistStateChangeListener.java deleted file mode 100644 index 7c64bcd..0000000 --- a/fsm/src/main/java/top/atluofu/fsm/listener/OrderPersistStateChangeListener.java +++ /dev/null @@ -1,31 +0,0 @@ -package top.atluofu.fsm.listener; - -import org.springframework.messaging.Message; -import org.springframework.statemachine.StateMachine; -import org.springframework.statemachine.state.State; -import org.springframework.statemachine.transition.Transition; -import top.atluofu.fsm.handler.PersistStateMachineHandler; -import top.atluofu.fsm.model.Events; -import top.atluofu.fsm.model.States; - -/** - * @ClassName: OrderPersistStateChangeListener - * @description: TODO - * @author: 有罗敷的马同学 - * @datetime: 2023Year-11Month-28Day-12:54 - * @Version: 1.0 - */ -public class OrderPersistStateChangeListener implements PersistStateMachineHandler.PersistStateChangeListener { - - @Override - public void onPersist(State state, Message message, - Transition transition, StateMachine stateMachine) { - if (message != null && message.getHeaders().containsKey("order")) { - Integer orderNum = message.getHeaders().get("order", Integer.class); - // save持久化 - States status = state.getId(); - System.out.println("save order: " + orderNum + ", order state: " + status); - } - } - -} diff --git a/fsm/src/main/java/top/atluofu/fsm/listener/OrderStateListener.java b/fsm/src/main/java/top/atluofu/fsm/listener/OrderStateListener.java deleted file mode 100644 index 93211b4..0000000 --- a/fsm/src/main/java/top/atluofu/fsm/listener/OrderStateListener.java +++ /dev/null @@ -1,52 +0,0 @@ -package top.atluofu.fsm.listener; - -import org.springframework.messaging.Message; -import org.springframework.statemachine.annotation.OnTransition; -import org.springframework.statemachine.annotation.WithStateMachine; -import org.springframework.stereotype.Component; -import top.atluofu.fsm.model.States; -import top.atluofu.fsm.po.OrderPO; -import top.atluofu.fsm.service.impl.OrderServiceImpl; - -import java.util.Objects; - -/** - * @ClassName: OrderStateListener - * @description: TODO - * @author: 有罗敷的马同学 - * @datetime: 2023Year-11Month-28Day-8:57 - * @Version: 1.0 - */ -@Component -@WithStateMachine(name = "ORDER_STATE_LISTENER") -public class OrderStateListener { - final OrderServiceImpl orderService; - - public OrderStateListener(OrderServiceImpl orderService) { - this.orderService = orderService; - } - - @OnTransition(source = "ORDER_WAIT_PAY", target = "ORDER_WAIT_SEND") - public void payToSend(Message message) { - OrderPO byId = orderService.getById(Objects.requireNonNull(message.getHeaders().get("orderId")).toString()); - byId.setState(States.ORDER_WAIT_SEND.toString()); - orderService.save(byId); - System.out.println("listener" + byId); - } - - @OnTransition(source = "ORDER_WAIT_SEND", target = "ORDER_WAIT_RECEIVE") - public void sendToReceive(Message message) { - OrderPO byId = orderService.getById(Objects.requireNonNull(message.getHeaders().get("orderId")).toString()); - byId.setState(States.ORDER_WAIT_RECEIVE.toString()); - orderService.save(byId); - System.out.println("listener" + byId); - } - - @OnTransition(source = "ORDER_WAIT_RECEIVE", target = "ORDER_FINISH") - public void toEnd(Message message) { - OrderPO byId = orderService.getById(Objects.requireNonNull(message.getHeaders().get("orderId")).toString()); - byId.setState(States.ORDER_FINISH.toString()); - orderService.save(byId); - System.out.println("listener" + byId); - } -} diff --git a/fsm/src/main/java/top/atluofu/fsm/listener/OrderStatePersistChangeListener.java b/fsm/src/main/java/top/atluofu/fsm/listener/OrderStatePersistChangeListener.java new file mode 100644 index 0000000..efe1e7d --- /dev/null +++ b/fsm/src/main/java/top/atluofu/fsm/listener/OrderStatePersistChangeListener.java @@ -0,0 +1,41 @@ +package top.atluofu.fsm.listener; + +import cn.hutool.core.util.ObjectUtil; +import org.springframework.messaging.Message; +import org.springframework.statemachine.StateMachine; +import org.springframework.statemachine.recipes.persist.PersistStateMachineHandler; +import org.springframework.statemachine.state.State; +import org.springframework.statemachine.transition.Transition; +import org.springframework.stereotype.Component; +import top.atluofu.fsm.model.States; +import top.atluofu.fsm.po.OrderPO; +import top.atluofu.fsm.service.impl.OrderServiceImpl; + +import java.util.Objects; + +/** + * @ClassName: OrderStatePersistChangeListener + * @description: OrderStatePersistChangeListener + * @author: 有罗敷的马同学 + * @datetime: 2023Year-12Month-01Day-8:41 + * @Version: 1.0 + */ +@Component +public class OrderStatePersistChangeListener implements PersistStateMachineHandler.PersistStateChangeListener { + private final OrderServiceImpl orderService; + + public OrderStatePersistChangeListener(OrderServiceImpl orderService) { + this.orderService = orderService; + } + + @Override + public void onPersist(State state, Message message, Transition transition, StateMachine stateMachine) { + if (ObjectUtil.isNotNull(message) && message.getHeaders().containsKey("orderId")) { + OrderPO byId = orderService.getById(Integer.valueOf(Objects.requireNonNull(message.getHeaders().get("orderId")).toString())); + String id = state.getId(); + States states = States.valueOf(id); + byId.setState(states.toString()); + orderService.saveOrUpdate(byId); + } + } +} diff --git a/fsm/src/main/java/top/atluofu/fsm/service/impl/OrderServiceImpl.java b/fsm/src/main/java/top/atluofu/fsm/service/impl/OrderServiceImpl.java index 0d83e72..d2289de 100644 --- a/fsm/src/main/java/top/atluofu/fsm/service/impl/OrderServiceImpl.java +++ b/fsm/src/main/java/top/atluofu/fsm/service/impl/OrderServiceImpl.java @@ -5,7 +5,6 @@ import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import top.atluofu.fsm.dao.OrderDao; -import top.atluofu.fsm.handler.PersistStateMachineHandler; import top.atluofu.fsm.po.OrderPO; import top.atluofu.fsm.service.OrderService; @@ -17,14 +16,5 @@ */ @Service("orderService") public class OrderServiceImpl extends ServiceImpl implements OrderService { - private PersistStateMachineHandler handler; - - @Lazy - @Autowired - public OrderServiceImpl(PersistStateMachineHandler handler) { - this.handler = handler; - } - - }