完成lightrag的Server创建

TangCheng

8 天以前 481e6f15a40c7556d0e214209b1bf6924c34cc74

完成lightrag的Server创建

 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);

                


 JAVA/SMTAIServer/src/main/java/com/smtaiserver/smtaiserver/lightrag/LightragServer.java

@@ -33,6 +33,11 @@
        _port = rec.getString("server_port");

    }

    

    public String getId()

    {

        return _id;

    }

	
    public String getPort()

    {

        return _port;