fix bug

Author: xlorne

springboot-starter-flow/src/main/java/com/codingapi/springboot/flow/service/FlowBindDataService.java

@@ -0,0 +1,35 @@
+package com.codingapi.springboot.flow.service;
+
+import com.codingapi.springboot.flow.bind.BindDataSnapshot;
+import com.codingapi.springboot.flow.bind.IBindData;
+import com.codingapi.springboot.flow.domain.FlowNode;
+import com.codingapi.springboot.flow.record.FlowRecord;
+import com.codingapi.springboot.flow.repository.FlowBindDataRepository;
+
+class FlowBindDataService {
+
+    private final FlowBindDataRepository flowBindDataRepository;
+    private final IBindData bindData;
+    private final FlowNode flowNode;
+
+
+    public FlowBindDataService(FlowBindDataRepository flowBindDataRepository, FlowNode flowNode, IBindData bindData) {
+        this.flowBindDataRepository = flowBindDataRepository;
+        this.bindData = bindData;
+        this.flowNode = flowNode;
+    }
+
+    /**
+     * 加载快照数据
+     */
+    public BindDataSnapshot loadOrCreateSnapshot(FlowRecord flowRecord) {
+        // 保存绑定数据
+        if (flowNode.isEditable()) {
+            BindDataSnapshot snapshot = new BindDataSnapshot(bindData);
+            flowBindDataRepository.save(snapshot);
+            return snapshot;
+        } else {
+            return flowBindDataRepository.getBindDataSnapshotById(flowRecord.getSnapshotId());
+        }
+    }
+}

springboot-starter-flow/src/main/java/com/codingapi/springboot/flow/service/FlowDirectionService.java

@@ -0,0 +1,121 @@
+package com.codingapi.springboot.flow.service;
+
+import com.codingapi.springboot.flow.domain.FlowNode;
+import com.codingapi.springboot.flow.domain.FlowWork;
+import com.codingapi.springboot.flow.domain.Opinion;
+import com.codingapi.springboot.flow.em.FlowSourceDirection;
+import com.codingapi.springboot.flow.record.FlowRecord;
+import lombok.Getter;
+
+import java.util.List;
+
+class FlowDirectionService {
+
+    private final FlowWork flowWork;
+    private final FlowNode flowNode;
+    private final Opinion opinion;
+
+    @Getter
+    private FlowSourceDirection flowSourceDirection;
+
+
+    private List<FlowRecord> historyRecords;
+
+    public FlowDirectionService(FlowNode flowNode,FlowWork flowWork, Opinion opinion) {
+        this.flowNode = flowNode;
+        this.opinion = opinion;
+        this.flowWork = flowWork;
+    }
+
+
+    public void bindHistoryRecords(List<FlowRecord> historyRecords) {
+        this.historyRecords = historyRecords;
+    }
+
+
+
+    /**
+     * 解析当前的审批方向
+     */
+    public void loadFlowSourceDirection() {
+        if (opinion.isSuccess()) {
+            flowSourceDirection = FlowSourceDirection.PASS;
+        }
+        if (opinion.isReject()) {
+            flowSourceDirection = FlowSourceDirection.REJECT;
+        }
+    }
+
+
+
+    /**
+     * 重新加载审批方向
+     * 根据会签结果判断是否需要重新设置审批方向
+     */
+    public FlowSourceDirection reloadFlowSourceDirection() {
+        if (flowNode.isSign()) {
+            boolean allPass = historyRecords.stream().filter(item -> !item.isTransfer()).allMatch(FlowRecord::isPass);
+            if (!allPass) {
+                flowSourceDirection = FlowSourceDirection.REJECT;
+            }
+        }
+        return flowSourceDirection;
+    }
+
+
+    /**
+     * 校验流程的审批方向
+     */
+    public void verifyFlowSourceDirection() {
+        if (flowSourceDirection == null) {
+            throw new IllegalArgumentException("flow source direction is null");
+        }
+        if (flowNode.isStartNode() && flowSourceDirection == FlowSourceDirection.REJECT) {
+            throw new IllegalArgumentException("flow node is start node");
+        }
+    }
+
+    /**
+     * 判断当前流程节点是否已经完成，是否可以继续流转
+     */
+    public boolean hasCurrentFlowNodeIsDone() {
+        // 会签处理流程
+        if (flowNode.isSign()) {
+            // 会签下所有人尚未提交时，不执行下一节点
+            boolean allDone = historyRecords.stream().filter(item -> !item.isTransfer()).allMatch(FlowRecord::isDone);
+            if (!allDone) {
+                // 流程尚未审批结束直接退出
+                return true;
+            }
+        }
+        return false;
+    }
+
+
+
+
+    /**
+     * 检测当前流程是否已经完成
+     * 即流程已经进行到了最终节点且审批意见为同意
+     */
+    public boolean hasCurrentFlowIsFinish() {
+        if (flowSourceDirection == FlowSourceDirection.PASS && flowNode.isOverNode()) {
+            return true;
+        }
+        return false;
+    }
+
+
+    public boolean isDefaultBackRecord() {
+        return flowSourceDirection == FlowSourceDirection.REJECT && !flowWork.hasBackRelation();
+    }
+
+    public boolean isPassBackRecord() {
+        return flowSourceDirection == FlowSourceDirection.PASS;
+    }
+
+    public boolean isCustomBackRecord() {
+        return flowSourceDirection == FlowSourceDirection.REJECT && flowWork.hasBackRelation();
+    }
+
+}