From 67485b16168ee64a57296eefd8f74e7a07374e06 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <sandu123456>
Date: 星期四, 17 三月 2022 18:21:37 +0800
Subject: [PATCH] fix

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java |   37 +++++++++++++++++++++++++------------
 1 files changed, 25 insertions(+), 12 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 5bfeea4..faea1fa 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
@@ -2,10 +2,8 @@
 
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.ArrayUtil;
-import cn.hutool.core.util.StrUtil;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageHelper;
+import com.sandu.common.domain.CommonPage;
 import com.sandu.common.domain.ResponseVO;
 import com.sandu.common.object.BaseConditionVO;
 import com.sandu.common.util.ResponseUtil;
@@ -14,7 +12,9 @@
 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.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.dao.domain.Pole;
@@ -22,10 +22,7 @@
 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;
 
 /**
  * 鐏潌妯″潡浠ュ強璁剧疆鍒嗙粍鍒板搴旂伅鏉�
@@ -39,7 +36,9 @@
 
     private final PoleService poleService;
     private MonitorService monitorService;
+    private IpVolumeService broadcastTerminalV2Service;
     private AirEquipmentService airEquipmentService;
+    private final PermissionConfig permissionConfig;
 
     @PostMapping("/add")
     public ResponseVO<Object> addPole(@RequestBody @Validated PoleParam param) {
@@ -56,14 +55,25 @@
         return ResponseUtil.success(poleService.deletePole(poleId));
     }
 
-    @GetMapping("/listPoleAndState")//鍙互鏁村悎//宸叉暣鍚� 寮冪敤
+    @PostMapping("/list")
     public ResponseVO<Object> listPole(BaseConditionVO baseConditionVO, @RequestBody PoleStatesParam param) {
+        if(!permissionConfig.check("璺伅鍒楄〃")){
+            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
+        }
         PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
-        List<Pole> poles = poleService.queryAllStatesAndList(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(),param);
-        return ResponseUtil.success(poles);
+        List<Pole> results = poleService.queryAllStatesAndList(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(),param);
+        CommonPage commonPage = CommonPage.restPage(results);
+        int size = results.size();
+        commonPage.setTotal((long) size);
+        commonPage.setTotalPage(size / baseConditionVO.getPageSize() + 1);
+        if (size % baseConditionVO.getPageSize() == 0) {
+            commonPage.setTotalPage(size / baseConditionVO.getPageSize());
+        }
+        return ResponseUtil.success(commonPage);
+       // return ResponseUtil.success(poles);
     }
 
-    @GetMapping("/list")
+    @GetMapping("/listPoleAndState")
     public ResponseVO<Object> listPoleAndState(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword,
                                                @RequestParam(value = "groupid", required = false) Long groupid) {
         PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
@@ -91,6 +101,7 @@
     }
 
 //TODO  璁惧鐨勭粦瀹氳В缁戦兘瑕佸崟鐙噸鏂板鐞�
+
     /**
      * 鐏潌缁戝畾璁惧
      */
@@ -111,6 +122,7 @@
                 case 4:
                     break;
                 case 5:
+                    broadcastTerminalV2Service.updateBingdingState(true, Integer.valueOf(param.getDeviceCode()).intValue());
                     break;
                 case 6:
                     break;
@@ -135,8 +147,8 @@
      * 鐏潌缁戝畾璁惧
      */
     @PostMapping("/unBind/{poleId}")
-    public ResponseVO<Object> unBindPole(@PathVariable Long poleId, @RequestBody  @Validated PoleBindingParam param) {
-        boolean result = poleService.unBindPole(param.getDeviceCode());
+    public ResponseVO<Object> unBindPole(@PathVariable Long poleId, @RequestBody @Validated PoleBindingParam param) {
+        boolean result = poleService.unBindPole(poleId, param.getDeviceCode());
         if (result) {
             //璁惧绫诲瀷锛�0璺伅锛�1led灞忓箷锛�2鍏呯數妗╋紝3澶ф皵鐩戞祴锛�4姘磋川鐩戞祴锛�5ip闊虫煴锛�6lcd骞垮憡鏈猴紝7鎽勫儚澶达紝8鏉嗕綋鍊炬祴锛�9涓�閿晳鍔�
             switch (param.getDeviceType()) {
@@ -151,6 +163,7 @@
                 case 4:
                     break;
                 case 5:
+                    broadcastTerminalV2Service.updateBingdingState(false, Integer.valueOf(param.getDeviceCode()).intValue());
                     break;
                 case 6:
                     break;

--
Gitblit v1.9.3