a_bazu
/
cloud-rule
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat():测试

yuan
yuan 2024-09-01 10:33:03 +08:00
parent 09dd035df1
commit cdf4d79cab
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cloud-rule-engine/src/main/java/com/muyu/load/OSSFileLoad.java
View File

@ -31,7 +31,9 @@ public class OSSFileLoad {
// bucket // bucket
private static final String bucketName = "java-web-generating-class"; private static final String bucketName = "java-web-generating-class";
// 本地文件下载路径 // 本地文件下载路径
private static final String localpath = "C:\\Users\\13636\\Desktop\\FileLoad\\"; private static final String localPath = "C:\\Users\\13636\\Desktop\\FileLoad\\";
// OSS文件路径
private static final String filePath = "build/version/rule/";
public static Result<Object> streamingDownload(String fileName) throws IOException { public static Result<Object> streamingDownload(String fileName) throws IOException {
String source = null; String source = null;
// 创建 OSSClient 实例 // 创建 OSSClient 实例
@ -42,12 +44,12 @@ public class OSSFileLoad {
System.out.println("bucket不存在"); System.out.println("bucket不存在");
return Result.error("bucket不存在"); return Result.error("bucket不存在");
} }
Boolean flag_file = ossClient.doesObjectExist(bucketName, fileName); Boolean flag_file = ossClient.doesObjectExist(bucketName, filePath+fileName);
if (!flag_file) { if (!flag_file) {
System.out.println("预下载文件不存在"); System.out.println("预下载文件不存在");
return Result.error("预下载文件不存在"); return Result.error("预下载文件不存在");
} }
ossClient.getObject(new GetObjectRequest(bucketName, fileName), new File(localpath)); ossClient.getObject(new GetObjectRequest(bucketName, filePath+fileName), new File(localPath));
// OSSObject ossObject = ossClient.getObject(bucketName, fileName); // OSSObject ossObject = ossClient.getObject(bucketName, fileName);
// BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent())); // BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
// while(true){ // while(true){
@ -61,7 +63,7 @@ public class OSSFileLoad {
ossClient.shutdown(); ossClient.shutdown();
// Map<String, byte[]> compile = OSSFileCompile.compile(fileName, source, "target/"); // Map<String, byte[]> compile = OSSFileCompile.compile(fileName, source, "target/");
Result<Object> compile = OSSFileCompile.compile(localpath+fileName, null); Result<Object> compile = OSSFileCompile.compile(localPath+fileName, null);
System.out.println(compile.getData()); System.out.println(compile.getData());
return Result.success(source); return Result.success(source);
} }

2
cloud-rule-server/src/main/java/com/muyu/controller/RuleVersionController.java
View File

@ -63,7 +63,7 @@ public class RuleVersionController {
ruleVersionService.save(RuleVersion.addBuild(ruleVersionAddReq)); ruleVersionService.save(RuleVersion.addBuild(ruleVersionAddReq));
Result<Object> objectResult = ALiYunUpload.uploadFiles(ruleVersionAddReq.getRuleVersionText(), ruleVersionAddReq.getRuleVersionType()); Result<Object> objectResult = ALiYunUpload.uploadFiles(ruleVersionAddReq.getRuleVersionText(), ruleVersionAddReq.getRuleVersionType());
System.out.println(objectResult.getMsg()); System.out.println(objectResult.getMsg());
Result<Object> result = OSSFileLoad.streamingDownload("build/version/rule/"+ruleVersionAddReq.getRuleVersionType() + ".java"); Result<Object> result = OSSFileLoad.streamingDownload(ruleVersionAddReq.getRuleVersionType() + ".java");
System.out.println("--------------"); System.out.println("--------------");
System.out.println(result.getData()); System.out.println(result.getData());
return Result.success(null,"操作成功"); return Result.success(null,"操作成功");