flow：新增@ListenFlowStart、@ListenExecutingNode、@ListenFlowEnd

Author: zhongxunking

flow/src/main/java/org/bekit/flow/annotation/listener/ListenExecutingNode.java

@@ -0,0 +1,34 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2016-12-17 17:06 创建
+ */
+package org.bekit.flow.annotation.listener;
+
+import org.bekit.event.annotation.listener.Listen;
+import org.bekit.event.listener.PriorityType;
+import org.bekit.flow.listener.ListenExecutingNodeResolver;
+import org.springframework.core.annotation.AliasFor;
+
+import java.lang.annotation.*;
+
+/**
+ * 监听正在执行的节点
+ * <p>
+ * 配合@TheFlowListener一起使用；当每次节点即将被执行时，都会调用本注解标注的方法。
+ * 对应的方法入参类型必须为（String, FlowContext）。
+ */
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Listen(resolver = ListenExecutingNodeResolver.class, priorityType = PriorityType.ASC)
+public @interface ListenExecutingNode {
+    /**
+     * 优先级类型（默认为升序）
+     */
+    @AliasFor(annotation = Listen.class, attribute = "priorityType")
+    PriorityType priorityType() default PriorityType.ASC;
+}

flow/src/main/java/org/bekit/flow/annotation/listener/ListenFlowEnd.java

@@ -0,0 +1,34 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2017-04-04 18:41 创建
+ */
+package org.bekit.flow.annotation.listener;
+
+import org.bekit.event.annotation.listener.Listen;
+import org.bekit.event.listener.PriorityType;
+import org.bekit.flow.listener.ListenFlowEndResolver;
+import org.springframework.core.annotation.AliasFor;
+
+import java.lang.annotation.*;
+
+/**
+ * 监听流程结束事件
+ * <p>
+ * 配合@TheFlowListener一起使用；当流程执行结束时，都会调用本注解标注的方法。
+ * 对应的方法入参类型必须为（FlowContext）。
+ */
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Listen(resolver = ListenFlowEndResolver.class, priorityType = PriorityType.ASC)
+public @interface ListenFlowEnd {
+    /**
+     * 优先级类型（默认为升序）
+     */
+    @AliasFor(annotation = Listen.class, attribute = "priorityType")
+    PriorityType priorityType() default PriorityType.ASC;
+}

flow/src/main/java/org/bekit/flow/annotation/listener/ListenFlowException.java

@@ -16,7 +16,7 @@
 import java.lang.annotation.*;
 
 /**
- * 监听流程异常
+ * 监听流程异常事件
  * <p>
  * 配合@TheFlowListener一起使用；当流程发生异常时，都会调用本注解标注的方法。
  * 对应的方法入参类型必须为（Throwable, FlowContext）。

flow/src/main/java/org/bekit/flow/annotation/listener/ListenFlowStart.java

@@ -0,0 +1,34 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2017-04-04 18:41 创建
+ */
+package org.bekit.flow.annotation.listener;
+
+import org.bekit.event.annotation.listener.Listen;
+import org.bekit.event.listener.PriorityType;
+import org.bekit.flow.listener.ListenFlowStartResolver;
+import org.springframework.core.annotation.AliasFor;
+
+import java.lang.annotation.*;
+
+/**
+ * 监听流程开始事件
+ * <p>
+ * 配合@TheFlowListener一起使用；当流程开始执行时，都会调用本注解标注的方法。
+ * 对应的方法入参类型必须为（FlowContext）。
+ */
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Listen(resolver = ListenFlowStartResolver.class, priorityType = PriorityType.ASC)
+public @interface ListenFlowStart {
+    /**
+     * 优先级类型（默认为升序）
+     */
+    @AliasFor(annotation = Listen.class, attribute = "priorityType")
+    PriorityType priorityType() default PriorityType.ASC;
+}

flow/src/main/java/org/bekit/flow/event/DecidedStateNodeEvent.java

