From be8f5982d0a2ccfc2880a3356e9cfe816affe9ef Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期二, 11 二月 2025 17:58:17 +0800
Subject: [PATCH] 主管部门sqlbug

---
 business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java |  125 ++++++++++++++++++++++-------------------
 1 files changed, 68 insertions(+), 57 deletions(-)

diff --git a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
index 75187b6..4dedffa 100644
--- a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
+++ b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
@@ -159,6 +159,7 @@
                 .set(ProjectProcess::getProcessInsId, processInsId)
                 .set(ProjectProcess::getDataLaunch, project.getCreateBy())
                 .update();
+
         return Result.ok("娴佺▼鍙樻洿鎴愬姛");
     }
 
@@ -207,9 +208,10 @@
         SysUser sysUser = SecurityUtils.getLoginUser().getUser();
         identityService.setAuthenticatedUserId(sysUser.getUserId().toString());
         variables.put(ProcessConstants.PROCESS_INITIATOR, sysUser.getUserId());
-
+        //娴嬭瘯瀹圭己
+        variables.put("miss",true);
         // 灏嗚椤圭洰鐨勭敵璇蜂汉锛堜笟涓绘柟锛変綔涓烘祦绋嬩腑鏌愪簺鐜妭鐨勫鐞嗕汉
-        variables.put(ProcessConstants.DATA_LAUNCH, createBy);
+        variables.put(ProcessConstants.DATA_LAUNCH, "dept:" + createBy);
         ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefId, projectId + "", variables);
         return processInstance.getId();
     }
