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

1

master
Cui YongXing 2024-09-08 21:24:22 +08:00
parent 14e7bdea81
commit a831863939
5 changed files with 22 additions and 113 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cloud-rule-common/pom.xml
View File

@ -34,6 +34,10 @@
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.12.0</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-datasources-common</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>

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

@ -1,5 +1,7 @@
package com.muyu.rule.common.engine;
import com.muyu.common.domain.DataValue;
import com.muyu.common.enums.DataType;
import com.muyu.rule.common.basic.abstracts.DataEngineValueActuator;

14
cloud-rule-common/src/main/java/com/muyu/rule/common/map/EngineHashMap.java 100644
View File

@ -0,0 +1,14 @@
package com.muyu.rule.common.map;
import com.muyu.common.domain.DataValue;
import com.muyu.rule.common.basic.BasicEngine;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class EngineHashMap {
public static Map<String, BasicEngine<DataValue>> engineMap = new ConcurrentHashMap<>();
public static Map<String, BasicEngine<DataValue[]>> engineRowMap = new ConcurrentHashMap<>();
public static Map<String, BasicEngine<DataValue[][]>> engineDataSetMap = new ConcurrentHashMap<>();
}

110
cloud-rule-server/src/main/java/com/muyu/rule/server/Main.java
View File

@ -1,110 +0,0 @@
package com.muyu.rule.server;
import com.muyu.common.domain.DataValue;
import com.muyu.common.enums.DataType;
import com.muyu.rule.common.basic.BasicEngine;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* @Author：张承志
* @Package：com.muyu.rule.server
* @Project：cloud-etl-rule
* @name：Main
* @Date：2024/8/29 15:57
*/
public class Main {
static Map<String , BasicEngine<DataValue>> engineMap = new ConcurrentHashMap<>();
static Map<String,BasicEngine<DataValue[]>> engineRowMap = new ConcurrentHashMap<>();
static Map<String,BasicEngine<DataValue[][]>> engineDataSetMap = new ConcurrentHashMap<>();
static {
try {
Class<?> aClass = Class.forName("com.muyu.rule.common.engine.ENGINE_VALUE_VFD1000_V1");
Class<?> aClass2 = Class.forName("com.muyu.rule.common.engine.ENGINE_VALUE_VFD1000_V2");
Class<?> aClass3 = Class.forName("com.muyu.rule.common.engine.ENGINE_ROW_HANG_R1");
Class<?> aClass4 = Class.forName("com.muyu.rule.common.engine.ENGINE_DataSet_asdf_S1");
try {
engineMap.put("ENGINE_VALUE_VFD1000_V1", (BasicEngine<DataValue>) aClass.newInstance());
engineMap.put("ENGINE_VALUE_VFD1000_V2", (BasicEngine<DataValue>) aClass2.newInstance());
engineRowMap.put("ENGINE_ROW_HANG_R1",(BasicEngine<DataValue[]>) aClass3.newInstance());
engineDataSetMap.put("ENGINE_DataSet_asdf_S1",(BasicEngine<DataValue[][]>) aClass4.newInstance());
} catch (InstantiationException e) {
throw new RuntimeException(e);
} catch (IllegalAccessException e) {
throw new RuntimeException(e);
}
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}
public static void main(String[] args) {
// System.out.println("字段规则测试:");
// DataValue dataValue = DataValue.builder()
// .type(DataType.valueOf("String"))
// .label("姓名")
// .key("name")
// .value(null)
// .build();
//
// BasicEngine<DataValue> engineValue = engineMap.get("ENGINE_VALUE_VFD1000_V1");
//
// engineValue.set(dataValue);
//
// engineValue.execution();
System.out.println("记录规则测试:");
// System.out.println(string);
DataValue[] dataValues = new DataValue[]{
new DataValue("name","姓名",DataType.VARCHAR,"张三"),
new DataValue("name","姓名",DataType.VARCHAR,"李四"),
new DataValue("name","姓名",DataType.VARCHAR,"王五"),
new DataValue("name","姓名",DataType.VARCHAR,"张三")
};
BasicEngine<DataValue[]> engineRowHangR1 = engineRowMap.get("ENGINE_ROW_HANG_R1");
engineRowHangR1.set(dataValues);
engineRowHangR1.execution();
// System.out.println("数据集规则测试:");
//
// DataValue[][] dataValuesSet = new DataValue[3][3];
//
//
// BasicEngine<DataValue[][]> engineDataSetAsdfS1 = engineDataSetMap.get("ENGINE_DataSet_asdf_S1");
//
// engineDataSetAsdfS1.set(dataValuesSet);
//
// engineDataSetAsdfS1.execution();
}
}

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

@ -27,6 +27,7 @@ import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import static com.muyu.rule.common.map.EngineHashMap.*;
import static com.muyu.rule.server.constant.SuffixClass.Suffix_CLASS;
import static com.muyu.rule.server.constant.SuffixClass.Suffix_JAVA;
@ -101,9 +102,7 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl<RuleEngineVersionM
/**
* 存放实例化引擎的容器
*/
public static Map<String, BasicEngine<DataValue>> engineMap = new ConcurrentHashMap<>();
public static Map<String, BasicEngine<DataValue[]>> engineRowMap = new ConcurrentHashMap<>();
public static Map<String, BasicEngine<DataValue[][]>> engineDataSetMap = new ConcurrentHashMap<>();
/**
* 服务器的存放java源代码的位置
*/