From c04eb4859667264dd55a77aed70c0f5479b3384a Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 12 八月 2022 15:53:39 +0800
Subject: [PATCH] changes

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java |  215 ++++++++++++++++++++++++-----------------------------
 1 files changed, 96 insertions(+), 119 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
index cc93454..ba24393 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
@@ -120,9 +120,11 @@
         //璁板綍杩欎簺鐏潌鍘熷厛鐨勪换鍔�
         List<LightTaskPoleRelation> oldLightTaskStatusAndPoles;
         if ("FFFF".equals(param.getLightAddress())) {
-            oldLightTaskStatusAndPoles = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, poleIdList).eq(LightTaskPoleRelation::getLightAddress, "0001").or(relation -> {
-                relation.eq(LightTaskPoleRelation::getLightAddress, "0002");
-            }));
+            oldLightTaskStatusAndPoles = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class)
+                    .in(LightTaskPoleRelation::getPoleId, poleIdList).eq(LightTaskPoleRelation::getLightAddress, "0001"));
+            List<LightTaskPoleRelation> list = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class)
+                    .in(LightTaskPoleRelation::getPoleId, poleIdList).eq(LightTaskPoleRelation::getLightAddress, "0002"));
+            oldLightTaskStatusAndPoles.addAll(list);
         } else {
             oldLightTaskStatusAndPoles = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, poleIdList).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress()));
         }
@@ -130,62 +132,55 @@
         /**
          * 閲嶅浠诲姟鐨勭伅澶�
          */
+        List<Long> taskIds = oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::getTaskId).collect(Collectors.toList());
+        List<Long> poleIds = oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
+        //poleIds涓噸澶嶅厓绱犲彧淇濈暀涓�涓�
+        taskIds = taskIds.stream().distinct().collect(Collectors.toList());
+        poleIds = poleIds.stream().distinct().collect(Collectors.toList());
         if (!oldLightTaskStatusAndPoles.isEmpty()) {
-            throw new BusinessException("浠诲姟涓瓨鍦ㄥ凡鏈変换鍔$殑鍗曠伅," + "浠诲姟id涓簕" + oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::getTaskId).collect(Collectors.toList()) + "}, " + "鐏潌id涓簕" + oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList()) + "}");
+            throw new BusinessException("浠诲姟涓瓨鍦ㄥ凡鏈変换鍔$殑鍗曠伅," + "浠诲姟id涓簕" + taskIds + "}, "
+                    + "鐏潌id涓簕" + poleIds + "}");
         }
-        //璁板綍杩欎簺鐏潌鍘熷厛鐨刬d
-        List<Long> oldList = oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
+//        //璁板綍杩欎簺鐏潌鍘熷厛鐨刬d
+//        List<Long> oldList = oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
 
         //鍒ゆ柇param.getPoleIdList()涓槸鍚︽湁鏃х殑鐏潌ID    (鐩存帴涓嬪彂)
-        List<Long> newPoleIdList = param.getPoleIdList().stream().filter(poleId -> !oldList.contains(poleId)).collect(Collectors.toList());
+//        List<Long> newPoleIdList = param.getPoleIdList().stream().filter(poleId -> !oldList.contains(poleId)).collect(Collectors.toList());
         //鍒ゆ柇param.getPoleIdList()涓槸鍚︽湁鏂扮殑鐏潌ID    (瑕嗙洊鎿嶄綔)
-        List<Long> oldPoleIdList = param.getPoleIdList().stream().filter(poleId -> oldList.contains(poleId)).collect(Collectors.toList());
+//        List<Long> oldPoleIdList = param.getPoleIdList().stream().filter(poleId -> oldList.contains(poleId)).collect(Collectors.toList());
         //鏂板涓嶅瓨鍦ㄥ叧鐏搷浣�
 
-//        //鍒ゆ柇鏃х伅鏉嗘槸鍚︽湁鏂扮伅澶村湴鍧�
-//        List<Long> oldPoleIdListHasNewLightAddress = oldPoleIdList.stream().filter(poleId -> {
-//            List<LightTaskPoleRelation> lightTaskPoleRelations = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class)
-//                    .eq(LightTaskPoleRelation::getPoleId, poleId).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress()));
-//            if (CollectionUtil.isNotEmpty(lightTaskPoleRelations)) {
-//                return !lightTaskPoleRelations.get(0).getLightAddress().equals(param.getLightAddress());
-//            }
-//            return false;
-//        }).collect(Collectors.toList());
-
-//        if (!oldPoleIdListHasNewLightAddress.isEmpty()) {
-//            throw new BusinessException("浠诲姟涓瓨鍦ㄥ凡鏈変换鍔$殑鍗曠伅,鐏潌id涓簕" + oldPoleIdListHasNewLightAddress + "}");
-//        }
 
         List<LightTaskPoleRelation> newPoleMap = new ArrayList<>();