@@ -738,24 +740,25 @@
                     // 鏈紑濮嬬殑浠诲姟锛屽叾鍏宠仈鐨勭敤鎴风粍杩欎簺閮藉彲浠ヤ粠UserTask涓嬁鍒帮紝鍥犱负鏈韩鏈紑濮嬬殑浠诲姟鏄病鏈塼ask鐨勶紝鎵�浠ヨ繖閲岀洿鎺ユ煡
                     if (StringUtils.isNotBlank(userTask.getAssignee())) {
                         vo.setHandlerType(HandlerTypeEnum.USER);
-                        // 澶勭悊鍙橀噺琛ㄨ揪寮�
-                        if (userTask.getAssignee().contains(ProcessConstants.DATA_LAUNCH)) {
-                            this.varReview(vo, projectId, processInsId);
-                        } else {
-                            SysUser sysUser = sysUserService.selectUserById(Long.parseLong(userTask.getAssignee()));
-                            if (Objects.nonNull(sysUser)) {
-                                handlerIds.add(sysUser.getUserId());
-                                handlerNames.add(sysUser.getNickName());
-                                if (Objects.nonNull(sysUser.getDept())) {
-                                    handlerUnitIds.add(sysUser.getDept().getDeptId());
-                                    handlerUnitNames.add(sysUser.getDept().getDeptName());
-                                }
+                        SysUser sysUser = sysUserService.selectUserById(Long.parseLong(userTask.getAssignee()));
+                        if (Objects.nonNull(sysUser)) {
+                            handlerIds.add(sysUser.getUserId());
+                            handlerNames.add(sysUser.getNickName());
+                            if (Objects.nonNull(sysUser.getDept())) {
+                                handlerUnitIds.add(sysUser.getDept().getDeptId());
+                                handlerUnitNames.add(sysUser.getDept().getDeptName());
                             }
                         }
+
                     } else if (CollectionUtil.isNotEmpty(userTask.getCandidateGroups())) {
                         List<String> groupIds = userTask.getCandidateGroups();
                         for (String groupId : groupIds) {
-                            if (groupId.startsWith("dept")) {   // 閮ㄩ棬鐨刬d鏄姞浜嗗墠缂�鐨勫锛歞ept:1
+                            // 澶勭悊鍙橀噺琛ㄨ揪寮忥紝DATA_LAUNCH鍙彲鑳芥槸閮ㄩ棬涓嶄細鏄鑹诧紝鍥犱负浠h〃鐨勬槸涓氫富閮ㄩ棬
+                            if (groupId.contains(ProcessConstants.DATA_LAUNCH)) {
+                                vo.setHandlerType(HandlerTypeEnum.DEPT);
+                                this.varYzReview(vo, projectId, processInsId, HandlerTypeEnum.DEPT);
+                            }
+                            else if (groupId.startsWith("dept")) {   // 閮ㄩ棬鐨刬d鏄姞浜嗗墠缂�鐨勫锛歞ept:1
                                 vo.setHandlerType(HandlerTypeEnum.DEPT);
                                 String[] split = groupId.split(":");
                                 if (split.length > 1) {
@@ -764,7 +767,6 @@
                                     if (Objects.nonNull(dept)) {
                                         handlerUnitIds.add(dept.getDeptId());
                                         handlerUnitNames.add(dept.getDeptName());
-
                                     }
                                 }
                             } else {
@@ -909,24 +911,21 @@
         // 娴佺▼澶勭悊浜轰俊鎭�
         List<IdentityLink> identityLinksForTask = taskService.getIdentityLinksForTask(task.getId());
         for (IdentityLinkInfo identityLink : identityLinksForTask) {
-//            if (StringUtils.isBlank(((IdentityLinkEntityImpl)identityLink).getId())) {
-//                continue;
-//            }
             // 缁戝畾鐨勬槸鐢ㄦ埛锛屾煡鍑虹敤鎴峰鍚嶃�侀儴闂�
             if (StringUtils.isNotBlank(identityLink.getUserId())) {
-                // 澶勭悊鍙橀噺琛ㄨ揪寮�
-                if (identityLink.getUserId().contains(ProcessConstants.DATA_LAUNCH)) {
-                    this.varReview(taskVO, projectId, task.getProcessInstanceId());
-                    continue;
-                }
+                // 澶勭悊鍙橀噺琛ㄨ揪寮忥紝杩愯涓殑浠诲姟鏃犻渶鍐嶅鐞嗚〃杈惧紡浜嗭紝flowable宸茬粡鑷姩鏍规嵁鍙橀噺璁剧疆浜�
+//                if (identityLink.getUserId().contains(ProcessConstants.DATA_LAUNCH)) {
+//                    this.varReview(taskVO, projectId, task.getProcessInstanceId());
+//                    continue;
+//                }
                 taskVO.setHandlerType(HandlerTypeEnum.USER);
                 SysUser sysUser = sysUserService.selectUserById(Long.parseLong(identityLink.getUserId()));
                 if (Objects.nonNull(sysUser)) {
-                    handlerIds.add(sysUser.getUserId());
-                    handlerNames.add(sysUser.getNickName());
+                    taskVO.getHandlerId().add(sysUser.getUserId());
+                    taskVO.getHandlerName().add(sysUser.getNickName());
                     if (Objects.nonNull(sysUser.getDept())) {
-                        handlerUnitIds.add(sysUser.getDept().getDeptId());
-                        handlerUnitNames.add(sysUser.getDept().getDeptName());
+                        taskVO.getHandlerUnitId().add(sysUser.getDept().getDeptId());
+                        taskVO.getHandlerUnitName().add(sysUser.getDept().getDeptName());
                     }
                 }
                 // 缁戝畾鐨勬槸瑙掕壊鎴栬�呴儴闂�
@@ -938,16 +937,16 @@
                         // 閮ㄩ棬
                         SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
                         if (Objects.nonNull(dept)) {
-                            handlerUnitIds.add(dept.getDeptId());
-                            handlerUnitNames.add(dept.getDeptName());
+                            taskVO.getHandlerUnitId().add(dept.getDeptId());
+                            taskVO.getHandlerUnitName().add(dept.getDeptName());
                         }
                     }
                 } else {
                     taskVO.setHandlerType(HandlerTypeEnum.ROLE);
                     SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
                     if (Objects.nonNull(role)) {
-                        handlerUnitIds.add(Long.parseLong(identityLink.getGroupId()));
-                        handlerUnitNames.add(role.getRoleName());
+                        taskVO.getHandlerUnitId().add(Long.parseLong(identityLink.getGroupId()));
+                        taskVO.getHandlerUnitName().add(role.getRoleName());
                     }
                 }
             }
@@ -1102,8 +1101,8 @@
                 long handlerUserId = Long.parseLong(hisTask.getAssignee());
                 SysUser handlerUser = sysUserService.selectUserById(handlerUserId);
                 if (Objects.nonNull(handlerUser)) {
-                    handlerIds.add(handlerUserId);
-                    handlerNames.add(handlerUser.getNickName());
+                    vo.getHandlerId().add(handlerUserId);
+                    vo.getHandlerName().add(handlerUser.getNickName());
                     vo.setActualHandlerUserId(hisTask.getAssignee());
                     vo.setActualHandlerUserName(handlerUser.getNickName());
                 }
@@ -1396,43 +1395,40 @@
             // 鏈紑濮嬬殑浠诲姟锛屽叾鍏宠仈鐨勭敤鎴风粍杩欎簺閮藉彲浠ヤ粠UserTask涓嬁鍒帮紝鍥犱负鏈韩鏈紑濮嬬殑浠诲姟鏄病鏈塼ask鐨勶紝鎵�浠ヨ繖閲岀洿鎺ユ煡
             if (StringUtils.isNotBlank(userTask.getAssignee())) {
                 vo.setHandlerType(HandlerTypeEnum.USER);
-
-                // 澶勭悊鍙橀噺琛ㄨ揪寮�
-                if (userTask.getAssignee().contains(ProcessConstants.DATA_LAUNCH)) {
-                    this.varReview(vo, projectId, processInsId);
-                    vos.add(vo);
-                    continue;
-                }
                 SysUser sysUser = sysUserService.selectUserById(Long.parseLong(userTask.getAssignee()));
                 if (Objects.nonNull(sysUser)) {
-                    handlerIds.add(sysUser.getUserId());
-                    handlerNames.add(sysUser.getNickName());
+                    vo.getHandlerId().add(sysUser.getUserId());
+                    vo.getHandlerName().add(sysUser.getNickName());
                     if (Objects.nonNull(sysUser.getDept())) {
-                        handlerUnitIds.add(sysUser.getDept().getDeptId());
-                        handlerUnitNames.add(sysUser.getDept().getDeptName());
+                        vo.getHandlerUnitId().add(sysUser.getDept().getDeptId());
+                        vo.getHandlerUnitName().add(sysUser.getDept().getDeptName());
                     }
                 }
             } else if (CollectionUtil.isNotEmpty(userTask.getCandidateGroups())) {
                 List<String> groupIds = userTask.getCandidateGroups();
                 for (String groupId : groupIds) {
-                    if (groupId.startsWith("dept")) {   // 閮ㄩ棬鐨刬d鏄姞浜嗗墠缂�鐨勫锛歞ept:1
+                    // 澶勭悊鍙橀噺琛ㄨ揪寮忥紝DATA_LAUNCH鍙彲鑳芥槸閮ㄩ棬涓嶄細鏄鑹诧紝鍥犱负浠h〃鐨勬槸涓氫富閮ㄩ棬
+                    if (groupId.contains(ProcessConstants.DATA_LAUNCH)) {
+                        vo.setHandlerType(HandlerTypeEnum.DEPT);
+                        this.varYzReview(vo, projectId, processInsId, HandlerTypeEnum.DEPT);
+                    }
+                    else if (groupId.startsWith("dept")) {   // 閮ㄩ棬鐨刬d鏄姞浜嗗墠缂�鐨勫锛歞ept:1
                         vo.setHandlerType(HandlerTypeEnum.DEPT);
                         String[] split = groupId.split(":");
                         if (split.length > 1) {
                             // 閮ㄩ棬
                             SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
                             if (Objects.nonNull(dept)) {
-                                handlerUnitIds.add(dept.getDeptId());
-                                handlerUnitNames.add(dept.getDeptName());
-
+                                vo.getHandlerUnitId().add(dept.getDeptId());
+                                vo.getHandlerUnitName().add(dept.getDeptName());
                             }
                         }
                     } else {
                         vo.setHandlerType(HandlerTypeEnum.ROLE);
                         SysRole role = sysRoleService.selectRoleById(Long.parseLong(groupId));
                         if (Objects.nonNull(role)) {
-                            handlerUnitIds.add(role.getRoleId());
-                            handlerUnitNames.add(role.getRoleName());
+                            vo.getHandlerUnitId().add(role.getRoleId());
+                            vo.getHandlerUnitName().add(role.getRoleName());
                         }
                     }
                 }
@@ -1457,11 +1453,11 @@
     }
 
     /**
-     * 澶勭悊娴佺▼鍙橀噺鐨勫鐞嗕汉鍥炴樉
+     * 澶勭悊娴佺▼鍙橀噺-涓氫富鍗曚綅
      *
      * @param vo
      */
-    private void varReview(CustomerTaskVO vo, Long projectId, String processInsId) {
+    private void varYzReview(CustomerTaskVO vo, Long projectId, String processInsId, HandlerTypeEnum type) {
         ProjectProcess projectProcess = new LambdaQueryChainWrapper<>(projectProcessMapper)
                 .eq(ProjectProcess::getProjectId, projectId)
                 .eq(ProjectProcess::getProcessInsId, processInsId)
@@ -1469,11 +1465,26 @@
         if (Objects.isNull(projectProcess)) {
             throw new RuntimeException("璇ユ祦绋嬫湭缁戝畾椤圭洰");
         }
-        SysUser user = sysUserService.selectUserById(projectProcess.getDataLaunch());
-        if (Objects.nonNull(user) && Objects.nonNull(user.getDept())) {
-            vo.getHandlerName().add(user.getDept().getDeptName());
-            vo.getHandlerId().add(user.getDept().getDeptId());
+        if (HandlerTypeEnum.USER.equals(type) || HandlerTypeEnum.FIX_USER.equals(type)) {
+            SysUser user = sysUserService.selectUserById(projectProcess.getDataLaunch());
+            if (Objects.nonNull(user) && Objects.nonNull(user.getDept())) {
+                vo.getHandlerName().add(user.getNickName());
+                vo.getHandlerId().add(user.getUserId());
+            }
+        } else if (HandlerTypeEnum.DEPT.equals(type)) {
+            SysDept dept = deptService.selectDeptById(projectProcess.getDataLaunch());
+            if (Objects.nonNull(dept)) {
+                vo.getHandlerUnitId().add(dept.getDeptId());
+                vo.getHandlerUnitName().add(dept.getDeptName());
+            }
+        } else if (HandlerTypeEnum.ROLE.equals(type)) {
+            SysRole role = sysRoleService.selectRoleById(projectProcess.getDataLaunch());
+            if (Objects.nonNull(role)) {
+                vo.getHandlerUnitId().add(role.getRoleId());
+                vo.getHandlerUnitName().add(role.getRoleName());
+            }
         }
+
         this.distinctVo(vo);
     }
 

--
Gitblit v1.8.0