From e55c8b0a92eb9715edd90c31dfd4de51a47b588b Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 04 十一月 2022 17:40:08 +0800
Subject: [PATCH] changes

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleGroupService.java |   82 +++++++++++++++++++++++++++++++++-------
 1 files changed, 67 insertions(+), 15 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleGroupService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleGroupService.java
index edcea02..1cc7691 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleGroupService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleGroupService.java
@@ -1,11 +1,15 @@
 package com.sandu.ximon.admin.service;
 
 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.service.impl.BaseServiceImpl;
-import com.sandu.ximon.admin.param.PoleGroupParam;
+import com.sandu.ximon.admin.param.GroupParam;
 import com.sandu.ximon.admin.security.SecurityUtils;
 import com.sandu.ximon.dao.domain.PoleGroup;
+import com.sandu.ximon.dao.domain.PoleGroupRelation;
+import com.sandu.ximon.dao.enums.OrderByEnums;
 import com.sandu.ximon.dao.mapper.PoleGroupMapper;
 import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
@@ -23,14 +27,16 @@
 
     private final PoleGroupRelationService poleGroupRelationService;
 
-    public boolean addGroup(PoleGroupParam param) {
+    public boolean addGroup(GroupParam param) {
         PoleGroup group = new PoleGroup();
-        group.setClientId(SecurityUtils.getClientId());
+        if (SecurityUtils.getClientId() != null) {
+            group.setClientId(SecurityUtils.getUserId());
+        }
         group.setGroupName(param.getGroupName());
         return save(group);
     }
 
-    public boolean updateGroup(Long groupId, PoleGroupParam param) {
+    public boolean updateGroup(Long groupId, GroupParam param) {
         PoleGroup poleGroup = getById(groupId);
         if (poleGroup == null) {
             throw new BusinessException("鏈壘鍒拌鍒嗙粍");
@@ -41,31 +47,77 @@
         return updateById(update);
     }
 
-    public boolean deleteGroup(Long groupId) {
-        PoleGroup poleGroup = getById(groupId);
-        if (poleGroup == null) {
+    public boolean deleteGroup(List<Long> groupIds) {
+        List<PoleGroup> poleGroups = listByIds(groupIds);
+        if (poleGroups.isEmpty()) {
             throw new BusinessException("鏈壘鍒拌鍒嗙粍");
         }
-        return removeById(groupId);
+        /**
+         * 鍒櫎
+         */
+        poleGroupRelationService.remove(Wrappers.lambdaQuery(PoleGroupRelation.class).in(PoleGroupRelation::getPoleGroupId, groupIds));
+        return removeByIds(groupIds);
     }
 
-    public List<PoleGroup> groupList() {
+    public List<PoleGroup> groupList(BaseConditionVO baseConditionVO, String keyword, Integer order, Integer seq) {
         Long clientId = SecurityUtils.getClientId();
-        if (clientId == null) {
-            return list();
-        } else {
-            return list(Wrappers.lambdaQuery(PoleGroup.class).eq(PoleGroup::getClientId, clientId));
+
+        //鎺掑簭瀛楁
+        String orderByResult = "group_id";
+        //姝ｅ簭銆佸�掑彊
+        String orderBySeq = OrderByEnums.ASC.getCode();
+        if (order != null) {
+            switch (order) {
+                case 1:
+                    orderByResult = OrderByEnums.POLE_GROUP_UPDATE_TIME.getCode();
+                    break;
+                case 2:
+                    orderByResult = OrderByEnums.POLE_GROUP_CREATE_TIME.getCode();
+                    break;
+                default:
+            }
         }
+        if (seq != null) {
+            switch (seq) {
+                case 1:
+                    orderBySeq = OrderByEnums.ASC.getCode();
+                    break;
+                case 2:
+                    orderBySeq = OrderByEnums.DESC.getCode();
+                    break;
+                default:
+                    break;
+            }
+        }
+        //鎺掑簭鏂瑰紡
+        String orderBy = orderByResult + " " + orderBySeq;
+
+        if (baseConditionVO != null) {
+            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(), orderBy);
+        }
+
+        List<PoleGroup> list;
+        if (clientId == null) {
+            list = list(Wrappers.lambdaQuery(PoleGroup.class).like(PoleGroup::getGroupName, keyword));
+
+        } else {
+            list = list(Wrappers.lambdaQuery(PoleGroup.class).eq(PoleGroup::getClientId, clientId).like(PoleGroup::getGroupName, keyword));
+        }
+
+        list.forEach(poleGroup -> {
+            poleGroup.setPoleCount(poleGroupRelationService.list(Wrappers.lambdaQuery(PoleGroupRelation.class).eq(PoleGroupRelation::getPoleGroupId, poleGroup.getGroupId())).size());
+        });
+        return list;
     }
 
     /**
      * 缁戝畾鐏潌
      */
-    public boolean bindPole(Long groupId,List<Long> poleIdList) {
+    public boolean bindPole(Long groupId, List<Long> poleIdList) {
         PoleGroup poleGroup = getById(groupId);
         if (poleGroup == null) {
             throw new BusinessException("鏈壘鍒拌鍒嗙粍");
         }
-        return poleGroupRelationService.saveBinding(groupId,poleIdList);
+        return poleGroupRelationService.saveBinding(groupId, poleIdList);
     }
 }

--
Gitblit v1.9.3