From d35545d88b9123b92b50aaf1b0fa4e3f20fd2209 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期五, 20 五月 2022 11:23:50 +0800
Subject: [PATCH] 摄像头

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/ClientService.java |  254 ++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 232 insertions(+), 22 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ClientService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ClientService.java
index e6bd78d..8555241 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ClientService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/ClientService.java
@@ -2,17 +2,28 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.sandu.common.enums.RoleLevelStatus;
 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.ClientPrarm;
+import com.sandu.common.util.SpringContextHolder;
+import com.sandu.ximon.admin.param.AddClientPrarm;
+import com.sandu.ximon.admin.param.PwdParam;
+import com.sandu.ximon.admin.param.UpdateClientPrarm;
+import com.sandu.ximon.admin.param.UserPwsParm;
 import com.sandu.ximon.admin.security.SecurityUtils;
+import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
+import com.sandu.ximon.dao.bo.MenuNode;
 import com.sandu.ximon.dao.domain.Client;
+import com.sandu.ximon.dao.domain.ClientRoleRelation;
+import com.sandu.ximon.dao.domain.Role;
+import com.sandu.ximon.dao.domain.RoleMenuRelation;
 import com.sandu.ximon.dao.mapper.ClientMapper;
 import lombok.AllArgsConstructor;
 import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
 
 @Service
@@ -21,35 +32,84 @@
 
     private final ClientMapper clientMapper;
     private final PasswordEncoder passwordEncoder;
+    private final ClientRoleRelationService clientRoleRelationService;
+    private final RoleService roleService;
 
 
-    public boolean addClient(ClientPrarm clientPrarm) {
+    public boolean addClient(AddClientPrarm addClientPrarm) {
 
-        if (getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, clientPrarm.getClientName().trim())) != null) {
+        if (getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, addClientPrarm.getClientName().trim())) != null) {
             throw new BusinessException("璇ョ敤鎴峰悕宸插瓨鍦紒");
         }
+        Long userId = SecurityUtils.getUserId();
+        boolean clientId = findClientId();
+        //鍒ゆ柇鏄惁涓轰簩绾у鎴�  濡傛灉鏄簩绾у鎴峰垯涓嶈兘缁х画娣诲姞   涓�绾у鎴蜂负FALSE
+        if (SecurityUtils.getClientId() != null && clientId) {
+            throw new BusinessException("鏉冮檺涓嶈冻,浜岀骇瀹㈡埛涓嶈兘鏂板鐢ㄦ埛锛�");
+        }
+
 
         Client client = new Client();
-        if (clientPrarm.getClientSuperior() != null && !"".equals(clientPrarm.getClientSuperior())) {
-            Client one = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, clientPrarm.getClientSuperior()));
+
+        if (SecurityUtils.getClientId() != null && !clientId) {
+            //涓�绾у鎴锋柊澧炵敤鎴锋椂 榛樿涓鸿嚜宸卞悕涓嬬殑浜岀骇瀹㈡埛
+            client.setSuperiorId(SecurityUtils.getUserId());
+            client.setClientSuperior(addClientPrarm.getClientSuperior());
+        } else if (addClientPrarm.getClientSuperior() != null && !"".equals(addClientPrarm.getClientSuperior())) {
+            //瓒呯
+            Client one = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, addClientPrarm.getClientSuperior()));
             if (one != null) {
-                client.setSuperiorId(one.getId());
+                if (one.getSuperiorId() == null) {
+                    client.setSuperiorId(one.getId());
+                    client.setClientSuperior(addClientPrarm.getClientSuperior());
+                } else {
+                    throw new BusinessException("涓婄骇瀹㈡埛涓嶈兘涓轰簩绾х敤鎴�");
+                }
             } else {
                 throw new BusinessException("涓婄骇瀹㈡埛涓嶅瓨鍦�");
             }
         }