-        if (!newPoleIdList.isEmpty()) {
+        if (!poleIdList.isEmpty()) {
             //鏂扮伅鏉嗕笅鍙戞柊浠诲姟
-            newPoleMap = sendControllerFrame(newLightTask, newPoleIdList, newLightTask.getFramePayload(), param.getLightAddress());
+            newPoleMap = sendControllerFrame(newLightTask, poleIdList, newLightTask.getFramePayload(), param.getLightAddress());
 
         }
 
-        List<LightTaskPoleRelation> oldPoleFail = new ArrayList<>();
-        List<LightTaskPoleRelation> oldPoleSuccess = new ArrayList<>();
-        if (!oldPoleIdList.isEmpty()) {
-            //瑕嗙洊鎿嶄綔鐏潌
-            Map<String, List<LightTaskPoleRelation>> oldPoleMap = sendControllerFrame(oldPoleIdList, newLightTask.getFramePayload(), param.getLightAddress());
-            oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>());
-            oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>());
-        }
-        //瑕嗙洊鎴愬姛 娣诲姞鏂扮殑浠诲姟鍏崇郴
-        if (!oldPoleSuccess.isEmpty()) {
-            oldPoleSuccess.forEach(success -> {
-                success.setTaskId(newLightTask.getTaskId());
-            });
-        }
+//        List<LightTaskPoleRelation> oldPoleFail = new ArrayList<>();
+//        List<LightTaskPoleRelation> oldPoleSuccess = new ArrayList<>();
+//        if (!oldPoleIdList.isEmpty()) {
+//            //瑕嗙洊鎿嶄綔鐏潌
+//            Map<String, List<LightTaskPoleRelation>> oldPoleMap = sendControllerFrame(oldPoleIdList, newLightTask.getFramePayload(), param.getLightAddress());
+//            oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>());
+//            oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>());
+//        }
+//        //瑕嗙洊鎴愬姛 娣诲姞鏂扮殑浠诲姟鍏崇郴
+//        if (!oldPoleSuccess.isEmpty()) {
+//            oldPoleSuccess.forEach(success -> {
+//                success.setTaskId(newLightTask.getTaskId());
+//            });
+//        }
 
         //鍒ゆ柇鏃х伅鏉嗚鐩栨搷浣滄槸鍚﹀瓨鍦ㄥけ璐�  濡傛灉瀛樺湪澶辫触锛屽垯淇濆瓨鏃х殑浠诲姟鍏崇郴
