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 c5e27cdf..f6cb1fd7 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
@@ -69,18 +69,18 @@ public class FaceProcessingKafkaService {
             // ========== 第一步: 同步写入数据库 (最高优先级) ==========
             boolean saved = saveFaceSample(faceMessage, faceSampleId);
             if (!saved) {
-                log.error("❌ 数据库写入失败, 不提交识别任务, faceSampleId={}", faceSampleId);
+                log.error("数据库写入失败, 不提交识别任务, faceSampleId={}", faceSampleId);
                 // 数据库写入失败,消费消息避免重复
                 ack.acknowledge();
                 return;
             }
 
-            log.debug("✅ 数据库写入成功, faceSampleId={}, status=0", faceSampleId);
+            log.debug("数据库写入成功, faceSampleId={}, status=0", faceSampleId);
 
             // ========== 第二步: 获取账号调度器上下文 ==========
             AccountSchedulerContext schedulerCtx = getSchedulerContextForScenic(faceMessage.getScenicId());
             if (schedulerCtx == null) {
-                log.error("❌ 无法获取调度器上下文, faceSampleId={}", faceSampleId);
+                log.error("无法获取调度器上下文, faceSampleId={}", faceSampleId);
                 updateFaceSampleStatusSafely(faceSampleId, -1);
                 ack.acknowledge();
                 return;
@@ -92,13 +92,13 @@ public class FaceProcessingKafkaService {
             });
 
             if (submitted) {
-                log.debug("✅ 任务已提交到调度器, account={}, cloudType={}, faceSampleId={}, schedulerQueue={}",
+                log.debug("任务已提交到调度器, account={}, cloudType={}, faceSampleId={}, schedulerQueue={}",
                         schedulerCtx.getAccountKey(),
                         schedulerCtx.getCloudType(),
                         faceSampleId,
                         schedulerCtx.getScheduler().getQueueSize());
             } else {
-                log.error("❌ 调度器队列已满, account={}, faceSampleId={}",
+                log.error("调度器队列已满, account={}, faceSampleId={}",
                         schedulerCtx.getAccountKey(), faceSampleId);
                 updateFaceSampleStatusSafely(faceSampleId, -1);
             }
@@ -107,7 +107,7 @@ public class FaceProcessingKafkaService {
             ack.acknowledge();
 
         } catch (Exception e) {
-            log.error("❌ 处理人脸消息异常, faceSampleId={}", faceSampleId, e);
+            log.error("处理人脸消息异常, faceSampleId={}", faceSampleId, e);
             if (faceSampleId != null) {
                 updateFaceSampleStatusSafely(faceSampleId, -1);
             }
@@ -180,7 +180,7 @@ public class FaceProcessingKafkaService {
             faceSampleMapper.updateStatus(faceSampleId, status);
             log.debug("状态更新成功: faceSampleId={}, status={}", faceSampleId, status);
         } catch (Exception e) {
-            log.error("⚠️ 状态更新失败(非致命): faceSampleId={}, status={}", faceSampleId, status, e);
+            log.error("状态更新失败(非致命): faceSampleId={}, status={}", faceSampleId, status, e);
             // 不抛出异常,避免影响消息消费
         }
     }
@@ -258,7 +258,7 @@ public class FaceProcessingKafkaService {
                 faceSampleMapper.updateScore(faceSampleId, addFaceResp.getScore());
                 updateFaceSampleStatusSafely(faceSampleId, 2);
 
-                log.info("✅ 人脸识别成功, faceSampleId={}, score={}, status=2",
+                log.info("人脸识别成功, faceSampleId={}, score={}, status=2",
                         faceSampleId, addFaceResp.getScore());
 
                 // 可选: 触发预订任务
@@ -271,13 +271,13 @@ public class FaceProcessingKafkaService {
 
             } else {
                 // addFace 返回 null,识别失败
-                log.warn("⚠️ addFace 返回 null, faceSampleId={}", faceSampleId);
+                log.warn("addFace 返回 null, faceSampleId={}", faceSampleId);
                 updateFaceSampleStatusSafely(faceSampleId, -1);
             }
 
         } catch (Exception e) {
             // ========== 异常处理: 更新状态为失败 ==========
-            log.error("❌ 人脸识别异常, faceSampleId={}", faceSampleId, e);
+            log.error("人脸识别异常, faceSampleId={}", faceSampleId, e);
             updateFaceSampleStatusSafely(faceSampleId, -1);
         }
     }