fix: Remove Alibailian related code

Author: lu-yg

Dockerfile

@@ -17,10 +17,6 @@ COPY --from=build /app/base/target/tiny-engine-base-*.jar /app/tiny-engine-base.
 COPY --from=build /app/documents /app/documents
 COPY --from=build /app/all-MiniLM-L6-v2 /app/all-MiniLM-L6-v2
 # 设置环境变量
-ENV ACCESS_KEY_ID=""
-ENV ACCESS_KEY_SECRET=""
-ENV INDEX_ID=""
-ENV WORK_SPACE_ID=""
 ENV FOLDER_PATH="/app/documents"
 # 替换为自己的域名接口路径
 ENV TINY_ENGINE_URL="https://agent.opentiny.design/material-center/api/resource/download"

base/src/main/java/com/tinyengine/it/controller/AiChatController.java

@@ -12,11 +12,9 @@
 
 package com.tinyengine.it.controller;
 
-import com.tinyengine.it.common.base.Result;
 import com.tinyengine.it.common.log.SystemControllerLog;
 import com.tinyengine.it.model.dto.ChatRequest;
 
-import com.tinyengine.it.model.dto.NodeDto;
 import com.tinyengine.it.service.app.v1.AiChatV1Service;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -124,24 +122,4 @@ public ResponseEntity<?> completions(@RequestBody ChatRequest request,
                 .body(e.getMessage());
         }
     }
-
-    /**
-     * AI search api
-     *
-     * @param content the AI search param
-     * @return ai回答信息 result
-     */
-    @Operation(summary = "搜索知识库", description = "搜索知识库",
-        parameters = {
-            @Parameter(name = "content", description = "入参对象")
-        }, responses = {
-            @ApiResponse(responseCode = "200", description = "返回信息",
-                content = @Content(mediaType = "application/json", schema = @Schema())),
-            @ApiResponse(responseCode = "400", description = "请求失败")
-    })
-    @SystemControllerLog(description = "AI serarch api")
-    @PostMapping("/ai/search")
-    public Result<List<NodeDto>> search(@RequestBody String content) throws Exception {
-        return aiChatV1Service.chatSearch(content);
-    }
 }

base/src/main/java/com/tinyengine/it/service/app/impl/v1/AiChatV1ServiceImpl.java

@@ -12,22 +12,12 @@
 
 package com.tinyengine.it.service.app.impl.v1;
 
-import com.aliyun.bailian20231229.Client;
-import com.aliyun.tea.TeaException;
-import com.aliyun.teaopenapi.models.Config;
-import com.aliyun.teaopenapi.models.OpenApiRequest;
-import com.aliyun.teaopenapi.models.Params;
-import com.aliyun.teautil.models.RuntimeOptions;
 import com.fasterxml.jackson.databind.JsonNode;
-import com.tinyengine.it.common.base.Result;
 import com.tinyengine.it.common.log.SystemServiceLog;
 import com.tinyengine.it.common.utils.JsonUtils;
 import com.tinyengine.it.config.OpenAIConfig;
 import com.tinyengine.it.model.dto.ChatRequest;
-import com.tinyengine.it.model.dto.NodeDto;
 import com.tinyengine.it.service.app.v1.AiChatV1Service;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
 
@@ -39,9 +29,7 @@
 import java.net.http.HttpResponse;
 import java.nio.charset.StandardCharsets;
 import java.time.Duration;
