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

添加版本删除

master
zhang chengzhi 2024-09-10 20:14:40 +08:00
parent 96f380ecf9
commit 6c61f33de4
4 changed files with 11 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,6 @@
package com.muyu.rule.common.engine; package com.muyu.rule.common.engine;
import cn.hutool.core.util.DesensitizedUtil; import com.muyu.rule.common.utils.Desensitization;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.muyu.etl.domain.DataValue; import com.muyu.etl.domain.DataValue;
@ -8,6 +8,7 @@ import com.muyu.rule.common.basic.abstracts.DataEngineDataSetActuator;
import com.muyu.rule.common.domain.DataValueRows; import com.muyu.rule.common.domain.DataValueRows;
/** /**
* @Author：张承志 * @Author：张承志
* @Package：com.muyu.rule.server.basic.engine.row * @Package：com.muyu.rule.server.basic.engine.row
@ -27,14 +28,15 @@ 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)){
dataValue1.setValue(DesensitizedUtil.mobilePhone((String) dataValue1.getValue())); dataValue1.setValue(Desensitization.mobilePhoneDesensitization((String) dataValue1.getValue()));
} }
} }
} }
dataValueRows.setDataValue(dataValues);
set(dataValueRows);
} }
} }

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

@ -57,6 +57,7 @@ public class RuleEngineVersionController {
boolean b = versionService.complierClass(ruleEngineVersion.getClassName(), ruleEngineVersion.getVersionClazz()); boolean b = versionService.complierClass(ruleEngineVersion.getClassName(), ruleEngineVersion.getVersionClazz());
if (true==b){ if (true==b){
versionService.update(updateWrapper); versionService.update(updateWrapper);
} }
return Result.success(); return Result.success();
@ -157,6 +158,7 @@ if (true==b){
String template = "package com.muyu.rule.common.engine;\n" + String template = "package com.muyu.rule.common.engine;\n" +
"\n" + "\n" +
"import com.muyu.etl.domain.DataValue;\n" + "import com.muyu.etl.domain.DataValue;\n" +
"import com.muyu.rule.common.utils.Desensitization;\n" +
"import com.muyu.rule.common.domain.${dataClass};\n" + "import com.muyu.rule.common.domain.${dataClass};\n" +
"import com.muyu.rule.common.basic.abstracts.${parentClass};\n" + "import com.muyu.rule.common.basic.abstracts.${parentClass};\n" +
"import com.muyu.rule.common.exception.DeliteException;\n" + "import com.muyu.rule.common.exception.DeliteException;\n" +

12
cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java
View File

@ -64,17 +64,6 @@ public interface RuleEngineVersionService extends IService<RuleEngineVersion> {
*/ */
boolean complierClass(String className, String versionClazz); boolean complierClass(String className, String versionClazz);
/**
*对规则引擎进行类加载
* @param className 规则引擎类名
*/
// void loadRuleEngineClass(String className);
/** /**
* 测试数据 * 测试数据
* *
@ -88,4 +77,5 @@ public interface RuleEngineVersionService extends IService<RuleEngineVersion> {
public DataValue[][] testEngine( String className, DataValueRows dataValues); public DataValue[][] testEngine( String className, DataValueRows dataValues);
} }

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

@ -250,6 +250,8 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
return dataValues1.getDataValue(); return dataValues1.getDataValue();
} }
public void execution(String engineKey,DataValueFie dataValue){ public void execution(String engineKey,DataValueFie dataValue){
BasicEngine<DataValueFie> dataValueBasicEngine = engineMap.get(engineKey); BasicEngine<DataValueFie> dataValueBasicEngine = engineMap.get(engineKey);