From cb34fb6d0b5c860d2bc7bbc083cbb1ccc08841fd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= <baifengji@163.com>
Date: Wed, 28 May 2025 15:29:35 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AE=BE=E5=A4=87=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81=E5=8A=A0=E9=94=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sgs/app/core/aspect/DeviceStateChangeAspect.java        | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/main/java/com/iflytop/sgs/app/core/aspect/DeviceStateChangeAspect.java b/src/main/java/com/iflytop/sgs/app/core/aspect/DeviceStateChangeAspect.java
index aaab584..992d730 100644
--- a/src/main/java/com/iflytop/sgs/app/core/aspect/DeviceStateChangeAspect.java
+++ b/src/main/java/com/iflytop/sgs/app/core/aspect/DeviceStateChangeAspect.java
@@ -8,8 +8,12 @@ import lombok.extern.slf4j.Slf4j;
 import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.annotation.After;
 import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
 import org.springframework.stereotype.Component;
 
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
 @Slf4j
 @Aspect
 @Component
@@ -18,6 +22,13 @@ public class DeviceStateChangeAspect {
     private final WebSocketSender webSocketService;
     private final DeviceStateService deviceStateService;
 
+    private final Lock lock = new ReentrantLock();
+
+    @Before("execution(* com.iflytop.sgs.app.model.bo.status..set*(..))")
+    public void beforeSetMethod(JoinPoint joinPoint) {
+        lock.lock();
+    }
+
     @After("execution(* com.iflytop.sgs.app.model.bo.status.device.*.set*(..))")
     public void afterSetMethod(JoinPoint joinPoint) {
         try {
@@ -32,6 +43,8 @@ public class DeviceStateChangeAspect {
             }
         } catch (Exception e) {
             log.error("处理状态变更后的值失败", e);
+        } finally {
+            lock.unlock();
         }
     }
 }