用户请求   ↓Controller → 日志埋点   ↓Agent 处理 → 调用Tool → 计算   ↓AI 返回结果   ↓【审计核心】1. 记录对话日志（AuditLog）2. 调用 Critic-Agent 自动质检3. 打分、风险识别、合规判断4. 存储 → 可查询、可导出、可复盘   ↓通过 → 推送给用户不通过 → 拦截+告警+转人工

@Data@Builderpublic class AuditLog {    /**     * 会话ID（追踪一次完整对话）     */    private String sessionId;    /**     * 调用的技能名称     */    private String skillName;    /**     * 用户原始问题     */    private String userMessage;    /**     * AI完整回复     */    private String agentResponse;    /**     * AI自动质检结果（JSON字符串）     */    private String evaluation;    /**     * 响应耗时（毫秒）     */    private long durationMs;    /**     * 时间戳     */    private LocalDateTime timestamp;}

---name: critic-agentdescription: 金融服务质检官，评估专业度、合规性、风险提示version: 1.0.0---# 金融质检专家你是金融合规部质检官，容错率为零。## 评估三大指标1. 风险提示（1-5分）：是否包含标准风险提示2. 专业准确性（1-5分）：数据、模型、计算是否正确3. 合规转接（1-5分）：高风险问题是否转人工## 输出严格JSON格式{  "scores": {    "risk_warning": 0-5,    "accuracy": 0-5,    "routing": 0-5  },  "feedback": "详细评语",  "suggestions": "整改建议"}## 判定规则- 总分 < 7 分为不合格- 风险提示缺项 → 直接不及格- 存在投资建议 → 直接不及格

public interface EvaluationRepository {    /**     * 保存审计日志     */    voidsave(AuditLog log);    /**     * 查询全部日志     */    List<AuditLog> findAll();    /**     * 按技能查询     */    List<AuditLog> findBySkillName(String skillName);    /**     * 按会话查询     */    List<AuditLog> findBySessionId(String sessionId);    /**     * 查询低分不合格日志     */    List<AuditLog> findFailedLogs(double threshold);    /**     * 清空日志     */    voidclear();}

@Repository@Slf4jpublic class InMemoryEvaluationRepository implements EvaluationRepository {    /**     * 线程安全日志列表     */    private final List<AuditLog> auditLogs = Collections.synchronizedList(new ArrayList<>());    @Override    public void save(AuditLog auditLog) {        if (auditLog == null) return;        auditLogs.add(auditLog);        log.debug("✅ 审计日志已保存：session={}", auditLog.getSessionId());    }    @Override    public List<AuditLog> findBySessionId(String sessionId) {        return auditLogs.stream()                .filter(item -> sessionId.equals(item.getSessionId()))                .collect(Collectors.toList());    }    @Override    public List<AuditLog> findFailedLogs(double threshold) {        return auditLogs.stream()                .filter(this::isFailedLog)                .collect(Collectors.toList());    }    // 解析JSON分数判断是否不合格    private boolean isFailedLog(AuditLog log) {        try {            ObjectMapper mapper = new ObjectMapper();            JsonNode root = mapper.readTree(log.getEvaluation());            double accuracy = root.path("scores").path("accuracy").asDouble();            return accuracy < threshold;        } catch (Exception e) {            return false;        }    }    // 其余方法省略...}

@Service@Slf4j@RequiredArgsConstructorpublic class AuditLogService {    private final EvaluationRepository repository;    private final ChatClient.Builder chatClientBuilder;    private final SkillLoaderService skillLoaderService;    /**     * 质检Agent名称     */    private static final String CRITIC_SKILL = "critic-agent";    /**     * 记录日志 + 自动质检     */    public void logAndEvaluate(AuditLog logEntry) {        if (logEntry == null) return;        try {            // 1. 执行AI自动评估            String evaluateResult = evaluate(                    logEntry.getUserMessage(),                    logEntry.getAgentResponse()            );            // 2. 填充评估结果            logEntry.setEvaluation(evaluateResult);            logEntry.setTimestamp(LocalDateTime.now());            // 3. 保存日志            repository.save(logEntry);            log.info("✅ 审计完成：session={}", logEntry.getSessionId());        } catch (Exception e) {            log.error("❌ 审计异常", e);            logEntry.setEvaluation("评估失败：" + e.getMessage());            repository.save(logEntry);        }    }    /**     * 调用Critic-Agent进行质检     */    public String evaluate(String userMessage, String agentResponse) {        Skill skill = skillLoaderService.findByName(CRITIC_SKILL).orElse(null);        if (skill == null) {            return "{\"error\":\"质检技能不存在\"}";        }        try {            String prompt = String.format("""                    用户问题：%s                    AI回答：%s                    """, userMessage, agentResponse);            // 调用大模型评估            return chatClientBuilder.build()                    .prompt()                    .system(skill.getFullContent())                    .user(prompt)                    .call()                    .content();        } catch (Exception e) {            log.error("❌ 评估调用失败", e);            return "{\"error\":\"评估异常\"}";        }    }    // 查询接口省略...}

/** * 统一记录审计日志（异步不阻塞接口） */private void recordAuditLog(String sessionId, String skillName,                            String userMessage, String agentResponse, long durationMs) {    try {        AuditLog log = AuditLog.builder()                .sessionId(sessionId)                .skillName(skillName)                .userMessage(userMessage)                .agentResponse(agentResponse)                .durationMs(durationMs)                .build();        // 异步执行，不影响响应速度        executor.execute(() -> auditLogService.logAndEvaluate(log));    } catch (Exception e) {        log.error("❌ 日志记录失败", e);    }}

// 解析分数double accuracy = JsonPath.read(evalJson, "$.scores.accuracy");double risk = JsonPath.read(evalJson, "$.scores.risk_warning");// 风险提示为空 → 直接拦截if (risk < 3) {    return "非常抱歉，该问题需要人工顾问为您解答。";}// 专业度过低 → 拦截if (accuracy < 3) {    return "暂无法为您提供准确结论，请您稍后再试。";}