From 481e6f15a40c7556d0e214209b1bf6924c34cc74 Mon Sep 17 00:00:00 2001
From: TangCheng <tangchengmail@163.com>
Date: 星期二, 22 四月 2025 18:43:57 +0800
Subject: [PATCH] 完成lightrag的Server创建
---
JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/core/SMTAIServerApp.java | 19 ++++++++++++++++++-
1 files changed, 18 insertions(+), 1 deletions(-)
diff --git a/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/core/SMTAIServerApp.java b/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/core/SMTAIServerApp.java
index 68ce215..9706cb7 100644
--- a/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/core/SMTAIServerApp.java
+++ b/JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/core/SMTAIServerApp.java
@@ -4,6 +4,7 @@
import com.smtaiserver.smtaiserver.attach.SMTAIAttachMetricDef;
import com.smtaiserver.smtaiserver.attach.SMTAIAttachTableDef;
import com.smtaiserver.smtaiserver.database.SMTDatabase;
+import com.smtaiserver.smtaiserver.database.SMTDatabase.DBRecord;
import com.smtaiserver.smtaiserver.database.SMTDatabase.DBRecords;
import com.smtaiserver.smtaiserver.gismap.SMTGisMapLayerDef;
import com.smtaiserver.smtaiserver.gismap.SMTMapOtypeDef;
@@ -313,6 +314,22 @@
_serverEncache.getAttachMetricDefMap();
_serverEncache.getQwenAgentManager();
+ initLightragServerList();
+ }
+
+ protected void initLightragServerList() throws Exception
+ {
+ try(SMTDatabase db = SMTAIServerApp.getApp().allocDatabase())
+ {
+ DBRecords recs = db.querySQL("SELECT * FROM lightrag_server_list WHERE is_enable='Y'", null);
+
+ for(DBRecord rec : recs.getRecords())
+ {
+ LightragServer server = new LightragServer(rec);
+ server.sureRunServer();
+ _mapId2LightragServer.put(server.getId(), server);
+ }
+ }
}
@@ -1426,7 +1443,7 @@
try(SMTDatabase db = SMTAIServerApp.getApp().allocDatabase())
{
- DBRecords recs = db.querySQL("SELECT * FROM lightrag_server_list WHERE server_id=?", new Object[] {id});
+ DBRecords recs = db.querySQL("SELECT * FROM lightrag_server_list WHERE server_id=? AND is_enable='Y'", new Object[] {id});
if(recs.getRowCount() == 0)
throw new Exception("can't find LightragServer : " + id);
--
Gitblit v1.9.3