-        List<LightTaskPoleRelation> failOldLightTaskStatusAndPoles = new ArrayList<>();
-        if (!oldPoleFail.isEmpty()) {
-            //鑾峰彇澶辫触鐨勭伅鏉唅d
-            List<Long> failPoleIdList = oldPoleFail.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
-            //浠巓ldLightTaskStatusAndPoles鑾峰彇澶辫触鐨勭伅鏉嗗師鍏堢殑浠诲姟缁戝畾鍏崇郴.
-            failOldLightTaskStatusAndPoles = oldLightTaskStatusAndPoles.stream().filter(lightTaskPoleRelation -> failPoleIdList.contains(lightTaskPoleRelation.getPoleId())).collect(Collectors.toList());
-        }
+//        List<LightTaskPoleRelation> failOldLightTaskStatusAndPoles = new ArrayList<>();
+//        if (!oldPoleFail.isEmpty()) {
+//            //鑾峰彇澶辫触鐨勭伅鏉唅d
+//            List<Long> failPoleIdList = oldPoleFail.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
+//            //浠巓ldLightTaskStatusAndPoles鑾峰彇澶辫触鐨勭伅鏉嗗師鍏堢殑浠诲姟缁戝畾鍏崇郴.
+//            failOldLightTaskStatusAndPoles = oldLightTaskStatusAndPoles.stream().filter(lightTaskPoleRelation -> failPoleIdList.contains(lightTaskPoleRelation.getPoleId())).collect(Collectors.toList());
+//        }
 
         /**
          * 涓嬪彂璺伅浠诲姟鏃ュ織璁板綍寮�濮�
@@ -199,32 +194,27 @@
 
         List<LightTaskPoleRelation> all = new ArrayList<>();
         all.addAll(newPoleMap);
-        all.addAll(oldPoleSuccess);
+        int num = (int) newPoleMap.stream().filter(lightTaskPoleRelation -> lightTaskPoleRelation.getIssueStatus() != 0).count();
+
+//        all.addAll(oldPoleSuccess)
         //鏃х伅鏉嗕笅鍙戝け璐ヤ笉闇�瑕佷繚瀛樹俊绠$郴
 
-        //鍒犻櫎鏃х伅鏉嗕腑瑕嗙洊鎴愬姛鐨勪换鍔d
-        List<Long> oldSuccessPoleId = new ArrayList<>();
-        for (LightTaskPoleRelation bean : oldPoleSuccess) {
-            oldSuccessPoleId.add(bean.getPoleId());
-        }
-        if (!oldSuccessPoleId.isEmpty()) {
-            lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldSuccessPoleId).eq(LightTaskPoleRelation::getTaskId, oldLightTaskStatusAndPoles.get(0).getTaskId()));
-
-        }
+//        //鍒犻櫎鏃х伅鏉嗕腑瑕嗙洊鎴愬姛鐨勪换鍔d
+//        List<Long> oldSuccessPoleId = new ArrayList<>();
+//        for (LightTaskPoleRelation bean : oldPoleSuccess) {
+//            oldSuccessPoleId.add(bean.getPoleId());
+//        }
+////        if (!oldSuccessPoleId.isEmpty()) {
+////            lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldSuccessPoleId).eq(LightTaskPoleRelation::getLightAddress, "0001"));
+////            lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldSuccessPoleId).eq(LightTaskPoleRelation::getLightAddress, "0002"));
+////        }
 
         //淇濆瓨鏂扮伅鏉嗕互鍙婃棫鐏潌瑕嗙洊鎴愬姛鐨勪换鍔″叧绯�
         if (!all.isEmpty()) {
-//            all.forEach(
-//                    bean->{
-//                        lightTaskPoleRelationService.save(bean);
-//                    }
-//            );
             lightTaskPoleRelationService.saveBatch(all);
         }
 
-        if (!param.getPoleIdList().isEmpty() && !all.isEmpty() && !oldPoleFail.isEmpty()) {
-            return "浠诲姟涓瓨鍦ㄤ笅鍙戝紓甯革紝寮傚父鐏潌鍘熶换鍔″叧绯讳繚鐣�";
-        } else if (!param.getPoleIdList().isEmpty() && all.isEmpty()) {
+        if (!param.getPoleIdList().isEmpty() && num == newPoleMap.size()) {
             //鎵�鏈夌伅鏉嗛兘涓嬪彂澶辫触 鏂板鐨勪换鍔′笉淇濈暀
             removeById(newLightTask);
             throw new BusinessException("鎸囦护涓嬪彂澶辫触,璇锋鏌ョ伅鏉嗙姸鎬佸悗閲嶆柊鏂板浠诲姟");
@@ -254,10 +244,10 @@
 
         LightTask newLightTask = new LightTask();
         newLightTask.setTaskName(param.getTaskName());
-        if (SecurityUtils.getClientId() != null) {
-            lightTask.setClientId(clientService.getClientId());
-            lightTask.setUserId(SecurityUtils.getUserId());
-        }
+
+        newLightTask.setClientId(clientService.getClientId());
+        newLightTask.setUserId(SecurityUtils.getUserId());
+
         newLightTask.setWeek(week);
         newLightTask.setCreateUser(SecurityUtils.getUsername());
         newLightTask.setControlOrder(param.getControlOrder());
@@ -270,6 +260,9 @@
 
         //缂栬緫鍚庣伅鏉咺D闆嗗悎
         List<Long> poleIdList = param.getPoleIdList();
+        if (poleIdList.isEmpty()) {
+            throw new BusinessException("缂栬緫浠诲姟鏃惰閫夋嫨鐏潌");
+        }
         //璁板綍浠诲姟缂栬緫鍣ㄥ墠鐏潌ID闆嗗悎
         List<LightTaskStatusAndPole> oldLightTaskStatusAndPoles = lightTaskPoleRelationService.listPoleAndStatusIdByTaskId(taskId);
         List<Long> oldList = oldLightTaskStatusAndPoles.stream().map(LightTaskStatusAndPole::getId).collect(Collectors.toList());
@@ -284,35 +277,34 @@
 
         //鍙栧嚭瑕嗙洊鎿嶄綔鐨勫叧绯讳俊鎭�
         //璁板綍杩欎簺鐏潌鍘熷厛鐨勪换鍔�
-        List<LightTaskPoleRelation> oldRelation;
+        List<LightTaskPoleRelation> oldRelation = new ArrayList<>();
         if ("FFFF".equals(param.getLightAddress())) {
             // 鐏潌涓瓨鍦ㄥ叾浠栦换鍔$殑鐏ご
-            oldRelation = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldPoleIdList).eq(LightTaskPoleRelation::getLightAddress, "0001").or(relation -> {
-                relation.eq(LightTaskPoleRelation::getLightAddress, "0002");
-            }).ne(LightTaskPoleRelation::getTaskId, taskId));
+            if (CollectionUtil.isNotEmpty(oldPoleIdList)) {
+                oldRelation = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldPoleIdList)
+                        .ne(LightTaskPoleRelation::getTaskId, taskId).eq(LightTaskPoleRelation::getLightAddress, "0001"));
+                List<LightTaskPoleRelation> list = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldPoleIdList)
+                        .ne(LightTaskPoleRelation::getTaskId, taskId).eq(LightTaskPoleRelation::getLightAddress, "0002"));
+                oldRelation.addAll(list);
+            }
         } else {
-            oldRelation = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldPoleIdList).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress()));
+            if (CollectionUtil.isNotEmpty(oldPoleIdList)) {
+                oldRelation = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldPoleIdList)
+                        .eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress()));
+            }
         }
 
         /**
          * 閲嶅浠诲姟鐨勭伅澶�
          */
