Skip to content

S
SchoolReportGen
Commit 9fe2ceb4 authored by 霍传世's avatar 霍传世
Browse files
Options

多线程测试生成PDF

parent 4d5e2933
Hide whitespace changes
Inline Side-by-side
Showing with 55 additions and 60 deletions
src/main/java/com/example/pdfgenerator/controller/GeneratorAllTypePdfByProvinceController.java
View file @ 9fe2ceb4
...@@ -447,73 +447,68 @@ public class GeneratorAllTypePdfByProvinceController { ...@@ -447,73 +447,68 @@ public class GeneratorAllTypePdfByProvinceController {
logger.info("Rows affected:" + rowsAffected); logger.info("Rows affected:" + rowsAffected);
}); });
}
}
if(retryCommands.size()!=0){
logger.info("size"+retryCommands.size());
for (RetryCommand retryCommand : retryCommands) {
String command = retryCommand.getRetryCommand();
Object params = retryCommand.getParams();
String filePrefix = "";
if ( params instanceof BasicReportParameters){
BasicReportParameters parametersOne = (BasicReportParameters) params;
filePrefix = parametersOne.getPrefix();
}
if (params instanceof ClassBasicReportParameters) {
ClassBasicReportParameters parametersTwo = (ClassBasicReportParameters) params;
filePrefix = parametersTwo.getPrefix();
}
if(retryCommands.size()!=0){ logger.info("RetryCommand:loading++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
logger.info("size"+retryCommands.size()); ProcessBuilder processBuilderClassSubject = new ProcessBuilder();
for (RetryCommand retryCommand : retryCommands) { processBuilderClassSubject.command("bash", "-c", command);
String command = retryCommand.getRetryCommand(); processBuilderClassSubject.redirectErrorStream(true); // 合并标准输出和错误输出
Object params = retryCommand.getParams(); Process processClassSubject = null;
String filePrefix = ""; try {
if ( params instanceof BasicReportParameters){ processClassSubject = processBuilderClassSubject.start();
BasicReportParameters parametersOne = (BasicReportParameters) params; } catch (IOException e) {
filePrefix = parametersOne.getPrefix(); throw new RuntimeException(e);
} }
if (params instanceof ClassBasicReportParameters) { BufferedReader readerClassSubject = new BufferedReader(new InputStreamReader(processClassSubject.getInputStream()));
ClassBasicReportParameters parametersTwo = (ClassBasicReportParameters) params; String lineClassSubject;
filePrefix = parametersTwo.getPrefix(); while (true) {
} try {
if (!((lineClassSubject = readerClassSubject.readLine()) != null)) break;
logger.info("RetryCommand:loading++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++"); } catch (IOException e) {
ProcessBuilder processBuilderClassSubject = new ProcessBuilder(); throw new RuntimeException(e);
processBuilderClassSubject.command("bash", "-c", command); }
processBuilderClassSubject.redirectErrorStream(true); // 合并标准输出和错误输出 }
Process processClassSubject = null; try {
try { int exitCodeSubjectClass = processClassSubject.waitFor();
processClassSubject = processBuilderClassSubject.start(); } catch (InterruptedException e) {
} catch (IOException e) { throw new RuntimeException(e);
throw new RuntimeException(e); }
} File classSubjectFile = new File(filePrefix);
BufferedReader readerClassSubject = new BufferedReader(new InputStreamReader(processClassSubject.getInputStream())); File[] classSubjectFiles = classSubjectFile.listFiles();
String lineClassSubject; assert classSubjectFiles != null;
while (true) { for (File file : classSubjectFiles) {
try { logger.info(file.getName()+"=file—>key="+fileToUrl.get(file.getName()));
if (!((lineClassSubject = readerClassSubject.readLine()) != null)) break; PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, fileToUrl.get(file.getName()), file);
} catch (IOException e) { try {
throw new RuntimeException(e); PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
} logger.info(putObjectResult.getRequestId());
} file.delete();
try { } catch (CosServiceException e) {
int exitCodeSubjectClass = processClassSubject.waitFor(); logger.info("cos服务出现问题");
} catch (InterruptedException e) { e.printStackTrace();
throw new RuntimeException(e); } catch (CosClientException e) {
} logger.info("cos客户端出现问题"+file.getName()+"文件上传有误,重新上传");
File classSubjectFile = new File(filePrefix);
File[] classSubjectFiles = classSubjectFile.listFiles();
assert classSubjectFiles != null;
for (File file : classSubjectFiles) {
logger.info(file.getName()+"=file—>key="+fileToUrl.get(file.getName()));
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, fileToUrl.get(file.getName()), file);
try {
PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
logger.info(putObjectResult.getRequestId());
file.delete();
} catch (CosServiceException e) {
logger.info("cos服务出现问题");
e.printStackTrace();
} catch (CosClientException e) {
logger.info("cos客户端出现问题"+file.getName()+"文件上传有误,重新上传");
}
}
} }
} }
} }
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment