Skip to content

S
SchoolReportGen
Commit 3ee6af0a authored by 霍传世's avatar 霍传世
Browse files
Options

测试生成上传任务表

parent c9a29266
Hide whitespace changes
Inline Side-by-side
Showing with 26 additions and 43 deletions
src/main/java/com/example/pdfgenerator/controller/PDFGeByProvinceBatchController.java
View file @ 3ee6af0a
...@@ -213,51 +213,34 @@ public class PDFGeByProvinceBatchController { ...@@ -213,51 +213,34 @@ public class PDFGeByProvinceBatchController {
List<BasicReportParameters> schoolBasicReport = schoolReport.get(key); List<BasicReportParameters> schoolBasicReport = schoolReport.get(key);
for (BasicReportParameters schoolLevel : schoolBasicReport) { for (BasicReportParameters schoolLevel : schoolBasicReport) {
logger.info("school:"+schoolLevel.getSchool()+"loading---------------------------------------------------------------"); logger.info("school:"+schoolLevel.getSchool()+"loading---------------------------------------------------------------");
executorService.submit(() -> { logger.info("basicReport:loading******************************************");
// 其他逻辑... ProcessBuilder processBuilder = new ProcessBuilder();
logger.info("basicReport:loading******************************************"); processBuilder.command("bash", "-c", schoolLevel.getCommand());
ProcessBuilder processBuilder = new ProcessBuilder(); processBuilder.redirectErrorStream(true); // 合并标准输出和错误输出
processBuilder.command("bash", "-c", schoolLevel.getCommand()); Process process = processBuilder.start();
processBuilder.redirectErrorStream(true); // 合并标准输出和错误输出 BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
Process process = null; String line;
while ((line = reader.readLine()) != null) {
}
int exitCode = process.waitFor();
logger.info("exitCode:"+schoolLevel.getSchool());
File file = new File("/myworkSpace/basic/");
File[] files1 = file.listFiles();
assert files1 != null;
for (File file1 : files1) {
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, "PdfTest/"+file1.getName(), file1);
try { try {
process = processBuilder.start(); PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
} catch (IOException e) { logger.info(putObjectResult.getRequestId());
throw new RuntimeException(e); file1.delete();
} catch (CosServiceException e) {
logger.info("cos服务出现问题");
e.printStackTrace();
} catch (CosClientException e) {
logger.info("cos客户端出现问题"+file.getName()+"文件上传有误,重新上传");
e.printStackTrace();
} }
BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); }
String line;
while (true) {
try {
if (!((line = reader.readLine()) != null)) break;
} catch (IOException e) {
throw new RuntimeException(e);
}
}
try {
int exitCode = process.waitFor();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
logger.info("exitCode:"+schoolLevel.getSchool());
// File file = new File("/myworkSpace/basic/");
// File[] files1 = file.listFiles();
// assert files1 != null;
// for (File file1 : files1) {
// PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, "PdfTest/"+file1.getName(), file1);
// try {
// PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
// logger.info(putObjectResult.getRequestId());
// file1.delete();
// } catch (CosServiceException e) {
// logger.info("cos服务出现问题");
// e.printStackTrace();
// } catch (CosClientException e) {
// logger.info("cos客户端出现问题"+file.getName()+"文件上传有误,重新上传");
// e.printStackTrace();
// }
// }
});
} }
} }
return null; return null;
......
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