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

11111

master
zhang chengzhi 2024-09-07 09:59:22 +08:00
parent 3fe148680c
commit 296bf035b3
3 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
cloud-rule-common/src/main/java/com/muyu/rule/common/utils/OssUtil.java
View File

@ -1,12 +1,10 @@
package com.muyu.rule.common.utils;
import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.*;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.OSSObject;
import com.aliyun.oss.model.PutObjectRequest;
import com.aliyun.oss.model.VoidResult;
import lombok.extern.log4j.Log4j2;
import org.springframework.web.multipart.MultipartFile;
@ -215,8 +213,19 @@ public class OssUtil {
} catch (ClientException ce) {
System.err.println("存储失败: " + ce.getErrorMessage());
}
}
public static void deliteOssClient(String key){
OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);
VoidResult voidResult = ossClient.deleteBucket(key);
log.info(voidResult);
}
}

1
cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java
View File

@ -35,7 +35,6 @@ public class RuleEngineVersionController {
* @return
*/
@PostMapping("/saveCode")
public Result saveCode(@RequestBody RuleEngineVersion ruleEngineVersion){

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

@ -84,8 +84,9 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
/**
* 将java源码存入OSS
*/
OssUtil.deliteOssClient(className+Suffix_CLASS);
ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(versionClazz.getBytes());
OssUtil.uploadFileInputStreamForBucket(bucketName, className + Suffix_JAVA, byteArrayInputStream);
OssUtil.uploadFileInputStreamForBucket(bucketName, className + Suffix_CLASS, byteArrayInputStream);
}