This commit is contained in:
hejinbo
2023-11-28 15:34:58 +08:00
parent c46f81c628
commit 9807b13101
3 changed files with 150 additions and 87 deletions
@@ -2856,16 +2856,16 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
return AjaxResult.error("请选择要上传的文件");
}
UUID uuid = UUID.randomUUID();
String targetPath = "\\home\\ruoyi\\uploadPath\\upload\\unzipFile\\";
//String targetPath = "D:\\home\\unzip\\" + uuid + "\\";
String targetPath = "/home/ruoyi/uploadPath/upload/unzipFile/"+uuid+ "/";
//String targetPath = "D:/home/unzip/" + uuid + "/";
File zipFile = null;
InputStream ins = null;
try {
ins = file.getInputStream();
//上传的压缩包保存的路径
//String savePath = "D:\\develop\\java\\";
String savePath = "\\home\\ruoyi\\uploadPath\\upload\\zipFile\\";
String saveName = uuid + file.getOriginalFilename();
String savePath = "/home/ruoyi/uploadPath/upload/zipFile/";
//String savePath = "D:/home/zipFile/";
String saveName = uuid + "_" + file.getOriginalFilename();
zipFile = new File(savePath + saveName);
inputChangeToFile(ins, zipFile);
} catch (IOException e) {
@@ -2880,13 +2880,17 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
//遍历路径
for (String pdfUrl : andConvertPDF) {
//获取文件的页数
System.out.println("这是查到的符合条件的文件路径====="+pdfUrl);
int fileNumPage = getFileNumPage(pdfUrl);
//文件转成base64
String base64 = OCRUtils.pdfConvertBase64(pdfUrl);
if (base64 == null){
return AjaxResult.error("文件转base64编码有误,请检查");
}
StringBuilder stringBuilder = new StringBuilder(); // 创建一个StringBuilder对象
for (int i = 0; i < fileNumPage; i++) {
//对接腾讯云接口.识别里面的数据
//暂时写死
String pdfFilePath = "http://121.40.189.20:9000/API/uploadPath/upload/2023/11/14/ca2ca4697e5449ff9b9d23f95b221f58.pdf";
String text = OCRUtils.pdfIdentifyText(pdfUrl, i + 1);
String text = OCRUtils.pdfIdentifyText(base64, i + 1);
if (stringBuilder.length() > 0) {
stringBuilder.append(","); // 在已有内容的情况下添加逗号分隔符
}
@@ -2894,56 +2898,69 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
}
// 将字符串按逗号分隔符切割
String[] fields = stringBuilder.toString().split(",");
JSONObject jsonObject = new JSONObject(); // 创建一个空的JSON对象
Map<String, List<String>> map = new HashMap<>();
for (String field : fields) {
// 对于每个字段,再按冒号分隔符拆分出键和值
String[] keyValue = field.split(":");
if (keyValue.length == 2) { // 对于合法的键值对,将其添加到JSON对象中
jsonObject.put(keyValue[0], keyValue[1]);
if (keyValue.length >= 2) {
String key = keyValue[0];
String value = keyValue[1];
// 判断Map中是否已存在该键
if (map.containsKey(key)) {
// 如果已存在,获取该键对应的值,并将新的值添加到集合中
List<String> values = map.get(key);
values.add(value);
} else {
// 如果不存在,创建一个新的集合,并将值添加到集合中
List<String> values = new ArrayList<>();
values.add(value);
map.put(key, values);
}
}
}
//调用新增案件的接口
CaseApplication caseApplication = new CaseApplication();
caseApplication.setApplicationOrganId(jsonObject.getString("统一社会信用代码"));
caseApplication.setCompLegalPerson(jsonObject.getString("法定代表人"));
caseApplication.setResidenAffiliAppli(jsonObject.getString("住所"));
caseApplication.setContactAddressAgent(jsonObject.getString("联系地址"));
caseApplication.setNameAgent(jsonObject.getString("委托代理人"));
caseApplication.setContactTelphoneAgent(jsonObject.getString("联系电话"));
caseApplication.setDebtorName(jsonObject.getString("被申请人"));
caseApplication.setDebtorIdentityNum(jsonObject.getString("居民身份证号码"));
caseApplication.setArbitratClaims(jsonObject.getString("仲裁请求"));
caseApplication.setCaseSubjectAmount(new BigDecimal(1));
List<CaseAffiliate> caseAffiliates = new ArrayList<>();
CaseAffiliate caseAffiliate = new CaseAffiliate();
caseAffiliate.setIdentityType(1);
caseAffiliate.setName(jsonObject.getString("申请人"));
caseAffiliate.setIdentityNum("");
caseAffiliate.setContactTelphone(jsonObject.getString("申请人联系电话"));
caseAffiliates.add(caseAffiliate);
CaseAffiliate caseAffiliate1 = new CaseAffiliate();
caseAffiliate1.setIdentityType(2);
caseAffiliate1.setName(jsonObject.getString("被申请人"));
caseAffiliate1.setIdentityNum("");
caseAffiliate1.setContactTelphone(jsonObject.getString("被申请人联系电话"));
caseAffiliates.add(caseAffiliate1);
caseApplication.setCaseAffiliates(caseAffiliates);
this.insertcaseApplication(caseApplication);
if (null != caseApplication.getId()) {
// 绑定案件与申请书
File file1 = new File(pdfUrl);
CaseAttach caseAttach = new CaseAttach();
caseAttach.setCaseAppliId(caseApplication.getId());
String saveName = "/profile/upload/" + file1.getName();
String savePath = "/home/ruoyi/uploadPath/upload";
caseAttach.setAnnexPath(savePath);
caseAttach.setAnnexName(saveName);
caseAttach.setAnnexType(1);
caseAttachMapper.save(caseAttach);
if (map.size()>0){
//调用新增案件的接口
CaseApplication caseApplication = new CaseApplication();
//默认案件标的
caseApplication.setCaseSubjectAmount(new BigDecimal(1));
caseApplication.setApplicationOrganId(map.get("统一社会信用代码").get(0));
caseApplication.setCompLegalPerson(map.get("负责人").get(0));
caseApplication.setNameAgent(map.get("委托代理人").get(0));
caseApplication.setArbitratClaims(map.get("仲裁请求").get(0));
List<CaseAffiliate> caseAffiliates = new ArrayList<>();
CaseAffiliate caseAffiliate = new CaseAffiliate();
caseAffiliate.setIdentityType(1);
caseAffiliate.setName(map.get("申请人").get(0));
caseAffiliate.setIdentityNum(map.get("统一社会信用代码").get(0));
caseAffiliate.setContactTelphone(map.get("联系电话").get(0));
caseAffiliate.setResidenAffili(map.get("住所").get(0));
caseAffiliate.setContactAddress(map.get("联系地址").get(0));
caseAffiliate.setSendEmail(map.get("电子邮件").get(0));
caseAffiliates.add(caseAffiliate);
CaseAffiliate caseAffiliate1 = new CaseAffiliate();
caseAffiliate1.setIdentityType(2);
caseAffiliate1.setName(map.get("被申请人").get(0));
caseAffiliate1.setIdentityNum(map.get("居民身份证号码").get(0));
caseAffiliate1.setContactTelphone(map.get("联系电话").get(1));
caseAffiliate1.setResidenAffili(map.get("住所").get(1));
caseAffiliates.add(caseAffiliate1);
caseApplication.setCaseAffiliates(caseAffiliates);
this.insertcaseApplication(caseApplication);
if (null != caseApplication.getId()) {
// 绑定案件与申请书
File file1 = new File(pdfUrl);
CaseAttach caseAttach = new CaseAttach();
caseAttach.setCaseAppliId(caseApplication.getId());
caseAttach.setAnnexPath(file1.getPath());
caseAttach.setAnnexName(file1.getName());
caseAttach.setAnnexType(1);
caseAttachMapper.save(caseAttach);
return AjaxResult.success("导入成功");
}
}else{
return AjaxResult.error("文件识别内容失败,请检查");
}
}
return AjaxResult.success("导入成功");
} else {
// 没有找到符合条件的文件
return AjaxResult.error("未找到符合条件的文件");
@@ -2952,7 +2969,7 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
// 解压失败
return AjaxResult.error("解压失败");
}
return null;
}
public static List<String> findAndConvertPDF(File directory) {
@@ -3026,8 +3043,8 @@ public class CaseApplicationServiceImpl implements ICaseApplicationService {
private static String convertToPDF(File file) {
String wordFilePath = file.getAbsolutePath();
// String pdfSaveDirectory = "D:\\home\\unzip\\wordToPDF\\";
String pdfSaveDirectory = "\\home\\ruoyi\\uploadPath\\upload\\wordToPDF\\";
//String pdfSaveDirectory = "D:\\home\\unzip\\wordToPDF\\";
String pdfSaveDirectory = "/home/ruoyi/uploadPath/upload/wordToPDF/";
File directory = new File(pdfSaveDirectory);
if (!directory.exists()) {
directory.mkdirs();