-import java.util.ArrayList;
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
 
 /**
@@ -51,13 +39,7 @@
  */
 @Service
 public class AiChatV1ServiceImpl implements AiChatV1Service {
-    private static final String ACCESS_KEY_ID = System.getenv("ACCESS_KEY_ID");
-    private static final String ACCESS_KEY_SECRET = System.getenv("ACCESS_KEY_SECRET");
-    private static final String ENDPOINT = "bailian.cn-beijing.aliyuncs.com";
-    private static final String INDEX_ID = System.getenv("INDEX_ID");
-    private static final String WORK_SPACE_ID = System.getenv("WORK_SPACE_ID");
     private final OpenAIConfig config = new OpenAIConfig();
-    private static final Logger log = LoggerFactory.getLogger(AiChatV1ServiceImpl.class);
     private HttpClient httpClient = HttpClient.newBuilder()
             .connectTimeout(Duration.ofSeconds(config.getTimeoutSeconds()))
             .build();
@@ -122,160 +104,6 @@ private String ensureUrlProtocol(String url) {
         return "https://" + url;
     }
 
-    /**
-     * 创建客户端
-     */
-    private Client createClient() throws Exception {
-        return new Client(new Config()
-                .setAccessKeyId(ACCESS_KEY_ID)
-                .setAccessKeySecret(ACCESS_KEY_SECRET)
-                .setEndpoint(ENDPOINT)
-                .setEndpointType("access_key"));
-    }
-
-    /**
-     * 创建API信息
-     */
-    private Params createApiInfo(String WorkspaceId) throws Exception {
-        return new Params()
-                // 接口名称
-                .setAction("Retrieve")
-                // 接口版本
-                .setVersion("2023-12-29")
-                // 接口协议
-                .setProtocol("HTTPS")
-                // 接口 HTTP 方法
-                .setMethod("POST")
-                .setAuthType("AK")
-                .setStyle("ROA")
-                // 接口 PATH
-                .setPathname("/" + com.aliyun.openapiutil.Client.getEncodeParam(WorkspaceId) + "/index/retrieve")
-                // 接口请求体内容格式
-                .setReqBodyType("json")
-                // 接口响应体内容格式
-                .setBodyType("json");
-    }
-
-    /**
-     * 安全类型转换工具方法
-     */
-    private <T> T safeCast(Object obj, Class<T> clazz, T defaultValue) {
-        if (obj == null) {
-            return defaultValue;
-        }
-        try {
-            return clazz.cast(obj);
-        } catch (ClassCastException e) {
-            log.warn("类型转换失败: {} 无法转换为 {}", obj.getClass().getName(), clazz.getName());
-            return defaultValue;
-        }
-    }
-
-    private String safeCastToString(Object obj) {
-        return safeCast(obj, String.class, "");
-    }
-
-    private Double safeCastToDouble(Object obj) {
-        return safeCast(obj, Double.class, 0.0);
-    }
-
-    private Long safeCastToLong(Object obj) {
-        return safeCast(obj, Long.class, 0L);
-    }
-
-    /**
-     * chatSearch.
-     *
-     * @param content the content
-     * @return String the String
-     */
-    public Result chatSearch(String content) {
-        try {
-            Client client = createClient();
-            Params params = createApiInfo(WORK_SPACE_ID);
-
-            Map<String, Object> queries = new HashMap<>();
-            queries.put("IndexId", INDEX_ID);
-            queries.put("Query", content);
-            queries.put("EnableRewrite", "true");
-
-            RuntimeOptions runtime = new RuntimeOptions();
-            OpenApiRequest request = new OpenApiRequest()
-                    .setQuery(com.aliyun.openapiutil.Client.query(queries));
-
-            Map<String, ?> response = client.callApi(params, request, runtime);
-            Map<String, Object> body = (Map<String, Object>) response.get("body");
-
-            if (body == null) {
-                return Result.failed("响应体为空");
-            }
-
-            long status = safeCastToLong(body.get("Status"));
-            if (status != 200L) {
-                String message = safeCastToString(body.get("Message"));
-                log.error("搜索失败: status={}, message={}", status, message);
-                return Result.failed("搜索失败: " + message);
-            }
-
-            Map data = safeCast(body.get("Data"), Map.class, new HashMap<>());
-            if (data == null || data.isEmpty()) {
-                return Result.success(new ArrayList<>());
-            }
-
-            List nodes = safeCast(data.get("Nodes"), List.class, new ArrayList<>());
-            if (nodes.isEmpty()) {
-                return Result.success(new ArrayList<>());
-            }
-
-            List nodeDtos = convertToNodeDtos(nodes);
-            return Result.success(nodeDtos);
-
-        } catch (TeaException e) {
-            log.error("阿里云Tea异常: {}", e.getMessage(), e);
-            return Result.failed("阿里云服务异常: " + e.getMessage());
-        } catch (Exception e) {
-            log.error("搜索异常: {}", e.getMessage(), e);
-            return Result.failed("系统异常: " + e.getMessage());
-        }
-    }
-
-    /**
-     * 转换节点数据
-     */
-    private List<NodeDto> convertToNodeDtos(List<Map<String, Object>> nodes) {
-        List<NodeDto> nodeDtos = new ArrayList<>();
-
-        for (Map<String, Object> node : nodes) {
-            try {
-                NodeDto nodeDto = new NodeDto();
-
-                // 安全获取文本内容
-                nodeDto.setContent(safeCastToString(node.get("Text")));
-
-                // 安全获取分数
-                Object scoreObj = node.get("Score");
-                if (scoreObj instanceof Number) {
-                    nodeDto.setScore(((Number) scoreObj).doubleValue());
-                } else {
-                    nodeDto.setScore(safeCastToDouble(scoreObj));
-                }
-
-                // 安全获取元数据
-                Map metadata = safeCast(node.get("Metadata"), Map.class, new HashMap<>());
-                if (metadata != null) {
-                    nodeDto.setDocName(safeCastToString(metadata.get("doc_name")));
-                }
-
-                nodeDtos.add(nodeDto);
-
-            } catch (Exception e) {
-                log.warn("节点数据转换失败: {}", e.getMessage());
-            }
-        }
-
-        return nodeDtos;
-    }
-
     private String buildRequestBody(ChatRequest request) {
         Map<String, Object> body = new HashMap<>();
         body.put("model", request.getModel() != null ? request.getModel() : config.getDefaultModel());

base/src/main/java/com/tinyengine/it/service/app/v1/AiChatV1Service.java

@@ -12,11 +12,7 @@
 
 package com.tinyengine.it.service.app.v1;
 
-import com.tinyengine.it.common.base.Result;
 import com.tinyengine.it.model.dto.ChatRequest;
-import com.tinyengine.it.model.dto.NodeDto;
-
-import java.util.List;
 
 /**
  * The interface AIChat v 1 service.
@@ -31,12 +27,4 @@ public interface AiChatV1Service {
      * @return Object the Object
      */
     public Object chatCompletion(ChatRequest request) throws Exception;
-
-    /**
-     * chatSearch.
-     *
-     * @param content the content
-     * @return String the String
-     */
-    public Result<List<NodeDto>> chatSearch(String content) throws Exception;
 }