package com.ots.project.tool.libreoffice;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.jodconverter.core.DocumentConverter;
|
import org.jodconverter.core.office.OfficeException;
|
import org.jodconverter.core.office.OfficeManager;
|
import org.jodconverter.local.LocalConverter;
|
import org.jodconverter.local.office.LocalOfficeManager;
|
import org.jodconverter.local.process.WindowsProcessManager;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.StringUtils;
|
|
import javax.annotation.PostConstruct;
|
import javax.annotation.PreDestroy;
|
import java.io.File;
|
import java.util.concurrent.BlockingQueue;
|
import java.util.concurrent.LinkedBlockingDeque;
|
import java.util.concurrent.locks.Lock;
|
import java.util.concurrent.locks.ReentrantLock;
|
|
/**
|
* @version 1.0
|
* @Author linzhijie
|
* @Description TODO
|
* @Date 2022/10/21 10:03
|
*/
|
@Slf4j
|
@Component
|
public class Office2PDFUtils {
|
|
@Value("${jodconverter.local.office-home}")
|
private String officeHome;
|
|
@Value("${jodconverter.local.portNumbers}")
|
private String portNumbers;
|
|
private static BlockingQueue<OfficeManager> OfficeManagerQueue = new LinkedBlockingDeque<>();
|
|
private static Lock lock = new ReentrantLock();
|
|
/**
|
* @Description: 使Office2003-2007全部格式的文档(.doc|.docx|.xls|.xlsx|.ppt|.pptx) 转化为pdf文件
|
* @method: openOfficeToPDF
|
* @Param: inputFilePath
|
* @Param: outputFilePath
|
* @return: boolean
|
* @auther: LHL
|
*/
|
public boolean openOfficeToPDF(String inputFilePath, String outputFilePath) {
|
return office2Pdf(inputFilePath, outputFilePath);
|
}
|
|
/**
|
* @Description: 根据操作系统的名称，获取OpenOffice.org 的安装目录
|
* @method: getOfficeHome
|
* @Param:
|
* @return: java.lang.String OpenOffice.org 的安装目录
|
* @auther: LHL
|
*/
|
/* private String getOfficeHome() {
|
String osName = System.getProperty("os.name");
|
log.debug("操作系统名称:" + osName);
|
if (Pattern.matches("Linux.*", osName)) {
|
return linuxPath;
|
} else if (Pattern.matches("Windows.*", osName)) {
|
return winPath;
|
} else if (Pattern.matches("Mac.*", osName)) {
|
return winPath;
|
}
|
return null;
|
}*/
|
|
/**
|
* @Description: 在bean创建实例时, 连接OpenOffice.org 并且启动OpenOffice.org
|
* @method: initOpenOfficeService
|
* @Param:
|
* @return: void
|
* @auther: LHL
|
*/
|
@PostConstruct
|
public void initOpenOfficeService() {
|
|
LocalOfficeManager.Builder builder = LocalOfficeManager.builder();
|
builder.officeHome(officeHome);
|
builder.portNumbers(2002);
|
builder.processTimeout(12000L);
|
builder.processRetryInterval(250L);
|
builder.maxTasksPerProcess(200);
|
builder.taskQueueTimeout(30000L);
|
for (String port : portNumbers.split(",")) {
|
builder.portNumbers(Integer.valueOf(port));
|
OfficeManager OfficeManager = builder.build();
|
try {
|
OfficeManager.start();
|
log.debug("***********************officeManager 启动!***********************");
|
} catch (OfficeException e) {
|
//打印日志
|
log.debug("***********************启动 openOffice 失败!***********************");
|
e.printStackTrace();
|
}
|
try {
|
OfficeManagerQueue.put(OfficeManager);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* @Description: bean销毁时停止
|
* @method: destroyOpenOfficeService
|
* @Param:
|
* @return: void
|
* @auther: LHL
|
*/
|
@PreDestroy
|
public void destroyOpenOfficeService() {
|
for (OfficeManager manager : OfficeManagerQueue) {
|
try {
|
log.debug("关闭 officeManager");
|
manager.stop();
|
} catch (OfficeException e) {
|
log.debug("officeManager关闭失败!" + e.getMessage());
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* @Description: 转换文件
|
* @method: convertFile
|
* @Param: inputFile
|
* @Param: outputFilePath
|
* @Param: officeManager
|
* @return: java.io.File
|
* @auther: LHL
|
*/
|
private File convertFile(File inputFile, String outputFilePath, OfficeManager officeManager) throws OfficeException {
|
File outputFile = new File(outputFilePath);
|
// 假如目标路径不存在,则新建该路径
|
if (!outputFile.getParentFile().exists()) {
|
outputFile.getParentFile().mkdirs();
|
}
|
DocumentConverter converter = LocalConverter.builder()
|
.officeManager(officeManager)
|
.build();
|
// 锁
|
lock.lock();
|
//converter.convert(inputFile).to(outputFile).execute();
|
converter.convert(inputFile).to(outputFile).execute();
|
//释放锁
|
lock.unlock();
|
try {
|
OfficeManagerQueue.put(officeManager);
|
log.debug("blockingQueue puted OfficeManagerQueue size :" + OfficeManagerQueue.size());
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
log.debug("文件：" + inputFile.getAbsolutePath() + "\n转换为目标文件：" + outputFile + "\n成功!");
|
return outputFile;
|
}
|
|
/**
|
* 文件名需要唯一
|
*/
|
public boolean office2Pdf(String inputFilePath, String outputFilePath) {
|
OfficeManager officeManager = null;
|
try {
|
if (StringUtils.isEmpty(inputFilePath)) {
|
log.debug("输入文件地址为空，转换终止!");
|
return false;
|
}
|
File inputFile = new File(inputFilePath);
|
if (!inputFile.exists()) {
|
log.debug("输入文件不存在，转换终止!");
|
return false;
|
}
|
officeManager = OfficeManagerQueue.take();
|
log.debug("blockingQueue taked , OfficeManagerQueue size :" + OfficeManagerQueue.size());
|
File file = convertFile(inputFile, outputFilePath, officeManager);
|
if (!file.exists()) {
|
log.debug("转换文件不存在!转换失败!!");
|
return false;
|
}
|
return true;
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.debug("转换异常");
|
return false;
|
}
|
}
|
}
|
