From 4db7c1f325c321f5d0127565713c72beab912aed Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=A7=9C=E7=8E=89=E7=90=A6?=
 <7507756+jiang_yuqi@user.noreply.gitee.com>
Date: Fri, 14 Mar 2025 00:53:24 +0800
Subject: [PATCH] =?UTF-8?q?=E6=84=8F=E8=A7=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/FlowBusinessKeyMapper.java         |  7 ++
 .../mapper/flowable/FlowBusinessKeyMapper.xml | 10 +++
 .../impl/FlowDefinitionServiceImpl.java       | 76 ++++++++++++++-----
 ...roProjectInfoSubdeptsUsersServiceImpl.java | 13 +++-
 4 files changed, 84 insertions(+), 22 deletions(-)

diff --git a/yanzhu-common/yanzhu-common-mapper/src/main/java/com/yanzhu/flowable/mapper/FlowBusinessKeyMapper.java b/yanzhu-common/yanzhu-common-mapper/src/main/java/com/yanzhu/flowable/mapper/FlowBusinessKeyMapper.java
index e0a02b40..181f18e7 100644
--- a/yanzhu-common/yanzhu-common-mapper/src/main/java/com/yanzhu/flowable/mapper/FlowBusinessKeyMapper.java
+++ b/yanzhu-common/yanzhu-common-mapper/src/main/java/com/yanzhu/flowable/mapper/FlowBusinessKeyMapper.java
@@ -53,6 +53,13 @@ public interface FlowBusinessKeyMapper {
      */
     public List<Map<String, Object>> selectMyAwaitFlowTask(FlowTaskEntity flowTaskEntity);
 
+    /**
+     * 查询我的驳回任务
+     * @param flowTaskEntity
+     * @return
+     */
+    public List<Map<String, Object>> selectMyRejectedFlowTask(FlowTaskEntity flowTaskEntity);
+
     /**
      * 根据条件查询我的代办分组数量统计
      * @param flowTaskEntity
diff --git a/yanzhu-common/yanzhu-common-mapper/src/main/resources/mapper/flowable/FlowBusinessKeyMapper.xml b/yanzhu-common/yanzhu-common-mapper/src/main/resources/mapper/flowable/FlowBusinessKeyMapper.xml
index 3fb9fd05..d839955d 100644
--- a/yanzhu-common/yanzhu-common-mapper/src/main/resources/mapper/flowable/FlowBusinessKeyMapper.xml
+++ b/yanzhu-common/yanzhu-common-mapper/src/main/resources/mapper/flowable/FlowBusinessKeyMapper.xml
@@ -95,6 +95,16 @@
         order by fa.createTime desc
     </select>
 
+    <!--查询我的驳回任务-->
+    <select id="selectMyRejectedFlowTask" parameterType="FlowTaskEntity" resultType="Map">
+        select fa.* from vw_flow_await fa
+        <where>
+            <if test="businessKey != null  and businessKey != ''"> and fa.businessKey = #{businessKey}</if>
+            <if test="startProId != null and startProId != ''"> and fa.startProId = #{startProId}</if>
+            AND fa.ASSIGNEE_ = #{assigneeId}
+        </where>
+    </select>
+
     <!--根据条件查询我的代办分组数量统计-->
     <select id="findAwaitCountGroupByCategory" parameterType="FlowTaskEntity" resultType="Map">
         select fa.category, count(1) as total from vw_flow_await fa where 1=1
diff --git a/yanzhu-modules/yanzhu-flowable/src/main/java/com/yanzhu/flowable/service/impl/FlowDefinitionServiceImpl.java b/yanzhu-modules/yanzhu-flowable/src/main/java/com/yanzhu/flowable/service/impl/FlowDefinitionServiceImpl.java
index 8debdfaa..f369de9b 100644
--- a/yanzhu-modules/yanzhu-flowable/src/main/java/com/yanzhu/flowable/service/impl/FlowDefinitionServiceImpl.java
+++ b/yanzhu-modules/yanzhu-flowable/src/main/java/com/yanzhu/flowable/service/impl/FlowDefinitionServiceImpl.java
@@ -10,7 +10,9 @@ import com.yanzhu.flowable.common.enums.FlowComment;
 import com.yanzhu.flowable.domain.SysForm;
 import com.yanzhu.flowable.domain.dto.FlowProcDefDto;
 import com.yanzhu.flowable.domain.my.FlowDeptVo;
+import com.yanzhu.flowable.domain.my.FlowTaskEntity;
 import com.yanzhu.flowable.factory.FlowServiceFactory;
+import com.yanzhu.flowable.mapper.FlowBusinessKeyMapper;
 import com.yanzhu.flowable.mapper.FlowDeployMapper;
 import com.yanzhu.flowable.service.IFlowDefinitionService;
 import com.yanzhu.flowable.service.ISysDeployFormService;
@@ -18,6 +20,7 @@ import com.yanzhu.manage.domain.ProProjectInfo;
 import com.yanzhu.system.api.domain.SysUser;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.flowable.bpmn.model.BpmnModel;
 import org.flowable.bpmn.model.UserTask;
 import org.flowable.engine.repository.Deployment;
@@ -25,6 +28,7 @@ import org.flowable.engine.repository.ProcessDefinition;
 import org.flowable.engine.repository.ProcessDefinitionQuery;
 import org.flowable.engine.runtime.ProcessInstance;
 import org.flowable.image.impl.DefaultProcessDiagramGenerator;
+import org.flowable.task.api.DelegationState;
 import org.flowable.task.api.Task;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -57,6 +61,9 @@ public class FlowDefinitionServiceImpl extends FlowServiceFactory implements IFl
     @Resource
     private ISysDeployFormService sysDeployFormService;
 
+    @Resource
+    private FlowBusinessKeyMapper flowBusinessKeyMapper;
+
     private static final String BPMN_FILE_SUFFIX = ".bpmn";
 
     @Override
@@ -139,7 +146,6 @@ public class FlowDefinitionServiceImpl extends FlowServiceFactory implements IFl
         Deployment deploy = repositoryService.createDeployment().addInputStream(name + BPMN_FILE_SUFFIX, in).name(name).category(category).deploy();
         ProcessDefinition definition = repositoryService.createProcessDefinitionQuery().deploymentId(deploy.getId()).singleResult();
         repositoryService.setProcessDefinitionCategory(definition.getId(), category);
-
     }
 
     /**
@@ -260,33 +266,63 @@ public class FlowDefinitionServiceImpl extends FlowServiceFactory implements IFl
     @Override
     public AjaxResult startProcessInstanceByParams(String procDefId, Map<String, Object> variables) {
         try {
-            ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(procDefId)
-                    .latestVersion().singleResult();
-            if (Objects.nonNull(processDefinition) && processDefinition.isSuspended()) {
-                return AjaxResult.error("流程已被挂起,请先激活流程");
+            boolean isModify = Convert.toBool(variables.get("isModify"),false);
+            if(isModify){
+                FlowTaskEntity flowQuery = new FlowTaskEntity();
+                flowQuery.setBusinessKey(Convert.toStr(variables.get("businessKey")));
+                flowQuery.setStartProId(Convert.toStr(variables.get("proId")));
+                flowQuery.setAssigneeId(Convert.toLong(variables.get("INITIATOR")));
+                List<Map<String, Object>> rejecteds = flowBusinessKeyMapper.selectMyRejectedFlowTask(flowQuery);
+                if(rejecteds.size()==0){
+                    return startProcessInstance(procDefId,variables);
+                }else{
+                    String userName = Convert.toStr(variables.get("userName"));
+                    String taskId = Convert.toStr(rejecteds.get(0).get("taskId"));
+                    Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
+                    if (Objects.isNull(task)) {
+                        return startProcessInstance(procDefId,variables);
+                    }
+                    taskService.addComment(taskId, task.getProcessInstanceId(), FlowComment.NORMAL.getType(), userName+"提交流程申请！！");
+                    taskService.complete(task.getId(), variables);
+                    return AjaxResult.success("流程重启成功");
+                }
+            }else{
+                return startProcessInstance(procDefId,variables);
             }
-            // 设置流程发起人Id到流程中
-            String userId = Convert.toStr(variables.get(ProcessConstants.PROCESS_INITIATOR));
-            String userName = Convert.toStr(variables.get("userName"));
-            String businessKey = Convert.toStr(variables.get("businessKey"));
-            identityService.setAuthenticatedUserId(userId);
-            ProcessInstance processInstance = runtimeService.startProcessInstanceById(procDefId, businessKey, variables);
-
-            // 给第一步申请人节点设置任务执行人和意见
-            Task task = taskService.createTaskQuery().processInstanceId(processInstance.getProcessInstanceId()).singleResult();
-            if (Objects.nonNull(task)) {
-                taskService.addComment(task.getId(), processInstance.getProcessInstanceId(), FlowComment.NORMAL.getType(), userName + "发起流程申请");
-                taskService.setAssignee(task.getId(), userId);
-                taskService.complete(task.getId(), variables);
-            }
-            return AjaxResult.success("流程启动成功");
         } catch (Exception e) {
             e.printStackTrace();
             return AjaxResult.error("流程启动错误");
         }
     }
 
+    /**
+     * 根据参数启动流程
+     * @param procDefId
+     * @param variables
+     * @return
+     */
+    private AjaxResult startProcessInstance(String procDefId, Map<String, Object> variables){
+        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(procDefId)
+                .latestVersion().singleResult();
+        if (Objects.nonNull(processDefinition) && processDefinition.isSuspended()) {
+            return AjaxResult.error("流程已被挂起,请先激活流程");
+        }
+        // 设置流程发起人Id到流程中
+        String userId = Convert.toStr(variables.get(ProcessConstants.PROCESS_INITIATOR));
+        String userName = Convert.toStr(variables.get("userName"));
+        String businessKey = Convert.toStr(variables.get("businessKey"));
+        identityService.setAuthenticatedUserId(userId);
+        ProcessInstance processInstance = runtimeService.startProcessInstanceById(procDefId, businessKey, variables);
 
+        // 给第一步申请人节点设置任务执行人和意见
+        Task task = taskService.createTaskQuery().processInstanceId(processInstance.getProcessInstanceId()).singleResult();
+        if (Objects.nonNull(task)) {
+            taskService.addComment(task.getId(), processInstance.getProcessInstanceId(), FlowComment.NORMAL.getType(), userName + "发起流程申请");
+            taskService.setAssignee(task.getId(), userId);
+            taskService.complete(task.getId(), variables);
+        }
+        return AjaxResult.success("流程启动成功");
+    }
 
     /**
      * 激活或挂起流程定义
diff --git a/yanzhu-modules/yanzhu-manage/src/main/java/com/yanzhu/manage/service/impl/ProProjectInfoSubdeptsUsersServiceImpl.java b/yanzhu-modules/yanzhu-manage/src/main/java/com/yanzhu/manage/service/impl/ProProjectInfoSubdeptsUsersServiceImpl.java
index 7a9fc3ea..fb94cdb0 100644
--- a/yanzhu-modules/yanzhu-manage/src/main/java/com/yanzhu/manage/service/impl/ProProjectInfoSubdeptsUsersServiceImpl.java
+++ b/yanzhu-modules/yanzhu-manage/src/main/java/com/yanzhu/manage/service/impl/ProProjectInfoSubdeptsUsersServiceImpl.java
@@ -970,10 +970,18 @@ public class ProProjectInfoSubdeptsUsersServiceImpl implements IProProjectInfoSu
             throw new ServiceException("承诺书生成失败...服务器异常！！！");
         }
 
+        boolean isModify = false;
         // 判断是否需要审批...
-        if(Objects.nonNull(proSubdeptsUser.getApproveStatus()) && proSubdeptsUser.getApproveStatus()<ApproveStatus.check.getCode()){
-            proSubdeptsUser.setApproveStatus(ApproveStatus.check.getCode());
+        if(Objects.nonNull(proSubdeptsUser.getApproveStatus())){
+            if(proSubdeptsUser.getApproveStatus()<ApproveStatus.check.getCode()){
+                proSubdeptsUser.setApproveStatus(ApproveStatus.check.getCode());
+            }else if(proSubdeptsUser.getApproveStatus()==ApproveStatus.refuse.getCode()){
+                isModify = true;
+                //查询流程...
+                proSubdeptsUser.setApproveStatus(ApproveStatus.check.getCode());
+            }
         }
+
         int res = proProjectInfoSubdeptsUsersMapper.updateProProjectInfoSubdeptsUsers(proSubdeptsUser);
 
         // 保存业务签名
@@ -998,6 +1006,7 @@ public class ProProjectInfoSubdeptsUsersServiceImpl implements IProProjectInfoSu
             String procDefId = Convert.toStr(procdefDatas.get(0).get("PROCDEF_ID_"));
             // 启动工作流审批节点...
             Map<String, Object> variables = new HashMap<>();
+            variables.put("isModify",isModify);
             variables.put("INITIATOR",proSubdeptsUser.getUserId());
             variables.put("userName",proSubdeptsUser.getUserName());
             variables.put("userDeptName",proSubdeptsUser.getSubDeptName());