diff --git a/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java b/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java
index e8ad62b0..3189ffd2 100644
--- a/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java
+++ b/zc-business/src/main/java/com/zc/business/controller/CodeScanningAlarmController.java
@@ -3,6 +3,7 @@ package com.zc.business.controller;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
 import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.utils.StringUtils;
@@ -103,7 +104,9 @@ public class CodeScanningAlarmController extends BaseController {
             dcWarning.setWarningSource(UniversalEnum.FIVE.getNumber());
             dcWarning.setWarningState(UniversalEnum.ONE.getNumber());
             //todo  推送kafak扫码报警事件
-            Gson gson = new Gson();
+            Gson gson = new GsonBuilder()
+                    .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                    .create();
             String jsonString = gson.toJson(dcWarning);
             KafkaTopicProducer kafkaTopicProducer = SpringUtils.getBean(KafkaTopicProducer.class);
             kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.scanAlarm.value());
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 cf5b8ad6..442c8ddb 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,7 @@ 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.GsonBuilder;
 import com.google.gson.JsonArray;
 import com.google.gson.JsonObject;
 import com.ruoyi.common.core.redis.RedisCache;
@@ -97,7 +98,9 @@ public class DeviceMessageHandler {
         WebSocketService.broadcast(WebSocketEvent.DEVICE_STATE, dcDevices); //推送设备状态更新
         //kafka消息推送
        //state 设备状态 0 异常 1 正常
-        Gson gson = new Gson();
+        Gson gson = new GsonBuilder()
+                .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                .create();
         String jsonString = gson.toJson(dcDevices);
         JsonArray jsonArray = gson.fromJson(jsonString, JsonArray.class);
         // 创建一个新的 JSON 对象，包装一层 "data"
@@ -240,7 +243,9 @@ public class DeviceMessageHandler {
             dcWarningService.insertDcWarning(dcWarning);
 
             //kafka消息推送 毫米波雷达
-            Gson gson = new Gson();
+            Gson gson = new GsonBuilder()
+                    .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                    .create();
             String jsonString = gson.toJson(dcWarning);
             kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.millimeterWaveRadar.value());
 
@@ -385,7 +390,9 @@ public class DeviceMessageHandler {
                     dcWarningService.insertDcWarning(dcWarning);
                     //kafka消息推送
                     // 使用Gson将对象转换为JSON字符串
-                    Gson gson = new Gson();
+                    Gson gson = new GsonBuilder()
+                            .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                            .create();
                     String jsonString = gson.toJson(dcWarning);
                     kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.videoAI.value());
                 }
@@ -393,7 +400,9 @@ public class DeviceMessageHandler {
                 dcWarningService.insertDcWarning(dcWarning);
                 //kafka消息推送
                 // 使用Gson将对象转换为JSON字符串
-                Gson gson = new Gson();
+                Gson gson = new GsonBuilder()
+                        .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                        .create();
                 String jsonString = gson.toJson(dcWarning);
                 kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.videoAI.value());
 
@@ -611,7 +620,9 @@ public class DeviceMessageHandler {
             dcWarning.setOtherConfig(dataJsonObject.toJSONString());
             dcWarningService.insertDcWarning(dcWarning);
             //kafka消息推送 护栏碰撞
-            Gson gson = new Gson();
+            Gson gson = new GsonBuilder()
+                    .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                    .create();
             String jsonString = gson.toJson(dcWarning);
             kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.guardrailCollision.value());
 
@@ -744,7 +755,9 @@ public class DeviceMessageHandler {
         //todo  推送kafak事件消息 气象检测器
         //kafka消息推送
         // 使用Gson将对象转换为JSON字符串
-        Gson gson = new Gson();
+        Gson gson = new GsonBuilder()
+                .setDateFormat("yyyy-MM-dd HH:mm:ss")
+                .create();
         String jsonString = gson.toJson(meteorologicalDetectorData);
         kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.weather.value());