-        client.setClientName(clientPrarm.getClientName());
-        client.setLinkMan(clientPrarm.getLinkMan());
-        client.setMobile(clientPrarm.getMobile());
-        client.setClientSuperior(clientPrarm.getClientSuperior());
-        client.setPassword(passwordEncoder.encode(clientPrarm.getPassword()));
+
+        Role role = roleService.getById(addClientPrarm.getRoleId());
+        if (role == null) {
+            throw new BusinessException("瑙掕壊涓嶅瓨鍦�");
+        }
+        if (!RoleLevelStatus.NORMAL.getCode().equals(role.getLevel())) {
+            throw new BusinessException("鏃犳硶娣诲姞瓒呯骇绠$悊鍛樻垨鐢ㄦ埛绠$悊鍛�");
+        }
 
 
-        return save(client);
+        client.setClientName(addClientPrarm.getClientName());
+        client.setLinkMan(addClientPrarm.getLinkMan());
+//        client.setClientSuperior(addClientPrarm.getClientSuperior());
+        client.setMobile(addClientPrarm.getMobile());
+        if (SecurityUtils.getClientId() != null && clientId) {
+            client.setClientSuperior(SecurityUtils.getUsername());
+        }
+        client.setPassword(passwordEncoder.encode(addClientPrarm.getPassword()));
+        boolean flag = save(client);
+
+        ClientRoleRelation clientRoleRelation = new ClientRoleRelation();
+        clientRoleRelation.setClientId(client.getId());
+        clientRoleRelation.setRoleId(addClientPrarm.getRoleId());
+        if (!clientRoleRelationService.save(clientRoleRelation)) {
+            throw new BusinessException("娣诲姞绠$悊鍛樿鑹插け璐�");
+        }
+
+        /**
+         * 娣诲姞鏅�氱敤鎴� 鏃ュ織璁板綍寮�濮�
+         */
+        String content = "鏂版敞鍐岀敤鎴凤細" + addClientPrarm.getClientName();
+        StoreOperationRecordsUtils.storeOperationData(null, null, "娣诲姞鏅�氱敤鎴�", content);
+        /**
+         * 娣诲姞鏅�氱敤鎴� 鏃ュ織璁板綍缁撴潫
+         */
+
+        return flag;
     }
 
 
-    public boolean updateClient(Long id, ClientPrarm clientPrarm) {
+    public boolean updateClient(Long id, UpdateClientPrarm updateClientPrarm) {
         //鍒ゆ柇鐢ㄦ埛鏄惁瀛樺湪
         Client one = getById(id);
         if (one == null) {
@@ -57,31 +117,96 @@
         }
 
         //鍒ゆ柇鐢ㄦ埛鍚嶆槸鍚﹂噸澶�
-        if (getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, clientPrarm.getClientName().trim())) != null) {
+        Client client1 = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, updateClientPrarm.getClientName().trim()));
+        if (client1 != null && !client1.getId().equals(one.getId())) {
             throw new BusinessException("璇ョ敤鎴峰悕宸插瓨鍦紒");
         }
+
         //鍒ゆ柇涓婄骇鐢ㄦ埛鏄惁瀛樺湪
+        boolean clientId = findClientId();
+        Long userId = SecurityUtils.getUserId();
+        //鍒ゆ柇鏇存敼鐨勭敤鎴锋槸鍚︽槸灞炰簬鑷繁鍚嶄笅鐨勪簩绾у鎴�
+        if (SecurityUtils.getClientId() != null && !clientId) {
+            if (SecurityUtils.getUserId() != one.getSuperiorId()) {
+                throw new BusinessException("鏉冮檺涓嶈冻锛屼笉鑳芥洿鏀瑰叾浠栧鎴风殑鎵�灞炲鎴蜂俊鎭紒");
+            }
+        }
+
         Client client = new Client();
