应征入伍保留学籍工作流

srs-flowable/src/main/java/com/srs/flowable/listener/enlistmentReserve/ApprovalAssigneeListener.java

@@ -0,0 +1,150 @@
+package com.srs.flowable.listener.enlistmentReserve;
+
+import com.srs.common.core.domain.entity.SysUser;
+
+
+import com.srs.common.utils.SecurityUtils;
+import com.srs.system.service.ISysUserService;
+import org.flowable.bpmn.model.BpmnModel;
+import org.flowable.bpmn.model.FlowNode;
+import org.flowable.engine.HistoryService;
+import org.flowable.engine.RepositoryService;
+import org.flowable.engine.delegate.DelegateExecution;
+import org.flowable.engine.delegate.ExecutionListener;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+
+/**
+ * 审批流程负责人自动流转监听器
+ * 用于节点审批通过时，更新下一个节点的负责人变量(approval)
+ */
+@Component("approvalAssigneeListener") // Spring Bean名称，与BPMN表达式对应
+public class ApprovalAssigneeListener implements ExecutionListener {
+
+    @Autowired
+    private ISysUserService sysUserService; // 用户服务（查询部门/学院负责人）
+
+//    @Autowired
+//    private FlowBusinessService enlistmentReserveMapper; // 业务表Mapper
+
+    @Autowired
+    private HistoryService historyService; // Flowable历史服务
+
+    // 用于查询流程定义中的节点信息
+    @Autowired
+    private RepositoryService repositoryService;
+
+    @Override
+    public void notify(DelegateExecution execution) {
+        // 1. 获取当前节点ID和流程定义ID
+        String currentActivityId = execution.getCurrentActivityId(); // 当前节点ID（兼容所有版本）
+        String processDefinitionId = execution.getProcessDefinitionId(); // 流程定义ID
+
+        // 2. 根据节点ID查询节点名称（核心修正：通过流程定义获取名称）
+        String currentNodeName = getNodeNameByActivityId(processDefinitionId, currentActivityId);
+        if (currentNodeName == null) {
+            throw new RuntimeException("未找到节点ID=" + currentActivityId + "的名称");
+        }
+
+        // 3. 获取流程实例ID
+        String processInstanceId = execution.getProcessInstanceId();
+
+        // 4. 后续逻辑不变：查询下一个节点负责人并更新变量
+        Long nextAssigneeId = getNextAssignee(currentNodeName, processInstanceId);
+        if (nextAssigneeId != null) {
+            execution.setVariable("approval", nextAssigneeId);
+            execution.setVariable("currentNode", currentNodeName);
+        }
+    }
+
+    /**
+     * 根据节点ID和流程定义ID，查询节点名称（兼容所有版本的核心方法）
+     */
+    private String getNodeNameByActivityId(String processDefinitionId, String activityId) {
+        // 获取流程模型
+        BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
+        if (bpmnModel == null) {
+            throw new RuntimeException("未找到流程定义ID=" + processDefinitionId + "的模型");
+        }
+
+        // 从模型中获取节点信息（FlowNode包含用户任务、网关等节点）
+        FlowNode flowNode = (FlowNode) bpmnModel.getFlowElement(activityId);
+        return flowNode != null ? flowNode.getName() : null;
+    }
+
+    /**
+     * 根据当前节点查询下一个节点的负责人
+     */
+    private Long getNextAssignee(String currentNodeName, String processInstanceId) {
+        // 获取当前登录用户的部门id
+        Long currentDeptId = SecurityUtils.getDeptId();
+        if (currentDeptId == null) {
+            throw new RuntimeException("当前登录用户未分配部门，无法匹配学务负责人");
+        }
+        // 注意：节点名称需与BPMN模型中完全一致（区分大小写）
+        switch (currentNodeName) {
+            case "辅导员审批":
+                // 辅导员通过后 → 下一个节点：学务（筛选出角色ID=105，且与当前部门一致）
+                // 查询角色ID=105（学务）的所有用户
+                SysUser queryUser = new SysUser();
+                queryUser.setRoleId(105L); // 学务角色固定ID
+                List<SysUser> academicAffairsUsers = sysUserService.selectAllocatedList(queryUser);
+                if (academicAffairsUsers.isEmpty()) {
+                    throw new RuntimeException("未查询到角色ID=105（学务）的用户");
+                }
+
+                // 3. 从学务用户中筛选出部门ID与当前辅导员部门一致的用户
+                SysUser targetAcademic = academicAffairsUsers.stream()
+                        .filter(user -> currentDeptId.equals(user.getDeptId())) // 部门ID匹配
+                        .findFirst() // 取第一个匹配的学务（若有多个，可根据排序或优先级调整）
+                        .orElseThrow(() -> new RuntimeException("未找到部门ID=" + currentDeptId + "的学务负责人"));
+
+                // 4. 返回匹配的学务用户ID（作为下一个节点负责人）
+                return targetAcademic.getUserId();
+
+            case "学务审批":
+                // 学务通过后 → 下一个节点：二级学院（角色ID=106，匹配学生所属学院）
+                // 查询当前流程对应的业务数据（获取学生所属学院ID）
+//                RtEnlistmentReserve reserve = enlistmentReserveMapper.selectRtEnlistmentReserveByProcessInstanceId(processInstanceId);
+//                if (reserve == null) {
+//                    throw new RuntimeException("未查询到流程对应的业务数据，processInstanceId=" + processInstanceId);
+//                }
+
+                // 查询角色ID=106（二级学院）的所有用户
+                SysUser qUser = new SysUser();
+                qUser.setRoleId(106L); // 二级学院角色固定ID=106
+                List<SysUser> collegeUsers = sysUserService.selectAllocatedList(qUser);
+                if (collegeUsers.isEmpty()) {
+                    throw new RuntimeException("未查询到角色ID=106（二级学院）的用户");
+                }
+
+                // 筛选出部门ID（学院ID）与登录用户所属学院一致的二级学院负责人
+                SysUser targetCollegeLeader = collegeUsers.stream()
+                        .filter(user -> currentDeptId.equals(user.getDeptId())) // 学院ID匹配（部门ID即学院ID）
+                        .findFirst()
+                        .orElseThrow(() -> new RuntimeException("未找到学院ID=" + currentDeptId + "的二级学院负责人（角色ID=106）"));
+
+                // 4. 返回匹配的二级学院负责人ID
+                return targetCollegeLeader.getUserId();
+
+            case "二级学院审批":
+                // 二级学院通过后 → 下一个节点：学籍管理科（假设部门ID=30）
+                return 30L;
+
+            case "学籍管理科审批":
+                // 学籍管理科通过后 → 下一个节点：教务处（假设部门ID=40）
+                return 40L;
+
+            case "教务处主管领导审批":
+                // 最后一个节点通过后 → 流程结束（无需设置负责人）
+                return null;
+
+            default:
+                throw new RuntimeException("未配置节点[" + currentNodeName + "]的下一个负责人规则");
+        }
+    }
+}