etl
/
cloud-etl-rule
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

11111

master
zhang chengzhi 2024-09-05 21:16:34 +08:00
parent 9a492da4a3
commit ba0e92c608
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineVersionServiceImpl.java
View File

@ -116,21 +116,31 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
// String filePath ="home/"+ossFilePath;
String filePath = engineConfig.getSourcePath() + ossFilePath;
//创建服务器项目容器的文件目录路径
//创建服务器项目容器的java源码文件目录路径
File serverFile = new File(engineWorkSourcePath, ossFilePath);
//如果目录不存在,则创建目录
if (!serverFile.getParentFile().exists()) {
serverFile.getParentFile().mkdirs();
}
serverFile.mkdirs();
try (BufferedWriter writer = new BufferedWriter(new FileWriter(filePath))) {
writer.write(versionClazz);
System.out.println("文件已成功创建并写入Java源码。");
} catch (IOException e) {
System.err.println("发生错误：" + e.getMessage());
}
File classFile = new File(engineWorkClassPath, ossFilePath2);
//如果目录不存在,则创建目录
if (!classFile.getParentFile().exists()) {
classFile.getParentFile().mkdirs();
}
//下载文件到指定服务器目录下
OssUtil.downloadFileForBucket(bucketName, ossFilePath, filePath);
//编译
////下载文件到指定服务器目录下
// OssUtil.downloadFileForBucket(bucketName, ossFilePath, filePath);
//编译
JavaCompiler javaCompiler = ToolProvider.getSystemJavaCompiler();
//
InputStream first = null; // 程序的输入 null 用 system.in
@ -142,15 +152,12 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
// 0 表示成功， 其他表示出现了错误
System.out.println(Arrays.toString(strings));
int i = javaCompiler.run(first, second, third, strings);
if (i == 0) {
System.out.println("成功");
} else {
System.out.println("错误");
}
OssUtil.ssss(className);
// 假设这是你的外部类文件路径
String externalClassFilePath =
"home/lib/" + "com/muyu/rule/common/engine/value/" + className + Suffix_CLASS;