@@ -22,7 +22,7 @@ public class DecidedStateNodeEvent {
     private final String flow;
     // 被选择的状态节点
     @Getter
-    private final String stateNode;
+    private final String node;
     // 流程上下文
     private final FlowContext<?> context;
 

flow/src/main/java/org/bekit/flow/event/ExecutingNodeEvent.java

@@ -20,7 +20,7 @@ public class ExecutingNodeEvent {
     // 流程名称
     @Getter
     private final String flow;
-    // 被选择的节点
+    // 正在执行的节点
     @Getter
     private final String node;
     // 流程上下文

flow/src/main/java/org/bekit/flow/listener/DefaultFlowListener.java

@@ -13,9 +13,7 @@
 import org.bekit.event.bus.EventBusHub;
 import org.bekit.event.publisher.DefaultEventPublisher;
 import org.bekit.flow.annotation.listener.FlowListener;
-import org.bekit.flow.event.DecidedNodeEvent;
-import org.bekit.flow.event.DecidedStateNodeEvent;
-import org.bekit.flow.event.FlowExceptionEvent;
+import org.bekit.flow.event.*;
 
 /**
  * 默认的流程监听器
@@ -31,9 +29,21 @@ public DefaultFlowListener(EventBusHub eventBusHub) {
         eventPublisher = new DefaultEventPublisher(eventBusHub.getEventBus(TheFlowListenerType.class));
     }
 
+    // 监听流程开始事件
+    @Listen
+    public void listenFlowStartEvent(FlowStartEvent event) {
+        eventPublisher.publish(event);
+    }
+
+    // 监听正在执行的节点事件
+    @Listen
+    public void listenExecutingNodeEvent(ExecutingNodeEvent event) {
+        eventPublisher.publish(event);
+    }
+
     // 监听节点选择事件
     @Listen
-    public void listenNodeDecidedEvent(DecidedNodeEvent event) {
+    public void listenDecidedNodeEvent(DecidedNodeEvent event) {
         eventPublisher.publish(event);
     }
 
@@ -48,4 +58,10 @@ public void listenStateNodeDecidedEvent(DecidedStateNodeEvent event) {
     public void listenFlowExceptionEvent(FlowExceptionEvent event) {
         eventPublisher.publish(event);
     }
+
+    // 监听流程结束事件
+    @Listen
+    public void listenFlowEndEvent(FlowEndEvent event) {
+        eventPublisher.publish(event);
+    }
 }

flow/src/main/java/org/bekit/flow/listener/ListenDecidedStateNodeResolver.java

@@ -47,6 +47,6 @@ public Object getEventType() {
     @Override
     public Object[] resolveParams(Object event) {
         DecidedStateNodeEvent decidedStateNodeEvent = (DecidedStateNodeEvent) event;
-        return new Object[]{decidedStateNodeEvent.getStateNode(), decidedStateNodeEvent.getContext()};
+        return new Object[]{decidedStateNodeEvent.getNode(), decidedStateNodeEvent.getContext()};
     }
 }

flow/src/main/java/org/bekit/flow/listener/ListenExecutingNodeResolver.java

@@ -0,0 +1,52 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2017-09-29 20:29 创建
+ */
+package org.bekit.flow.listener;
+
+import org.bekit.event.extension.ListenResolver;
+import org.bekit.flow.annotation.listener.TheFlowListener;
+import org.bekit.flow.engine.FlowContext;
+import org.bekit.flow.event.ExecutingNodeEvent;
+import org.springframework.core.annotation.AnnotatedElementUtils;
+import org.springframework.util.Assert;
+
+import java.lang.reflect.Method;
+
+/**
+ * 监听注解@ListenExecutingNode的解决器
+ */
+public class ListenExecutingNodeResolver implements ListenResolver {
+    // 监听的事件类型
+    private TheFlowEventType eventType;
+
+    @Override
+    public void init(Method listenMethod) {
+        TheFlowListener theFlowListenerAnnotation = AnnotatedElementUtils.findMergedAnnotation(listenMethod.getDeclaringClass(), TheFlowListener.class);
+        if (theFlowListenerAnnotation == null) {
+            throw new IllegalArgumentException("@ListenExecutingNode只能标注在特定流程监听器（@TheFlowListener）的方法上");
+        }
+        // 校验入参类型
+        Class[] parameterTypes = listenMethod.getParameterTypes();
+        Assert.isTrue(parameterTypes.length == 2
+                && parameterTypes[0] == String.class
+                && parameterTypes[1] == FlowContext.class, String.format("@ListenExecutingNode方法[%s]的入参类型必须是(String, FlowContext<T>)", listenMethod));
+
+        eventType = new TheFlowEventType(theFlowListenerAnnotation.flow(), ExecutingNodeEvent.class);
+    }
+
+    @Override
+    public Object getEventType() {
+        return eventType;
+    }
+
+    @Override
+    public Object[] resolveParams(Object event) {
+        ExecutingNodeEvent executingNodeEvent = (ExecutingNodeEvent) event;
+        return new Object[]{executingNodeEvent.getNode(), executingNodeEvent.getContext()};
+    }
+}

flow/src/main/java/org/bekit/flow/listener/ListenFlowEndResolver.java

@@ -0,0 +1,50 @@
+/* 
+ * 作者：钟勋 (e-mail:zhongxunking@163.com)
+ */
+
+/*
+ * 修订记录:
+ * @author 钟勋 2017-09-29 20:57 创建
+ */
+package org.bekit.flow.listener;
+
+import org.bekit.event.extension.ListenResolver;
+import org.bekit.flow.annotation.listener.TheFlowListener;
+import org.bekit.flow.engine.FlowContext;
+import org.bekit.flow.event.FlowEndEvent;
+import org.springframework.core.annotation.AnnotatedElementUtils;
+import org.springframework.util.Assert;
+
+import java.lang.reflect.Method;
+
+/**
+ * 监听注解@ListenFlowEnd的解决器
+ */
+public class ListenFlowEndResolver implements ListenResolver {
+    // 监听的事件类型
+    private TheFlowEventType eventType;
+
+    @Override
+    public void init(Method listenMethod) {
+        TheFlowListener theFlowListenerAnnotation = AnnotatedElementUtils.findMergedAnnotation(listenMethod.getDeclaringClass(), TheFlowListener.class);
+        if (theFlowListenerAnnotation == null) {
+            throw new IllegalArgumentException("@ListenFlowEnd只能标注在特定流程监听器（@TheFlowListener）的方法上");
+        }
+        // 校验入参类型
+        Class[] parameterTypes = listenMethod.getParameterTypes();
+        Assert.isTrue(parameterTypes.length == 1 && parameterTypes[0] == FlowContext.class, String.format("@ListenFlowEnd方法[%s]的入参类型必须是(FlowContext<T>)", listenMethod));
+
+        eventType = new TheFlowEventType(theFlowListenerAnnotation.flow(), FlowEndEvent.class);
+    }
+
+    @Override
+    public Object getEventType() {
+        return eventType;
+    }
+
+    @Override
+    public Object[] resolveParams(Object event) {
+        FlowEndEvent flowEndEvent = (FlowEndEvent) event;
+        return new Object[]{flowEndEvent.getContext()};
+    }
+}