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

添加版本删除

master
zhang chengzhi 2024-09-10 15:59:24 +08:00
parent df65b3d7bf
commit c44b4acd21
3 changed files with 46 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S2.java
View File

@ -27,6 +27,8 @@ public class ENGINE_DataSet_ytrrt_S2 extends DataEngineDataSetActuator {
JSONObject jsonObject = JSON.parseObject(key1); JSONObject jsonObject = JSON.parseObject(key1);
String key = (String)jsonObject.get("key"); String key = (String)jsonObject.get("key");
for (DataValue[] value : dataValues) { for (DataValue[] value : dataValues) {
for (DataValue dataValue1 : value) { for (DataValue dataValue1 : value) {
if (dataValue1.getKey().equals(key)){ if (dataValue1.getKey().equals(key)){

41
cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_ytrrt_S3.java 100644
View File

@ -0,0 +1,41 @@
package com.muyu.rule.common.engine;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.muyu.etl.domain.DataValue;
import com.muyu.rule.common.basic.abstracts.DataEngineDataSetActuator;
import com.muyu.rule.common.domain.DataValueRows;
/**
* @Author：张承志
* @Package：com.muyu.rule.server.basic.engine.row
* @Project：cloud-etl-rule
* @name：数据集指定字段进行脱敏
* @Date：2024/8/30 11:13
*/
public class ENGINE_DataSet_ytrrt_S3 extends DataEngineDataSetActuator {
@Override
public void run() {
DataValueRows dataValueRows = get();
String json = dataValueRows.getKey();
JSONObject jsonObject = JSON.parseObject(json);
String key = (String) jsonObject.get("key");
String valueFie = (String) jsonObject.get("value");
DataValue[][] dataValue = dataValueRows.getDataValue();
for (int i = 0; i < dataValue.length; i++) {
for (int j = 0; j < dataValue[i].length; j++) {
if (dataValue[i][j].getKey().equals(key) ) {
if (dataValue[i][j].getValue()==null || dataValue[i][j].getValue().equals("")) {
dataValue[i][j].setValue(valueFie);
}
}
}
}
dataValueRows.setDataValue(dataValue);
set(dataValueRows);
}
}

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

@ -139,6 +139,9 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
@Override @Override
public void complierClass(String className, String versionClazz) { public void complierClass(String className, String versionClazz) {
log.info("======>" + versionClazz); log.info("======>" + versionClazz);
versionClazz = versionClazz.replace("&lt;", "<").replace("&gt;", ">");
String ossFilePath = className + Suffix_JAVA; String ossFilePath = className + Suffix_JAVA;
//创建服务器项目容器的java源码文件目录路径 //创建服务器项目容器的java源码文件目录路径
File serverFile = new File(engineWorkSourcePath, ossFilePath); File serverFile = new File(engineWorkSourcePath, ossFilePath);