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:35:31 +08:00
parent a39877067a
commit f8fa7829bc
2 changed files with 2 additions and 66 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_DataSet_asdf_S1.java
View File

@ -20,6 +20,7 @@ public class ENGINE_DataSet_asdf_S1 extends DataEngineDataSetActuator {
@Override
public void run() {
DataValueRows dataValueRows = get();
DataValue[][] dataValues = dataValueRows.getDataValue();
String key = dataValueRows.getKey();

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

@ -202,72 +202,7 @@ public class RuleEngineVersionController {
}
// @PostMapping("/deposit/{type}")
// public Result deposit(@PathVariable("type")Integer type,@Validated @RequestBody VersionAddReq versionAddReq){
//
// log.info("传入参数{}"+type);
//
// //String versionClass = versionService.deposit(type);
//
// String parentClass = null;
// if (type==1){
// parentClass = "DataEngineValueActuator";
// }else if (type==2){
// parentClass="DataEngineRowActuator";
// }else if (type==3){
// parentClass="DataEngineDataSetActuator";
// }
//
// String template = "package com.muyu.rule.common.engine;\n" +
// "\n" +
// "import cn.hutool.core.util.DesensitizedUtil;\n" +
// "import com.alibaba.fastjson2.JSON;\n" +
// "import com.alibaba.fastjson2.JSONObject;\n" +
// "import com.muyu.etl.domain.DataValue;\n" +
// "import com.muyu.rule.common.basic.abstracts.${parentClass};\n" +
// "\n" +
// "\n" +
// "/**\n" +
// " * @Author：张承志\n" +
// " * @Package：com.muyu.rule.server.basic.engine.row\n" +
// " * @Project：cloud-etl-rule\n" +
// " * @name：数据集指定字段进行脱敏\n" +
// " * @Date：2024/8/30 11:13\n" +
// " */\n" +
// "\n" +
// "public class ${className} extends ${parentClass} {\n" +
// "\n" +
// " @Override\n" +
// " public void run() {\n" +
// "\n" +
// " DataValue[][] dataValues = get();\n" +
// "\n" +
// " String dataValue = getDataValue();\n" +
// "\n" +
// " JSONObject jsonObject = JSON.parseObject(dataValue);\n" +
// "\n" +
// " String key = (String)jsonObject.get(\"key\");\n" +
// "\n" +
// " for (DataValue[] value : dataValues) {\n" +
// " for (DataValue dataValue1 : value) {\n" +
// " if (dataValue1.getKey().equals(key)){\n" +
// " dataValue1.setValue(DesensitizedUtil.mobilePhone((String) dataValue1.getValue()));\n" +
// " }\n" +
// " }\n" +
// " }\n" +
// " set(dataValues);\n" +
// "\n" +
// " }\n" +
// "}\n";
//
// String versionClass = template.replace("${className}", versionAddReq.getClassName());
// versionClass = template.replace("${parentClass}",parentClass);
//
// versionAddReq.setVersionClazz(versionClass);
//
//
// return Result.success(versionAddReq);
// }
@PostMapping("/readByOss/{className}")
@Operation(summary = "从Oss获取数据", description = "传入参数oss的key名从oss读取数据")