From d938c951a1669b4df877ffc6521aef17f0fac809 Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 28 十月 2022 17:53:05 +0800
Subject: [PATCH] changes

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java |   26 ++++++++++++++++++--------
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java      |    6 ++++--
 2 files changed, 22 insertions(+), 10 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 7ca83bb..c528e04 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
@@ -284,10 +284,12 @@
             //鏂扮伅鏉嗕笅鍙戞柊浠诲姟
             Map<String, List<LightTaskPoleRelation>> newPoleMap = sendControllerFrame(newPoleIdList, newLightTask.getFramePayload(), param.getLightAddress());
 
-            //newPoleAll闆嗗悎鍚庨潰鐢ㄤ簬瀛樺偍鍏崇郴琛�
-            newPoleAll = newPoleMap.getOrDefault("all", new ArrayList<>());
-            newPoleSuccess = newPoleMap.getOrDefault("success", new ArrayList<>());
-            newPoleFail = newPoleMap.getOrDefault("fail", new ArrayList<>());
+            if (newPoleMap != null) {
+                //newPoleAll闆嗗悎鍚庨潰鐢ㄤ簬瀛樺偍鍏崇郴琛�
+                newPoleAll = newPoleMap.getOrDefault("all", new ArrayList<>());
+                newPoleSuccess = newPoleMap.getOrDefault("success", new ArrayList<>());
+                newPoleFail = newPoleMap.getOrDefault("fail", new ArrayList<>());
+            }
         }
 
         List<LightTaskPoleRelation> oldPoleFail = new ArrayList<>();
@@ -295,8 +297,10 @@
         if (CollectionUtil.isNotEmpty(oldPoleIdList)) {
             //瑕嗙洊鎿嶄綔鐏潌
             Map<String, List<LightTaskPoleRelation>> oldPoleMap = sendControllerFrame(oldPoleIdList, newLightTask.getFramePayload(), param.getLightAddress());
-            oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>());
-            oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>());
+            if (oldPoleMap != null) {
+                oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>());
+                oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>());
+            }
         }
 
 
@@ -308,8 +312,10 @@
             String framePayloadClose = "";
             //鍏崇伅鎿嶄綔鐏潌
             Map<String, List<LightTaskPoleRelation>> closePoleMap = sendControllerFrame(closeLight, framePayloadClose, param.getLightAddress());
-            closePoleFail = closePoleMap.getOrDefault("fail", new ArrayList<>());
-            closePoleSuccess = closePoleMap.getOrDefault("success", new ArrayList<>());
+            if (closePoleMap != null) {
+                closePoleFail = closePoleMap.getOrDefault("fail", new ArrayList<>());
+                closePoleSuccess = closePoleMap.getOrDefault("success", new ArrayList<>());
+            }
         }
 
 
@@ -664,6 +670,10 @@
             //瀛樺湪浠诲姟鍏崇郴   涓嬪彂娓呴櫎浠诲姟鎸囦护
             Map<String, List<LightTaskPoleRelation>> ffff = sendControllerFrame(poleIds, "", byId.getLightAdress());
 
+            if (ffff == null) {
+                throw new BusinessException("鍒犻櫎澶辫触");
+            }
+
             /**
              * 鍒犻櫎鎺х伅浠诲姟鏃ュ織璁板綍寮�濮�
              */
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
index 0223e89..e112f59 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
@@ -136,6 +136,8 @@
         }
         // 鍒犻櫎鐏潌缁戝畾鍏崇郴
         poleBindingService.remove(Wrappers.<PoleBinding>lambdaQuery().eq(PoleBinding::getPoleId, poleId));
+        SpringContextHolder.getBean(LightTaskPoleRelationService.class)
+                .remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getPoleId, poleId));
 
         /**
          * 鍒犻櫎鐏潌鏃ュ織璁板綍寮�濮�
@@ -863,8 +865,8 @@
      *
      * @return 鏄惁鎴愬姛
      */
-    public boolean unBindPole(Long poleId, String deviceCode,Integer deviceType) {
-        return poleBindingService.unBindPole(poleId, deviceCode,deviceType);
+    public boolean unBindPole(Long poleId, String deviceCode, Integer deviceType) {
+        return poleBindingService.unBindPole(poleId, deviceCode, deviceType);
     }
 
 

--
Gitblit v1.9.3