2112A-ONE
/
cloud-rule-engine
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化

master
chentaisen 2024-09-10 16:45:34 +08:00
parent 4416738dc6
commit a018e0b9d1
44 changed files with 45 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/BasicEngine.java
View File

@ -3,7 +3,7 @@ package com.muyu.etl.rule.basic;
import com.muyu.etl.rule.basic.handler.BasicEngineHandler; import com.muyu.etl.rule.basic.handler.BasicEngineHandler;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 规则引擎基准 * @Description 规则引擎基准
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/abstracts/DataEngineRowActuator.java
View File

@ -5,7 +5,7 @@ import com.muyu.etl.rule.basic.BasicEngine;
import com.muyu.etl.rule.basic.handler.EngineRowHandler; import com.muyu.etl.rule.basic.handler.EngineRowHandler;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 数据行处理对象 * @Description 数据行处理对象
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/abstracts/DataEngineRowsActuator.java
View File

@ -6,7 +6,7 @@ import com.muyu.etl.rule.basic.handler.EngineRowHandler;
import com.muyu.etl.rule.basic.handler.EngineRowsHandler; import com.muyu.etl.rule.basic.handler.EngineRowsHandler;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 数据组处理对象 * @Description 数据组处理对象
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/abstracts/DataEngineValueActuator.java
View File

@ -6,7 +6,7 @@ import com.muyu.etl.rule.basic.handler.BasicEngineHandler;
import com.muyu.etl.rule.basic.handler.EngineValueHandler; import com.muyu.etl.rule.basic.handler.EngineValueHandler;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 数据值处理对象 * @Description 数据值处理对象
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/handler/BasicEngineHandler.java
View File

@ -1,7 +1,7 @@
package com.muyu.etl.rule.basic.handler; package com.muyu.etl.rule.basic.handler;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 规则引擎作用域 * @Description 规则引擎作用域
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/handler/EngineRowHandler.java
View File

@ -6,7 +6,7 @@ import com.muyu.etl.domain.DataStructure;
import java.math.BigDecimal; import java.math.BigDecimal;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 行数据引擎作用域 * @Description 行数据引擎作用域
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/handler/EngineRowsHandler.java
View File

@ -4,7 +4,7 @@ package com.muyu.etl.rule.basic.handler;
import com.muyu.etl.domain.DataStructure; import com.muyu.etl.domain.DataStructure;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 数据组处理 * @Description 数据组处理
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/basic/handler/EngineValueHandler.java
View File

@ -7,7 +7,7 @@ import java.math.BigDecimal;
import java.util.Date; import java.util.Date;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/29 * @Data 2024/8/29
* @Description 数据值作用域 * @Description 数据值作用域
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/DataStructureResp.java
View File

@ -1,7 +1,7 @@
package com.muyu.etl.rule.domain; package com.muyu.etl.rule.domain;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/9/1 * @Data 2024/9/1
* @Description 参数类型 * @Description 参数类型
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/RuleInfo.java
View File

@ -13,7 +13,7 @@ import com.baomidou.mybatisplus.annotation.IdType;
/** /**
* 规则维护对象 etl_rule_info * 规则维护对象 etl_rule_info
* *
* @author WangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/RuleVersion.java
View File

@ -11,7 +11,7 @@ import org.apache.commons.lang3.builder.ToStringStyle;
/** /**
* 规则版本对象 etl_rule_version * 规则版本对象 etl_rule_version
* *
* @author wangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/constants/RuleConstants.java
View File

@ -1,7 +1,7 @@
package com.muyu.etl.rule.domain.constants; package com.muyu.etl.rule.domain.constants;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/9/9 * @Data 2024/9/9
* @Description * @Description
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/DataSourceAddReq.java
View File

@ -10,7 +10,7 @@ import lombok.experimental.SuperBuilder;
/** /**
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author Cc
* @Date 2024/8/19 19:14 * @Date 2024/8/19 19:14
* @注释 * @注释
*/ */

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/DataSqlField.java
View File

@ -7,7 +7,7 @@ import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder; import lombok.experimental.SuperBuilder;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/9/2 * @Data 2024/9/2
* @Description * @Description
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/DataTestReq.java
View File

@ -9,7 +9,7 @@ import lombok.experimental.SuperBuilder;
import java.util.List; import java.util.List;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/9/2 * @Data 2024/9/2
* @Description 数据测试请求参数 * @Description 数据测试请求参数
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/EtlRuleEngineReq.java
View File

@ -8,7 +8,7 @@ import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/24 * @Data 2024/8/24
* @Description 启动规则引擎请求 * @Description 启动规则引擎请求
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/EtlRuleListReq.java
View File

@ -8,7 +8,7 @@ import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description 规则列表请求参数 * @Description 规则列表请求参数
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/EtlRuleSaveReq.java
View File

@ -8,7 +8,7 @@ import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder; import lombok.experimental.SuperBuilder;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description 规则添加请求参数 * @Description 规则添加请求参数
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/ExecutionRuleVersionReq.java
View File

