From 08aa034b673d0a0dfc1913ea60e46b3b17d9ec15 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期四, 03 七月 2025 17:41:03 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/TaskUtil.java |   35 +++++++++++++++++++++++------------
 1 files changed, 23 insertions(+), 12 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/TaskUtil.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/TaskUtil.java
index bc9e42e..70c6d87 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/TaskUtil.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/task/TaskUtil.java
@@ -80,8 +80,6 @@
     }
 
     public void createInspection(TTemplate template) {
-        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        Date date = new Date();
         // 查询所有的模板详情
         List<TTemplateDetail> list = templateDetailService.list(Wrappers.lambdaQuery(TTemplateDetail.class)
                 .eq(TTemplateDetail::getTemplateId, template.getId()));
@@ -118,20 +116,36 @@
             // 获取点位类型的占比
             String num4 = detail.getNum4();
 
+            SysUser sysUser = sysUsers.get(0);
+            List<TProjectDept> projectDeptLists = new ArrayList<>();
+            if(sysUser.getDeptType() == 1){
+                TProjectDept projectDept = projectDeptService.getById(sysUser.getDeptId());
+                if("0".equals(projectDept.getParentId())){
+                    projectDeptLists = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
+                            .eq(TProjectDept::getParentId, projectDept.getId()));
+                }else {
+                    projectDeptLists.add(projectDept);
+                }
+            }else {
+                projectDeptLists = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
+                        .ne(TProjectDept::getParentId,0));
+            }
+            List<String> proDeptIds = projectDeptLists.stream().map(TProjectDept::getId).collect(Collectors.toList());
+
             // 获取项目部在该模板详情中的权重
             List<String> projectDeptIds = redisCache.getCacheList(detail.getId() + PROJECT_DEPT_WEIGHT);
             // 获取项目部列表
             List<TProjectDept> projectDeptList;
             if(CollectionUtils.isEmpty(projectDeptIds)){
-                projectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
-                        .ne(TProjectDept::getParentId,0));
+                projectDeptList = projectDeptLists;
             }else {
                 projectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class)
                         .ne(TProjectDept::getParentId,0)
-                        .in(TProjectDept::getId, projectDeptIds));
+                        .in(TProjectDept::getId, proDeptIds)
+                        .notIn(TProjectDept::getId, projectDeptIds));
                 // 所过所有的项目部都被抽取了,则重新抽取,并且清空项目部权重
                 if(CollectionUtils.isEmpty(projectDeptList)){
-                    projectDeptList = projectDeptService.list(Wrappers.lambdaQuery(TProjectDept.class));
+                    projectDeptList = projectDeptLists;
                     redisCache.deleteObject(detail.getId() + PROJECT_DEPT_WEIGHT);
                 }
             }
@@ -265,12 +279,9 @@
                     task.setCleanerId(tCleaner.getId());
                 });
                 // 获取巡检员
-                if(!CollectionUtils.isEmpty(sysUsers)){
-                    SysUser sysUser = sysUsers.get(0);
-                    task.setPatrolInspector(sysUser.getUserId().toString());
-                    task.setPatrolInspectorDept(sysUser.getDeptId());
-                    task.setUserId(sysUser.getUserId());
-                }
+                task.setPatrolInspector(sysUser.getUserId().toString());
+                task.setPatrolInspectorDept(sysUser.getDeptId());
+                task.setUserId(sysUser.getUserId());
                 task.setStatus(1);
                 task.setLocationId(tLocation.getId());
                 task.setImplementTime(LocalDateTime.now().plusDays(1));

--
Gitblit v1.7.1