添加向量库

qianbao
1 parent fa60f81a
Showing 5 changed files with 87 additions and 2 deletions
src/main/java/com/xly/service/XlyErpService.java
src/main/java/com/xly/tool/DynamicToolProvider.java
src/main/java/com/xly/tts/bean/TTSRequestDTO.java
src/main/java/com/xly/tts/service/PythonTtsProxyService.java
src/main/java/com/xly/web/TTSStreamController.java
@@ -250,6 +250,52 @@ public class XlyErpService {
     /***
      * @Author 钱豹
+     * @Date 14:37 2026/4/7
+     * @Param [userInput, userId, sUserName, sBrandsId, sSubsidiaryId, sUserType, authorization]
+     * @return com.xly.entity.AiResponseDTO
+     * @Description 清空条件
+     **/
+    public AiResponseDTO removeCondition(String userId ,
+                                            String sUserName ,
+                                            String sBrandsId ,
+                                            String sSubsidiaryId,
+                                            String sUserType,
+                                            String authorization,
+                                            String removeCondition
+    ) {
+        String sceneName = StrUtil.EMPTY;
+        String methodName = StrUtil.EMPTY;
+        UserSceneSession session=null;
+        try {
+            // 1. 初始化用户场景会话（权限内场景）
+            session = userSceneSessionService.getUserSceneSession(userId,sUserName,sBrandsId,sSubsidiaryId,sUserType,authorization);
+            session.setAuthorization(authorization);
+            session.setSFunPrompts(null);
+            session.setDbCach(StrUtil.EMPTY);
+            session.setDbType(StrUtil.EMPTY);
+            sceneName = ObjectUtil.isNotEmpty(session.getCurrentScene())?session.getCurrentScene().getSSceneName():StrUtil.EMPTY;
+            Map<String, Object> args = session.getArgs();
+            String[] removeConditionA = removeCondition.split(",");
+            for(String one:removeConditionA){
+                args.remove(one);
+            }
+            session.setArgs(args);
+            String sResponMessage = dynamicToolProvider.doDynamicTool(session.getCurrentTool(),session);
+            return AiResponseDTO.builder().sSceneName(sceneName).sMethodName(methodName).aiText(sResponMessage).dbType(session.getDbType()).dbCach(session.getDbCach()).sReturnType(ReturnTypeCode.HTML.getCode()).build();
+        } catch (Exception e) {
+            e.printStackTrace();
+            return AiResponseDTO.builder().sSceneName(sceneName).sMethodName(methodName).aiText("系统异常：" + e.getMessage() + "，请稍后重试！").dbType(session.getDbType()).dbCach(session.getDbCach()).sReturnType(ReturnTypeCode.HTML.getCode()).build();
+        }finally {
+            //5.执行工具方法后，清除记忆
+            if(session !=null && session.getBCleanMemory()){
+                doCleanUserMemory(session,userId);
+            }
+        }
+    }
+
+
+    /***
+     * @Author 钱豹
      * @Date 19:18 2026/1/27
      * @Param [userInput, userId, sUserType]
      * @return java.lang.String
@@ -1135,10 +1135,17 @@ public class DynamicToolProvider implements ToolProvider {
                     if(ObjectUtil.isNotEmpty(argsOld.get(one.getSParam()))){
                         if(one.getSParamValue().startsWith("d")){
                             if(Double.valueOf(argsOld.get(one.getSParam()).toString())>0){
-                                markdown.append(one.getSParam()).append(":").append(argsOld.get(one.getSParam()).toString()).append(" ");
+                                markdown.append("<span style=\"color: #1890ff;margin-right: 10px;position: relative;display: inline-block;padding: 0 10px;\">")
+                                        .append(one.getSParam()).append(":").append(argsOld.get(one.getSParam()).toString()).append(" ")
+                                        .append(" <span style=\"font-weight: bold;font-size: 22px;position: absolute;right: -5px;top: -12px;color: #ff4d4f;display: inline-block;\" data-action=\"clearSql\" data-text=\""+one.getSParam()+","+one.getSParamValue()+"\" onclick=\"clearSql('"+one.getSParam()+","+one.getSParamValue()+"')\"> × </span>")
+                                        .append("</span>");
                             }
                         }else{
-                            markdown.append(one.getSParam()).append(":").append(argsOld.get(one.getSParam()).toString()).append(" ");
+                            markdown.append("<span style=\"color: #1890ff;margin-right: 10px;position: relative;display: inline-block;padding: 0 10px;\">")
+                                    .append(one.getSParam()).append(":").append(argsOld.get(one.getSParam()).toString()).append(" ")
+                                    .append(" <span style=\"font-weight: bold;font-size: 22px;position: absolute;right: -5px;top: -12px;color: #ff4d4f;display: inline-block;\" data-action=\"clearSql\" data-text=\""+one.getSParam()+","+one.getSParamValue()+"\" onclick=\"clearSql('"+one.getSParam()+","+one.getSParamValue()+"')\"> × </span>")
+                                    .append("</span>");
+//                            markdown.append(one.getSParam()).append(":").append(argsOld.get(one.getSParam()).toString()).append(" ");
                         }
                     }
                 }
@@ -18,6 +18,7 @@ public class TTSRequestDTO {
     private Integer page;
     private Integer pageCount;
     private String sceneId;
+    private String removeCondition;
 }
 \ No newline at end of file
@@ -87,6 +87,25 @@ public class PythonTtsProxyService {
         return synthesizeStreamAi(request, voiceText);
     }
+    /***
+     * @Author 钱豹
+     * @Date 14:35 2026/4/7
+     * @Param [request]
+     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
+     * @Description 清空条件
+     **/
+    public ResponseEntity<TTSResponseDTO> removeCondition(TTSRequestDTO request) {
+        String sUserId = request.getUserid();
+        String sUserName = request.getUsername();
+        String sBrandsId = request.getBrandsid();
+        String sSubsidiaryId = request.getSubsidiaryid();
+        String sUserType = request.getUsertype();
+        String authorization = request.getAuthorization();
+        String removeCondition = request.getRemoveCondition();
+        AiResponseDTO voiceText = xlyErpService.removeCondition(sUserId, sUserName, sBrandsId, sSubsidiaryId, sUserType, authorization,removeCondition);
+        return synthesizeStreamAi(request, voiceText);
+    }
+
     /**
      * 【保持原有返回类型】AI对话 + 流式TTS
      */
@@ -89,6 +89,18 @@ public class TTSStreamController {
         return pythonTtsProxyService.change(request);
     }
+    /***
+     * @Author 钱豹
+     * @Date 8:53 2026/4/7
+     * @Param [request]
+     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
+     * @Description 换一换
+     **/
+    @PostMapping(value = "/stream/removeCondition", consumes = {MediaType.APPLICATION_JSON_VALUE, MediaType.ALL_VALUE})
+    public ResponseEntity<TTSResponseDTO> removeCondition(@RequestBody TTSRequestDTO request) {
+        return pythonTtsProxyService.removeCondition(request);
+    }
+
     /**
      * 流式合成语音（代理到Python服务）
      */