Merge pull request #30 from lunasaw/2.6.0

2.6.0 流程引擎单节点扩展

Author: lunasaw

pom.xml

@@ -7,7 +7,7 @@
     <groupId>io.github.lunasaw</groupId>
     <artifactId>luna-common</artifactId>
     <name>luna-common</name>
-    <version>2.5.9</version>
+    <version>2.6.0</version>
     <description>common is project which contains common utils</description>
     <url>https://github.com/lunasaw/luna-common</url>
 

src/main/java/com/luna/common/engine/model/NodeName.java

@@ -1,12 +1,12 @@
 package com.luna.common.engine.model;
 
+import java.util.Objects;
+
 import com.luna.common.check.Assert;
-import lombok.AllArgsConstructor;
+
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
-import java.util.Objects;
-
 /**
  * 节点Key
  */

src/main/java/com/luna/common/engine/spi/AbstractBatchNodeNodeSpi.java

@@ -0,0 +1,12 @@
+package com.luna.common.engine.spi;
+
+import com.luna.common.engine.model.EngineRunData;
+
+public abstract class AbstractBatchNodeNodeSpi<T> implements BatchNodeNodeSpi<T> {
+
+    @Override
+    public boolean isAccept(EngineRunData engineRunData) {
+        return true;
+    }
+
+}

src/main/java/com/luna/common/engine/spi/BatchNodeNodeSpi.java

@@ -0,0 +1,24 @@
+package com.luna.common.engine.spi;
+
+import com.luna.common.engine.model.EngineRunData;
+
+/**
+ * 每个流程节点的扩展点
+ **/
+public interface BatchNodeNodeSpi<T> extends NodeSpi {
+    /**
+     * 判断该扩展点是否需要执行 true:需要执行; false:不需要执行
+     *
+     * @param spiData
+     * @return
+     */
+    default boolean isAccept(EngineRunData spiData) {
+        return true;
+    }
+
+    /**
+     * 封装spi的业务逻辑方法
+     *
+     */
+    void invoke(EngineRunData spiData);
+}

src/main/java/com/luna/common/engine/spi/NodeSpi.java

@@ -0,0 +1,8 @@
+package com.luna.common.engine.spi;
+
+/**
+ * SPI接口
+ */
+public interface NodeSpi {
+
+}

src/main/java/com/luna/common/engine/task/AbstractEngineNode.java

@@ -1,16 +1,37 @@
 package com.luna.common.engine.task;
 
+import java.util.ArrayList;
+import java.util.List;
+
 import com.luna.common.engine.model.EngineContext;
+import com.luna.common.engine.spi.NodeSpi;
+
+import lombok.Data;
 
 /**
  * @author luna
  */
+@Data
 public abstract class AbstractEngineNode<T> implements EngineNode<T> {
+    /**
+     * SPI列表
+     */
+    private List<NodeSpi> batchNodeNodeList = new ArrayList<>();
+
     @Override
     public boolean couldContinueExecute(EngineContext engineContext) {
         if (engineContext.isStop()) {
             return false;
         }
         return true;
     }
+
+    @Override
+    public List<NodeSpi> getSpiList() {
+        return batchNodeNodeList;
+    }
+
+    public void add(NodeSpi nodeSpi) {
+        batchNodeNodeList.add(nodeSpi);
+    }
 }

src/main/java/com/luna/common/engine/task/EngineNode.java

@@ -1,7 +1,10 @@
 package com.luna.common.engine.task;
 
+import java.util.List;
+
 import com.luna.common.engine.model.EngineContext;
 import com.luna.common.engine.model.EngineRunData;
+import com.luna.common.engine.spi.NodeSpi;
 
 /**
  *
@@ -40,4 +43,11 @@ public interface EngineNode<T> {
      */
     boolean couldContinueExecute(EngineContext engineContext);
 
+    /**
+     * 获取扩展spi
+     * 
+     * @return
+     */
+    List<NodeSpi> getSpiList();
+
 }

src/main/java/com/luna/common/engine/task/NodeParallelTask.java

@@ -1,10 +1,15 @@
 package com.luna.common.engine.task;
 
+import java.util.List;
+
+import com.luna.common.engine.spi.NodeSpi;
+import org.apache.commons.collections4.CollectionUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.luna.common.engine.model.EngineContext;
 import com.luna.common.engine.model.EngineRunData;
+import com.luna.common.engine.spi.BatchNodeNodeSpi;
 import com.luna.common.exception.BaseException;
 
 /**
@@ -41,6 +46,15 @@ public Object execute() throws BaseException {
         try {
             // Node前置检查
             Object o = engineNode.invokeNode(engineRunData, engineContext);
+            List<NodeSpi> spiList = engineNode.getSpiList();
+            if (CollectionUtils.isNotEmpty(spiList)) {
+                for (NodeSpi nodeSpi : spiList) {
+                    BatchNodeNodeSpi batchNodeNodeSpi = (BatchNodeNodeSpi)nodeSpi;
+                    if (batchNodeNodeSpi.isAccept(engineRunData)) {
+                        batchNodeNodeSpi.invoke(engineRunData);
+                    }
+                }
+            }
             engineNode.afterInvoke(engineRunData, engineContext);
             // 后置处理
             return o;

src/test/java/com/luna/common/utils/EngineNodeTest.java

@@ -1,15 +1,19 @@
 package com.luna.common.utils;
 
 import org.junit.Test;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.stereotype.Component;
 
+import com.alibaba.fastjson2.JSON;
 import com.luna.common.engine.model.EngineContext;
 import com.luna.common.engine.model.EngineRunData;
 import com.luna.common.engine.model.NodeChain;
 import com.luna.common.engine.model.NodeConf;
+import com.luna.common.engine.spi.AbstractBatchNodeNodeSpi;
 import com.luna.common.engine.task.AbstractEngineExecute;
 import com.luna.common.engine.task.AbstractEngineNode;
 import com.luna.common.spring.SpringBeanService;
@@ -49,6 +53,28 @@ public TestEngineNode testEngineNode() {
         public SpringBeanService springBeanService() {
             return new SpringBeanService();
         }
+
+        @Bean
+        public TestBatchNodeNodeSpi testBatchNodeNodeSpi() {
+            return new TestBatchNodeNodeSpi();
+        }
+    }
+
+    @Component
+    public static class TestBatchNodeNodeSpi extends AbstractBatchNodeNodeSpi<TestAdaptor> implements InitializingBean {
+
+        @Autowired
+        private TestEngineNode testEngineNode;
+
+        @Override
+        public void invoke(EngineRunData engineRunData) {
+            System.out.println(JSON.toJSONString(engineRunData));
+        }
+
+        @Override
+        public void afterPropertiesSet() {
+            testEngineNode.add(this);
+        }
     }
 
     @Component
@@ -85,7 +111,7 @@ public static class EngineFlow {
             testLink.add("1", TestEngineNode.class, new NodeConf(true, 100));
             testLink.add("1", TestEngineNode.class, new NodeConf(true, 100));
             testLink.add("2", TestEngineNode.class, new NodeConf(true, 100));
-            testLink.add("2", TestEngineNode.class, new NodeConf(false, 100));
+            testLink.add("2", TestEngineNode.class, new NodeConf(true, 100));
         }
     }