添加向量库

qianbao
1 parent c357bb83
Showing 11 changed files with 310 additions and 121 deletions
src/main/java/com/xly/milvus/service/AiGlobalAgentQuestionSqlEmitterService.java
src/main/java/com/xly/milvus/service/MilvusService.java
src/main/java/com/xly/milvus/service/impl/AiGlobalAgentQuestionSqlEmitterServiceImpl.java
src/main/java/com/xly/milvus/service/impl/MilvusServiceImpl.java
src/main/java/com/xly/milvus/web/MilvusController.java
src/main/java/com/xly/ocr/service/OcrService.java
src/main/java/com/xly/ocr/test/Test.java → src/main/java/com/xly/ocr/util/OcrUtil.java
src/main/java/com/xly/ocr/web/OcrController.java
src/main/java/com/xly/service/XlyErpService.java
src/main/java/com/xly/thread/AiUserAgentQuestionThread.java
src/main/resources/application.yml
@@ -12,7 +12,7 @@ public interface AiGlobalAgentQuestionSqlEmitterService {
      * @return void
      * @Description 插入向量库
      **/
-    void addAiGlobalAgentQuestionSqlEmitter(String sKey,Map<String,Object>  data,String sQuestion,String sSqlContent,String cachType,String collectionName);
+    void addAiGlobalAgentQuestionSqlEmitter(String sKey,Map<String,Object>  data,String sQuestion,String sSqlContent,String cachType,String collectionName,Boolean isInit);
     Map<String, Object> queryAiGlobalAgentQuestionSqlEmitter(String searchText, String collectionName);
@@ -22,6 +22,24 @@ public interface MilvusService {
     TTSResponseDTO initDataToMilvus(Map<String, Object> reqMap);
+    /***
+     * @Author 钱豹
+     * @Date 9:00 2026/4/1
+     * @Param [reqMap]
+     * @return com.xly.tts.bean.TTSResponseDTO
+     * @Description 客户问题库转入全局问题库
+     **/
+    TTSResponseDTO addGlobalAgentQuestion(Map<String, Object> reqMap);
+
+    /***
+     * @Author 钱豹
+     * @Date 9:28 2026/4/1
+     * @Param [reqMap]
+     * @return com.xly.tts.bean.TTSResponseDTO
+     * @Description 初始化全局SQL进入向量库
+     **/
+    TTSResponseDTO initGlobalAgentQuestion(Map<String, Object> reqMap);
+
     /**
      * 创建集合（如果不存在）
@@ -58,7 +58,7 @@ public class AiGlobalAgentQuestionSqlEmitterServiceImpl implements AiGlobalAgent
      * @Description 插入数据
      **/
     @Override
-    public void addAiGlobalAgentQuestionSqlEmitter(String sKey,Map<String,Object>  data,String sQuestion,String sSqlContent,String cachType,String collectionName) {
+    public void addAiGlobalAgentQuestionSqlEmitter(String sKey,Map<String,Object>  data,String sQuestion,String sSqlContent,String cachType,String collectionName,Boolean isInit) {
         // 向量化
         List<Float> vector = vectorizationService.textToVector(sKey);
@@ -83,10 +83,12 @@ public class AiGlobalAgentQuestionSqlEmitterServiceImpl implements AiGlobalAgent
                 .build();
         InsertResp insertResp = milvusClient.insert(insertReq);
-        //调用数据库插入数据库
-        Map<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
-        dynamicExeDbService.getCallPro(searMap, sProName);
-
+        //是否初始化。初始化不需要插入到数据库
+        if(!isInit){
+            //调用数据库插入数据库
+            Map<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
+            dynamicExeDbService.getCallPro(searMap, sProName);
+        }
         System.out.println("成功插入 " + insertResp.getInsertCnt() + " 条数据");
         System.out.println("   - 数据预览:");
     }
@@ -10,6 +10,7 @@ import com.google.common.reflect.TypeToken;
 import com.google.gson.Gson;
 import com.google.gson.JsonArray;
 import com.google.gson.JsonObject;
+import com.xly.milvus.service.AiGlobalAgentQuestionSqlEmitterService;
 import com.xly.milvus.service.MilvusService;
 import com.xly.milvus.service.VectorizationService;
 import com.xly.milvus.util.MapToJsonConverter;
@@ -60,6 +61,7 @@ public class MilvusServiceImpl implements MilvusService {
     private final MilvusClientV2 milvusClient;
     private final VectorizationService vectorizationService;
     private final DynamicExeDbService dynamicExeDbService;
+    private final AiGlobalAgentQuestionSqlEmitterService aiGlobalAgentQuestionSqlEmitterService;
     private static final long NULL_TIMESTAMP = -1L;
     // 日期格式常量
     private static final DateTimeFormatter ISO_FORMATTER =
@@ -128,6 +130,80 @@ public class MilvusServiceImpl implements MilvusService {
                 .build();
     }
+    /***
+     * @Author 钱豹
+     * @Date 9:20 2026/4/1
+     * @Param [reqMap]
+     * @return com.xly.tts.bean.TTSResponseDTO
+     * @Description 用户问题列表转换成全局问题
+     **/
+    @Override
+    public TTSResponseDTO addGlobalAgentQuestion(Map<String, Object> reqMap) {
+        if(ObjectUtil.isEmpty(reqMap.get("sRowData"))){
+            return TTSResponseDTO.builder()
+                    .code(-1)
+                    .message("请选择数据")
+                    .build();
+        }
+        //遍历数据
+        List<Map<String,Object>> data = (List<Map<String, Object>>) reqMap.get("sRowData");
+        if(ObjectUtil.isEmpty(data)){
+            return TTSResponseDTO.builder()
+                    .code(-1)
+                    .message("请选择数据")
+                    .build();
+        }
+        StringBuffer sb = new StringBuffer();
+        data.forEach(one->{
+            //查询向量库是否存在
+            String sSceneId = one.get("sSceneId").toString();
+            String sMethodId = one.get("sMethodId").toString();
+            String sUserInput = one.get("sUserInput").toString();
+            String sSqlContent = one.get("sSqlContent").toString();
+            String searchText = sSceneId+"_"+sMethodId+"_"+sUserInput;
+            if(ObjectUtil.isNotEmpty(sUserInput)){
+                //根据问题查询向量库
+                Map<String,Object> serMap = aiGlobalAgentQuestionSqlEmitterService.queryAiGlobalAgentQuestionSqlEmitter(searchText, "ai_global_agent_question_sql");
+                if(ObjectUtil.isNotEmpty(serMap)){
+                    aiGlobalAgentQuestionSqlEmitterService.addAiGlobalAgentQuestionSqlEmitter(searchText,one,sUserInput,sSqlContent,"MYSQL","ai_global_agent_question_sql",false);
+                }else{
+                    sb.append(sUserInput).append("已经存在").append("\n");
+                }
+                //更新数据是否是全局问题，等待朱总确定是否需要
+
+
+            }
+        });
+        if(ObjectUtil.isEmpty(sb)){
+            sb.append("操作成功");
+        }
+        return TTSResponseDTO.builder()
+                .code(200)
+                .message(sb.toString())
+                .build();
+    }
+
+    @Override
+    public TTSResponseDTO initGlobalAgentQuestion(Map<String, Object> reqMap) {
+        //全局问题初始化
+        List<Map<String,Object>> data = getGlobalAgentQuestion();
+        data.forEach(one->{
+            //查询向量库是否存在
+            String sSceneId = one.get("sSceneId").toString();
+            String sMethodId = one.get("sMethodId").toString();
+            String sUserInput = one.get("sUserInput").toString();
+            String sSqlContent = one.get("sSqlContent").toString();
+            String searchText = sSceneId+"_"+sMethodId+"_"+sUserInput;
+            if(ObjectUtil.isNotEmpty(sUserInput)){
+                aiGlobalAgentQuestionSqlEmitterService.addAiGlobalAgentQuestionSqlEmitter(searchText,one,sUserInput,sSqlContent,"MYSQL","ai_global_agent_question_sql",true);
+            }
+        });
+        return TTSResponseDTO.builder()
+                .code(200)
+                .message("操作成功")
+                .build();
+    }
+
     public String getUpdateDateUp(String sInputTabelName) {
         Map<String,Object> serDataMap = new HashMap<>();
         String sSql ="SELECT DATE_FORMAT(tUpdateDate,'%Y-%m-%d %H:%i:%s') AS tUpdateDate FROM ai_milvus_vector_record WHERE sInputTabelName = #{sInputTabelName}";
@@ -139,6 +215,14 @@ public class MilvusServiceImpl implements MilvusService {
         return data.get(0).get("tUpdateDate").toString();
     }
+    public List<Map<String,Object>> getGlobalAgentQuestion() {
+        Map<String,Object> serDataMap = new HashMap<>();
+        String sSql ="SELECT * FROM ai_global_agent_question_sql";
+        //删除集合全部数据
+        List<Map<String,Object>> data = this.dynamicExeDbService.findSql(serDataMap,sSql);
+        return data;
+    }
+
     /***
      * @Author 钱豹
      * @Date 22:24 2026/3/24
@@ -45,5 +45,31 @@ public class MilvusController {
          return ResponseEntity.ok(responseDTO);
     }
+    /***
+     * @Author 钱豹
+     * @Date 14:32 2026/2/10
+     * @Param [request]
+     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
+     * @Description 初始化AI所有变量 热启动
+     **/
+    @PostMapping("/addGlobalAgentQuestion")
+    public ResponseEntity<TTSResponseDTO> addGlobalAgentQuestion(@RequestBody Map<String,Object> reqMap) {
+        TTSResponseDTO responseDTO =  milvusService.addGlobalAgentQuestion(reqMap);
+        return ResponseEntity.ok(responseDTO);
+    }
+
+    /***
+     * @Author 钱豹
+     * @Date 14:32 2026/2/10
+     * @Param [request]
+     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
+     * @Description 初始化全局SQL
+     **/
+    @PostMapping("/initGlobalAgentQuestion")
+    public ResponseEntity<TTSResponseDTO> initGlobalAgentQuestion(@RequestBody Map<String,Object> reqMap) {
+        TTSResponseDTO responseDTO =  milvusService.initGlobalAgentQuestion(reqMap);
+        return ResponseEntity.ok(responseDTO);
+    }
+
 }
 \ No newline at end of file
 package com.xly.ocr.service;
+import com.xly.ocr.util.OcrUtil;
+import lombok.extern.slf4j.Slf4j;
 import net.sourceforge.tess4j.Tesseract;
 import net.sourceforge.tess4j.TesseractException;
 import org.slf4j.Logger;
@@ -18,11 +20,16 @@ import java.nio.file.Path;
 import java.util.Arrays;
 import java.util.List;
-@Service
+@Slf4j
+@Service("ocrService")
 public class OcrService {
     private static final Logger logger = LoggerFactory.getLogger(OcrService.class);
+    @Value("${ocr.tmpPath}")
+    private String tmpPath;
+
+
     private final Tesseract tesseract;
     // 配置参数
@@ -457,28 +464,8 @@ public class OcrService {
             logger.warn("不支持的文件格式: {}", originalFilename);
             return "不支持的文件格式，仅支持: " + String.join(", ", ALLOWED_EXTENSIONS);
         }
-
-        Path tempFile = null;
-        try {
-            // 创建临时文件
-            String suffix = getFileExtension(originalFilename);
-            tempFile = Files.createTempFile("ocr_", suffix);
-            file.transferTo(tempFile.toFile());
-
-            logger.info("临时文件创建成功: {}", tempFile);
-
-            // 执行 OCR
-            String result = extractText(tempFile.toFile());
-
-            return result;
-
-        } catch (IOException e) {
-            logger.error("文件处理失败: {}", e.getMessage(), e);
-            return "文件处理失败: " + e.getMessage();
-        } finally {
-            // 清理临时文件
-            cleanupTempFile(tempFile);
-        }
+        String sText = OcrUtil.ocrFile(file,tmpPath);
+        return sText;
     }
     /**
-package com.xly.ocr.test;
+package com.xly.ocr.util;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.util.StrUtil;
 import com.benjaminwan.ocrlibrary.OcrResult;
 import com.benjaminwan.ocrlibrary.TextBlock;
 import io.github.mymonstercat.Model;
 import io.github.mymonstercat.ocr.InferenceEngine;
 import io.github.mymonstercat.ocr.config.ParamConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.multipart.MultipartFile;
 import javax.imageio.ImageIO;
 import java.awt.*;
@@ -13,7 +17,8 @@ import java.io.File;
 import java.io.IOException;
 import java.util.List;
-public class Test {
+@Slf4j
+public class OcrUtil {
     static {
         try {
@@ -35,71 +40,64 @@ public class Test {
         }
     }
-    public static void main(String[] args) {
+    public static String ocrFile(MultipartFile imageFile, String sTmpPath){
+        String processedImagePath = StrUtil.EMPTY;
         try {
-            System.out.println("OCR 程序开始执行...");
-
+            log.info("OCR 程序开始执行...");
             // 1. 初始化引擎（使用 v4 模型）
-            System.out.println("正在初始化 OCR 引擎 (PP-OCRv4)...");
+            log.info("正在初始化 OCR 引擎 (PP-OCRv4)...");
             InferenceEngine engine = InferenceEngine.getInstance(Model.ONNX_PPOCR_V4);
-
             // 2. 创建优化的参数配置
             ParamConfig config = createOptimizedParamConfig();
-
-            // 3. 图片路径
-            String imagePath = "E:/aa/b.jpg";
-            File imageFile = new File(imagePath);
-            if (!imageFile.exists()) {
-                System.err.println("图片文件不存在: " + imagePath);
-                return;
-            }
-
             // 4. 图像预处理（直接处理原图，不保存临时文件）
             System.out.println("正在进行图像预处理...");
-            BufferedImage processedImage = preprocessImage(imageFile);
-
+            File file = multipartFileToFile(imageFile);
+            BufferedImage processedImage = preprocessImage(file);
             // 5. 保存预处理后的图片到临时目录
-            String processedImagePath = "D:/temp/ocrJava/processed_" + System.currentTimeMillis() + ".png";
+            if(!FileUtil.exist(sTmpPath)){
+                FileUtil.mkdir(sTmpPath);
+            }
+            processedImagePath = sTmpPath+"/processed_" + System.currentTimeMillis() + ".png";
             ImageIO.write(processedImage, "png", new File(processedImagePath));
-            System.out.println("预处理图片已保存: " + processedImagePath);
-
+            log.info("预处理图片已保存: " + processedImagePath);
             // 6. 执行识别
-            System.out.println("开始识别图片...");
+            log.info("开始识别图片...");
             long startTime = System.currentTimeMillis();
             OcrResult ocrResult = engine.runOcr(processedImagePath, config);
             long endTime = System.currentTimeMillis();
-
             // 7. 输出结果
             String text = ocrResult.getStrRes().trim();
-            System.out.println("\n==================================");
-            System.out.println("识别结果：");
-            System.out.println(text);
-            System.out.println("==================================");
-            System.out.println("识别耗时: " + (endTime - startTime) + " ms");
-
+            log.info("\n==================================");
+            log.info("识别结果：");
+            log.info(text);
+            log.info("==================================");
+            log.info("识别耗时: " + (endTime - startTime) + " ms");
             // 8. 输出每个文本块
-            if (ocrResult.getTextBlocks() != null && !ocrResult.getTextBlocks().isEmpty()) {
-                System.out.println("\n文本块详情（共" + ocrResult.getTextBlocks().size() + "块）：");
-                List<TextBlock> textBlocks = ocrResult.getTextBlocks();
-                for (int i = 0; i < textBlocks.size(); i++) {
-                    TextBlock block = textBlocks.get(i);
-                    System.out.printf("  块%d: %s (置信度: %.2f)%n",
-                            i + 1,
-                            block.getText(),
-                            block.getBoxScore()
-                    );
-                }
-            }
-
-            // 9. 清理临时文件
-            new File(processedImagePath).delete();
+//            if (ocrResult.getTextBlocks() != null && !ocrResult.getTextBlocks().isEmpty()) {
+//                System.out.println("\n文本块详情（共" + ocrResult.getTextBlocks().size() + "块）：");
+//                List<TextBlock> textBlocks = ocrResult.getTextBlocks();
+//                for (int i = 0; i < textBlocks.size(); i++) {
+//                    TextBlock block = textBlocks.get(i);
+//                    System.out.printf("  块%d: %s (置信度: %.2f)%n",
+//                            i + 1,
+//                            block.getText(),
+//                            block.getBoxScore()
+//                    );
+//                }
+//            }
+            return text;
         } catch (Exception e) {
             System.err.println("OCR 识别失败: " + e.getMessage());
             e.printStackTrace();
+        }finally {
+            // 9. 清理临时文件
+            FileUtil.del(processedImagePath);
         }
+        return StrUtil.EMPTY;
     }
+
     /**
      * 优化的参数配置
      */
@@ -142,6 +140,20 @@ public class Test {
         return processed;
     }
+    /***
+     * @Author 钱豹
+     * @Date 11:01 2026/4/1
+     * @Param [multipartFile]
+     * @return java.io.File
+     * @Description 图片对象转换
+     **/
+    public static File multipartFileToFile(MultipartFile multipartFile) throws IOException {
+        // 创建临时文件
+        File file = File.createTempFile("temp", null);
+        // 将 MultipartFile 的内容传输到 File
+        multipartFile.transferTo(file);
+        return file;
+    }
     /**
      * 调整图片大小
@@ -179,4 +191,69 @@ public class Test {
         }
         return result;
     }
+
+    public static void main(String[] args) {
+        try {
+            System.out.println("OCR 程序开始执行...");
+
+            // 1. 初始化引擎（使用 v4 模型）
+            System.out.println("正在初始化 OCR 引擎 (PP-OCRv4)...");
+            InferenceEngine engine = InferenceEngine.getInstance(Model.ONNX_PPOCR_V4);
+
+            // 2. 创建优化的参数配置
+            ParamConfig config = createOptimizedParamConfig();
+
+            // 3. 图片路径
+            String imagePath = "E:/aa/b.jpg";
+            File imageFile = new File(imagePath);
+            if (!imageFile.exists()) {
+                System.err.println("图片文件不存在: " + imagePath);
+                return;
+            }
+
+            // 4. 图像预处理（直接处理原图，不保存临时文件）
+            System.out.println("正在进行图像预处理...");
+            BufferedImage processedImage = preprocessImage(imageFile);
+
+            // 5. 保存预处理后的图片到临时目录
+            String processedImagePath = "D:/temp/ocrJava/processed_" + System.currentTimeMillis() + ".png";
+            ImageIO.write(processedImage, "png", new File(processedImagePath));
+            System.out.println("预处理图片已保存: " + processedImagePath);
+
+            // 6. 执行识别
+            System.out.println("开始识别图片...");
+            long startTime = System.currentTimeMillis();
+            OcrResult ocrResult = engine.runOcr(processedImagePath, config);
+            long endTime = System.currentTimeMillis();
+
+            // 7. 输出结果
+            String text = ocrResult.getStrRes().trim();
+            System.out.println("\n==================================");
+            System.out.println("识别结果：");
+            System.out.println(text);
+            System.out.println("==================================");
+            System.out.println("识别耗时: " + (endTime - startTime) + " ms");
+
+            // 8. 输出每个文本块
+            if (ocrResult.getTextBlocks() != null && !ocrResult.getTextBlocks().isEmpty()) {
+                System.out.println("\n文本块详情（共" + ocrResult.getTextBlocks().size() + "块）：");
+                List<TextBlock> textBlocks = ocrResult.getTextBlocks();
+                for (int i = 0; i < textBlocks.size(); i++) {
+                    TextBlock block = textBlocks.get(i);
+                    System.out.printf("  块%d: %s (置信度: %.2f)%n",
+                            i + 1,
+                            block.getText(),
+                            block.getBoxScore()
+                    );
+                }
+            }
+
+            // 9. 清理临时文件
+            new File(processedImagePath).delete();
+
+        } catch (Exception e) {
+            System.err.println("OCR 识别失败: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
 }
 \ No newline at end of file
-//package com.xly.ocr.web;
-//
-//import com.xly.ocr.service.OcrService;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.http.ResponseEntity;
-//import org.springframework.web.bind.annotation.*;
-//import org.springframework.web.multipart.MultipartFile;
-//
-//import java.util.HashMap;
-//import java.util.List;
-//import java.util.Map;
-//
-//@RestController
-//@RequestMapping("/api/ocr")
-//public class OcrController {
-//
-//    @Autowired
-//    private OcrService ocrService;
-//
-//    @PostMapping("/extract")
-//    public ResponseEntity<Map<String, Object>> extractText(
-//            @RequestParam("file") MultipartFile file) {
-//
-//        Map<String, Object> response = new HashMap<>();
-//        long startTime = System.currentTimeMillis();
-//
-//        String result = ocrService.extractTextFromMultipartFile(file);
-//
-//        response.put("text", result);
-//        response.put("time", System.currentTimeMillis() - startTime);
-//        response.put("success", !result.startsWith("错误") && !result.startsWith("失败"));
-//
-//        return ResponseEntity.ok(response);
-//    }
-//
-//    @PostMapping("/batch")
-//    public ResponseEntity<List<String>> batchExtract(
-//            @RequestParam("files") List<MultipartFile> files) {
-//        List<String> results = ocrService.batchExtractText(files);
-//        return ResponseEntity.ok(results);
-//    }
-//}
 \ No newline at end of file
+package com.xly.ocr.web;
+
+import com.xly.ocr.service.OcrService;
+import com.xly.tts.bean.TTSResponseDTO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/ocr")
+public class OcrController {
+
+    @Autowired
+    private OcrService ocrService;
+
+    @PostMapping("/extract")
+    public ResponseEntity<TTSResponseDTO> extractText(
+            @RequestParam("file") MultipartFile file) {
+        String result = ocrService.extractTextFromMultipartFile(file);
+        TTSResponseDTO dto= TTSResponseDTO.builder()
+                .code(200)
+                .message("操作成功")
+                .processedText(result)
+                .build();
+        return ResponseEntity.ok(dto);
+    }
+
+    @PostMapping("/batch")
+    public ResponseEntity<List<String>> batchExtract(
+            @RequestParam("files") List<MultipartFile> files) {
+        List<String> results = ocrService.batchExtractText(files);
+        return ResponseEntity.ok(results);
+    }
+}
 \ No newline at end of file
@@ -668,10 +668,8 @@ public class XlyErpService {
         //如果查询不到数据走向量库
         if(ObjectUtil.isEmpty(sqlResult)){
             session.setDbType("X");
-
             //数据集为空的也记录到历史问题中
-            doAiSqlErrorHistoryThread(session, cleanSql, StrUtil.EMPTY, StrUtil.EMPTY,input);
-
+            doAiSqlErrorHistoryThread(session, StrUtil.EMPTY,cleanSql, "结果为空",input);
             return getMilvus(session, input, aiAgent,false);
         }
         // 5. 调用AI服务生成自然语言解释（传入表结构，让解释更贴合业务）
@@ -679,7 +677,7 @@ public class XlyErpService {
         //执行正确去修改对应正确的SQl
         if(Integer.valueOf(iErroCount)>0){
-            doAiSqlErrorHistoryThread(session, cleanSql, StrUtil.EMPTY, StrUtil.EMPTY,input);
+            doAiSqlErrorHistoryThread(session, cleanSql, StrUtil.EMPTY, "执行正确去修改对应正确的SQl",input);
         }
         //插入常用操作  不包含where 条件
         if(doAddSql){
@@ -733,7 +731,7 @@ public class XlyErpService {
      **/
     private Map<String,Object> getDynamicTableCach(UserSceneSession session,String input){
         try{
-            String searchText = session.getCurrentScene().getSId()+"_"+session.getCurrentTool().getSId()+input;
+            String searchText = session.getCurrentScene().getSId()+"_"+session.getCurrentTool().getSId()+"_"+input;
             //根据问题查询向量库
             Map<String,Object> serMap = aiGlobalAgentQuestionSqlEmitterService.queryAiGlobalAgentQuestionSqlEmitter(searchText, "ai_global_agent_question_sql");
             return serMap;
@@ -57,7 +57,7 @@ public class AiUserAgentQuestionThread implements Runnable {
 //                SqlValidateUtil.getsKey( sSceneId, sMethodId, SqlValidateUtil.getsQuestion(session.getSUserQuestionList()));
         //存入向量库 不包含where 条件
         if(!SqlWhereHelper.hasWhereButNoCompareOperators(sSqlContent)){
-            aiGlobalAgentQuestionSqlEmitterService.addAiGlobalAgentQuestionSqlEmitter(sKey,data,sQuestion,sSqlContent,cachType,"ai_global_agent_question_sql");
+            aiGlobalAgentQuestionSqlEmitterService.addAiGlobalAgentQuestionSqlEmitter(sKey,data,sQuestion,sSqlContent,cachType,"ai_global_agent_question_sql",false);
         }
        //调用数据库插入数据库
         Map<String, Object> searMap = dynamicExeDbService.getDoProMap(sProName, data);
@@ -65,6 +65,8 @@ spring:
           max-active: 8        # 连接池最大连接数
           max-idle: 8          # 连接池最大空闲连接
           min-idle: 0          # 连接池最小空闲连接'
+ocr:
+  tmpPath: D:/xlyweberp/ai/ocrtmp
 milvus:
   host: 112.82.245.194