diff --git a/muyu-rule-server/src/main/java/com/muyu/rule/controller/RuleEditionController.java b/muyu-rule-server/src/main/java/com/muyu/rule/controller/RuleEditionController.java index 77a1399..3aa4e32 100644 --- a/muyu-rule-server/src/main/java/com/muyu/rule/controller/RuleEditionController.java +++ b/muyu-rule-server/src/main/java/com/muyu/rule/controller/RuleEditionController.java @@ -65,6 +65,8 @@ public class RuleEditionController { //java OSS UploadOss.uploadFiles(ruleEdition.getRuleEngine(), ruleEdition.getRuleKind()); + + OSSFileDownload.streamingDownload(ruleEdition.getRuleKind()); OSSFileDownload.compile(ruleEdition.getRuleKind()); // //对路径里的.java文件进行编译 diff --git a/muyu-rule-server/src/main/java/com/muyu/rule/test/OSSFileDownload.java b/muyu-rule-server/src/main/java/com/muyu/rule/test/OSSFileDownload.java index bd44bb1..ab87376 100644 --- a/muyu-rule-server/src/main/java/com/muyu/rule/test/OSSFileDownload.java +++ b/muyu-rule-server/src/main/java/com/muyu/rule/test/OSSFileDownload.java @@ -23,30 +23,30 @@ public class OSSFileDownload { private static final String filePath = "oss/"; -// public static Result streamingDownload(String fileName) { -// -// String source = null; -// // 创建 OSSClient 实例 -// OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret); -// // 判断 bucket 是否存在 -// Boolean flag_bucket = ossClient.doesBucketExist(bucketName); -// if (!flag_bucket) { -// System.out.println("bucket不存在"); -// return Result.error("bucket不存在"); -// } -// String objectName = fileName + ".java"; -// Boolean flag_file = ossClient.doesObjectExist(bucketName, filePath + objectName); -// if (!flag_file) { -// System.out.println("预下载文件不存在"); -// return Result.error("预下载文件不存在"); -// } -// // 本地文件下载路径 -// String localPath = "home/" + objectName; -// ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + objectName), new File(localPath)); -// System.out.println(object); -// ossClient.shutdown(); -// return Result.success(source); -// } + public static Result streamingDownload(String fileName) { + + String source = null; + // 创建 OSSClient 实例 + OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret); + // 判断 bucket 是否存在 + Boolean flag_bucket = ossClient.doesBucketExist(bucketName); + if (!flag_bucket) { + System.out.println("bucket不存在"); + return Result.error("bucket不存在"); + } + String objectName = fileName + ".java"; + Boolean flag_file = ossClient.doesObjectExist(bucketName, filePath + objectName); + if (!flag_file) { + System.out.println("预下载文件不存在"); + return Result.error("预下载文件不存在"); + } + // 本地文件下载路径 + String localPath = "home/" + objectName; + ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + objectName), new File(localPath)); + System.out.println(object); + ossClient.shutdown(); + return Result.success(source); + } public static Result compile(String fileName) { JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();