From 25467e37012939fb621ee6e43edc2587ba48dc63 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期一, 18 四月 2022 17:16:20 +0800
Subject: [PATCH] 广播素材列表

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java |   82 ++++++++++++++++++++++++++++++-----------
 1 files changed, 60 insertions(+), 22 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 0489617..52356a2 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;
@@ -13,19 +11,19 @@
 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.security.PermissionConfig;
 import com.sandu.ximon.admin.service.AirEquipmentService;
-import com.sandu.ximon.admin.service.BroadcastTerminalV2Service;
+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;
+import com.sandu.ximon.dao.enums.MenuEnum;
 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;
 
 /**
  * 鐏潌妯″潡浠ュ強璁剧疆鍒嗙粍鍒板搴旂伅鏉�
@@ -39,8 +37,9 @@
 
     private final PoleService poleService;
     private MonitorService monitorService;
-    private BroadcastTerminalV2Service broadcastTerminalV2Service;
+    private IpVolumeService broadcastTerminalV2Service;
     private AirEquipmentService airEquipmentService;
+    private final PermissionConfig permissionConfig;
 
     @PostMapping("/add")
     public ResponseVO<Object> addPole(@RequestBody @Validated PoleParam param) {
@@ -57,26 +56,38 @@
         return ResponseUtil.success(poleService.deletePole(poleId));
     }
 
-    @GetMapping("/list")
-    public ResponseVO<Object> listPole(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword) {
-        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
-        LambdaQueryWrapper<Pole> wrapper = Wrappers.lambdaQuery(Pole.class).orderByDesc(Pole::getId);
-        if (StrUtil.isNotBlank(keyword)) {
-            wrapper.like(Pole::getPoleCode, keyword)
-                    .or(lampPostLambdaQueryWrapper -> {
-                        lampPostLambdaQueryWrapper.like(Pole::getPoleName, keyword);
-                    });
+    @PostMapping("/list")
+    public ResponseVO<Object> listPole(BaseConditionVO baseConditionVO, @RequestBody PoleStatesParam param) {
+        if(!permissionConfig.check(MenuEnum.POLE_LIST.getCode())){
+            return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
         }
-        List<Pole> list = poleService.list(wrapper);
-        return ResponseUtil.successPage(list);
+        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+        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("/listPoleAndState")
-    public ResponseVO<Object> listPoleAndState(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword) {
+    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());
-
-        List<Pole> poles = poleService.queryStatesAndList(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+        List<Pole> poles = poleService.queryStatesAndList(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(),keyword,groupid);
         return ResponseUtil.successPage(poles);
+    }
+
+    /**
+     * 鍦ㄧ嚎鏁伴噺
+     */
+    @GetMapping("/online")
+    public ResponseVO<Object> online() {
+        return ResponseUtil.success(poleService.poleCount());
     }
 
 
@@ -203,4 +214,31 @@
     }
 
 
+    /**
+     * 鏌ユ壘鑷繁鎷ユ湁鐨勭伅鏉�
+     */
+    @PostMapping("/getOwnerPole/{cilentId}")
+    public ResponseVO<Object> getOwnerPole(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword
+            ,@PathVariable Long cilentId) {
+        List<Pole> results = poleService.getOwnerPole(baseConditionVO, keyword, cilentId);
+//        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(results);
+    }
+
+    /**
+     * 鏌ョ湅鐏潌缁戝畾鐨勮澶�
+     */
+    @PostMapping("/getPoleBindDevice/{poleId}")
+    public ResponseVO<Object> getPoleBindDevice(@PathVariable Long poleId) {
+        return ResponseUtil.success(poleService.getBindByPoleId(poleId));
+    }
+
+
 }

--
Gitblit v1.9.3