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

1

master
Cui YongXing 2024-09-10 11:34:52 +08:00
parent b9311db720
commit 74a78301bc
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cloud-rule-common/src/main/java/com/muyu/rule/common/engine/ENGINE_VALUE_VFD1000_V1.java
View File

@ -19,8 +19,9 @@ public class ENGINE_VALUE_VFD1000_V1 extends DataEngineValueActuator {
@Override @Override
public void run() { public void run() {
DataValueFie dataValueFie = get(); DataValueFie dataValueFie = get();
System.out.println("==="+dataValueFie);
DataValue dataValue = dataValueFie.getDataValue(); DataValue dataValue = dataValueFie.getDataValue();
System.out.println("----"+dataValue);
if (dataValue.getValue() == null){ if (dataValue.getValue() == null){
throw new DeliteException("数据为空，需要丢弃!"); throw new DeliteException("数据为空，需要丢弃!");
}else{ }else{

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

@ -136,8 +136,8 @@ public class RuleEngineVersionController {
"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" +
"import com.alibaba.fastjson2.JSON;" + "import com.alibaba.fastjson2.JSON;\n" +
"import com.alibaba.fastjson2.JSONObject;"+ "import com.alibaba.fastjson2.JSONObject;\n"+
"\n" + "\n" +
"\n" + "\n" +
"/**\n" + "/**\n" +