hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-07 01:46:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

[DAT] 接口调用失败的数据挡板2

Browse Source
This commit is contained in:
liu.zixi
2025-10-23 09:26:41 +08:00
parent ceaeda8614
commit 4fab87998d
1 changed files with 9 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CaseKnowledgeServiceImpl.java
View File

@@ -25,10 +25,7 @@ import com.xboe.module.boecase.service.ICaseKnowledgeService;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.*;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
@@ -95,8 +92,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
@Override
public boolean uploadCaseDocument(Cases cases) {
// String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload";
String uploadUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/upload"; // 失败挡板
String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload";
JSONObject requestBody = new JSONObject();
String userId = getCurrentUserId();
requestBody.put("userId", userId);
@@ -172,7 +168,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
HttpPost httpPost = new HttpPost(uploadUrl);
HttpPut httpPost = new HttpPut(uploadUrl); //FIXME 需要改回post
httpPost.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpPost.setHeader("access_token", accessToken);
@@ -250,8 +246,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
@Override
public boolean deleteCaseDocument(Cases cases) {
// String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete";
String deleteUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/delete"; // 失败挡板
String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete";
String caseId = cases.getId();
if (cases == null) {
@@ -307,7 +302,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("删除案例文档第{}次尝试，caseId: {}, taskId: {}", attempt, caseId, taskId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
HttpDelete httpDelete = new HttpDelete(deleteUrl + "?" + params);
HttpPatch httpDelete = new HttpPatch(deleteUrl + "?" + params); // 需要换回delete
httpDelete.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpDelete.setHeader("access_token", accessToken);
httpDelete.setHeader("Content-Type", "application/x-www-form-urlencoded");
@@ -397,8 +392,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
@Override
public boolean updateCaseDocument(Cases cases) {
// String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete";
String deleteUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/delete"; // 失败挡板
String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete";
String caseId = cases.getId();
if (cases == null) {
@@ -454,7 +448,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("删除案例文档第{}次尝试，caseId: {}, taskId: {}", attempt, caseId, deleteTaskId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
HttpDelete httpDelete = new HttpDelete(deleteUrl + "?" + params);
HttpPatch httpDelete = new HttpPatch(deleteUrl + "?" + params);
httpDelete.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpDelete.setHeader("access_token", accessToken);
httpDelete.setHeader("Content-Type", "application/x-www-form-urlencoded");
@@ -580,8 +574,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
requestBody.put("callbackUrl", caseAiProperties.getFileUploadCallbackUrl());
}
// String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload";
String uploadUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/upload"; // 失败挡板
String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload";
// 3. 获取access_token
String accessToken = aiAccessTokenService.getAccessToken();
@@ -596,7 +589,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
HttpPost httpPost = new HttpPost(uploadUrl);
HttpPut httpPost = new HttpPut(uploadUrl);
httpPost.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpPost.setHeader("access_token", accessToken);