add #82

Author: xlorne

flow-engine-framework/src/main/java/com/codingapi/flow/action/actions/AddAuditAction.java

@@ -9,6 +9,7 @@
 import com.codingapi.flow.exception.FlowExecutionException;
 import com.codingapi.flow.manager.NodeStrategyManager;
 import com.codingapi.flow.manager.OperatorManager;
+import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.node.IFlowNode;
 import com.codingapi.flow.operator.IFlowOperator;
 import com.codingapi.flow.record.FlowRecord;
@@ -107,7 +108,7 @@ public void run(FlowSession flowSession) {
 
         for (FlowRecord record : flowRecords) {
             if (record.isShow()) {
-                flowEvents.add(new FlowRecordTodoEvent(record));
+                flowEvents.add(new FlowRecordTodoEvent(record,repositoryHolder instanceof MockRepositoryHolder));
             }
         }
 

flow-engine-framework/src/main/java/com/codingapi/flow/action/actions/DelegateAction.java

@@ -9,6 +9,7 @@
 import com.codingapi.flow.event.IFlowEvent;
 import com.codingapi.flow.exception.FlowExecutionException;
 import com.codingapi.flow.manager.OperatorManager;
+import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.operator.IFlowOperator;
 import com.codingapi.flow.record.FlowRecord;
 import com.codingapi.flow.script.node.OperatorLoadScript;
@@ -59,7 +60,7 @@ public void run(FlowSession flowSession) {
         currentRecord.update(flowSession, true);
 
         recordList.add(currentRecord);
-        flowEvents.add(new FlowRecordDoneEvent(currentRecord));
+        flowEvents.add(new FlowRecordDoneEvent(currentRecord,repositoryHolder instanceof MockRepositoryHolder));
 
         List<IFlowOperator> operators = flowSession.getAdvice().getForwardOperators();
 
@@ -76,7 +77,7 @@ public void run(FlowSession flowSession) {
             FlowRecord flowRecord = currentRecord.create(flowSession.updateSession(operator));
             flowRecord.resetDelegate(currentRecord);
             recordList.add(flowRecord);
-            flowEvents.add(new FlowRecordTodoEvent(flowRecord));
+            flowEvents.add(new FlowRecordTodoEvent(flowRecord,repositoryHolder instanceof MockRepositoryHolder));
         }
 
         repositoryHolder.saveRecords(recordList);

flow-engine-framework/src/main/java/com/codingapi/flow/action/actions/PassAction.java

@@ -7,6 +7,7 @@
 import com.codingapi.flow.event.FlowRecordTodoEvent;
 import com.codingapi.flow.event.IFlowEvent;
 import com.codingapi.flow.manager.NodeStrategyManager;
+import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.node.BaseAuditNode;
 import com.codingapi.flow.node.IFlowNode;
 import com.codingapi.flow.operator.IFlowOperator;
@@ -74,7 +75,7 @@ public void run(FlowSession flowSession) {
         boolean isFinish = currentNode.isFinish(flowSession);
         currentRecord.update(flowSession, true);
         // 添加流程结束事件
-        flowEvents.add(new FlowRecordDoneEvent(currentRecord));
+        flowEvents.add(new FlowRecordDoneEvent(currentRecord,repositoryHolder instanceof MockRepositoryHolder));
         recordList.add(currentRecord);
 
         // 激活下一个按顺序审批的记录数据
@@ -85,7 +86,7 @@ public void run(FlowSession flowSession) {
                 if (record.getNodeOrder() == currentRecord.getNodeOrder() + 1) {
                     record.show();
                     recordList.add(record);
-                    flowEvents.add(new FlowRecordTodoEvent(record));
+                    flowEvents.add(new FlowRecordTodoEvent(record,repositoryHolder instanceof MockRepositoryHolder));
                 }
             }
         }
@@ -98,7 +99,7 @@ public void run(FlowSession flowSession) {
                 notifyRecord.notifyRecord(flowSession.updateSession(forwardOperator));
                 // 如果不存储这个记录，若下一流程是结束流程时，无法更新流程状态为结束状态。
                 repositoryHolder.saveRecord(notifyRecord);
-                flowEvents.add(new FlowRecordDoneEvent(notifyRecord));
+                flowEvents.add(new FlowRecordDoneEvent(notifyRecord,repositoryHolder instanceof MockRepositoryHolder));
             }
 
             // 是否委托记录
@@ -109,17 +110,17 @@ public void run(FlowSession flowSession) {
                 rebackRecord.clearDelegate();
 
                 recordList.add(rebackRecord);
-                flowEvents.add(new FlowRecordTodoEvent(rebackRecord));
+                flowEvents.add(new FlowRecordTodoEvent(rebackRecord,repositoryHolder instanceof MockRepositoryHolder));
             } else {
                 this.triggerNode(flowSession, (triggerSession) -> {
                     List<FlowRecord> records = this.generateRecords(triggerSession);
                     if (!records.isEmpty()) {
                         for (FlowRecord record : records) {
                             if (record.isShow()) {
                                 if (record.isNotify()) {
-                                    flowEvents.add(new FlowRecordDoneEvent(record));
+                                    flowEvents.add(new FlowRecordDoneEvent(record,repositoryHolder instanceof MockRepositoryHolder));
                                 } else {
-                                    flowEvents.add(new FlowRecordTodoEvent(record));
+                                    flowEvents.add(new FlowRecordTodoEvent(record,repositoryHolder instanceof MockRepositoryHolder));
                                 }
                             }
                         }

flow-engine-framework/src/main/java/com/codingapi/flow/action/actions/RejectAction.java

@@ -7,6 +7,7 @@
 import com.codingapi.flow.event.FlowRecordTodoEvent;
 import com.codingapi.flow.event.IFlowEvent;
 import com.codingapi.flow.exception.FlowStateException;
+import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.node.IFlowNode;
 import com.codingapi.flow.record.FlowRecord;
 import com.codingapi.flow.script.action.RejectActionScript;
@@ -97,7 +98,7 @@ public void run(FlowSession flowSession) {
             recordList.addAll(records);
             for (FlowRecord record : records) {
                 if (record.isShow()) {
-                    flowEvents.add(new FlowRecordTodoEvent(record));
+                    flowEvents.add(new FlowRecordTodoEvent(record,repositoryHolder instanceof MockRepositoryHolder));
                 }
             }
         }

flow-engine-framework/src/main/java/com/codingapi/flow/action/actions/ReturnAction.java

@@ -6,6 +6,7 @@
 import com.codingapi.flow.event.FlowRecordDoneEvent;
 import com.codingapi.flow.event.FlowRecordTodoEvent;
 import com.codingapi.flow.event.IFlowEvent;
+import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.node.IFlowNode;
 import com.codingapi.flow.record.FlowRecord;
 import com.codingapi.flow.session.FlowSession;
@@ -47,14 +48,14 @@ public void run(FlowSession flowSession) {
         currentRecord.update(flowSession, true);
         recordList.add(currentRecord);
 
-        flowEvents.add(new FlowRecordDoneEvent(currentRecord));
+        flowEvents.add(new FlowRecordDoneEvent(currentRecord,repositoryHolder instanceof MockRepositoryHolder));
 
         List<FlowRecord> flowRecords = backNode.generateCurrentRecords(flowSession.updateSession(backNode));
         recordList.addAll(flowRecords);
 
         for (FlowRecord record : flowRecords) {
             if (record.isShow()) {
-                flowEvents.add(new FlowRecordTodoEvent(record));
+                flowEvents.add(new FlowRecordTodoEvent(record,repositoryHolder instanceof MockRepositoryHolder));
             }
         }
 

flow-engine-framework/src/main/java/com/codingapi/flow/action/actions/TransferAction.java

@@ -9,6 +9,7 @@
 import com.codingapi.flow.event.IFlowEvent;
 import com.codingapi.flow.exception.FlowExecutionException;
 import com.codingapi.flow.manager.OperatorManager;
+import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.operator.IFlowOperator;
 import com.codingapi.flow.record.FlowRecord;
 import com.codingapi.flow.script.node.OperatorLoadScript;
@@ -66,7 +67,7 @@ public void run(FlowSession flowSession) {
 
         currentRecord.update(flowSession, true);
         recordList.add(currentRecord);
-        flowEvents.add(new FlowRecordDoneEvent(currentRecord));
+        flowEvents.add(new FlowRecordDoneEvent(currentRecord,repositoryHolder instanceof MockRepositoryHolder));
 
         List<IFlowOperator> operators = flowSession.getAdvice().getForwardOperators();
         if (script != null) {
@@ -81,7 +82,7 @@ public void run(FlowSession flowSession) {
         for (IFlowOperator operator : operators) {
             FlowRecord flowRecord = currentRecord.create(flowSession.updateSession(operator));
             recordList.add(flowRecord);
-            flowEvents.add(new FlowRecordTodoEvent(flowRecord));
+            flowEvents.add(new FlowRecordTodoEvent(flowRecord,repositoryHolder instanceof MockRepositoryHolder));
         }
 
         repositoryHolder.saveRecords(recordList);

flow-engine-framework/src/main/java/com/codingapi/flow/event/FlowRecordDoneEvent.java

@@ -13,4 +13,8 @@ public class FlowRecordDoneEvent implements IFlowEvent {
 
     private final FlowRecord flowRecord;
 
+    private final boolean mock;
+
+
+
 }

flow-engine-framework/src/main/java/com/codingapi/flow/event/FlowRecordFinishEvent.java

@@ -13,4 +13,5 @@ public class FlowRecordFinishEvent implements IFlowEvent {
 
     private final FlowRecord flowRecord;
 
+    private final boolean mock;
 }

flow-engine-framework/src/main/java/com/codingapi/flow/event/FlowRecordStartEvent.java

@@ -13,4 +13,5 @@ public class FlowRecordStartEvent implements IFlowEvent {
 
     private final FlowRecord flowRecord;
 
+    private final boolean mock;
 }

flow-engine-framework/src/main/java/com/codingapi/flow/event/FlowRecordTodoEvent.java

@@ -13,4 +13,5 @@ public class FlowRecordTodoEvent implements IFlowEvent {
 
     private final FlowRecord flowRecord;
 
+    private final boolean mock;
 }