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

544245

master
zhang chengzhi 2024-09-10 14:41:49 +08:00
parent f8fa7829bc
commit 202811aa8f
2 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -215,16 +215,17 @@ public class OssUtil {
} }
} }
/**
public static void deliteOssClient(String key){ * 根据buctName和oss名称删除
* @param key 类名+ .class
*/
public static void deliteOssClient(String key){
OSS ossClient = new OSSClientBuilder().build(endPoint,accessKeyId,accessKeySecret); OSS ossClient = new OSSClientBuilder().build(endPoint,accessKeyId,accessKeySecret);
VoidResult voidResult = ossClient.deleteObject(bucketName, key); VoidResult voidResult = ossClient.deleteObject(bucketName, key);
log.info(voidResult); log.info(voidResult);
} }
} }

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

@ -4,12 +4,14 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.etl.domain.DataValue; import com.muyu.etl.domain.DataValue;
import com.muyu.rule.common.constant.SuffixClass;
import com.muyu.rule.common.domain.DataValueFie; import com.muyu.rule.common.domain.DataValueFie;
import com.muyu.rule.common.domain.DataValueRow; import com.muyu.rule.common.domain.DataValueRow;
import com.muyu.rule.common.domain.DataValueRows; import com.muyu.rule.common.domain.DataValueRows;
import com.muyu.rule.common.domain.RuleEngineVersion; import com.muyu.rule.common.domain.RuleEngineVersion;
import com.muyu.rule.common.domain.req.VersionAddReq; import com.muyu.rule.common.domain.req.VersionAddReq;
import com.muyu.rule.common.utils.LoadEngineClass; import com.muyu.rule.common.utils.LoadEngineClass;
import com.muyu.rule.common.utils.OssUtil;
import com.muyu.rule.server.service.RuleEngineVersionService; import com.muyu.rule.server.service.RuleEngineVersionService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
@ -48,8 +50,12 @@ public class RuleEngineVersionController {
log.info("==>"+ruleEngineVersion.getVersionClazz()); log.info("==>"+ruleEngineVersion.getVersionClazz());
UpdateWrapper<RuleEngineVersion> updateWrapper = new UpdateWrapper<>(); UpdateWrapper<RuleEngineVersion> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq("id",ruleEngineVersion.getId()).set("version_clazz",ruleEngineVersion.getVersionClazz()); updateWrapper.eq("id",ruleEngineVersion.getId()).set("version_clazz",ruleEngineVersion.getVersionClazz());
versionService.Upload(ruleEngineVersion.getVersionClazz(),ruleEngineVersion.getClassName());
versionService.update(updateWrapper); versionService.update(updateWrapper);
//删除对应oss上的类
OssUtil.deliteOssClient(ruleEngineVersion.getClassName()+SuffixClass.Suffix_CLASS);
//编译并上传
versionService.complierClass(ruleEngineVersion.getClassName(),ruleEngineVersion.getVersionClazz());
return Result.success(); return Result.success();
} }
@ -202,7 +208,11 @@ public class RuleEngineVersionController {
} }
/**
* 从oss读取数据
* @param className
* @return
*/
@PostMapping("/readByOss/{className}") @PostMapping("/readByOss/{className}")
@Operation(summary = "从Oss获取数据", description = "传入参数oss的key名从oss读取数据") @Operation(summary = "从Oss获取数据", description = "传入参数oss的key名从oss读取数据")