From a36535db12500082c443ef86a0c53bc039f5b615 Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期一, 26 九月 2022 18:30:04 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java |   47 +++++++++++++++++++++++++++++++----------------
 1 files changed, 31 insertions(+), 16 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 b1e0c81..21a7f9e 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
@@ -6,20 +6,19 @@
 import com.github.pagehelper.PageHelper;
 import com.sandu.common.domain.CommonPage;
 import com.sandu.common.domain.ResponseVO;
+import com.sandu.common.execption.BusinessException;
 import com.sandu.common.object.BaseConditionVO;
 import com.sandu.common.security.annotation.AnonymousAccess;
 import com.sandu.common.util.ResponseUtil;
 import com.sandu.ximon.admin.dto.DeviceStatus;
 import com.sandu.ximon.admin.dto.DeviceStatusDto;
-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.param.PoleStatesParam;
+import com.sandu.ximon.admin.param.*;
 import com.sandu.ximon.admin.security.PermissionConfig;
 import com.sandu.ximon.admin.service.AirEquipmentService;
 import com.sandu.ximon.admin.service.IpVolumeService;
 import com.sandu.ximon.admin.service.MonitorService;
 import com.sandu.ximon.admin.service.PoleService;
+import com.sandu.ximon.admin.utils.response.VnnoxResult;
 import com.sandu.ximon.admin.vo.PoleBindVO;
 import com.sandu.ximon.dao.domain.Pole;
 import com.sandu.ximon.dao.enums.MenuEnum;
@@ -154,9 +153,9 @@
     @AnonymousAccess
     @PostMapping("/poleReset/{poleId}")
     public ResponseVO<Object> poleReset(@PathVariable Long poleId) {
-//        if (!permissionConfig.check(MenuEnum.POLE_REAL_RESET.getCode())) {
-//            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
-//        }
+        if (!permissionConfig.check(MenuEnum.POLE_REAL_RESET.getCode())) {
+            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
+        }
         return ResponseUtil.success(poleService.poleReset(poleId));
     }
 
@@ -271,9 +270,9 @@
     @AnonymousAccess
     @PostMapping("/listStatusByDeviceCode")
     public ResponseVO<Object> getStatusById(@RequestBody String[] deviceCodeList) {
-//        if (!permissionConfig.check(MenuEnum.GET_STATE_BY_DEVICECODE.getCode())) {
-//            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
-//        }
+        if (!permissionConfig.check(MenuEnum.GET_STATE_BY_DEVICECODE.getCode())) {
+            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
+        }
         for (String s : deviceCodeList) {
             if (s == null) {
                 return ResponseUtil.fail("鍙傛暟涓嶈兘涓虹┖");
@@ -297,9 +296,9 @@
     @AnonymousAccess
     @PostMapping("/isRegisterByCode")
     public ResponseVO<Object> getStatusByCode() {
-//        if (!permissionConfig.check(MenuEnum.GET_STATE_BY_DEVICECODE.getCode())) {
+/*//        if (!permissionConfig.check(MenuEnum.GET_STATE_BY_DEVICECODE.getCode())) {
 //            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
-//        }
+//        }*/
         ArrayList<String> deviceCodeList = new ArrayList<>();
         deviceCodeList.add("baseDevice01");
         deviceCodeList.add("baseDevice02");
@@ -351,9 +350,17 @@
         return ResponseUtil.success(poleService.ClientBindingPole(param.getClientId(), param.getPoleIds()));
     }
 
+    @PostMapping("/ClientUnBindingPole")
+    public ResponseVO<Object> ClientUnBindingPole(@RequestBody PoleBindParam param) {
+        if (!permissionConfig.check(MenuEnum.CLIENT_UNBINDING_POLE.getCode())) {
+            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
+        }
+        return ResponseUtil.success(poleService.ClientUnBindingPole(param.getClientId(), param.getPoleIds()));
+    }
+
 
     /**
-     * 鏌ユ壘鑷繁鎷ユ湁鐨勭伅鏉�
+     * 鏌ユ壘鎷ユ湁鐨勭伅鏉�
      */
     @PostMapping("/getOwnerPole/{cilentId}")
     public ResponseVO<Object> getOwnerPole(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword
@@ -380,12 +387,20 @@
     /**
      * 鎺ㄩ�佸ぇ姘旇澶囧埌璇虹摝
      */
-    @GetMapping("/pushAidDataToNova/{poleId}")
-    public ResponseVO<Object> pushAirDataToNova(@PathVariable Long poleId) {
+    @PostMapping("/pushAidDataToNova")
+    public ResponseVO<Object> pushAirDataToNova(@RequestBody @Validated PushAirDataToNovaParam param) {
         if (!permissionConfig.check(MenuEnum.PUSH_AIR_DATA_TO_NOVA.getCode())) {
             return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
         }
-        return ResponseUtil.success(poleService.pushAirDataToNova(poleId));
+        if (param.getDuration() <= 0 || param.getDuration() > 86400000) {
+            throw new BusinessException("鎾斁鏃堕棿闇�澶т簬闆朵笖灏忎簬86400000 !");
+        }
+        VnnoxResult vnnoxResult = poleService.pushAirDataToNova(param);
+        if (vnnoxResult.getSuccess().size() != 0) {
+            return ResponseUtil.success("鎺ㄩ�佹垚鍔�");
+        } else {
+            return ResponseUtil.fail("鎺ㄩ�佸け璐�");
+        }
     }
 
     /**

--
Gitblit v1.9.3