From 3099e68a979907a92745ddc424fa7b836058f10b Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Fri, 3 Oct 2025 13:46:22 +0800
Subject: [PATCH] =?UTF-8?q?refactor(logging):=20=E8=B0=83=E6=95=B4?=
 =?UTF-8?q?=E4=BA=BA=E8=84=B8=E5=A4=84=E7=90=86=E6=9C=8D=E5=8A=A1=E4=B8=AD?=
 =?UTF-8?q?=E7=9A=84=E6=97=A5=E5=BF=97=E7=BA=A7=E5=88=AB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将接收到人脸消息的日志级别从 info 调整为 debug
- 移除了部分冗余的 info 级别日志输出
- 统一异常处理中的日志记录方式
-优化日志内容，减少不必要的信息输出
- 确保关键操作仍然保留适当日志记录- 提升系统在高并发下的日志可读性与性能
---
 .../service/FaceProcessingKafkaService.java   | 20 ++++++-------------
 .../service/ZTSourceConsumerService.java      |  2 +-
 2 files changed, 7 insertions(+), 15 deletions(-)

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 2d578740..3a727adb 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
@@ -48,7 +48,7 @@ public class FaceProcessingKafkaService {
     public void processFaceMessage(String message, Acknowledgment ack) {
         try {
             FaceProcessingMessage faceMessage = JacksonUtil.parseObject(message, FaceProcessingMessage.class);
-            log.info("接收到外部人脸处理消息, scenicId: {}, deviceId: {}, faceUrl: {}", 
+            log.debug("接收到外部人脸处理消息, scenicId: {}, deviceId: {}, faceUrl: {}",
                     faceMessage.getScenicId(), faceMessage.getDeviceId(), faceMessage.getFaceUrl());
 
             // 使用外部传入的faceSampleId
@@ -78,16 +78,14 @@ public class FaceProcessingKafkaService {
             } else {
                 log.warn("人脸样本保存失败，但消息仍将被消费, faceSampleId: {}", externalFaceId);
             }
-            
+
             // 无论处理是否成功，都消费消息
             ack.acknowledge();
-            log.info("消息已消费, faceSampleId: {}", externalFaceId);
-            
+
         } catch (Exception e) {
             log.error("处理外部人脸消息失败: {}", e.getMessage(), e);
             // 即使发生异常也消费消息，避免消息堆积
             ack.acknowledge();
-            log.info("异常情况下消息已消费，避免重复处理");
         }
     }
 
@@ -113,12 +111,10 @@ public class FaceProcessingKafkaService {
             } else {
                 faceSample.setCreateAt(new Date());
             }
-            
+
             // 保存到数据库
             faceSampleMapper.add(faceSample);
-            log.info("人脸样本数据已保存, 使用外部faceId: {}, scenicId: {}, deviceId: {}, faceUrl: {}", 
-                    externalFaceId, faceMessage.getScenicId(), faceMessage.getDeviceId(), faceMessage.getFaceUrl());
-            
+
             return true;
         } catch (Exception e) {
             log.error("保存人脸样本数据失败, 外部faceId: {}, scenicId: {}, deviceId: {}", 
@@ -166,16 +162,13 @@ public class FaceProcessingKafkaService {
                 // 更新人脸样本得分和状态
                 faceSampleMapper.updateScore(faceSampleId, addFaceResp.getScore());
                 updateFaceSampleStatus(faceSampleId, 2);
-                log.info("人脸识别处理完成, faceSampleId: {}, score: {}", 
-                        faceSampleId, addFaceResp.getScore());
 
                 // 查询设备配置，判断是否启用预订功能
                 Long deviceId = message.getDeviceId();
                 DeviceConfigManager deviceConfig = deviceRepository.getDeviceConfigManager(deviceId);
-                if (deviceConfig != null && 
+                if (deviceConfig != null &&
                     Integer.valueOf(1).equals(deviceConfig.getInteger("enable_pre_book"))) {
                     DynamicTaskGenerator.addTask(faceSampleId);
-                    log.info("已添加到预订任务队列, faceSampleId: {}", faceSampleId);
                 }
                 return true;
             } else {
@@ -200,7 +193,6 @@ public class FaceProcessingKafkaService {
     private void updateFaceSampleStatus(Long faceSampleId, Integer status) {
         try {
             faceSampleMapper.updateStatus(faceSampleId, status);
-            log.info("人脸样本状态已更新, faceSampleId: {}, status: {} (0:初始,1:处理中,2:成功,-1:失败)", faceSampleId, status);
         } catch (Exception e) {
             log.error("更新人脸样本状态失败, faceSampleId: {}", faceSampleId, e);
         }
diff --git a/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java b/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java
index 2e39ca51..7b3013aa 100644
--- a/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java
+++ b/src/main/java/com/ycwl/basic/service/ZTSourceConsumerService.java
@@ -42,7 +42,7 @@ public class ZTSourceConsumerService {
             sourceMessage = JacksonUtil.parseObject(message, ZTSourceMessage.class);
 
             // 输出业务相关的日志信息
-            log.info("接收到ZT-Source消息, sourceId: {}, deviceId: {}, faceSampleId: {}",
+            log.debug("接收到ZT-Source消息, sourceId: {}, deviceId: {}, faceSampleId: {}",
                     sourceMessage.getSourceId(), sourceMessage.getDeviceId(), sourceMessage.getFaceSampleId());
 
             // 处理消息