From 8940316b8599319c39a5211922ca6bbe527e341c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=85=B4=E7=90=B3?= <1911390090@qq.com>
Date: Wed, 9 Apr 2025 11:25:55 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../message/device/handler/DeviceMessageHandler.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
index adc50d25..cf5b8ad6 100644
--- a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
+++ b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
@@ -5,6 +5,8 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.google.gson.Gson;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
 import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.utils.spring.SpringUtils;
 import com.zc.business.constant.RedisKeyConstants;
@@ -97,7 +99,13 @@ public class DeviceMessageHandler {
        //state 设备状态 0 异常 1 正常
         Gson gson = new Gson();
         String jsonString = gson.toJson(dcDevices);
-        kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.deviceStatus.value());
+        JsonArray jsonArray = gson.fromJson(jsonString, JsonArray.class);
+        // 创建一个新的 JSON 对象，包装一层 "data"
+        JsonObject wrappedJson = new JsonObject();
+        wrappedJson.add("data", jsonArray);
+        // 将新的 JSON 对象转换为字符串
+        String wrappedJsonString = gson.toJson(wrappedJson);
+        kafkaTopicProducer.KafkaTopicProducer(wrappedJsonString, KafkEnum.deviceStatus.value());
 
        // 批量更新中间库设备状态
         middleDatabaseService.updateMiddleDatabaseDeviceByList(dcDevices);