@ -10,7 +10,7 @@ import lombok.NoArgsConstructor;
import java.util.HashMap; import java.util.HashMap;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/27 * @Data 2024/8/27
* @Description 执行规则请求对象 * @Description 执行规则请求对象
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/req/WriteFileReq.java
View File

@ -9,7 +9,7 @@ import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/27 * @Data 2024/8/27
* @Description 写入请求对象 * @Description 写入请求对象
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/domain/resp/EtlRuleListResp.java
View File

@ -13,7 +13,7 @@ import java.util.List;
import java.util.function.Supplier; import java.util.function.Supplier;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description etl数据列表响应对象 * @Description etl数据列表响应对象
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/bean/constant/FileConstants.java
View File

@ -1,7 +1,7 @@
package com.muyu.etl.rule.engine.bean.constant; package com.muyu.etl.rule.engine.bean.constant;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description 文件相关常量 * @Description 文件相关常量
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/core/EngineContainer.java
View File

@ -13,7 +13,7 @@ import java.util.List;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/23 * @Data 2024/8/23
* @Descriptio * @Descriptio
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/core/EngineExecution.java
View File

@ -11,7 +11,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/23 * @Data 2024/8/23
* @Description 规则引擎方法执行器 * @Description 规则引擎方法执行器
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/core/classLoad/ExternalClassLoader.java
View File

@ -7,7 +7,7 @@ import java.nio.file.Files;
import java.nio.file.Path; import java.nio.file.Path;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/9/4 * @Data 2024/9/4
* @Description 自定义classloader * @Description 自定义classloader
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/core/classLoad/JavaBinaryClassLoader.java
View File

@ -20,7 +20,7 @@ import java.util.Map;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description java 字节码文件 加载器 * @Description java 字节码文件 加载器
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/core/complier/SourceCodeCompiler.java
View File

@ -14,7 +14,7 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description java源码编译工具 * @Description java源码编译工具
* @Version 1.0.0 * @Version 1.0.0

4
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/util/FileLoadUtil.java
View File

