From e1a15f095ac3f038e59ef90b2eeb06b3c1490d6f Mon Sep 17 00:00:00 2001
From: Qin Dong Ming <2720806930@qq.com>
Date: Fri, 30 Aug 2024 18:31:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E6=8E=A5=E5=8F=A3?=
=?UTF-8?q?=E7=BC=96=E5=86=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
...ineClientConfig.java => EngineConfig.java} | 10 ++++-
.../com/muyu/controller/EngIneController.java | 6 ---
elt-data-access/pom.xml | 6 +++
.../main/java/com/bwie/muyu/EngIneTest.java | 39 +++++++++++++++++++
.../com/bwie/muyu/base/EngineContainer.java | 24 ++++++++++++
.../com/bwie/muyu/base/EngineException.java | 20 ++++++++++
.../java/com/bwie/muyu/base/EngineParam.java | 22 +++++++++++
.../bwie/muyu/base/Engine_2020_11_3_2347.java | 34 ++++++++++++++++
.../main/java/com/bwie/muyu/base/Test.java | 17 ++++++++
.../main/java/com/bwie/muyu/base/User.java | 22 +++++++++++
10 files changed, 193 insertions(+), 7 deletions(-)
rename cloud-etl-client/src/main/java/com/muyu/config/{RuleEngineClientConfig.java => EngineConfig.java} (95%)
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/EngIneTest.java
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/base/EngineContainer.java
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/base/EngineException.java
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/base/EngineParam.java
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/base/Engine_2020_11_3_2347.java
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/base/Test.java
create mode 100644 elt-data-access/src/main/java/com/bwie/muyu/base/User.java
diff --git a/cloud-etl-client/src/main/java/com/muyu/config/RuleEngineClientConfig.java b/cloud-etl-client/src/main/java/com/muyu/config/EngineConfig.java
similarity index 95%
rename from cloud-etl-client/src/main/java/com/muyu/config/RuleEngineClientConfig.java
rename to cloud-etl-client/src/main/java/com/muyu/config/EngineConfig.java
index 117ad4a..9d25497 100644
--- a/cloud-etl-client/src/main/java/com/muyu/config/RuleEngineClientConfig.java
+++ b/cloud-etl-client/src/main/java/com/muyu/config/EngineConfig.java
@@ -30,7 +30,7 @@ import java.util.Map;
@ComponentScan
@Component
@Import(value = {RuleEngineClientRunner.class})
-public class RuleEngineClientConfig {
+public class EngineConfig {
@Autowired
private RemoteVersionService remoteVersionService;
@@ -78,4 +78,12 @@ public class RuleEngineClientConfig {
}
return Result.success("测试正常,无异常数据返回");
}
+
+ public Object getLocation() {
+ return "没有信息";
+ }
+
+ public Object getPack() {
+ return null;
+ }
}
diff --git a/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java b/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java
index 180a3c0..01d3fcd 100644
--- a/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java
+++ b/cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java
@@ -14,7 +14,6 @@ import lombok.val;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
-import java.util.Collections;
import java.util.List;
/**
@@ -36,11 +35,6 @@ public class EngIneController extends BaseController {
return engIneService.getMaintenanceList(engineMaintenanceQueryReq);
}
- public static void main(String[] args) {
- System.out.println("你好");
- }
-
-
@PostMapping("/delete/{id}")
public Integer remove(@PathVariable Long id) {
return engIneService.deletes(id);
diff --git a/elt-data-access/pom.xml b/elt-data-access/pom.xml
index 9baf79a..daaa19c 100644
--- a/elt-data-access/pom.xml
+++ b/elt-data-access/pom.xml
@@ -22,5 +22,11 @@
com.muyu
cloud-common-core
+
+ com.muyu
+ cloud-etl-client
+ 1.0.0
+
+
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/EngIneTest.java b/elt-data-access/src/main/java/com/bwie/muyu/EngIneTest.java
new file mode 100644
index 0000000..febd97a
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/EngIneTest.java
@@ -0,0 +1,39 @@
+//package com.bwie.muyu;
+//
+//import com.bwie.muyu.base.EngineException;
+//import com.muyu.config.EngineConfig;
+//import lombok.Data;
+//import lombok.extern.log4j.Log4j2;
+//import org.springframework.stereotype.Component;
+//
+//import java.util.HashMap;
+//import java.util.Map;
+//
+///**
+// * @Author:qdm
+// * @Package:com.bwie.muyu
+// * @Project:cloud-etl-engine
+// * @name:EngIneTest
+// * @Date:2024/8/30 9:27
+// */
+//@Component
+//@Log4j2
+//@Data
+//public class EngIneTest {
+//
+// private static Object SouRceCodeCompiler;
+//
+// public static void main(String[] args) {
+// EngineConfig engineConfig = new EngineConfig();
+// //扫描源码进行注释
+// SouRceCodeCompiler.javaCompilerPath(engineConfig.getLocation());
+// Map> stringClassMap = JavaBinaryClassLoader.loadClassByLocation(engineConfig.getPack(), engineConfig, getLocation);
+// stringClassMap.forEach((key, value) -> {
+// EngineContainer.loadEngineInstance(key, value);
+// }); jn
+// HashMap params = new HashMap<>();
+// params.put("idCard", "142021200212215977");
+// EngineException.engineExe("Engine_2020_11_3_2347", params);
+// System.out.println("Engine_2020_11_3_2347");
+// }
+//}
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/base/EngineContainer.java b/elt-data-access/src/main/java/com/bwie/muyu/base/EngineContainer.java
new file mode 100644
index 0000000..10c09e3
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/base/EngineContainer.java
@@ -0,0 +1,24 @@
+package com.bwie.muyu.base;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author:qdm
+ * @Package:com.bwie.muyu.base
+ * @Project:cloud-etl-engine
+ * @name:EngineContainer
+ * @Date:2024/8/30 11:32
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class EngineContainer {
+
+ public static Integer getSumEngine() {
+ return null;
+ }
+}
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/base/EngineException.java b/elt-data-access/src/main/java/com/bwie/muyu/base/EngineException.java
new file mode 100644
index 0000000..8e37558
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/base/EngineException.java
@@ -0,0 +1,20 @@
+package com.bwie.muyu.base;
+
+import java.util.HashMap;
+
+/**
+ * @Author:qdm
+ * @Package:com.bwie.muyu.base
+ * @Project:cloud-etl-engine
+ * @name:EngineExcepion
+ * @Date:2024/8/30 10:50
+ */
+public class EngineException {
+// public engineException(String message){
+// super.(message);
+// }
+
+ public static void engineExe(String engine20201132347, HashMap params) {
+
+ }
+}
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/base/EngineParam.java b/elt-data-access/src/main/java/com/bwie/muyu/base/EngineParam.java
new file mode 100644
index 0000000..90406c1
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/base/EngineParam.java
@@ -0,0 +1,22 @@
+package com.bwie.muyu.base;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * @Author:qdm
+ * @Package:com.bwie.muyu.base
+ * @Project:cloud-etl-engine
+ * @name:EngineParam
+ * @Date:2024/8/30 10:46
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.PARAMETER)
+public @interface EngineParam {
+ /**
+ * 输入字段名称
+ */
+ public String name();
+}
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/base/Engine_2020_11_3_2347.java b/elt-data-access/src/main/java/com/bwie/muyu/base/Engine_2020_11_3_2347.java
new file mode 100644
index 0000000..7ca5877
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/base/Engine_2020_11_3_2347.java
@@ -0,0 +1,34 @@
+package com.bwie.muyu.base;
+
+import com.muyu.common.core.utils.SpringUtils;
+import org.springframework.boot.autoconfigure.security.SecurityProperties;
+
+import java.util.Date;
+
+/**
+ * @Author:qdm
+ * @Package:com.bwie.muyu.base
+ * @Project:cloud-etl-engine
+ * @name:Engine_2020_11_3_2347
+ * @Date:2024/8/30 10:32
+ */
+public class Engine_2020_11_3_2347 {
+ public String execute(@EngineParam(name="idCard")String idCard){
+ String msg = "";
+ Integer year = Integer.valueOf(idCard.substring(6, 10));
+ Date date = new Date();
+ int thisYear = date.getYear() + 1900;
+ msg = "这个身份证的年龄是:"+ (thisYear - year);
+ Integer two = Integer.valueOf(idCard.substring(16, 17));
+ if (two % 2 == 0){
+ msg += ",这个身份证是男生";
+ }else {
+ msg += ",这个身份证是女生";
+ }
+ Integer sumEngine = EngineContainer.getSumEngine();
+ System.out.println("项目中规则引擎数量为:"+sumEngine);
+ User bean = SpringUtils.getBean(User.class);
+ System.out.println(bean.getName()+"--"+bean.getAge);
+ return msg;
+ }
+}
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/base/Test.java b/elt-data-access/src/main/java/com/bwie/muyu/base/Test.java
new file mode 100644
index 0000000..3d4a00d
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/base/Test.java
@@ -0,0 +1,17 @@
+package com.bwie.muyu.base;
+
+import com.muyu.config.EngineConfig;
+
+/**
+ * @Author:qdm
+ * @Package:com.bwie.muyu.base
+ * @Project:cloud-etl-engine
+ * @name:Test
+ * @Date:2024/8/30 11:16
+ */
+public class Test {
+ public static void main(String[] args) {
+ EngineConfig engineConfig = new EngineConfig();
+
+ }
+}
diff --git a/elt-data-access/src/main/java/com/bwie/muyu/base/User.java b/elt-data-access/src/main/java/com/bwie/muyu/base/User.java
new file mode 100644
index 0000000..6bafba3
--- /dev/null
+++ b/elt-data-access/src/main/java/com/bwie/muyu/base/User.java
@@ -0,0 +1,22 @@
+package com.bwie.muyu.base;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author:qdm
+ * @Package:com.bwie.muyu.base
+ * @Project:cloud-etl-engine
+ * @name:User
+ * @Date:2024/8/30 11:33
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class User {
+ public String getAge;
+ private String name;
+}