You've already forked FrameTour-BE
chore(log): 移除日志中的特殊符号以提升可读性
All checks were successful
ZhenTu-BE/pipeline/head This commit looks good
All checks were successful
ZhenTu-BE/pipeline/head This commit looks good
- 删除了所有日志语句中的 ❌ 符号 - 删除了所有日志语句中的 ✅ 符号 - 删除了所有日志语句中的 ⚠️ 符号 - 统一了日志输出格式,使其更简洁清晰 - 保留了关键错误信息的记录方式 - 确保日志信息在不同终端下的一致性显示
This commit is contained in:
@@ -69,18 +69,18 @@ public class FaceProcessingKafkaService {
|
|||||||
// ========== 第一步: 同步写入数据库 (最高优先级) ==========
|
// ========== 第一步: 同步写入数据库 (最高优先级) ==========
|
||||||
boolean saved = saveFaceSample(faceMessage, faceSampleId);
|
boolean saved = saveFaceSample(faceMessage, faceSampleId);
|
||||||
if (!saved) {
|
if (!saved) {
|
||||||
log.error("❌ 数据库写入失败, 不提交识别任务, faceSampleId={}", faceSampleId);
|
log.error("数据库写入失败, 不提交识别任务, faceSampleId={}", faceSampleId);
|
||||||
// 数据库写入失败,消费消息避免重复
|
// 数据库写入失败,消费消息避免重复
|
||||||
ack.acknowledge();
|
ack.acknowledge();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
log.debug("✅ 数据库写入成功, faceSampleId={}, status=0", faceSampleId);
|
log.debug("数据库写入成功, faceSampleId={}, status=0", faceSampleId);
|
||||||
|
|
||||||
// ========== 第二步: 获取账号调度器上下文 ==========
|
// ========== 第二步: 获取账号调度器上下文 ==========
|
||||||
AccountSchedulerContext schedulerCtx = getSchedulerContextForScenic(faceMessage.getScenicId());
|
AccountSchedulerContext schedulerCtx = getSchedulerContextForScenic(faceMessage.getScenicId());
|
||||||
if (schedulerCtx == null) {
|
if (schedulerCtx == null) {
|
||||||
log.error("❌ 无法获取调度器上下文, faceSampleId={}", faceSampleId);
|
log.error("无法获取调度器上下文, faceSampleId={}", faceSampleId);
|
||||||
updateFaceSampleStatusSafely(faceSampleId, -1);
|
updateFaceSampleStatusSafely(faceSampleId, -1);
|
||||||
ack.acknowledge();
|
ack.acknowledge();
|
||||||
return;
|
return;
|
||||||
@@ -92,13 +92,13 @@ public class FaceProcessingKafkaService {
|
|||||||
});
|
});
|
||||||
|
|
||||||
if (submitted) {
|
if (submitted) {
|
||||||
log.debug("✅ 任务已提交到调度器, account={}, cloudType={}, faceSampleId={}, schedulerQueue={}",
|
log.debug("任务已提交到调度器, account={}, cloudType={}, faceSampleId={}, schedulerQueue={}",
|
||||||
schedulerCtx.getAccountKey(),
|
schedulerCtx.getAccountKey(),
|
||||||
schedulerCtx.getCloudType(),
|
schedulerCtx.getCloudType(),
|
||||||
faceSampleId,
|
faceSampleId,
|
||||||
schedulerCtx.getScheduler().getQueueSize());
|
schedulerCtx.getScheduler().getQueueSize());
|
||||||
} else {
|
} else {
|
||||||
log.error("❌ 调度器队列已满, account={}, faceSampleId={}",
|
log.error("调度器队列已满, account={}, faceSampleId={}",
|
||||||
schedulerCtx.getAccountKey(), faceSampleId);
|
schedulerCtx.getAccountKey(), faceSampleId);
|
||||||
updateFaceSampleStatusSafely(faceSampleId, -1);
|
updateFaceSampleStatusSafely(faceSampleId, -1);
|
||||||
}
|
}
|
||||||
@@ -107,7 +107,7 @@ public class FaceProcessingKafkaService {
|
|||||||
ack.acknowledge();
|
ack.acknowledge();
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("❌ 处理人脸消息异常, faceSampleId={}", faceSampleId, e);
|
log.error("处理人脸消息异常, faceSampleId={}", faceSampleId, e);
|
||||||
if (faceSampleId != null) {
|
if (faceSampleId != null) {
|
||||||
updateFaceSampleStatusSafely(faceSampleId, -1);
|
updateFaceSampleStatusSafely(faceSampleId, -1);
|
||||||
}
|
}
|
||||||
@@ -180,7 +180,7 @@ public class FaceProcessingKafkaService {
|
|||||||
faceSampleMapper.updateStatus(faceSampleId, status);
|
faceSampleMapper.updateStatus(faceSampleId, status);
|
||||||
log.debug("状态更新成功: faceSampleId={}, status={}", faceSampleId, status);
|
log.debug("状态更新成功: faceSampleId={}, status={}", faceSampleId, status);
|
||||||
} catch (Exception e) {
|
} 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());
|
faceSampleMapper.updateScore(faceSampleId, addFaceResp.getScore());
|
||||||
updateFaceSampleStatusSafely(faceSampleId, 2);
|
updateFaceSampleStatusSafely(faceSampleId, 2);
|
||||||
|
|
||||||
log.info("✅ 人脸识别成功, faceSampleId={}, score={}, status=2",
|
log.info("人脸识别成功, faceSampleId={}, score={}, status=2",
|
||||||
faceSampleId, addFaceResp.getScore());
|
faceSampleId, addFaceResp.getScore());
|
||||||
|
|
||||||
// 可选: 触发预订任务
|
// 可选: 触发预订任务
|
||||||
@@ -271,13 +271,13 @@ public class FaceProcessingKafkaService {
|
|||||||
|
|
||||||
} else {
|
} else {
|
||||||
// addFace 返回 null,识别失败
|
// addFace 返回 null,识别失败
|
||||||
log.warn("⚠️ addFace 返回 null, faceSampleId={}", faceSampleId);
|
log.warn("addFace 返回 null, faceSampleId={}", faceSampleId);
|
||||||
updateFaceSampleStatusSafely(faceSampleId, -1);
|
updateFaceSampleStatusSafely(faceSampleId, -1);
|
||||||
}
|
}
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
// ========== 异常处理: 更新状态为失败 ==========
|
// ========== 异常处理: 更新状态为失败 ==========
|
||||||
log.error("❌ 人脸识别异常, faceSampleId={}", faceSampleId, e);
|
log.error("人脸识别异常, faceSampleId={}", faceSampleId, e);
|
||||||
updateFaceSampleStatusSafely(faceSampleId, -1);
|
updateFaceSampleStatusSafely(faceSampleId, -1);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user