-        if (clientPrarm.getClientSuperior() != null) {
-            Client superior = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, clientPrarm.getClientSuperior()));
+        client.setClientName(updateClientPrarm.getClientName());
+        if (SecurityUtils.getClientId() != null && clientId) {
+            //涓�绾у鎴锋柊澧炵敤鎴锋椂 榛樿涓鸿嚜宸卞悕涓嬬殑浜岀骇瀹㈡埛
+            client.setSuperiorId(SecurityUtils.getUserId());
+            client.setClientSuperior(updateClientPrarm.getClientSuperior());
+        } else if (updateClientPrarm.getClientSuperior() != null && updateClientPrarm.getClientSuperior().trim().length() != 0) {
+            //瓒呯
+            Client superior = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getClientName, updateClientPrarm.getClientSuperior()));
             if (superior != null) {
                 if (superior.getId().equals(one.getId())) {
                     throw new BusinessException("涓婄骇瀹㈡埛涓烘湰璐︽埛锛�");
                 } else {
                     client.setSuperiorId(superior.getId());
+                    client.setClientSuperior(updateClientPrarm.getClientSuperior());
                 }
             } else {
                 throw new BusinessException("涓婄骇瀹㈡埛涓嶅瓨鍦�");
             }
         }
         client.setId(id);
-        client.setClientName(clientPrarm.getClientName());
-        client.setLinkMan(clientPrarm.getLinkMan());
-        client.setMobile(clientPrarm.getMobile());
-        client.setClientSuperior(clientPrarm.getClientSuperior());
-        client.setPassword(passwordEncoder.encode(clientPrarm.getPassword()));
+//        client.setClientName(updateClientPrarm.getClientName());
+        client.setLinkMan(updateClientPrarm.getLinkMan());
+        client.setMobile(updateClientPrarm.getMobile());
 
-        // update(client);
+        /**
+         * 缂栬緫鏅�氱敤鎴� 鏃ュ織璁板綍寮�濮�
+         */
+        String content = "缂栬緫鏅�氱敤鎴凤細" + client.getClientName() + "鐢ㄦ埛id锛�" + id;
+        StoreOperationRecordsUtils.storeOperationData(null, null, "缂栬緫鏅�氱敤鎴�", content);
+        /**
+         * 缂栬緫鏅�氱敤鎴� 鏃ュ織璁板綍缁撴潫
+         */
+        return updateById(client);
+    }
+
+    /**
+     * 淇敼褰撳墠鐧诲綍鐢ㄦ埛瀵嗙爜
+     *
+     * @param param
+     * @return
+     */
+    public boolean resetPassword(PwdParam param) {
+
+        Client client = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getId, SecurityUtils.getUserDetails().getUserId()));
+
+        if (client == null) {
+            throw new BusinessException("璇ョ敤鎴蜂笉瀛樺湪锛�");
+        }
+
+        //鍒ゆ柇鏃у瘑鐮佷笌鏁版嵁搴撴槸鍚︿竴鑷�
+        if (passwordEncoder.matches(param.getOldPass(), client.getPassword())) {
+            //鍔犲瘑鏂板瘑鐮�
+            String encode = passwordEncoder.encode(param.getNewPass());
+            client.setPassword(encode);
+            return updateById(client);
+        } else {
+            throw new BusinessException("鏃у瘑鐮佷笉姝g‘锛岃閲嶆柊纭瀵嗙爜锛�");
+        }
+    }
+
+    /**
+     * 淇敼绠$悊鍛樼殑瀵嗙爜
+     *
+     * @param param
+     * @return
+     */
+    public boolean updateAdminPassword(UserPwsParm param) {
+        Client client = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getId, param.getUserid()));
+        if (client == null) {
+            throw new BusinessException("鐢ㄦ埛涓嶅瓨鍦�");
+        }
+
+        //鍔犲瘑鏂板瘑鐮�
+        client.setPassword(passwordEncoder.encode(param.getNewPass()));
         return updateById(client);
     }
 
@@ -98,6 +223,14 @@
         if (list != null && list.size() != 0) {
             throw new BusinessException("鍒犻櫎鐨勭敤鎴蜂笅鏈変笅绾х敤鎴凤紝涓嶅厑璁稿垹闄�");
         }
