From fec6e6c27d484ac964684cfa47f0cc9295bd592f Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Thu, 15 Jan 2026 11:34:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=A3=85=E7=BD=AE=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81=E7=BF=BB=E8=BD=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../message/consumer/DeviceRunFlagDataConsumer.java   | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/message/message-boot/src/main/java/com/njcn/message/consumer/DeviceRunFlagDataConsumer.java b/message/message-boot/src/main/java/com/njcn/message/consumer/DeviceRunFlagDataConsumer.java
index 4d9d033..b35e4bf 100644
--- a/message/message-boot/src/main/java/com/njcn/message/consumer/DeviceRunFlagDataConsumer.java
+++ b/message/message-boot/src/main/java/com/njcn/message/consumer/DeviceRunFlagDataConsumer.java
@@ -13,6 +13,7 @@ import com.njcn.stat.api.MessAnalysisFeignClient;
 import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -82,7 +83,15 @@ public class DeviceRunFlagDataConsumer extends EnhanceConsumerMessageHandler<Dev
 
     @Override
     protected void handleMessage(DevComFlagDTO message) {
-        messAnalysisFeignClient.handleDevRunflag(message);
+        //获取之前设备状态
+        String devFalg =redisUtil.getStringByKey(RedisKeyPrefix.DEVICE_RUN_FLAG.concat(message.getId()));
+
+        if(StringUtils.isBlank(devFalg)||(!Objects.equals(Integer.valueOf(devFalg),message.getStatus()))){
+            //状态翻转
+            messAnalysisFeignClient.handleDevRunflag(message);
+        }
+
+        redisUtil.saveByKey(RedisKeyPrefix.DEVICE_RUN_FLAG.concat(message.getId()),message.getStatus()+"");
     }