From da6ea6d775461e6d56eb50cbdd79e6ba3b8f41e4 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期二, 01 三月 2022 14:22:30 +0800
Subject: [PATCH] 灯杆绑定设备,解绑设备

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java |   96 ++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 92 insertions(+), 4 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java
index f2b7920..d6cf828 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java
@@ -10,16 +10,21 @@
 import com.sandu.common.object.BaseConditionVO;
 import com.sandu.common.util.ResponseUtil;
 import com.sandu.ximon.admin.dto.DeviceStatus;
+import com.sandu.ximon.admin.param.PoleBindParam;
 import com.sandu.ximon.admin.param.PoleBindingParam;
 import com.sandu.ximon.admin.param.PoleParam;
+import com.sandu.ximon.admin.service.AirEquipmentService;
+import com.sandu.ximon.admin.service.MonitorService;
 import com.sandu.ximon.admin.service.PoleService;
 import com.sandu.ximon.dao.domain.Pole;
 import lombok.AllArgsConstructor;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import javax.validation.constraints.NotEmpty;
 import java.util.Arrays;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 鐏潌妯″潡浠ュ強璁剧疆鍒嗙粍鍒板搴旂伅鏉�
@@ -32,6 +37,8 @@
 public class PoleController {
 
     private final PoleService poleService;
+    private MonitorService monitorService;
+    private AirEquipmentService airEquipmentService;
 
     @PostMapping("/add")
     public ResponseVO<Object> addPole(@RequestBody @Validated PoleParam param) {
@@ -62,9 +69,10 @@
         return ResponseUtil.successPage(list);
     }
 
-    @GetMapping("listPoleAndState")
+    @GetMapping("/listPoleAndState")
     public ResponseVO<Object> listPoleAndState(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword) {
         PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+
         List<Pole> poles = poleService.queryStatesAndList(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
         return ResponseUtil.successPage(poles);
     }
@@ -75,7 +83,9 @@
      */
     @PostMapping("/setMac/{baseMac}")
     public ResponseVO<Object> setMac(@PathVariable String baseMac) {
+        //public ResponseVO<Object> setMac() {
         return ResponseUtil.success(poleService.setMac(baseMac));
+        // return ResponseUtil.success(poleService.setMac());
     }
 
     /**
@@ -86,7 +96,7 @@
         return ResponseUtil.success(poleService.poleReset(poleId));
     }
 
-
+//TODO  璁惧鐨勭粦瀹氳В缁戦兘瑕佸崟鐙噸鏂板鐞�
     /**
      * 鐏潌缁戝畾璁惧
      */
@@ -94,20 +104,98 @@
     public ResponseVO<Object> bindPole(@PathVariable Long poleId, @RequestBody @Validated PoleBindingParam param) {
         boolean result = poleService.bindPole(poleId, param);
         if (result) {
+            //璁惧绫诲瀷锛�0璺伅锛�1led灞忓箷锛�2鍏呯數妗╋紝3澶ф皵鐩戞祴锛�4姘磋川鐩戞祴锛�5ip闊虫煴锛�6lcd骞垮憡鏈猴紝7鎽勫儚澶达紝8鏉嗕綋鍊炬祴锛�9涓�閿晳鍔�
+            switch (param.getDeviceType()) {
+                case 0:
+                    break;
+                case 1:
+                    break;
+                case 2:
+                    break;
+                case 3:
+                    break;
+                case 4:
+                    break;
+                case 5:
+                    break;
+                case 6:
+                    break;
+                case 7:
+                    monitorService.updateBingdingState(true, param.getDeviceCode());
+                    break;
+                case 8:
+                    break;
+                case 9:
+                    break;
+                default:
+                    break;
+            }
+
             return ResponseUtil.success("缁戝畾鎴愬姛");
         } else {
             return ResponseUtil.fail("缁戝畾澶辫触");
         }
     }
 
+    /**
+     * 鐏潌缁戝畾璁惧
+     */
+    @PostMapping("/unBind/{poleId}")
+    public ResponseVO<Object> unBindPole(@PathVariable Long poleId, @RequestBody  @Validated PoleBindingParam param) {
+        boolean result = poleService.unBindPole(param.getDeviceCode());
+        if (result) {
+            //璁惧绫诲瀷锛�0璺伅锛�1led灞忓箷锛�2鍏呯數妗╋紝3澶ф皵鐩戞祴锛�4姘磋川鐩戞祴锛�5ip闊虫煴锛�6lcd骞垮憡鏈猴紝7鎽勫儚澶达紝8鏉嗕綋鍊炬祴锛�9涓�閿晳鍔�
+            switch (param.getDeviceType()) {
+                case 0:
+                    break;
+                case 1:
+                    break;
+                case 2:
+                    break;
+                case 3:
+                    break;
+                case 4:
+                    break;
+                case 5:
+                    break;
+                case 6:
+                    break;
+                case 7:
+                    monitorService.updateBingdingState(false, param.getDeviceCode());
+                    break;
+                case 8:
+                    break;
+                case 9:
+                    break;
+                default:
+                    break;
+            }
+
+            return ResponseUtil.success("瑙g粦鎴愬姛");
+        } else {
+            return ResponseUtil.fail("瑙g粦澶辫触");
+        }
+    }
+
     @PostMapping("/listStatusByDeviceCode")
-    public ResponseVO<Object> getStatusById(@RequestBody String[] deviceCodeList){
-        if(ArrayUtil.isEmpty(deviceCodeList)) {
+    public ResponseVO<Object> getStatusById(@RequestBody String[] deviceCodeList) {
+        for (String s : deviceCodeList) {
+            if (s == null) {
+                return ResponseUtil.fail("鍙傛暟涓嶈兘涓虹┖");
+            }
+
+        }
+        if (ArrayUtil.isEmpty(deviceCodeList)) {
             return ResponseUtil.fail("鍙傛暟涓嶈兘涓虹┖");
         }
         List<DeviceStatus> statusList = poleService.listStatusByDeviceCode(CollectionUtil.toList(deviceCodeList));
         return ResponseUtil.success(statusList);
     }
 
+    @PostMapping("/ClientBindingPole")
+    public ResponseVO<Object> ClientBindingPole(@RequestBody PoleBindParam param) {
+        return ResponseUtil.success(poleService.ClientBindingPole(param.getClientId(), param.getPoleIds()));//////////////
+    }
+
 
 }

--
Gitblit v1.9.3