diff --git a/src/main/java/com/ycwl/basic/integration/kafka/dto/FaceProcessingMessage.java b/src/main/java/com/ycwl/basic/integration/kafka/dto/FaceProcessingMessage.java
index 78f542ec..82fd46ce 100644
--- a/src/main/java/com/ycwl/basic/integration/kafka/dto/FaceProcessingMessage.java
+++ b/src/main/java/com/ycwl/basic/integration/kafka/dto/FaceProcessingMessage.java
@@ -6,7 +6,7 @@ import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
-import java.time.LocalDateTime;
+import java.util.Date;
 
 /**
  * zt-face topic消息结构
@@ -44,7 +44,7 @@ public class FaceProcessingMessage {
      * 拍摄时间
      */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
-    private LocalDateTime shotTime;
+    private Date shotTime;
 
     // status字段已移除，由系统内部管理状态
 
@@ -54,7 +54,7 @@ public class FaceProcessingMessage {
      * 消息创建时间
      */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
-    private LocalDateTime createTime;
+    private Date createTime;
 
     /**
      * 消息来源
@@ -69,14 +69,14 @@ public class FaceProcessingMessage {
      * 创建人脸处理消息的工厂方法（使用外部传入的faceId）
      */
     public static FaceProcessingMessage create(Long externalFaceId, Long scenicId, Long deviceId, 
-                                             String faceUrl, LocalDateTime shotTime) {
+                                             String faceUrl, Date shotTime) {
         return FaceProcessingMessage.builder()
                 .faceSampleId(externalFaceId) // 使用外部传入的ID作为唯一标识
                 .scenicId(scenicId)
                 .deviceId(deviceId)
                 .faceUrl(faceUrl)
                 .shotTime(shotTime)
-                .createTime(LocalDateTime.now())
+                .createTime(new Date())
                 .source("external-system")
                 .build();
     }
diff --git a/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java b/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java
index 72248f89..bab12bd5 100644
--- a/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java
+++ b/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java
@@ -88,7 +88,7 @@ public class FaceProcessingKafkaService {
             
             // 转换时间格式
             if (faceMessage.getShotTime() != null) {
-                Date shotTime = Date.from(faceMessage.getShotTime().atZone(ZoneId.systemDefault()).toInstant());
+                Date shotTime = faceMessage.getShotTime();
                 faceSample.setCreateAt(shotTime);
             } else {
                 faceSample.setCreateAt(new Date());