fix a bug of branchGraph cache with test_case

Author: lvcangquan.lcq

scripts/bash-buddy

@@ -539,7 +539,8 @@ private List<TransitionNode> buildGatewayFollowingNodes(TransitionNode flowNode)
     }
 
     private List<TransitionNode> buildBranchNodes(TransitionNode branchNode) {
-        if (branchGraph.containsKey(branchNode.getId())) {
+        if (branchGraph.containsKey(branchNode.getId()) &&
+            !branchNode.getIncomingNodes().stream().anyMatch(incomingNode -> incomingNode instanceof GatewayElement)) {
             return branchGraph.get(branchNode.getId());
         }
 

src/main/java/com/alibaba/compileflow/engine/runtime/impl/AbstractProcessRuntime.java

@@ -42,6 +42,19 @@ public void testProcessEngine() {
         System.out.println(processEngine.execute(code, context));
     }
 
+    @Test
+    public void testBranchGraph() {
+        final String code = "bpm.om.branchGraphTest";
+        Map<String, Object> context = new HashMap<String, Object>();
+        int input = 16;
+        int finalResult = -1;
+        context.put("input", input);
+        context.put("finalResult", finalResult);
+        final ProcessEngine processEngine = ProcessEngineFactory.getProcessEngine();
+        processEngine.execute(code, context);
+        //todo
+    }
+
     @Test
     public void testProcessEngineBpmn20() {
         final String code = "bpmn20.ktv.ktvExample";

src/test/java/com/allibaba/compileflow/test/ProcessEngineTest.java

@@ -0,0 +1,15 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+public class InputCheckOp {
+    public InputCheckOp() {
+    }
+
+    public Boolean process(int input) {
+        int compareNumber = 20;
+        if (input > compareNumber) {
+            return false;
+        } else {
+            return true;
+        }
+    }
+}

src/test/java/com/allibaba/compileflow/test/om/branch_graph/calculate/InputCheckOp.java

@@ -0,0 +1,12 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+public class OnlinePreProcessOp {
+    public OnlinePreProcessOp() {
+    }
+
+    public int process(int sqrtResult) {
+        int addNumber = 2;
+        int onlineInput = sqrtResult + addNumber;
+        return onlineInput;
+    }
+}

src/test/java/com/allibaba/compileflow/test/om/branch_graph/calculate/OnlinePreProcessOp.java

@@ -0,0 +1,12 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+public class OnlineSolveOp {
+    public OnlineSolveOp() {
+    }
+
+    public int process(int onlineInput) {
+        int addNumber = 2;
+        int onlineResult = onlineInput + addNumber;
+        return onlineResult;
+    }
+}

src/test/java/com/allibaba/compileflow/test/om/branch_graph/calculate/OnlineSolveOp.java

@@ -0,0 +1,15 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+import java.math.BigInteger;
+
+public class PreProcessOp {
+    public PreProcessOp() {
+    }
+
+    public void process(int input) {
+        int compareNumber = 10;
+        if (input < compareNumber) {
+            System.out.println("input is smaller than 10");
+        }
+    }
+}

src/test/java/com/allibaba/compileflow/test/om/branch_graph/calculate/PreProcessOp.java

@@ -0,0 +1,10 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+public class RandomOp {
+    public RandomOp() {
+    }
+
+    public void process(int result) {
+        System.out.println("Random process is finished");
+    }
+}

src/test/java/com/allibaba/compileflow/test/om/branch_graph/calculate/RandomOp.java

@@ -0,0 +1,12 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+public class RayPreProcessOp {
+    public RayPreProcessOp () {
+    }
+
+    public int process(int sqrtResult) {
+        int addNumber = 100;
+        int rayInput = sqrtResult + addNumber;
+        return rayInput;
+    }
+}

src/test/java/com/allibaba/compileflow/test/om/branch_graph/calculate/RayPreProcessOp.java

@@ -0,0 +1,12 @@
+package com.allibaba.compileflow.test.om.branch_graph.calculate;
+
+public class RaySolveOp {
+    public RaySolveOp() {
+    }
+
+    public int process(int rayInput) {
+        int addNumber = 200;
+        int rayResult = rayInput + addNumber;
+        return rayResult;
+    }
+}