From e6d0e883fb0df0b90a9bf048fc5325e5b07a7d94 Mon Sep 17 00:00:00 2001
From: daiyongfei <974332738@qq.com>
Date: Thu, 21 Aug 2025 16:51:17 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=A1=E7=90=86=E5=91=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../domain/query/DeviceQueryCriteria.java     |  5 +++
 .../domain/query/DeviceTypeQueryCriteria.java |  6 ++++
 .../service/impl/DeviceServiceImpl.java       |  7 +++++
 .../service/impl/DeviceTypeServiceImpl.java   | 20 +++++++++---
 .../mapper/equipment/DeviceMapper.xml         | 31 +++++++++++--------
 5 files changed, 52 insertions(+), 17 deletions(-)

diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java
index 09f9815f..d8a9505e 100644
--- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java
+++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceQueryCriteria.java
@@ -65,4 +65,9 @@ public class DeviceQueryCriteria extends BaseEntity {
 
     /* app绑定用户id */
     private Long bindingUserId;
+
+
+    /* 是否为管理员 */
+    private Boolean isAdmin = false;
+
 }
diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceTypeQueryCriteria.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceTypeQueryCriteria.java
index a2a0ad09..2beea69a 100644
--- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceTypeQueryCriteria.java
+++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/query/DeviceTypeQueryCriteria.java
@@ -35,4 +35,10 @@ public class DeviceTypeQueryCriteria extends BaseEntity implements Serializable
 
     @Schema(name = "每页数据量", example = "10")
     private Integer pageSize = 10;
+
+
+    /* 是否为管理员 */
+    private Boolean isAdmin = false;
+
+
 }
diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceServiceImpl.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceServiceImpl.java
index 92ba94ac..357a82d1 100644
--- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceServiceImpl.java
+++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceServiceImpl.java
@@ -106,6 +106,13 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> impleme
                 criteria.setDeviceType(deviceTypeGrant.getDeviceTypeId());
             }
         }
+
+        // 管理员
+        String username = LoginHelper.getUsername();
+        if (username.equals("admin")) {
+            criteria.setIsAdmin(true);
+        }
+
         IPage<Device> devices = deviceMapper.findAll(criteria, page);
 
         List<Device> records = devices.getRecords();
diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceTypeServiceImpl.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceTypeServiceImpl.java
index 8f9d7f7a..c069ddf6 100644
--- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceTypeServiceImpl.java
+++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/service/impl/DeviceTypeServiceImpl.java
@@ -53,8 +53,12 @@ public class DeviceTypeServiceImpl extends ServiceImpl<DeviceTypeMapper, DeviceT
      */
     @Override
     public TableDataInfo<DeviceType> queryAll(DeviceTypeQueryCriteria criteria, Page<DeviceType> page) {
-        criteria.setCustomerId(LoginHelper.getUserId());
-        // return
+        // 管理员
+        String username = LoginHelper.getUsername();
+        if (!username.equals("admin")) {
+            criteria.setCustomerId(LoginHelper.getUserId());
+        }
+
         IPage<DeviceType> deviceTypeIPage = deviceTypeMapper.findAll(criteria, page);
         return new TableDataInfo<DeviceType>(deviceTypeIPage.getRecords(), deviceTypeIPage.getTotal());
     }
@@ -74,8 +78,16 @@ public class DeviceTypeServiceImpl extends ServiceImpl<DeviceTypeMapper, DeviceT
     @Override
     public List<DeviceType> queryDeviceTypes() {
         DeviceTypeQueryCriteria criteria = new DeviceTypeQueryCriteria();
-        Long userId = LoginHelper.getUserId();
-        criteria.setCustomerId(userId);
+
+        // 管理员
+        String username = LoginHelper.getUsername();
+        if (!username.equals("admin")) {
+            criteria.setCustomerId(LoginHelper.getUserId());
+
+            Long userId = LoginHelper.getUserId();
+            criteria.setCustomerId(userId);
+        }
+
         return deviceTypeMapper.findAll(criteria);
     }
 
diff --git a/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml b/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml
index e5c95a31..3439362f 100644
--- a/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml
+++ b/fys-modules/fys-equipment/src/main/resources/mapper/equipment/DeviceMapper.xml
@@ -74,8 +74,11 @@
             <if test="criteria.params.beginTime != null and criteria.params.endTime != null">
                 and da.create_time between #{criteria.params.beginTime} and #{criteria.params.endTime}
             </if>
-            AND da.assignee_id = #{criteria.currentOwnerId}
-            AND dg.customer_id = #{criteria.currentOwnerId}
+            <!-- 管理员可以查看所有设备，普通用户只能查看自己的设备 -->
+            <if test="criteria.isAdmin != true">
+                AND da.assignee_id = #{criteria.currentOwnerId}
+                AND dg.customer_id = #{criteria.currentOwnerId}
+            </if>
         </where>
         ) AS ranked
         WHERE rn = 1
@@ -213,18 +216,20 @@
         WHERE original_device_id = #{originalDeviceId}
     </select>
     <select id="getDeviceInfo" resultType="com.fuyuanshen.equipment.domain.vo.AppDeviceVo">
-        select d.id, d.device_name, d.device_name,
-        d.device_name,
-        d.device_mac,
-        d.device_sn,
-        d.device_imei,
-        d.device_pic,
-        dt.type_name,
-        dt.communication_mode,
-        d.bluetooth_name,
-        dt.model_dictionary detailPageUrl
+        select d.id,
+               d.device_name,
+               d.device_name,
+               d.device_name,
+               d.device_mac,
+               d.device_sn,
+               d.device_imei,
+               d.device_pic,
+               dt.type_name,
+               dt.communication_mode,
+               d.bluetooth_name,
+               dt.model_dictionary detailPageUrl
         from device d
-        inner join device_type dt on d.device_type = dt.id
+                 inner join device_type dt on d.device_type = dt.id
         where d.device_mac = #{deviceMac}
     </select>