You've already forked FrameTour-BE
refactor(kafka): 统一时人脸消息时间类型为Date
- 将FaceProcessingMessage中的LocalDateTime替换为Date类型- 更新消息创建工厂方法以使用Date参数 - 调整Kafka服务中时间转换逻辑以匹配新类型 - 移除LocalDateTime相关的导入和引用- 更新字段注释以反映新的时间类型
This commit is contained in:
@@ -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();
|
||||
}
|
||||
|
@@ -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());
|
||||
|
Reference in New Issue
Block a user