From 09e376e089173b6c58acceaaea7995184ac1ff30 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Thu, 25 Sep 2025 18:09:17 +0800
Subject: [PATCH] =?UTF-8?q?refactor(kafka):=20=E7=BB=9F=E4=B8=80=E6=97=B6?=
 =?UTF-8?q?=E4=BA=BA=E8=84=B8=E6=B6=88=E6=81=AF=E6=97=B6=E9=97=B4=E7=B1=BB?=
 =?UTF-8?q?=E5=9E=8B=E4=B8=BADate?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将FaceProcessingMessage中的LocalDateTime替换为Date类型- 更新消息创建工厂方法以使用Date参数
- 调整Kafka服务中时间转换逻辑以匹配新类型
- 移除LocalDateTime相关的导入和引用- 更新字段注释以反映新的时间类型
---
 .../integration/kafka/dto/FaceProcessingMessage.java   | 10 +++++-----
 .../kafka/service/FaceProcessingKafkaService.java      |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

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());