hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-08 18:36:51 +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 c29dcd5966
commit e20a20ec43
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 lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpEntity; import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse; import org.apache.http.HttpResponse;
import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.*;
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.entity.mime.MultipartEntityBuilder; import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.ContentType; import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity; import org.apache.http.entity.StringEntity;
@@ -95,8 +92,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
@Override @Override
public boolean uploadCaseDocument(Cases cases) { public boolean uploadCaseDocument(Cases cases) {
// String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload"; String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload";
String uploadUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/upload"; // 失败挡板
JSONObject requestBody = new JSONObject(); JSONObject requestBody = new JSONObject();
String userId = getCurrentUserId(); String userId = getCurrentUserId();
requestBody.put("userId", userId); requestBody.put("userId", userId);
@@ -172,7 +168,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId); log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) { 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("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpPost.setHeader("access_token", accessToken); httpPost.setHeader("access_token", accessToken);
@@ -250,8 +246,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
@Override @Override
public boolean deleteCaseDocument(Cases cases) { public boolean deleteCaseDocument(Cases cases) {
// String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete"; String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete";
String deleteUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/delete"; // 失败挡板
String caseId = cases.getId(); String caseId = cases.getId();
if (cases == null) { if (cases == null) {
@@ -307,7 +302,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("删除案例文档第{}次尝试，caseId: {}, taskId: {}", attempt, caseId, taskId); log.info("删除案例文档第{}次尝试，caseId: {}, taskId: {}", attempt, caseId, taskId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) { 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("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpDelete.setHeader("access_token", accessToken); httpDelete.setHeader("access_token", accessToken);
httpDelete.setHeader("Content-Type", "application/x-www-form-urlencoded"); httpDelete.setHeader("Content-Type", "application/x-www-form-urlencoded");
@@ -397,8 +392,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
@Override @Override
public boolean updateCaseDocument(Cases cases) { public boolean updateCaseDocument(Cases cases) {
// String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete"; String deleteUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/delete";
String deleteUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/delete"; // 失败挡板
String caseId = cases.getId(); String caseId = cases.getId();
if (cases == null) { if (cases == null) {
@@ -454,7 +448,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("删除案例文档第{}次尝试，caseId: {}, taskId: {}", attempt, caseId, deleteTaskId); log.info("删除案例文档第{}次尝试，caseId: {}, taskId: {}", attempt, caseId, deleteTaskId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) { 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("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpDelete.setHeader("access_token", accessToken); httpDelete.setHeader("access_token", accessToken);
httpDelete.setHeader("Content-Type", "application/x-www-form-urlencoded"); httpDelete.setHeader("Content-Type", "application/x-www-form-urlencoded");
@@ -580,8 +574,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
requestBody.put("callbackUrl", caseAiProperties.getFileUploadCallbackUrl()); requestBody.put("callbackUrl", caseAiProperties.getFileUploadCallbackUrl());
} }
// String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload"; String uploadUrl = caseAiProperties.getBaseUrl() + "/apigateway/knowledge/v1/file/upload";
String uploadUrl = "http://10.10.181.114:30000" + "/apigateway/knowledge/v1/file/upload"; // 失败挡板
// 3. 获取access_token // 3. 获取access_token
String accessToken = aiAccessTokenService.getAccessToken(); String accessToken = aiAccessTokenService.getAccessToken();
@@ -596,7 +589,7 @@ public class CaseKnowledgeServiceImpl implements ICaseKnowledgeService {
log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId); log.info("上传案例文档第{}次尝试，caseId: {}", attempt, caseId);
try (CloseableHttpClient httpClient = HttpClients.createDefault()) { try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
HttpPost httpPost = new HttpPost(uploadUrl); HttpPut httpPost = new HttpPut(uploadUrl);
httpPost.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode()); httpPost.setHeader("X-AI-ApiCode", caseAiProperties.getAiApiCode());
httpPost.setHeader("access_token", accessToken); httpPost.setHeader("access_token", accessToken);