[模型模块]新增检查是否已在运行中的机制

src/main/java/com/tykj/workflowcore/model/service/TableInfoExService.java

@@ -10,6 +10,7 @@ import com.tykj.workflowcore.model.entity.TableInfoEx;
 import com.tykj.workflowcore.model.repository.BindRepository;
 import com.tykj.workflowcore.model.repository.TableInfoExRepository;
 import com.tykj.workflowcore.model.repository.TableInfoRepository;
+import com.tykj.workflowcore.workflow_editer.service.FormPageService;
 import org.apache.logging.log4j.util.Strings;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -31,7 +32,8 @@ public class TableInfoExService {
     BindRepository bindRepository;
     @Autowired
     TableInfoService tableInfoService;
-
+    @Autowired
+    FormPageService formPageService;
     public void save(TableInfoEx tableInfoEx) {
         //数据检查
         boolean exists = tableInfoExRepository.existsByName(tableInfoEx.getName());
@@ -63,11 +65,14 @@ public class TableInfoExService {
         if (nonNull(tableInfoEx.getId())) {
             throw new RuntimeException("修改操作不可附带id");
         }
-        Integer count = tableInfoExRepository.countByName(tableInfoEx.getName());
+        //检查是否已在运行中
+        formPageService.checkIfWorking(tableInfoEx.getProcessKey());
         //设置时间
         Date date = new Date();
         tableInfoEx.setCreatedTime(date);
         tableInfoEx.setUpdatedTime(date);
+        //设置版本号
+        Integer count = tableInfoExRepository.countByName(tableInfoEx.getName());
         tableInfoEx.setVersion(count + 1);
         //保存数据
         Integer id = tableInfoExRepository.save(tableInfoEx).getId();
@@ -96,6 +101,9 @@ public class TableInfoExService {
 
     public List<TableInfoEx> findByProcessKey(String processKey) {
         return tableInfoExRepository.findByProcessKey(processKey).stream()
+                .map(TableInfoEx::getName)
+                .distinct()
+                .map(this::findLastVersion)
                 .map(this::getBinds)
                 .collect(Collectors.toList());
     }

src/main/java/com/tykj/workflowcore/model/service/TableInfoService.java

 package com.tykj.workflowcore.model.service;
 
+import com.tykj.workflowcore.base.result.ApiException;
 import com.tykj.workflowcore.model.entity.ColumnInfo;
 import com.tykj.workflowcore.model.entity.Quote;
 import com.tykj.workflowcore.model.entity.TableInfo;
 import com.tykj.workflowcore.model.repository.ColumnInfoRepository;
 import com.tykj.workflowcore.model.repository.QuoteRepository;
 import com.tykj.workflowcore.model.repository.TableInfoRepository;
+import com.tykj.workflowcore.workflow_editer.entity.FlowsInfo;
+import com.tykj.workflowcore.workflow_editer.service.FormPageService;
+import com.tykj.workflowcore.workflow_editer.service.WorkFlowService;
+import org.flowable.engine.runtime.ProcessInstance;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -30,6 +35,8 @@ public class TableInfoService {
     private ColumnInfoRepository columnInfoRepository;
     @Autowired
     private QuoteRepository quoteRepository;
+    @Autowired
+    private FormPageService formPageService;
 
     public void save(TableInfo tableInfo) {
         //数据检查
@@ -62,11 +69,14 @@ public class TableInfoService {
         if (nonNull(tableInfo.getId())) {
             throw new RuntimeException("修改操作不可附带id");
         }
-        Integer count = tableInfoRepository.countByName(tableInfo.getName());
+        //检查是否已经在运行中
+        formPageService.checkIfWorking(tableInfo.getProcessKey());
         //设置时间
         Date date = new Date();
         tableInfo.setCreatedTime(date);
         tableInfo.setUpdatedTime(date);
+        //设置版本号
+        Integer count = tableInfoRepository.countByName(tableInfo.getName());
         tableInfo.setVersion(count + 1);
         //保存数据
         Integer tableInfoId = tableInfoRepository.save(tableInfo).getId();

src/main/java/com/tykj/workflowcore/workflow_editer/service/FormPageService.java

@@ -57,5 +57,10 @@ public interface FormPageService {
 
     Specification<FormPage> specificationBuild(PageFormPageVo pageFormPageVo);
 
+    /**
+     * 根据processKey检查是否已在运行中
+     * @param processKey
+     */
+    void checkIfWorking(String processKey);
 
 }

src/main/java/com/tykj/workflowcore/workflow_editer/service/impl/FormPageServiceImpl.java

@@ -117,5 +117,21 @@ public class FormPageServiceImpl implements FormPageService {
         return and.build();
     }
 
+    @Override
+    public void checkIfWorking(String processKey) {
+        //查询对应的processKey
+        FlowsInfo byFlowKey = flowInfoService.findByFlowKey(processKey);
+        //判断 byFlowKey 是否正在运行
+        Integer state = byFlowKey.getState();
+        // 0代表这个流程正在运行过程中
+        if (state == 0) {
+            throw new ApiException("该页面正在流程中运行,无法被修改");
+        }
+        //判断该流程是否存在正在运行的流程实例如果存在将不允许修改页面
+        List<ProcessInstance> processInstances = workFlowService.queryUnfinishedProcessInstance(processKey);
+        if (processInstances.size() > 0) {
+            throw new ApiException("该页面正在流程中运行,无法被修改.请先停止所有正在运行的流程实例");
+        }
+    }
 
 }