@ -11,7 +11,7 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/22 * @Data 2024/8/22
* @Description 文件扫描 * @Description 文件扫描
* @Version 1.0.0 * @Version 1.0.0
@ -167,7 +167,7 @@ public class FileLoadUtil {
"import org.apache.logging.log4j.Logger;\n" + "import org.apache.logging.log4j.Logger;\n" +
"\n" + "\n" +
"/**\n" + "/**\n" +
" * @Author WangXin\n" + " * @Author Chen\n" +
" * @Data 2024/8/23\n" + " * @Data 2024/8/23\n" +
" * @Description\n" + " * @Description\n" +
" * @Version 1.0.0\n" + " * @Version 1.0.0\n" +

2
etl-rule-common/src/main/java/com/muyu/etl/rule/engine/util/PropertiesUtil.java
View File

@ -10,7 +10,7 @@ import java.util.concurrent.ConcurrentHashMap;
/** /**
* @ClassName: PropertiesUtil * @ClassName: PropertiesUtil
* @Description: 读取配置文件工具类 * @Description: 读取配置文件工具类
* @author: wangXin * @author: Chen
* @date: 2024/6/18 19:45 * @date: 2024/6/18 19:45
* @Version 1.0.0 * @Version 1.0.0
*/ */

2
etl-rule-common/src/main/java/com/muyu/etl/rule/util/EnginePackUtil.java
View File

@ -4,7 +4,7 @@ import com.muyu.etl.rule.basic.BasicEngine;
import com.muyu.etl.rule.basic.abstracts.DataEngineValueActuator; import com.muyu.etl.rule.basic.abstracts.DataEngineValueActuator;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/24 * @Data 2024/8/24
* @Description 规则引擎全限定名转换 * @Description 规则引擎全限定名转换
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-remote/src/main/java/com/muyu/etl/rule/remote/RemoteRuleVersion.java
View File

@ -11,7 +11,7 @@ import org.springframework.web.bind.annotation.RequestBody;
/** /**
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author Cc
* @Date 2024/9/2 14:35 * @Date 2024/9/2 14:35
* @注释 * @注释
*/ */

2
etl-rule-remote/src/main/java/com/muyu/etl/rule/remote/factory/RemoteRuleVersionBackFactory.java
View File

@ -10,7 +10,7 @@ import org.springframework.stereotype.Component;
/** /**
* @version 1.0 * @version 1.0
* @Author xie ya ru * @Author Cc
* @Date 2024/9/1 10:04 * @Date 2024/9/1 10:04
* @注释 * @注释
*/ */

1
etl-rule-server/pom.xml
View File

@ -24,6 +24,7 @@
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId> <artifactId>cloud-common-core</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>etl-datasource-remote</artifactId> <artifactId>etl-datasource-remote</artifactId>

2
etl-rule-server/src/main/java/com/muyu/etl/rule/ENGINE_NOT_NULL_NAME_V1.java
View File

@ -8,7 +8,7 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
/** /**
* @Author WangXin * @Author Chen
* @Data Mon Sep 09 2024 01:04:05 GMT+0800 (中国标准时间) * @Data Mon Sep 09 2024 01:04:05 GMT+0800 (中国标准时间)
* @Description null * @Description null
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-server/src/main/java/com/muyu/etl/rule/config/EngineConfig.java
View File

@ -6,7 +6,7 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/8/27 * @Data 2024/8/27
* @Description 规则配置类 * @Description 规则配置类
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-server/src/main/java/com/muyu/etl/rule/controller/RuleInfoController.java
View File

@ -24,7 +24,7 @@ import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* @Author WangXin * @Author Chen
* @Data ${date} * @Data ${date}
* @Description 规则维护控制层 * @Description 规则维护控制层
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-server/src/main/java/com/muyu/etl/rule/controller/RuleVersionController.java
View File

@ -31,7 +31,7 @@ import org.springframework.validation.annotation.Validated;
import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.common.core.web.page.TableDataInfo;
/** /**
* @Author wangXin * @Author Chen
* @Data ${date} * @Data ${date}
* @Description 规则版本控制层 * @Description 规则版本控制层
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-server/src/main/java/com/muyu/etl/rule/mapper/RuleInfoMapper.java
View File

@ -9,7 +9,7 @@ import org.apache.ibatis.annotations.Mapper;
/** /**
* 规则维护Mapper接口 * 规则维护Mapper接口
* *
* @author WangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */
@Mapper @Mapper

2
etl-rule-server/src/main/java/com/muyu/etl/rule/mapper/RuleVersionMapper.java
View File

@ -8,7 +8,7 @@ import org.apache.ibatis.annotations.Mapper;
/** /**
* 规则版本Mapper接口 * 规则版本Mapper接口
* *
* @author wangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */
@Mapper @Mapper

2
etl-rule-server/src/main/java/com/muyu/etl/rule/operation/ArrayUtil.java
View File

@ -12,7 +12,7 @@ import java.util.Arrays;
import java.util.Iterator; import java.util.Iterator;
/** /**
* @Author WangXin * @Author Chen
* @Data 2024/9/3 * @Data 2024/9/3
* @Description 压栈工具 * @Description 压栈工具
* @Version 1.0.0 * @Version 1.0.0

2
etl-rule-server/src/main/java/com/muyu/etl/rule/service/IRuleInfoService.java
View File

@ -8,7 +8,7 @@ import com.muyu.etl.rule.domain.req.EtlRuleListReq;
/** /**
* 规则维护Service接口 * 规则维护Service接口
* *
* @author WangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */
public interface IRuleInfoService extends IService<RuleInfo> { public interface IRuleInfoService extends IService<RuleInfo> {

2
etl-rule-server/src/main/java/com/muyu/etl/rule/service/IRuleVersionService.java
View File

@ -17,7 +17,7 @@ import org.apache.commons.codec.language.bm.RuleType;
/** /**
* 规则版本Service接口 * 规则版本Service接口
* *
* @author wangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */
public interface IRuleVersionService extends IService<RuleVersion> { public interface IRuleVersionService extends IService<RuleVersion> {

2
etl-rule-server/src/main/java/com/muyu/etl/rule/service/impl/RuleInfoServiceImpl.java
View File

@ -15,7 +15,7 @@ import java.util.List;
/** /**
* 规则维护Service业务层处理 * 规则维护Service业务层处理
* *
* @author WangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */
@Service @Service

33
etl-rule-server/src/main/java/com/muyu/etl/rule/service/impl/RuleVersionServiceImpl.java
View File

@ -45,7 +45,7 @@ import java.util.stream.Collectors;
/** /**
* 规则版本Service业务层处理 * 规则版本Service业务层处理
* *
* @author wangXin * @author Chen
* @date 2024-08-25 * @date 2024-08-25
*/ */
@Service @Service
@ -334,37 +334,6 @@ public class RuleVersionServiceImpl
} }
} }
public static void main(String[] args) {
// String engineKey = "TelTuoMing";
// String locationPath = "C:\\Users\\wx\\Desktop\\测试";
// String page = "com.muyu.etl.rule";
//
// SourceCodeCompiler.javaCompilerPath(locationPath);
//
// Map<String, Class<?>> stringClassMap = JavaBinaryClassLoader
// .loadClassByLocation(page, locationPath);
//
// stringClassMap.forEach((k, v) -> {
// EngineContainer.loadEngineInstance("run", k, v);
// });
//
// DataStructure dataStructure = new DataStructure();
// dataStructure.setValue("15335893491");
// dataStructure.setType(DataType.STRING);
// dataStructure.setKey("tel");
// dataStructure.setLabel("手机号");
//
// ConcurrentHashMap<String, Object> instanceMap = EngineContainer.instanceMap;
// Object object = instanceMap.get(engineKey);
// if (object != null && object instanceof BasicEngine<?>) {
// BasicEngine<DataStructure> engine = (BasicEngine<DataStructure>) object;
// engine.set(dataStructure);
// engine.execution();
// }
}
/** /**
* 查詢所有規則(字段,数据集,记录)规则下拉框 * 查詢所有規則(字段,数据集,记录)规则下拉框
* @return List<RuleInfo> * @return List<RuleInfo>