diff --git a/src/main/java/com/ycwl/basic/dto/ZTSourceMessage.java b/src/main/java/com/ycwl/basic/dto/ZTSourceMessage.java
index 92a63950..4cac5f0c 100644
--- a/src/main/java/com/ycwl/basic/dto/ZTSourceMessage.java
+++ b/src/main/java/com/ycwl/basic/dto/ZTSourceMessage.java
@@ -45,6 +45,9 @@ public class ZTSourceMessage {
     @JsonProperty("faceSampleId")
     private Long faceSampleId;
 
+    @JsonProperty("posJson")
+    private String posJson;
+
     /**
      * 判断是否为视频片段
      */
diff --git a/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java b/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java
index afdf3880..2e39ca51 100644
--- a/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java
+++ b/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java
@@ -42,9 +42,8 @@ public class ZTSourceConsumerService {
             sourceMessage = JacksonUtil.parseObject(message, ZTSourceMessage.class);
 
             // 输出业务相关的日志信息
-            log.info("接收到ZT-Source消息, sourceId: {}, sourceType: {}, scenicId: {}, deviceId: {}, sourceUrl: {}",
-                    sourceMessage.getSourceId(), sourceMessage.getSourceType(),
-                    sourceMessage.getScenicId(), sourceMessage.getDeviceId(), sourceMessage.getSourceUrl());
+            log.info("接收到ZT-Source消息, sourceId: {}, deviceId: {}, faceSampleId: {}",
+                    sourceMessage.getSourceId(), sourceMessage.getDeviceId(), sourceMessage.getFaceSampleId());
 
             // 处理消息
             boolean processed = ztSourceDataService.processZTSourceMessage(sourceMessage);
diff --git a/src/main/java/com/ycwl/basic/service/ZTSourceDataService.java b/src/main/java/com/ycwl/basic/service/ZTSourceDataService.java
index 3c0a6f1d..f99c2e76 100644
--- a/src/main/java/com/ycwl/basic/service/ZTSourceDataService.java
+++ b/src/main/java/com/ycwl/basic/service/ZTSourceDataService.java
@@ -109,6 +109,9 @@ public class ZTSourceDataService {
         // 人脸样本ID处理
         entity.setFaceSampleId(message.getFaceSampleId());
 
+        // 位置信息JSON处理
+        entity.setPosJson(message.getPosJson());
+
         // 时间处理
         Date shootTime = message.getShootTime();
         if (shootTime != null) {
diff --git a/src/main/resources/mapper/SourceMapper.xml b/src/main/resources/mapper/SourceMapper.xml
index ab3ae6a4..e61f9b57 100644
--- a/src/main/resources/mapper/SourceMapper.xml
+++ b/src/main/resources/mapper/SourceMapper.xml
@@ -6,8 +6,8 @@
         values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{videoUrl}, #{type}, #{faceSampleId}, #{posJson}, #{createTime})
     </insert>
     <insert id="addFromZTSource">
-        insert into source(id, scenic_id, device_id, url, `type`, face_sample_id, create_time)
-        values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{type}, #{faceSampleId}, #{createTime})
+        insert into source(id, scenic_id, device_id, url, `type`, face_sample_id, pos_json, create_time)
+        values (#{id}, #{scenicId}, #{deviceId}, #{url}, #{type}, #{faceSampleId}, #{posJson}, #{createTime})
     </insert>
     <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>)