From bd3abf9b8101a31e745de1ec76f6d98317b2de2e Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期三, 04 十二月 2024 13:50:45 +0800
Subject: [PATCH] 首页流程待办查询接口支持部门

---
 business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java |   57 +++++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 41 insertions(+), 16 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 6291572..103571d 100644
--- a/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
+++ b/business/src/main/java/com/ycl/service/impl/ProjectProcessServiceImpl.java
@@ -79,6 +79,7 @@
 
     /**
      * 鍒嗛〉鏌ヨ
+     *
      * @param query
      * @return
      */
@@ -165,6 +166,7 @@
 
     /**
      * 鑾峰彇娴佺▼璇︽儏
+     *
      * @param projectId
      * @return
      */
@@ -205,7 +207,7 @@
         Result result = Result.ok();
 
         // 浠e姙浠诲姟
-        this.getTodoTaskList(projectProcess.getProcessInsId(),"", 5, 1, result);
+        this.getTodoTaskList(projectProcess.getProcessInsId(), "", 5, 1, result);
         return result.data(detail);
     }
 
@@ -222,16 +224,16 @@
         Result ok = Result.ok();
         switch (query.getTaskType()) {
             case TaskTypeConstant.ALL:
-                this.getAllUserTask(query.getProcessDefId(), projectProcess.getProcessInsId(), query.getTaskName (), (int)query.getCurrentPage(), (int)query.getPageSize(), ok);
+                this.getAllUserTask(query.getProcessDefId(), projectProcess.getProcessInsId(), query.getTaskName(), (int) query.getCurrentPage(), (int) query.getPageSize(), ok);
                 break;
             case TaskTypeConstant.TODO:
-                this.getTodoTaskList(projectProcess.getProcessInsId(), query.getTaskName(), (int)query.getPageSize(), (int)query.getCurrentPage(), ok);
+                this.getTodoTaskList(projectProcess.getProcessInsId(), query.getTaskName(), (int) query.getPageSize(), (int) query.getCurrentPage(), ok);
                 ok.data(ok.get("taskList"));
                 break;
             case TaskTypeConstant.CURRENT:
                 break;
             case TaskTypeConstant.REMAINING:
-                this.getRemainingTask(query.getProcessDefId(), projectProcess.getProcessInsId(), query.getTaskName (), (int)query.getCurrentPage(), (int)query.getPageSize(), ok);
+                this.getRemainingTask(query.getProcessDefId(), projectProcess.getProcessInsId(), query.getTaskName(), (int) query.getCurrentPage(), (int) query.getPageSize(), ok);
                 break;
             default:
                 break;
@@ -293,20 +295,43 @@
                         }
                         taskVO.setHandlerName(sysUser.getNickName());
                     }
-                    // 缁戝畾鐨勬槸瑙掕壊锛屾煡鍑鸿鑹插悕绉�
+                    // 缁戝畾鐨勬槸瑙掕壊鎴栬�呴儴闂�
                 } else if (StringUtils.isNotBlank(identityLink.getGroupId())) {
-                    SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
-                    if (Objects.nonNull(role)) {
-                        taskVO.setHandlerUnitId(Long.parseLong(identityLink.getGroupId()));
-                        taskVO.setHandlerUnitName("鐢辨嫢鏈夎鑹诧細銆�" + role.getRoleName() + "銆戠殑浜哄鐞�");
-                        taskVO.setHandlerName("鏆傛湭澶勭悊");
-                        taskVO.setHandlerId(null);
+                    if (identityLink.getGroupId().startsWith("dept")) {   // 閮ㄩ棬鐨刬d鏄姞浜嗗墠缂�鐨勫锛歞ept:1
+                        String[] split = identityLink.getGroupId().split(":");
+                        if (split.length > 1) {
+                            // 閮ㄩ棬
+                            SysDept dept = sysDeptService.selectDeptById(Long.parseLong(split[1]));
+                            if (Objects.nonNull(dept)) {
+                                taskVO.setHandlerUnitId(dept.getDeptId());
+                                taskVO.setHandlerUnitName(dept.getDeptName());
+                                taskVO.setHandlerName("鏆傛湭澶勭悊");
+                                taskVO.setHandlerId(null);
+                            }
+                        }
+                    } else {
+                        SysRole role = sysRoleService.selectRoleById(Long.parseLong(identityLink.getGroupId()));
+                        if (Objects.nonNull(role)) {
+                            taskVO.setHandlerUnitId(Long.parseLong(identityLink.getGroupId()));
+                            taskVO.setHandlerUnitName("鐢辨嫢鏈夎鑹诧細銆�" + role.getRoleName() + "銆戠殑浜哄鐞�");
+                            taskVO.setHandlerName("鏆傛湭澶勭悊");
+                            taskVO.setHandlerId(null);
+                        }
                     }
                 }
             }
             vos.add(taskVO);
         }
         result.put("taskList", vos);
+    }
+
+    @Override
+    public Result detailByProcessInsId(com.ycl.domain.query.TaskQuery query) {
+        List<ProjectProcess> list = new LambdaQueryChainWrapper<>(baseMapper)
+                .eq(ProjectProcess::getProcessInsId, query.getProcessInsId())
+                .eq(ProjectProcess::getProcessDefId, query.getProcessDefId())
+                .list();
+        return Result.ok().data(list);
     }
 
     /**
@@ -405,7 +430,7 @@
      * 鑾峰彇鎵�鏈変换鍔�
      *
      * @param processDefinitionId 娴佺▼杩愯id
-     * @param processInsId 娴佺▼瀹炰緥id
+     * @param processInsId        娴佺▼瀹炰緥id
      * @param pageNum
      * @param pageSize
      * @param result
@@ -602,7 +627,7 @@
      * 鏌ヨ鍓╀綑浜嬮」锛堟湭寮�濮嬬殑浠诲姟锛夋暟閲�
      *
      * @param processDefinitionId 娴佺▼瀹氫箟id
-     * @param processInsId 娴佺▼瀹炰緥id
+     * @param processInsId        娴佺▼瀹炰緥id
      * @return
      */
     private Long getRemainingTaskNum(String processDefinitionId, String processInsId) {
@@ -687,7 +712,7 @@
                     }
                 }
             }
-        } else if (TaskStatusEnum.FINISHED.equals(taskVO.getTaskStatus())){
+        } else if (TaskStatusEnum.FINISHED.equals(taskVO.getTaskStatus())) {
             for (IdentityLinkInfo identityLink : identityLinkInfos) {
                 // 缁戝畾鐨勬槸鐢ㄦ埛锛屾煡鍑虹敤鎴峰鍚嶃�侀儴闂�
                 if (StringUtils.isNotBlank(identityLink.getUserId())) {
@@ -764,7 +789,7 @@
     /**
      * 鑾峰彇娴佺▼鑺傜偣鏁帮紙鎬讳换鍔℃暟锛屼笉鍖呭惈寮�濮嬨�佺粨鏉熺瓑鐗规畩鐨勶紝鍙粺璁serTask绫诲瀷鐨勶級
      *
-     * @param processDefinitionId  娴佺▼瀹氫箟id
+     * @param processDefinitionId 娴佺▼瀹氫箟id
      * @return
      */
     private Long getTotalTaskNum(String processDefinitionId) {
@@ -798,6 +823,6 @@
      * @return
      */
     private List<Task> getCurrentNodeTaskList(String processInstanceId) {
-       return taskService.createTaskQuery().processDefinitionId(processInstanceId).list();
+        return taskService.createTaskQuery().processDefinitionId(processInstanceId).list();
     }
 }

--
Gitblit v1.8.0