From ceb66c0a1dcfcfdd7c331d104f66be9e033ac902 Mon Sep 17 00:00:00 2001
From: liuhaonan <konodioda2333@vip.qq.com>
Date: 星期一, 21 三月 2022 16:47:15 +0800
Subject: [PATCH] bug修复

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java |   35 +++++++++++++++++++++++++++++++++++
 1 files changed, 35 insertions(+), 0 deletions(-)

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 d591e72..c9a4119 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
@@ -8,6 +8,7 @@
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageHelper;
 import com.sandu.common.execption.BusinessException;
+import com.sandu.common.object.BaseConditionVO;
 import com.sandu.common.redis.RedisService;
 import com.sandu.common.service.impl.BaseServiceImpl;
 import com.sandu.ximon.admin.dto.DeviceStatus;
@@ -60,6 +61,7 @@
     private final RedisService redisService;
     private final PoleBindingService poleBindingService;
     private final PoleGroupRelationService groupRelationService;
+    private final ClientService clientService;
 
     public boolean addPole(PoleParam param) {
         Pole pole = new Pole();
@@ -649,4 +651,37 @@
         }
         return r;
     }
+
+
+    public List<Pole> getOwnerPole(BaseConditionVO baseConditionVO, String keyword) {
+        LambdaQueryWrapper<Pole> eq;
+        if(SecurityUtils.getClientId()!=null){
+            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+            if(clientService.findClientId()){
+                eq = Wrappers.lambdaQuery(Pole.class).eq(Pole::getUserId, SecurityUtils.getUserId());
+            }else{
+                eq = Wrappers.lambdaQuery(Pole.class).eq(Pole::getClientId, SecurityUtils.getUserId());
+            }
+
+        }else {
+            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
+            eq = Wrappers.lambdaQuery(Pole.class);
+        }
+        if (!keyword.isEmpty()){
+            eq.like(Pole::getPoleName,keyword).or(
+                    code->{
+                        code.like(Pole::getPoleCode,keyword);
+                    }
+            ).or(
+                    deviceCode->{
+                        deviceCode.like(Pole::getDeviceCode,keyword);
+                    }
+            );
+        }
+        List<Pole> list ;
+        list =list(eq);
+        setCount(list);
+        setOnline(list);
+        return list;
+    }
 }

--
Gitblit v1.9.3