-        if (!oldLightTaskStatusAndPoles.isEmpty()) {
-            throw new BusinessException("浠诲姟涓瓨鍦ㄥ凡鏈変换鍔$殑鍗曠伅," + "浠诲姟id涓簕" + oldRelation.stream().map(LightTaskPoleRelation::getTaskId).collect(Collectors.toList()) + "}, " + "鐏潌id涓簕" + oldRelation.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList()) + "}");
-        }
-
-
-        //鍒ゆ柇鏃х伅鏉嗘槸鍚︽湁鏂扮伅澶村湴鍧�
-        List<Long> oldPoleIdListHasNewLightAddress = oldPoleIdList.stream().filter(poleId -> {
-            List<LightTaskPoleRelation> lightTaskPoleRelations = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getPoleId, poleId).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress()));
-            if (CollectionUtil.isNotEmpty(lightTaskPoleRelations)) {
-                return !lightTaskPoleRelations.get(0).getLightAddress().equals(param.getLightAddress());
-            }
-            return false;
-        }).collect(Collectors.toList());
-
-        if (!oldPoleIdListHasNewLightAddress.isEmpty()) {
-            throw new BusinessException("浠诲姟涓瓨鍦ㄥ凡鏈変换鍔$殑鍗曠伅,鐏潌id涓簕" + oldPoleIdListHasNewLightAddress + "}");
+        if (!oldRelation.isEmpty()) {
+            List<Long> taskIds = oldRelation.stream().map(LightTaskPoleRelation::getTaskId).collect(Collectors.toList());
+            List<Long> poleIds = oldRelation.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
+            //poleIds涓噸澶嶅厓绱犲彧淇濈暀涓�涓�
+            taskIds = taskIds.stream().distinct().collect(Collectors.toList());
+            poleIds = poleIds.stream().distinct().collect(Collectors.toList());
+            throw new BusinessException("浠诲姟涓瓨鍦ㄥ凡鏈変换鍔$殑鍗曠伅," + "浠诲姟id涓簕" + taskIds + "}, "
+                    + "鐏潌id涓簕" + poleIds + "}");
         }
 
 
@@ -329,14 +321,14 @@
             newPoleFail = newPoleMap.getOrDefault("fail", new ArrayList<>());
         }
 
-        List<LightTaskPoleRelation> oldPoleFail = new ArrayList<>();
-        List<LightTaskPoleRelation> oldPoleSuccess = new ArrayList<>();
-        if (CollectionUtil.isNotEmpty(oldPoleIdList)) {
-            //瑕嗙洊鎿嶄綔鐏潌
-            Map<String, List<LightTaskPoleRelation>> oldPoleMap = sendControllerFrame(oldPoleIdList, lightTask.getFramePayload(), param.getLightAddress());
-            oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>());
-            oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>());
-        }
+//        List<LightTaskPoleRelation> oldPoleFail = new ArrayList<>();
+//        List<LightTaskPoleRelation> oldPoleSuccess = new ArrayList<>();
+//        if (CollectionUtil.isNotEmpty(oldPoleIdList)) {
+//            //瑕嗙洊鎿嶄綔鐏潌
+//            Map<String, List<LightTaskPoleRelation>> oldPoleMap = sendControllerFrame(oldPoleIdList, lightTask.getFramePayload(), param.getLightAddress());
+//            oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>());
+//            oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>());
+//        }
 
         List<LightTaskPoleRelation> closePoleFail = new ArrayList<>();
         List<LightTaskPoleRelation> closePoleSuccess = new ArrayList<>();
