feat(dto): 添加位置信息字段支持

- 在 ZTSourceMessage DTO 中新增 posJson 字段
- 更新数据库插入语句以支持 posJson 字段存储
- 调整日志输出内容,突出关键业务标识
- 在数据服务层增加对 posJson 的处理逻辑
This commit is contained in:
2025-09-27 23:09:44 +08:00
parent 9bc34fcfdb
commit f4a16b5b09
4 changed files with 10 additions and 5 deletions

View File

@@ -45,6 +45,9 @@ public class ZTSourceMessage {
@JsonProperty("faceSampleId") @JsonProperty("faceSampleId")
private Long faceSampleId; private Long faceSampleId;
@JsonProperty("posJson")
private String posJson;
/** /**
* 判断是否为视频片段 * 判断是否为视频片段
*/ */

View File

@@ -42,9 +42,8 @@ public class ZTSourceConsumerService {
sourceMessage = JacksonUtil.parseObject(message, ZTSourceMessage.class); sourceMessage = JacksonUtil.parseObject(message, ZTSourceMessage.class);
// 输出业务相关的日志信息 // 输出业务相关的日志信息
log.info("接收到ZT-Source消息, sourceId: {}, sourceType: {}, scenicId: {}, deviceId: {}, sourceUrl: {}", log.info("接收到ZT-Source消息, sourceId: {}, deviceId: {}, faceSampleId: {}",
sourceMessage.getSourceId(), sourceMessage.getSourceType(), sourceMessage.getSourceId(), sourceMessage.getDeviceId(), sourceMessage.getFaceSampleId());
sourceMessage.getScenicId(), sourceMessage.getDeviceId(), sourceMessage.getSourceUrl());
// 处理消息 // 处理消息
boolean processed = ztSourceDataService.processZTSourceMessage(sourceMessage); boolean processed = ztSourceDataService.processZTSourceMessage(sourceMessage);

View File

@@ -109,6 +109,9 @@ public class ZTSourceDataService {
// 人脸样本ID处理 // 人脸样本ID处理
entity.setFaceSampleId(message.getFaceSampleId()); entity.setFaceSampleId(message.getFaceSampleId());
// 位置信息JSON处理
entity.setPosJson(message.getPosJson());
// 时间处理 // 时间处理
Date shootTime = message.getShootTime(); Date shootTime = message.getShootTime();
if (shootTime != null) { if (shootTime != null) {

View File

@@ -6,8 +6,8 @@
values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{videoUrl}, #{type}, #{faceSampleId}, #{posJson}, #{createTime}) values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{videoUrl}, #{type}, #{faceSampleId}, #{posJson}, #{createTime})
</insert> </insert>
<insert id="addFromZTSource"> <insert id="addFromZTSource">
insert into source(id, scenic_id, device_id, url, `type`, face_sample_id, create_time) insert into source(id, scenic_id, device_id, url, `type`, face_sample_id, pos_json, create_time)
values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{type}, #{faceSampleId}, #{createTime}) values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{type}, #{faceSampleId}, #{posJson}, #{createTime})
</insert> </insert>
<insert id="addRelation"> <insert id="addRelation">
replace member_source(scenic_id, face_id, member_id, source_id, is_buy, type, order_id<if test="isFree">, is_free</if>) replace member_source(scenic_id, face_id, member_id, source_id, is_buy, type, order_id<if test="isFree">, is_free</if>)