refactor(logging): 调整人脸处理服务中的日志级别

- 将接收到人脸消息的日志级别从 info 调整为 debug
- 移除了部分冗余的 info 级别日志输出
- 统一异常处理中的日志记录方式
-优化日志内容，减少不必要的信息输出
- 确保关键操作仍然保留适当日志记录- 提升系统在高并发下的日志可读性与性能

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

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());
 
             // 处理消息