From 3cf7c8116293d9f6b2cf2f1ef19c89f61c2a5d3d Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Mon, 1 Dec 2025 10:55:13 +0800 Subject: [PATCH] =?UTF-8?q?chore(log):=20=E7=A7=BB=E9=99=A4=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E4=B8=AD=E7=9A=84=E7=89=B9=E6=AE=8A=E7=AC=A6=E5=8F=B7?= =?UTF-8?q?=E4=BB=A5=E6=8F=90=E5=8D=87=E5=8F=AF=E8=AF=BB=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除了所有日志语句中的 ❌ 符号 - 删除了所有日志语句中的 ✅ 符号 - 删除了所有日志语句中的 ⚠️ 符号 - 统一了日志输出格式，使其更简洁清晰 - 保留了关键错误信息的记录方式 - 确保日志信息在不同终端下的一致性显示 --- .../service/FaceProcessingKafkaService.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 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 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); } }