@@ -350,12 +342,12 @@
         }
 
 
-        if (closePoleFail.size() == 0 && oldPoleFail.size() == 0) {
+        if (closePoleFail.size() == 0) {
             //鏃т换鍔′腑鍏ㄩ儴鍙戦�佹寚浠ゆ垚鍔燂紝鏇存柊鍘熸湰浠诲姟涓殑鏁版嵁
             newLightTask.setTaskId(lightTask.getTaskId());
             updateById(newLightTask);
         } else {
-            if (!newPoleSuccess.isEmpty() || !oldPoleSuccess.isEmpty()) {
+            if (!newPoleSuccess.isEmpty()) {
                 //鏈夊け鏁楃殑闇�瑕佷繚瀛樻棫鐨勪换鍕欙紝鏂板鏂扮殑浠诲姟鏁版嵁杩涜淇濆瓨
                 save(newLightTask);
             }
@@ -380,14 +372,6 @@
         for (LightTaskPoleRelation bean : newPoleSuccess) {
             bean.setTaskId(newLightTask.getTaskId());
         }
-        //鎴愬姛鐢ㄦ柊鐨勪换鍔D
-        for (LightTaskPoleRelation bean : oldPoleSuccess) {
-            bean.setTaskId(newLightTask.getTaskId());
-        }
-        //澶辫触鐢ㄦ棫鐨勪换鍔D
-        for (LightTaskPoleRelation bean : oldPoleFail) {
-            bean.setTaskId(lightTask.getTaskId());
-        }
 
         //澶辫触鐢ㄦ棫鐨勪换鍔D
         for (LightTaskPoleRelation bean : closePoleFail) {
@@ -396,19 +380,11 @@
 
         List<LightTaskPoleRelation> all = new ArrayList<>();
         all.addAll(newPoleSuccess);
-        all.addAll(oldPoleSuccess);
-        all.addAll(oldPoleFail);
-        all.addAll(closePoleFail);
+//        all.addAll(closePoleFail);
 
 
         List<Long> allPoleId = new ArrayList<>();
         for (LightTaskPoleRelation bean : newPoleSuccess) {
-            allPoleId.add(bean.getPoleId());
-        }
-        for (LightTaskPoleRelation bean : oldPoleSuccess) {
-            allPoleId.add(bean.getPoleId());
-        }
-        for (LightTaskPoleRelation bean : oldPoleFail) {
             allPoleId.add(bean.getPoleId());
         }
         for (LightTaskPoleRelation bean : closePoleSuccess) {
@@ -419,6 +395,7 @@
             lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, allPoleId));
 
         }
+
         if (!all.isEmpty()) {
             lightTaskPoleRelationService.saveBatch(all);
         }
@@ -433,13 +410,13 @@
          * 涓嬪彂璺伅浠诲姟鏃ュ織璁板綍缁撴潫
          */
 
-        if (newPoleFail.isEmpty() && oldPoleFail.isEmpty() && closePoleFail.isEmpty()) {
+        if (newPoleFail.isEmpty() && closePoleFail.isEmpty()) {
             return "缂栬緫鎴愬姛";
-        } else if (newPoleSuccess.isEmpty() && oldPoleSuccess.isEmpty() && closePoleSuccess.isEmpty()) {
-            throw new BusinessException("缂栬緫澶辫触,璇锋鏌ョ紪杈戠殑璁惧鏄惁鍦ㄧ嚎!");
-        } else if (!closePoleFail.isEmpty() /*|| !oldPoleFail.isEmpty()*/) {
+        } else if (newPoleSuccess.isEmpty() && closePoleSuccess.isEmpty()) {
+            throw new BusinessException("缂栬緫澶辫触,璇锋鏌ュ師鏈夎澶囧拰缂栬緫鍚庣殑璁惧鏄惁鍦ㄧ嚎!");
+        } else if (!closePoleFail.isEmpty() && !newPoleSuccess.isEmpty()) {
             return "鍘熶换鍔′腑瀛樺湪涓嬪彂寮傚父锛屽師浠诲姟淇濈暀锛屽垱寤烘柊浠诲姟杩涜淇濆瓨";
-        } else if (!newPoleFail.isEmpty()) {
+        } else if (!newPoleFail.isEmpty() && !newPoleSuccess.isEmpty()) {
             return "鏂颁换鍔′腑瀛樺湪涓嬪彂寮傚父锛屽拷鐣ュ紓甯告搷浣滅殑鐏潌";
         } else {
             return "鎿嶄綔寮傚父";

--
Gitblit v1.9.3