From e321dcd6522dcd3417eec1a564890642b8eddeeb Mon Sep 17 00:00:00 2001
From: daiyongfei <974332738@qq.com>
Date: Fri, 18 Jul 2025 10:23:04 +0800
Subject: [PATCH 1/4] =?UTF-8?q?=20=E4=BF=AE=E6=94=B9=E5=AE=A2=E6=88=B7?=
 =?UTF-8?q?=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../customer/service/impl/CustomerServiceImpl.java           | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/service/impl/CustomerServiceImpl.java b/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/service/impl/CustomerServiceImpl.java
index 49baa0b..ac996d4 100644
--- a/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/service/impl/CustomerServiceImpl.java
+++ b/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/service/impl/CustomerServiceImpl.java
@@ -112,6 +112,11 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> i
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void updateCustomer(Customer resources) throws Exception {
+        if (resources.getEnabled()) {
+            resources.setStatus("0");
+        } else {
+            resources.setStatus("1");
+        }
         saveOrUpdate(resources);
     }
 

From 0fa0e4ab1b36fff43b54f27298c6bb370c658ea2 Mon Sep 17 00:00:00 2001
From: daiyongfei <974332738@qq.com>
Date: Fri, 18 Jul 2025 10:36:02 +0800
Subject: [PATCH 2/4] =?UTF-8?q?=E5=B8=90=E5=8F=B7=E7=8A=B6=E6=80=81?=
 =?UTF-8?q?=EF=BC=880=E6=AD=A3=E5=B8=B8=201=E5=81=9C=E7=94=A8=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/fuyuanshen/customer/domain/vo/ConsumerVo.java  | 6 ++++++
 .../src/main/resources/mapper/customer/CustomerMapper.xml   | 2 +-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/vo/ConsumerVo.java b/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/vo/ConsumerVo.java
