From 63b01db83d9aad8a15276b4236a9a22e4aeef065 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 05 五月 2026 12:30:59 +0800
Subject: [PATCH] # Agent数据分析V3.0.1.7
---
src/main/java/com/zy/ai/service/impl/LlmCallLogServiceImpl.java | 20 ++++++++++++++++++--
1 files changed, 18 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/ai/service/impl/LlmCallLogServiceImpl.java b/src/main/java/com/zy/ai/service/impl/LlmCallLogServiceImpl.java
index 7b411b2..f2053e6 100644
--- a/src/main/java/com/zy/ai/service/impl/LlmCallLogServiceImpl.java
+++ b/src/main/java/com/zy/ai/service/impl/LlmCallLogServiceImpl.java
@@ -12,19 +12,35 @@
public class LlmCallLogServiceImpl extends ServiceImpl<LlmCallLogMapper, LlmCallLog> implements LlmCallLogService {
private volatile boolean disabled = false;
+ private volatile long lastRetryTime = 0;
+ private static final long RETRY_INTERVAL_MS = 60_000; // 1 鍒嗛挓鍚庨噸璇�
@Override
public void saveIgnoreError(LlmCallLog logItem) {
- if (logItem == null || disabled) {
+ if (logItem == null) {
return;
+ }
+ if (disabled) {
+ // 瀹氭湡閲嶈瘯锛岄槻姝㈣〃鍚庢潵鍒涘缓浜嗕絾 disabled 涓�鐩翠负 true
+ long now = System.currentTimeMillis();
+ if (now - lastRetryTime < RETRY_INTERVAL_MS) {
+ return;
+ }
+ lastRetryTime = now;
+ log.info("LLM璋冪敤鏃ュ織涔嬪墠宸茬鐢紝灏濊瘯閲嶆柊鍐欏叆...");
}
try {
save(logItem);
+ if (disabled) {
+ disabled = false;
+ log.info("LLM璋冪敤鏃ュ織鍐欏叆鎴愬姛锛屽凡鎭㈠鏃ュ織璁板綍");
+ }
} catch (Exception e) {
String msg = e.getMessage() == null ? "" : e.getMessage();
if (msg.contains("doesn't exist") || msg.contains("涓嶅瓨鍦�")) {
disabled = true;
- log.warn("LLM璋冪敤鏃ュ織琛ㄤ笉瀛樺湪锛屾棩蹇楄褰曞凡鑷姩鍏抽棴锛岃鍏堟墽琛屽缓琛⊿QL");
+ lastRetryTime = System.currentTimeMillis();
+ log.warn("LLM璋冪敤鏃ュ織琛ㄤ笉瀛樺湪锛屾棩蹇楄褰曞凡鏆傚仠锛岃鍏堟墽琛屽缓琛⊿QL");
return;
}
log.warn("鍐欏叆LLM璋冪敤鏃ュ織澶辫触: {}", msg);
--
Gitblit v1.9.1