From 0e1a10a860323eb38112a2642ff631ceaf6e8e21 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Mon, 24 Jun 2024 14:14:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B9=B2=E6=89=B0=E6=BA=90=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E5=BB=BA=E6=A1=A3=E6=98=AF=E5=90=A6=E6=B2=BB=E7=90=86=E6=B2=BB?=
 =?UTF-8?q?=E7=90=86=E5=AE=A1=E6=A0=B8=E9=80=9A=E8=BF=87=EF=BC=8C=E6=89=8D?=
 =?UTF-8?q?=E8=83=BD=E5=8E=BB=E8=AF=95=E8=BF=90=E8=A1=8C=EF=BC=8C=E5=90=A6?=
 =?UTF-8?q?=E5=88=99=E8=A6=81=E6=8F=90=E7=A4=BA=E5=87=BA=E6=9D=A5;?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ...SupervisionTempLineRunTestServiceImpl.java | 45 ++++++++++++++++++-
 1 file changed, 43 insertions(+), 2 deletions(-)

diff --git a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineRunTestServiceImpl.java b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineRunTestServiceImpl.java
index 36d14eb1b..9adc22684 100644
--- a/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineRunTestServiceImpl.java
+++ b/pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionTempLineRunTestServiceImpl.java
@@ -3,6 +3,7 @@ package com.njcn.supervision.service.device.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.text.StrPool;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -28,10 +29,13 @@ import com.njcn.supervision.mapper.device.SupervisionTempLineRunTestMapper;
 import com.njcn.supervision.pojo.param.device.SupervisionTempLineRunTestParam;
 import com.njcn.supervision.pojo.po.device.SupervisionTempLineReport;
 import com.njcn.supervision.pojo.po.device.SupervisionTempLineRunTestPO;
-import com.njcn.supervision.pojo.vo.device.CheckDeviceVo;
+import com.njcn.supervision.pojo.po.user.UserReportNormalPO;
+import com.njcn.supervision.pojo.po.user.UserReportProjectPO;
+import com.njcn.supervision.pojo.po.user.UserReportSensitivePO;
+import com.njcn.supervision.pojo.po.user.UserReportSubstationPO;
 import com.njcn.supervision.pojo.vo.device.SupervisionTempLineRunTestVO;
 import com.njcn.supervision.service.device.ISupervisionTempLineRunTestService;
-import com.njcn.supervision.service.user.UserReportPOService;
+import com.njcn.supervision.service.user.*;
 import com.njcn.supervision.utils.InstanceUtil;
 import com.njcn.web.utils.RequestUtil;
 import lombok.RequiredArgsConstructor;
@@ -69,6 +73,10 @@ public class SupervisionTempLineRunTestServiceImpl extends ServiceImpl<Supervisi
 
     private final UserReportPOService userReportPOService;
 
+    private final UserReportProjectPOService userReportProjectPOService;
+    private final UserReportSubstationPOService userReportSubstationPOService;
+    private final UserReportSensitivePOService userReportSensitivePOService;
+    private final IUserReportNormalService iUserReportNormalService;
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Boolean addRunTest(SupervisionTempLineRunTestParam supervisionTempLineRunTestParam) {
@@ -83,6 +91,39 @@ public class SupervisionTempLineRunTestServiceImpl extends ServiceImpl<Supervisi
         }
 
         //校验
+        //查询干扰源用户建档是否治理治理审核通过，才能去试运行，否则要提示出来;
+        List<String> userIds = supervisionTempLineReportList.stream().map(SupervisionTempLineReport::getUserId).collect(Collectors.toList());
+        List<UserReportProjectPO> list = userReportProjectPOService.lambdaQuery().in(UserReportProjectPO::getId, userIds).eq(UserReportProjectPO::getNeedGovernance, 1).list();
+        List<UserReportSubstationPO> list2 = userReportSubstationPOService.lambdaQuery().in(UserReportSubstationPO::getId, userIds).eq(UserReportSubstationPO::getNeedGovernance, 1).list();
+        List<UserReportSensitivePO> list3 = userReportSensitivePOService.lambdaQuery().in(UserReportSensitivePO::getId, userIds).eq(UserReportSensitivePO::getNeedGovernance, 1).list();
+        List<String> tempUserIds = list.stream().map(UserReportProjectPO::getId).collect(Collectors.toList());
+        tempUserIds.addAll(list2.stream().map(UserReportSubstationPO::getId).collect(Collectors.toList()));
+        tempUserIds.addAll(list3.stream().map(UserReportSensitivePO::getId).collect(Collectors.toList()));
+
+
+
+        if(CollectionUtil.isNotEmpty(tempUserIds)){
+            for (int i = tempUserIds.size() - 1; i >= 0; i--) {
+                List<UserReportNormalPO> list1 = iUserReportNormalService.lambdaQuery().eq(UserReportNormalPO::getUserReportId, tempUserIds.get(i)).list();
+                if (CollectionUtil.isNotEmpty(list1)){
+                    //为空则没有治理工程不需要移除，存在审核未通过的也不要移除,只有全是2的移除
+                    list1 = list1.stream().filter(temp->!Objects.equals(temp.getStatus(),2)).collect(Collectors.toList());
+                    if(CollectionUtil.isEmpty(list1)){
+                        tempUserIds.remove(i);
+                    }
+                }
+            }
+
+        }
+        if(CollectionUtil.isNotEmpty(tempUserIds)){
+          String userNames = supervisionTempLineReportList.stream()
+                    .filter(temp->tempUserIds.contains(temp.getUserId()))
+                    .map(SupervisionTempLineReport::getUserName)
+                    .collect(Collectors.joining(", "));
+            throw new BusinessException(CommonResponseEnum.FAIL,"存在关联干扰源用户:"+userNames+"需要治理通过才可以进行试运行");
+        }
+
+
         List<SupervisionTempLineRunTestPO> supervisionTempLineRunTestPOList = this.list(new LambdaQueryWrapper<SupervisionTempLineRunTestPO>().in(SupervisionTempLineRunTestPO::getId,ids).ne(SupervisionTempLineRunTestPO::getStatus,BpmTaskStatusEnum.REJECT.getStatus()));
         if(CollUtil.isNotEmpty(supervisionTempLineRunTestPOList)){
             String msg = assMsg(supervisionTempLineReportList,supervisionTempLineRunTestPOList);