index d17971c..ea1b54a 100644
--- a/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/vo/ConsumerVo.java
+++ b/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/vo/ConsumerVo.java
@@ -58,6 +58,12 @@ public class ConsumerVo  extends TenantEntity {
     @Schema(name = "是否启用")
     private Boolean enabled;
 
+    /**
+     * 帐号状态（0正常 1停用）
+     */
+    @Schema(name = "帐号状态（0正常 1停用）")
+    private String status;
+
     @Schema(name = "是否为admin账号", hidden = true)
     private Boolean isAdmin = false;
 
diff --git a/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml b/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml
index 885753d..c0c229c 100644
--- a/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml
+++ b/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml
@@ -94,7 +94,7 @@
     <!-- 分页查询客户 -->
     <select id="findCustomers" resultType="com.fuyuanshen.customer.domain.Customer">
         select
-        u.user_id as customerId, u.nick_name , u.user_name, u.enabled, u.create_time
+        u.user_id as customerId, u.nick_name , u.user_name, u.enabled, u.create_time,u.status
         from sys_user u
         <where>
             <if test="criteria.ids != null and !criteria.ids.isEmpty()">

From 34188f20dd7c74c59cf31381bd28ac34b320374b Mon Sep 17 00:00:00 2001
From: daiyongfei <974332738@qq.com>
Date: Fri, 18 Jul 2025 11:18:30 +0800
Subject: [PATCH 3/4] =?UTF-8?q?=E5=B8=90=E5=8F=B7=E7=8A=B6=E6=80=81?=
 =?UTF-8?q?=EF=BC=880=E6=AD=A3=E5=B8=B8=201=E5=81=9C=E7=94=A8=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../customer/domain/query/UserQueryCriteria.java     |  6 ++++++
 .../resources/mapper/customer/CustomerMapper.xml     | 12 ++++++------
 2 files changed, 12 insertions(+), 6 deletions(-)

diff --git a/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/query/UserQueryCriteria.java b/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/query/UserQueryCriteria.java
index c454b4a..94526cf 100644
--- a/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/query/UserQueryCriteria.java
+++ b/fys-modules/fys-customer/src/main/java/com/fuyuanshen/customer/domain/query/UserQueryCriteria.java
@@ -50,6 +50,12 @@ public class UserQueryCriteria extends BaseEntity {
     @Schema(name = "是否启用")
     private Boolean enabled;
 
+    /**
+     * 帐号状态（0正常 1停用）
+     */
+    @Schema(name = "帐号状态（0正常 1停用）")
+    private String status;
+
     @Schema(name = "部门ID")
     private Long deptId;
 
diff --git a/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml b/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml
index c0c229c..21e91bc 100644
--- a/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml
+++ b/fys-modules/fys-customer/src/main/resources/mapper/customer/CustomerMapper.xml
@@ -68,8 +68,8 @@
             <if test="criteria.id != null">
                 and u1.user_id = #{criteria.id}
             </if>
-            <if test="criteria.enabled != null">
-                and u1.enabled = #{criteria.enabled}
+            <if test="criteria.status != null">
+                and u.status = #{criteria.status}
             </if>
             <if test="criteria.deptIds != null and criteria.deptIds.size() != 0">
                 and u1.dept_id in
@@ -109,8 +109,8 @@
             <if test="criteria.blurry != null and criteria.blurry.trim() != ''">
                 and u.nick_name like concat('%', TRIM(#{criteria.blurry}), '%')
             </if>
-            <if test="criteria.enabled != null">
-                and u.enabled = #{criteria.enabled}
+            <if test="criteria.status != null">
+                and u.status = #{criteria.status}
             </if>
             <if test="criteria.params.beginTime != null and criteria.params.endTime != null">
                 and u.create_time between #{criteria.params.beginTime} and #{criteria.params.endTime}
@@ -139,8 +139,8 @@
             <if test="criteria.blurry != null and criteria.blurry.trim() != ''">
                 and u.nick_name like concat('%', TRIM(#{criteria.blurry}), '%')
             </if>
-            <if test="criteria.enabled != null">
-                and u.enabled = #{criteria.enabled}
+            <if test="criteria.status != null">
+                and u.status = #{criteria.status}
             </if>
             <if test="criteria.params.beginTime != null and criteria.params.endTime != null">
                 and u.create_time between #{criteria.params.beginTime} and #{criteria.params.endTime}

From ad0681174768f84d97510156db3c5526ea0c2c8d Mon Sep 17 00:00:00 2001
From: daiyongfei <974332738@qq.com>
Date: Fri, 18 Jul 2025 15:06:39 +0800
Subject: [PATCH 4/4] =?UTF-8?q?=E6=92=A4=E5=9B=9E=E8=AE=BE=E5=A4=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../equipment/domain/DeviceAssignments.java   |  2 +-
 .../service/impl/DeviceServiceImpl.java       | 55 ++-----------------
 2 files changed, 5 insertions(+), 52 deletions(-)

diff --git a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAssignments.java b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAssignments.java
index 071cb5a..e3ea3ce 100644
--- a/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAssignments.java
+++ b/fys-modules/fys-equipment/src/main/java/com/fuyuanshen/equipment/domain/DeviceAssignments.java
@@ -34,7 +34,7 @@ public class DeviceAssignments extends TenantEntity {
     private Long fromCustomerId;
 
     /**
-     * 接收方
+     * 接收方(当前设备所处位置)
      */
     private Long toCustomerId;
 
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 f0d1072..f9baab1 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
@@ -44,6 +44,7 @@ import com.fuyuanshen.system.domain.vo.SysOssVo;
 import com.fuyuanshen.system.service.ISysOssService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.ss.formula.functions.T;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -319,9 +320,9 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> impleme
         List<DeviceTypeGrants> deviceTypeGrants = new ArrayList<>();
         for (DeviceAssignments assignment : assignments) {
 
-            if (assignment.getToCustomerId() != null) {
+            if (assignment.getToCustomerId() != null && assignment.getToCustomerId() != 0L) {
                 log.info("设备已经分配客户！！！");
-                continue;
+                throw new RuntimeException("设备已经分配客户！！！");
             }
 
             Device device = deviceMapper.selectById(assignment.getDeviceId());
@@ -412,54 +413,6 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> impleme
     }
 
 
-    /**
-     * 撤回设备
-     *
-     * @param ids
-     */
-    // @Override
-    // public void withdrawDevice(List<Long> ids) {
-    //     ids.forEach((id) -> {
-    //         List<Device> deviceChain = getDeviceChain(id);
-    //         deviceChain.forEach((device) -> {
-    //             device.setDeviceStatus(DeviceStatusEnum.INVALID.getCode());
-    //             deviceMapper.updateById(device);
-    //         });
-    //     });
-    //
-    //     ids.forEach((id) -> {
-    //         Device device = new Device();
-    //         device.setId(id);
-    //         device.setCustomerId(null);
-    //         device.setCustomerName("");
-    //         deviceMapper.updateById(device);
-    //     });
-    //
-    // }
-    //
-    //
-    // public List<Device> getDeviceChain(Long originalDeviceId) {
-    //     List<Device> chain = new ArrayList<>();
-    //     Set<Long> visited = new HashSet<>(); // 防止循环引用
-    //     findNext(chain, visited, originalDeviceId);
-    //     return chain;
-    // }
-    //
-    // private void findNext(List<Device> chain, Set<Long> visited, Long currentOriginalDeviceId) {
-    //     if (visited.contains(currentOriginalDeviceId)) {
-    //         log.info("检测到循环引用，终止递归");
-    //         return;
-    //     }
-    //     visited.add(currentOriginalDeviceId);
-    //
-    //     List<Device> devices = deviceMapper.findByOriginalDeviceId(currentOriginalDeviceId);
-    //     for (Device device : devices) {
-    //         chain.add(device);
-    //         findNext(chain, visited, device.getId());
-    //     }
-    // }
-
-
     /**
      * 撤回设备
      *
@@ -474,7 +427,7 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> impleme
             Device device = deviceMapper.selectById(assignment.getDeviceId());
             // 接收者
             assignment.setAssigneeName("");
-            assignment.setToCustomerId(null);
+            assignment.setToCustomerId(0L);
             deviceAssignmentsMapper.updateById(assignment);
 
             // 获取所有已分配的设备