package com.ruoyi.service.impl;
|
|
import cn.hutool.json.JSONObject;
|
import com.ruoyi.service.IArchiveDoublePdfGenerateService;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.ParseException;
|
import org.apache.http.client.ClientProtocolException;
|
|
import cn.hutool.http.HttpRequest;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClientBuilder;
|
import org.apache.http.util.EntityUtils;
|
import org.springframework.stereotype.Service;
|
|
import java.io.File;
|
import java.io.IOException;
|
import java.net.URI;
|
import java.nio.file.Files;
|
import java.nio.file.Paths;
|
import java.util.UUID;
|
|
@Service
|
public class IArchiveDoublePdfGenerateServiceImpl implements IArchiveDoublePdfGenerateService {
|
private final String OCRServer = "http://127.0.0.1:1224/";
|
private String MUL_LAYER_PDF_URL = OCRServer + "api/doc/upload";
|
private String MUL_LAYER_PDF_STATE_URL = OCRServer + "api/doc/result";
|
private String MUL_LAYER_PDF_DOWNLOAD_URL = OCRServer + "api/doc/download";
|
|
|
public void unicodeEscapeToChinese (String unicodeEscapedString) {
|
// 解码Unicode转义序列
|
StringBuilder decodedString = new StringBuilder();
|
int i = 0;
|
while (i < unicodeEscapedString.length()) {
|
if (unicodeEscapedString.startsWith("\\u", i)) {
|
// 找到一个Unicode转义序列
|
int codePoint = Integer.parseInt(unicodeEscapedString.substring(i + 2, i + 6), 16);
|
decodedString.appendCodePoint(codePoint);
|
i += 6; // 跳过这个Unicode转义序列
|
} else {
|
// 不是Unicode转义序列，直接添加字符
|
decodedString.append(unicodeEscapedString.charAt(i));
|
i++;
|
}
|
}
|
// 打印解码后的字符串
|
System.out.println(decodedString.toString());
|
}
|
|
|
public void testConnection() throws IOException {
|
File pdfFile = new File("34.pdf");
|
String base64 = java.util.Base64.getEncoder().encodeToString(Files.readAllBytes(pdfFile.toPath()));
|
|
JSONObject inputObject = new JSONObject();
|
inputObject.put("base64", base64);
|
//inputObject.put("options", new JSONObject().put("ocr.language", "models/config_chinese.txt"));
|
|
String response = HttpRequest.post(OCRServer+ "api/doc/result")
|
.body(inputObject.toString())
|
.contentType("application/json")
|
.execute()
|
.body();
|
unicodeEscapeToChinese(response);
|
// System.out.println("unicodeEscapeToChinese("\u672a\u586b\u5199id\u3002"));
|
// // 获得Http客户端(可以理解为:你得先有一个浏览器;注意:实际上HttpClient与浏览器是不一样的)
|
// CloseableHttpClient httpClient = HttpClientBuilder.create().build();
|
// // 创建Get请求
|
// HttpGet httpGet = new HttpGet(OCRServer);
|
//
|
// // 响应模型
|
// CloseableHttpResponse response = null;
|
// try {
|
// // 由客户端执行(发送)Get请求
|
// response = httpClient.execute(httpGet);
|
// // 从响应模型中获取响应实体
|
// HttpEntity responseEntity = response.getEntity();
|
// System.out.println("响应状态为:" + response.getStatusLine());
|
// if (responseEntity != null) {
|
// System.out.println("响应内容长度为:" + responseEntity.getContentLength());
|
// System.out.println("响应内容为:" + EntityUtils.toString(responseEntity));
|
// }
|
// } catch (ClientProtocolException e) {
|
// e.printStackTrace();
|
// } catch (ParseException e) {
|
// e.printStackTrace();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// } finally {
|
// try {
|
// // 释放资源
|
// if (httpClient != null) {
|
// httpClient.close();
|
// }
|
// if (response != null) {
|
// response.close();
|
// }
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// }
|
|
}
|
|
public void doublePdfGenerate() throws IOException {
|
// String ocrUrl = "http://localhost:32009/umi/api/ocr";
|
File pdfFile = new File("34.pdf");
|
String base64 = java.util.Base64.getEncoder().encodeToString(Files.readAllBytes(pdfFile.toPath()));
|
|
JSONObject inputObject = new JSONObject();
|
inputObject.put("base64", base64);
|
//inputObject.put("options", new JSONObject().put("ocr.language", "models/config_chinese.txt"));
|
|
String response = HttpRequest.post(OCRServer+"/umi/api/ocr")
|
.body(inputObject.toString())
|
.contentType("application/json")
|
.execute()
|
.body();
|
|
System.out.println("识别结果: " + response);
|
|
// 创建HttpClient实例
|
// HttpClient client = HttpClient.newHttpClient();
|
|
//// 生成boundary用于分隔表单数据
|
// String boundary = UUID.randomUUID().toString();
|
//
|
//// 构建multipart/form-data请求体
|
// StringBuilder sb = new StringBuilder();
|
//// 添加JSON参数部分
|
// sb.append("--").append(boundary).append("\r\n");
|
// sb.append("Content-Disposition: form-data; name=\"json\"\r\n");
|
// sb.append("Content-Type: application/json\r\n");
|
// sb.append("\r\n");
|
// sb.append(options_json).append("\r\n");
|
//
|
//// 添加文件部分
|
// sb.append("--").append(boundary).append("\r\n");
|
// sb.append("Content-Disposition: form-data; name=\"file\"; filename=\"")
|
// .append(Paths.get(path).getFileName()).append("\"\r\n");
|
// sb.append("Content-Type: application/pdf\r\n"); // 明确指定PDF类型
|
// sb.append("\r\n");
|
//
|
//// 读取文件内容并构建完整请求体
|
// byte[] fileBytes = Files.readAllBytes(Paths.get(path));
|
// byte[] requestBody = new byte[sb.toString().getBytes().length + fileBytes.length
|
// + ("\r\n--" + boundary + "--\r\n").getBytes().length];
|
// System.arraycopy(sb.toString().getBytes(), 0, requestBody, 0, sb.toString().getBytes().length);
|
// System.arraycopy(fileBytes, 0, requestBody, sb.toString().getBytes().length, fileBytes.length);
|
// System.arraycopy(("\r\n--" + boundary + "--\r\n").getBytes(), 0, requestBody,
|
// sb.toString().getBytes().length + fileBytes.length,
|
// ("\r\n--" + boundary + "--\r\n").getBytes().length);
|
//
|
//// 创建并发送请求
|
// HttpRequest request = HttpRequest.newBuilder()
|
// .uri(URI.create(url))
|
// .header("Content-Type", "multipart/form-data; boundary=" + boundary)
|
// .POST(HttpRequest.BodyPublishers.ofByteArray(requestBody))
|
// .build();
|
//
|
//// 处理响应
|
// HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
|
// System.out.println("响应状态码: " + response.statusCode());
|
// System.out.println("响应内容: " + response.body());
|
}
|
}
|