+        /**
+         * 鍒犻櫎鏅�氱敤鎴� 鏃ュ織璁板綍寮�濮�
+         */
+        String content = "鍒犻櫎鏅�氱敤鎴凤細" + one.getClientName() + "鐢ㄦ埛id锛�" + id;
+        StoreOperationRecordsUtils.storeOperationData(null, null, "鍒犻櫎鏅�氱敤鎴�", content);
+        /**
+         * 鍒犻櫎鏅�氱敤鎴� 鏃ュ織璁板綍缁撴潫
+         */
 
         return removeById(id);
     }
@@ -129,6 +262,23 @@
     }
 
     /**
+     * \
+     * 鍏朵粬绫荤敤鏉ユ煡鎵惧鎴穒d浣跨敤  濡傛灉娌℃湁涓婄骇瀹㈡埛 杩欒繑鍥炵敤鎴稩D
+     *
+     * @param
+     * @return
+     */
+    public Long getClientId(Long userId) {
+        Client one = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getId, userId));
+        if (one != null && one.getSuperiorId() != null) {
+            return one.getSuperiorId();
+        } else {
+            return userId;
+        }
+
+    }
+
+    /**
      * 涓�绾у鎴疯繑鍥瀎alse  浜岀骇瀹㈡埛杩斿洖true
      *
      * @return
@@ -143,4 +293,64 @@
         }
 
     }
+
+    /**
+     * 涓�绾у鎴疯繑鍥瀎alse  浜岀骇瀹㈡埛杩斿洖true
+     *
+     * @return
+     */
+    public boolean findClientId(Long userId) {
+        Client one = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getId, userId));
+        if (one != null && one.getSuperiorId() != null) {
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+    /**
+     * 淇敼鏅�氱敤鎴峰ご鍍�
+     *
+     * @param userId
+     * @param IconUrl
+     * @return
+     */
+    public boolean updateIcon(Long userId, String IconUrl) {
+        Client one = getOne(Wrappers.lambdaQuery(Client.class).eq(Client::getId, userId));
+        if (one == null) {
+            throw new BusinessException("鐢ㄦ埛涓嶅瓨鍦�");
+        }
+        one.setIcon(IconUrl);
+        return updateById(one);
+    }
+
+    /**
+     * 鑾峰彇鐢ㄦ埛鏉冮檺鍒楄〃鍦�
+     */
+    public List<MenuNode> getUserPermissionList() {
+        //閫氳繃鐢ㄦ埛UserID鑾峰彇鐢ㄦ埛瑙掕壊
+        ClientRoleRelation one = SpringContextHolder.getBean(ClientRoleRelationService.class).
+                getOne(Wrappers.lambdaQuery(ClientRoleRelation.class).eq(ClientRoleRelation::getClientId, SecurityUtils.getUserId()));
+        //鍒ょ┖
+        if (one == null) {
+            throw new BusinessException("璇ョ敤鎴锋湭缁戝畾瑙掕壊");
+        }
+
+        //閫氳繃RoleID鑾峰彇MeunId鍒楄〃
+        List<RoleMenuRelation> menuIdList = SpringContextHolder.getBean(RoleMenuRelationService.class)
+                .list(Wrappers.lambdaQuery(RoleMenuRelation.class).eq(RoleMenuRelation::getRoleId, one.getRoleId()));
+
+        //鍒ょ┖
+        if (menuIdList.isEmpty()) {
+            return new ArrayList<>();
+        }
+
+        List<Long> menuIds = new ArrayList<>(menuIdList.size());
+        for (RoleMenuRelation bean : menuIdList) {
+            menuIds.add(bean.getMenuId());
+        }
+
+        List<MenuNode> resultList = SpringContextHolder.getBean(MenuService.class).getUserPermissionListById(menuIds);
+        return resultList;
+    }
 }

--
Gitblit v1.9.3