diff --git a/adc-da-convert/pom.xml b/adc-da-convert/pom.xml
index 49b7dbb2..f2b4d1ef 100644
--- a/adc-da-convert/pom.xml
+++ b/adc-da-convert/pom.xml
@@ -23,20 +23,26 @@
3.0.0
+
+
+ com.artofsolving
+ jodconverter
+ 2.2.1
+
org.jodconverter
jodconverter-core
- 4.2.2
+ 4.3.0
org.jodconverter
jodconverter-spring-boot-starter
- 4.2.2
+ 4.3.0
org.jodconverter
jodconverter-local
- 4.2.2
+ 4.3.0
diff --git a/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverterPdf.java b/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverterPdf.java
index 5fd73037..503973d9 100644
--- a/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverterPdf.java
+++ b/adc-da-convert/src/main/java/com/adc/da/convert/common/DocConverterPdf.java
@@ -1,16 +1,20 @@
package com.adc.da.convert.common;
+import com.artofsolving.jodconverter.openoffice.connection.SocketOpenOfficeConnection;
+import com.artofsolving.jodconverter.openoffice.converter.StreamOpenOfficeDocumentConverter;
import org.apache.commons.lang.StringUtils;
-import org.jodconverter.DocumentConverter;
-import org.jodconverter.JodConverter;
-import org.jodconverter.OfficeDocumentConverter;
-import org.jodconverter.document.DefaultDocumentFormatRegistry;
-import org.jodconverter.office.*;
+import org.jodconverter.core.DocumentConverter;
+import org.jodconverter.core.office.OfficeException;
+import org.jodconverter.core.office.OfficeManager;
+import org.jodconverter.core.office.OfficeUtils;
+import org.jodconverter.local.JodConverter;
+import org.jodconverter.local.office.LocalOfficeManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import java.io.*;
+import java.net.ConnectException;
public class DocConverterPdf {
@@ -75,6 +79,35 @@ public class DocConverterPdf {
*/
private static final int openOfficePort = 8100;
+ /**
+ *
+ * @param input 初始文件的路径,例:C:\Users\...\Desktop\test\1.doc
+ * @param output 转换后的存储路径,例:C:\Users\...\Desktop\test\
+ */
+ public void convert(File input , File output){
+
+ if (!input.exists()){
+ System.out.println("源文件不存在");
+ return;
+ }
+ SocketOpenOfficeConnection connection = new SocketOpenOfficeConnection("0.0.0.0", 8100);
+// SocketOpenOfficeConnection connection = new SocketOpenOfficeConnection("10.10.66.176", 8100);
+ try {
+ connection.connect();
+ System.out.println("获取连接成功!");
+ } catch (ConnectException e) {
+ System.out.println("获取连接失败!");
+ e.printStackTrace();
+ }
+// OpenOfficeDocumentConverter converter = new OpenOfficeDocumentConverter(connection);
+ StreamOpenOfficeDocumentConverter converter = new StreamOpenOfficeDocumentConverter(connection);
+ System.out.println("开始转换!");
+ converter.convert(input, output);
+ System.out.println("转换成功!");
+ System.out.println("关闭连接!");
+ connection.disconnect();
+ }
+
/**
* 转化文档
* @param input
@@ -113,7 +146,7 @@ public class DocConverterPdf {
try {
// in = new FileInputStream(docFile);
// out = new FileOutputStream(convertPdfFile);
- convertFile(docFile,convertPdfFile);
+ convert(docFile,convertPdfFile);
// converter.convert(in).as(DefaultDocumentFormatRegistry.getFormatByMediaType(filesType)).
// to(out).as(DefaultDocumentFormatRegistry.PDF);
// close the connection
diff --git a/adc-da-search/src/main/java/com/adc/da/search/service/impl/SearchCenterServiceImpl.java b/adc-da-search/src/main/java/com/adc/da/search/service/impl/SearchCenterServiceImpl.java
index d172428e..66c976c8 100644
--- a/adc-da-search/src/main/java/com/adc/da/search/service/impl/SearchCenterServiceImpl.java
+++ b/adc-da-search/src/main/java/com/adc/da/search/service/impl/SearchCenterServiceImpl.java
@@ -571,13 +571,13 @@ public class SearchCenterServiceImpl implements SearchCenterService {
boolQueryBuilder.must(QueryBuilders.wildcardQuery("standSort.keyword", "*"+searchInfoEO.getStandSort()+"*"));
}
if (StringUtils.isNotBlank(searchInfoEO.getStandCode())) {
- boolQueryBuilder.must(QueryBuilders.wildcardQuery("standCode.keyword", "*"+searchInfoEO.getStandCode()+"*"));
+ boolQueryBuilder.must(QueryBuilders.wildcardQuery("standNumber.keyword", "*"+searchInfoEO.getStandCode()+"*"));
}
if (StringUtils.isNotBlank(searchInfoEO.getStandYear())) {
boolQueryBuilder.must(QueryBuilders.wildcardQuery("standYear.keyword", "*"+searchInfoEO.getStandYear()+"*"));
}
if (StringUtils.isNotBlank(searchInfoEO.getStandName())) {
- boolQueryBuilder.must(QueryBuilders.wildcardQuery("standName.keyword", "*"+searchInfoEO.getStandName()+"*"));
+ boolQueryBuilder.must(QueryBuilders.wildcardQuery("stand_name.keyword", "*"+searchInfoEO.getStandName()+"*"));
}
if (StringUtils.isNotBlank(searchInfoEO.getStandEnName())) {
boolQueryBuilder.must(QueryBuilders.wildcardQuery("standEnName.keyword", "*"+searchInfoEO.getStandEnName()+"*"));
diff --git a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java
index 6664c6bb..73534336 100644
--- a/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java
+++ b/adc-da-slrs/src/main/java/com/adc/da/scheduled/ScheduledJob.java
@@ -12,7 +12,9 @@ import com.adc.da.slrs.sarStandardsInfo.dao.SarStandardsInfoDao;
import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo;
import com.adc.da.util.UUIDUtils;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.sun.corba.se.spi.ior.iiop.IIOPFactories;
import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
@@ -21,9 +23,9 @@ import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDate;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
@EnableScheduling
@Component
@@ -205,37 +207,84 @@ public class ScheduledJob {
/**
- * 被多个标准代替的标准变为“被代替”,只有一个被代替的自动变为“废止”
+ * 被多个标准代替的标准变为“被代替”,只被一个标准代替的自动变为“废止”
*/
- QueryWrapper columns = new QueryWrapper<>();
- columns.select("DTBJH","STAND_ID");
- List