From 75b396def4ff3fd08877327427ed341fa6e8e62a Mon Sep 17 00:00:00 2001 From: qianbao Date: Tue, 31 Mar 2026 15:53:58 +0800 Subject: [PATCH] 添加向量库 --- src/main/java/com/xly/milvus/service/impl/AiGlobalAgentQuestionSqlEmitterServiceImpl.java | 9 ++++----- src/main/java/com/xly/thread/AiUserAgentQuestionThread.java | 1 + 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/xly/milvus/service/impl/AiGlobalAgentQuestionSqlEmitterServiceImpl.java b/src/main/java/com/xly/milvus/service/impl/AiGlobalAgentQuestionSqlEmitterServiceImpl.java index 0e5610f..f86cd02 100644 --- a/src/main/java/com/xly/milvus/service/impl/AiGlobalAgentQuestionSqlEmitterServiceImpl.java +++ b/src/main/java/com/xly/milvus/service/impl/AiGlobalAgentQuestionSqlEmitterServiceImpl.java @@ -83,11 +83,10 @@ public class AiGlobalAgentQuestionSqlEmitterServiceImpl implements AiGlobalAgent .build(); InsertResp insertResp = milvusClient.insert(insertReq); - if(insertResp.getInsertCnt()>0){ - //调用数据库插入数据库 - Map searMap = dynamicExeDbService.getDoProMap(sProName, data); - dynamicExeDbService.getCallPro(searMap, sProName); - } + //调用数据库插入数据库 + Map searMap = dynamicExeDbService.getDoProMap(sProName, data); + dynamicExeDbService.getCallPro(searMap, sProName); + System.out.println("成功插入 " + insertResp.getInsertCnt() + " 条数据"); System.out.println(" - 数据预览:"); } diff --git a/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java b/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java index c892c0a..c9374ac 100644 --- a/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java +++ b/src/main/java/com/xly/thread/AiUserAgentQuestionThread.java @@ -47,6 +47,7 @@ public class AiUserAgentQuestionThread implements Runnable { data.put("sQuestion",SqlValidateUtil.getsQuestion(session.getSUserQuestionList())); data.put("sId",new UUIDGenerator().next()); data.put("cachType",cachType); + data.put("userInput",sQuestion); //插入Redis缓存 if(bRedis==1 && ObjectUtil.isNotEmpty(sSqlContent)){ String sReidKey = SqlValidateUtil.getsKey( sSceneId, sMethodId, sQuestionGroupNo); -- libgit2 0.22.2