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<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
-            dynamicExeDbService.getCallPro(searMap, sProName);
-        }
+        //调用数据库插入数据库
+        Map<String, Object> 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);