zhangxu
/
ruoyi-muyu-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 新增了规则引擎增删改查,规则引擎初始化,测试调用

master
yaoxin 2024-05-02 16:16:11 +08:00
parent fa6963552a
commit b92a8cef22
15 changed files with 967 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
muyu-modules/muyu-file/src/main/java/com/muyu/file/controller/SysFileController.java
View File

@ -23,6 +23,7 @@ public class SysFileController {
@Autowired
private ISysFileService sysFileService;
/**
* 文件上传请求
*/

84
muyu-modules/muyu-rule-engine/pom.xml 100644
View File

@ -0,0 +1,84 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>muyu-modules</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>muyu-rule-engine</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- SpringCloud Alibaba Nacos Config -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- SpringCloud Alibaba Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- SpringBoot Actuator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Swagger UI -->
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>${swagger.fox.version}</version>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- MuYu Common DataSource -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>muyu-common-datasource</artifactId>
</dependency>
<!-- MuYu Common DataScope -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>muyu-common-datascope</artifactId>
</dependency>
<!-- MuYu Common Log -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>muyu-common-log</artifactId>
</dependency>
<!-- MuYu Common Swagger -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>muyu-common-swagger</artifactId>
</dependency>
</dependencies>
</project>

7
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/Main.java 100644
View File

@ -0,0 +1,7 @@
package com.muyu;
public class Main {
public static void main(String[] args) {
System.out.println("Hello world!");
}
}

54
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/ClassLoading/CustomClassLoader.java 100644
View File

@ -0,0 +1,54 @@
package com.muyu.rule.engine.ClassLoading;
import java.io.*;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
/**
* @ClassName CustomClassLoader
* @Description 描述
* @Author Xin.Yao
* @Date 2024/5/1 19:37
*/
public class CustomClassLoader extends URLClassLoader {
public CustomClassLoader(ClassLoader parent, String classPath) throws MalformedURLException {
super(new URL[]{new URL("file:" + classPath)},parent);
}
@Override
protected Class<?> findClass(String name) throws ClassNotFoundException {
try {
byte[] classBytes = loadClassData(name);
return defineClass(name, classBytes, 0, classBytes.length);
} catch (IOException e) {
throw new ClassNotFoundException(name, e);
}
}
private byte[] loadClassData(String className) throws IOException {
String fileName = className.replace('.', File.separatorChar) + ".class";
File classFile = new File(getPathForResource(fileName));
if (!classFile.exists()) {
throw new FileNotFoundException("Class file not found: " + classFile.getAbsolutePath());
}
try (InputStream in = new FileInputStream(classFile)) {
ByteArrayOutputStream out = new ByteArrayOutputStream();
byte[] buffer = new byte[4096];
int n;
while ((n = in.read(buffer)) != -1) {
out.write(buffer, 0, n);
}
return out.toByteArray();
}
}
private String getPathForResource(String resource) {
URL url = super.getResource(resource);
if (url == null) {
throw new IllegalArgumentException("Resource not found: " + resource);
}
return url.getPath();
}
}

22
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/MuYuRuleEngineApplication.java 100644
View File

@ -0,0 +1,22 @@
package com.muyu.rule.engine;
import com.muyu.common.security.annotation.EnableCustomConfig;
import com.muyu.common.security.annotation.EnableMyFeignClients;
import com.muyu.common.swagger.annotation.EnableCustomSwagger2;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* 系统模块
*
* @author muyu
*/
@EnableCustomConfig
@EnableCustomSwagger2
@EnableMyFeignClients
@SpringBootApplication
public class MuYuRuleEngineApplication {
public static void main (String[] args) {
SpringApplication.run(MuYuRuleEngineApplication.class, args);
}
}

111
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/controller/EngineMaintenanceController.java 100644
View File

@ -0,0 +1,111 @@
package com.muyu.rule.engine.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import com.muyu.common.log.annotation.Log;
import com.muyu.common.log.enums.BusinessType;
import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.rule.engine.domain.EngineMaintenance;
import com.muyu.rule.engine.service.IEngineMaintenanceService;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.page.TableDataInfo;
/**
* 【请填写功能名称】Controller
*
* @author ruoyi
* @date 2024-05-02
*/
@RestController
@RequestMapping("/maintenance")
public class EngineMaintenanceController extends BaseController
{
@Autowired
private IEngineMaintenanceService engineMaintenanceService;
/**
* 查询【请填写功能名称】列表
*/
@GetMapping("/list")
public Result<TableDataInfo<EngineMaintenance>> list(EngineMaintenance engineMaintenance)
{
startPage();
List<EngineMaintenance> list = engineMaintenanceService.selectEngineMaintenanceList(engineMaintenance);
return getDataTable(list);
}
/**
* 导出【请填写功能名称】列表
*/
@Log(title = "【请填写功能名称】", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, EngineMaintenance engineMaintenance)
{
List<EngineMaintenance> list = engineMaintenanceService.selectEngineMaintenanceList(engineMaintenance);
ExcelUtil<EngineMaintenance> util = new ExcelUtil<EngineMaintenance>(EngineMaintenance.class);
util.exportExcel(response, list, "【请填写功能名称】数据");
}
/**
* 获取【请填写功能名称】详细信息
*/
@GetMapping(value = "/{id}")
public Result getInfo(@PathVariable("id") Long id)
{
return success(engineMaintenanceService.selectEngineMaintenanceById(id));
}
/**
* 测试方法
* @param code
* @return
*/
@GetMapping(value = "/TestMethod")
public Result testMethod(@RequestParam("code") String code)
{
return engineMaintenanceService.testMethod(code);
}
/**
* 新增【请填写功能名称】
*/
@Log(title = "【请填写功能名称】", businessType = BusinessType.INSERT)
@PostMapping
public Result add(@RequestBody EngineMaintenance engineMaintenance)
{
return toAjax(engineMaintenanceService.insertEngineMaintenance(engineMaintenance));
}
/**
* 初始化规则引擎类
*/
@PostMapping("/InitializeRuleEngine")
public Result initializeRuleEngine(@RequestBody EngineMaintenance engineMaintenance)
{
return engineMaintenanceService.initializeRuleEngine(engineMaintenance);
}
/**
* 修改【请填写功能名称】
*/
@Log(title = "【请填写功能名称】", businessType = BusinessType.UPDATE)
@PutMapping
public Result edit(@RequestBody EngineMaintenance engineMaintenance)
{
return toAjax(engineMaintenanceService.updateEngineMaintenance(engineMaintenance));
}
/**
* 删除【请填写功能名称】
*/
@Log(title = "【请填写功能名称】", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public Result remove(@PathVariable Long[] ids)
{
return toAjax(engineMaintenanceService.deleteEngineMaintenanceByIds(ids));
}
}

152
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/domain/EngineMaintenance.java 100644
View File

@ -0,0 +1,152 @@
package com.muyu.rule.engine.domain;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.muyu.common.core.annotation.Excel;
import com.muyu.common.core.web.domain.BaseEntity;
/**
* 【请填写功能名称】对象 engine_maintenance
*
* @author ruoyi
* @date 2024-05-02
*/
public class EngineMaintenance extends BaseEntity {
private static final long serialVersionUID = 1L;
/** $column.columnComment */
private Long id;
/** 规则引擎名称 */
@Excel(name = "规则引擎名称")
private String name;
/** 规则引擎类型 */
@Excel(name = "规则引擎类型")
private String type;
/** 规则引擎激活状态 */
@Excel(name = "规则引擎激活状态")
private String isActivate;
/** 规则引擎状态 */
@Excel(name = "规则引擎状态")
private String status;
/** 规则引擎描述 */
@Excel(name = "规则引擎描述")
private String description;
/** 规则引擎编码 */
@Excel(name = "规则引擎编码")
private String code;
/** 规则引擎级别 */
@Excel(name = "规则引擎级别")
private String level;
/** 编辑代码文本 */
@Excel(name = "编辑代码文本")
private String codeText;
public String getCodeText() {
return codeText;
}
public void setCodeText(String codeText) {
this.codeText = codeText;
}
public void setId(Long id)
{
this.id = id;
}
public Long getId()
{
return id;
}
public void setName(String name)
{
this.name = name;
}
public String getName()
{
return name;
}
public void setType(String type)
{
this.type = type;
}
public String getType()
{
return type;
}
public void setIsActivate(String isActivate)
{
this.isActivate = isActivate;
}
public String getIsActivate()
{
return isActivate;
}
public void setStatus(String status)
{
this.status = status;
}
public String getStatus()
{
return status;
}
public void setDescription(String description)
{
this.description = description;
}
public String getDescription()
{
return description;
}
public void setCode(String code)
{
this.code = code;
}
public String getCode()
{
return code;
}
public void setLevel(String level)
{
this.level = level;
}
public String getLevel()
{
return level;
}
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("id", getId())
.append("name", getName())
.append("type", getType())
.append("isActivate", getIsActivate())
.append("status", getStatus())
.append("description", getDescription())
.append("code", getCode())
.append("level", getLevel())
.append("codeText", getCodeText())
.append("remark", getRemark())
.append("createBy", getCreateBy())
.append("createTime", getCreateTime())
.append("updateBy", getUpdateBy())
.append("updateTime", getUpdateTime())
.toString();
}
}

61
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/mapper/EngineMaintenanceMapper.java 100644
View File

@ -0,0 +1,61 @@
package com.muyu.rule.engine.mapper;
import java.util.List;
import com.muyu.rule.engine.domain.EngineMaintenance;
/**
* 【请填写功能名称】Mapper接口
*
* @author ruoyi
* @date 2024-05-02
*/
public interface EngineMaintenanceMapper
{
/**
* 查询【请填写功能名称】
*
* @param id 【请填写功能名称】主键
* @return 【请填写功能名称】
*/
public EngineMaintenance selectEngineMaintenanceById(Long id);
/**
* 查询【请填写功能名称】列表
*
* @param engineMaintenance 【请填写功能名称】
* @return 【请填写功能名称】集合
*/
public List<EngineMaintenance> selectEngineMaintenanceList(EngineMaintenance engineMaintenance);
/**
* 新增【请填写功能名称】
*
* @param engineMaintenance 【请填写功能名称】
* @return 结果
*/
public int insertEngineMaintenance(EngineMaintenance engineMaintenance);
/**
* 修改【请填写功能名称】
*
* @param engineMaintenance 【请填写功能名称】
* @return 结果
*/
public int updateEngineMaintenance(EngineMaintenance engineMaintenance);
/**
* 删除【请填写功能名称】
*
* @param id 【请填写功能名称】主键
* @return 结果
*/
public int deleteEngineMaintenanceById(Long id);
/**
* 批量删除【请填写功能名称】
*
* @param ids 需要删除的数据主键集合
* @return 结果
*/
public int deleteEngineMaintenanceByIds(Long[] ids);
}

67
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/service/IEngineMaintenanceService.java 100644
View File

@ -0,0 +1,67 @@
package com.muyu.rule.engine.service;
import java.util.List;
import com.muyu.common.core.domain.Result;
import com.muyu.rule.engine.domain.EngineMaintenance;
/**
* 【请填写功能名称】Service接口
*
* @author ruoyi
* @date 2024-05-02
*/
public interface IEngineMaintenanceService
{
/**
* 查询【请填写功能名称】
*
* @param id 【请填写功能名称】主键
* @return 【请填写功能名称】
*/
public EngineMaintenance selectEngineMaintenanceById(Long id);
/**
* 查询【请填写功能名称】列表
*
* @param engineMaintenance 【请填写功能名称】
* @return 【请填写功能名称】集合
*/
public List<EngineMaintenance> selectEngineMaintenanceList(EngineMaintenance engineMaintenance);
/**
* 新增【请填写功能名称】
*
* @param engineMaintenance 【请填写功能名称】
* @return 结果
*/
public int insertEngineMaintenance(EngineMaintenance engineMaintenance);
/**
* 修改【请填写功能名称】
*
* @param engineMaintenance 【请填写功能名称】
* @return 结果
*/
public int updateEngineMaintenance(EngineMaintenance engineMaintenance);
/**
* 批量删除【请填写功能名称】
*
* @param ids 需要删除的【请填写功能名称】主键集合
* @return 结果
*/
public int deleteEngineMaintenanceByIds(Long[] ids);
/**
* 删除【请填写功能名称】信息
*
* @param id 【请填写功能名称】主键
* @return 结果
*/
public int deleteEngineMaintenanceById(Long id);
Result initializeRuleEngine(EngineMaintenance engineMaintenance);
Result testMethod(String code);
}

192
muyu-modules/muyu-rule-engine/src/main/java/com/muyu/rule/engine/service/impl/EngineMaintenanceServiceImpl.java 100644
View File

@ -0,0 +1,192 @@
package com.muyu.rule.engine.service.impl;
import java.io.File;
import java.io.FileWriter;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.List;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.DateUtils;
import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.rule.engine.ClassLoading.CustomClassLoader;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.muyu.rule.engine.mapper.EngineMaintenanceMapper;
import com.muyu.rule.engine.domain.EngineMaintenance;
import com.muyu.rule.engine.service.IEngineMaintenanceService;
import javax.tools.JavaCompiler;
import javax.tools.StandardJavaFileManager;
import javax.tools.ToolProvider;
/**
* 【请填写功能名称】Service业务层处理
*
* @author ruoyi
* @date 2024-05-02
*/
@Service
@Log4j2
public class EngineMaintenanceServiceImpl implements IEngineMaintenanceService
{
@Autowired
private EngineMaintenanceMapper engineMaintenanceMapper;
/**
* 查询【请填写功能名称】
*
* @param id 【请填写功能名称】主键
* @return 【请填写功能名称】
*/
@Override
public EngineMaintenance selectEngineMaintenanceById(Long id)
{
return engineMaintenanceMapper.selectEngineMaintenanceById(id);
}
/**
* 查询【请填写功能名称】列表
*
* @param engineMaintenance 【请填写功能名称】
* @return 【请填写功能名称】
*/
@Override
public List<EngineMaintenance> selectEngineMaintenanceList(EngineMaintenance engineMaintenance)
{
return engineMaintenanceMapper.selectEngineMaintenanceList(engineMaintenance);
}
/**
* 新增【请填写功能名称】
*
* @param engineMaintenance 【请填写功能名称】
* @return 结果
*/
@Override
public int insertEngineMaintenance(EngineMaintenance engineMaintenance)
{
String className = "Rule"+Character.toUpperCase(engineMaintenance.getCode().charAt(0)) + engineMaintenance.getCode().substring(1)+"Class";
engineMaintenance.setCreateTime(DateUtils.getNowDate());
engineMaintenance.setCreateBy(SecurityUtils.getUsername());
engineMaintenance.setCodeText("package com.muyu.rule.engine.domain;\n\n\n"+
"public class " + className + " {\n" +
"}");
return engineMaintenanceMapper.insertEngineMaintenance(engineMaintenance);
}
/**
* 修改【请填写功能名称】
*
* @param engineMaintenance 【请填写功能名称】
* @return 结果
*/
@Override
public int updateEngineMaintenance(EngineMaintenance engineMaintenance)
{
engineMaintenance.setUpdateTime(DateUtils.getNowDate());
engineMaintenance.setUpdateBy(SecurityUtils.getUsername());
return engineMaintenanceMapper.updateEngineMaintenance(engineMaintenance);
}
/**
* 批量删除【请填写功能名称】
*
* @param ids 需要删除的【请填写功能名称】主键
* @return 结果
*/
@Override
public int deleteEngineMaintenanceByIds(Long[] ids)
{
return engineMaintenanceMapper.deleteEngineMaintenanceByIds(ids);
}
/**
* 删除【请填写功能名称】信息
*
* @param id 【请填写功能名称】主键
* @return 结果
*/
@Override
public int deleteEngineMaintenanceById(Long id)
{
return engineMaintenanceMapper.deleteEngineMaintenanceById(id);
}
@Override
public Result initializeRuleEngine(EngineMaintenance engineMaintenance) {
try {
//创建源文件
String className = "Rule"+Character.toUpperCase(engineMaintenance.getCode().charAt(0)) + engineMaintenance.getCode().substring(1)+"Class";
// 源文件路径和名称
String javaPath = "D:\\work\\ruoyi-cloud-server\\muyu-modules\\muyu-rule-engine\\src\\main\\java\\com\\muyu\\rule\\engine\\domain\\";
String classPath = "D:\\work\\ruoyi-cloud-server\\muyu-modules\\muyu-rule-engine\\target\\classes\\";
String filename = javaPath+className+".java";
File file = new File(filename);
// 确保源文件所在的目录存在
File fileParent = file.getParentFile();
if (!fileParent.exists()) {
fileParent.mkdir();
}
// 确保源文件存在，如果已存在则先删除再创建
if (file.exists()) {
file.delete(); // 删除存在的文件
}
file.createNewFile();
// 将源代码写入文件
FileWriter fw = new FileWriter(file);
fw.write(engineMaintenance.getCodeText());
fw.flush();
fw.close();
// 使用JavaCompiler 编译java文件
// 获取系统Java编译器
JavaCompiler jc = ToolProvider.getSystemJavaCompiler();
// 获取标准文件管理器
StandardJavaFileManager fileManager = jc.getStandardFileManager(null, null, null);
// 获取要编译的文件对象
Iterable fileObjects = fileManager.getJavaFileObjects(filename);
// 设置编译选项，指定输出目录
List<String> options = Arrays.asList("-d", classPath);
// 创建编译任务
JavaCompiler.CompilationTask cTask = jc.getTask(null, fileManager, null, options, null, fileObjects);
// 执行编译任务
Boolean call = cTask.call();
// 关闭文件管理器
fileManager.close();
if (call){
return Result.success("初始化成功");
}
}catch (Exception e){
log.error(e.getMessage());
Result.error("初始化失败");
}
return Result.error("初始化失败");
}
@Override
public Result testMethod(String code) {
String className = "Rule"+Character.toUpperCase(code.charAt(0)) + code.substring(1)+"Class";
String classPath = "D:\\work\\ruoyi-cloud-server\\muyu-modules\\muyu-rule-engine\\target\\classes\\";
try {
// 使用CustomClassLoader加载class到内存
CustomClassLoader customClassLoader = new CustomClassLoader(ClassLoader.getSystemClassLoader(), classPath);
// 加载类
Class<?> aClass = customClassLoader.loadClass("com.muyu.rule.engine.domain."+className);
// 实例化类
Object obj = aClass.newInstance();
//获取类中所有方法
Method[] methods = aClass.getDeclaredMethods();
for (Method method : methods) {
method.invoke(obj);
}
customClassLoader = null;
} catch (Exception e) {
log.error(e.getMessage());
Result.error("测试失败");
}
return Result.success("测试成功");
}
}

2
muyu-modules/muyu-rule-engine/src/main/resources/banner.txt 100644
View File

@ -0,0 +1,2 @@
Spring Boot Version: ${spring-boot.version}
Spring Application Name: ${spring.application.name}

28
muyu-modules/muyu-rule-engine/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,28 @@
# Tomcat
server:
port: 9205
# Spring
spring:
application:
# 应用名称
name: muyu-ruleEngine
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 43.142.44.217:8848
config:
# 配置中心地址
server-addr: 43.142.44.217:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
logging:
level:
com.muyu.rule.engine.mapper: DEBUG

74
muyu-modules/muyu-rule-engine/src/main/resources/logback.xml 100644
View File

@ -0,0 +1,74 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/muyu-system"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

111
muyu-modules/muyu-rule-engine/src/main/resources/mapper/ruleEngine/EngineMaintenanceMapper.xml 100644
View File

@ -0,0 +1,111 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.muyu.rule.engine.mapper.EngineMaintenanceMapper">
<resultMap type="com.muyu.rule.engine.domain.EngineMaintenance" id="EngineMaintenanceResult">
<result property="id" column="id" />
<result property="name" column="name" />
<result property="type" column="type" />
<result property="isActivate" column="is_activate" />
<result property="status" column="status" />
<result property="description" column="description" />
<result property="code" column="code" />
<result property="level" column="level" />
<result property="codeText" column="code_text" />
<result property="remark" column="remark" />
<result property="createBy" column="create_by" />
<result property="createTime" column="create_time" />
<result property="updateBy" column="update_by" />
<result property="updateTime" column="update_time" />
</resultMap>
<sql id="selectEngineMaintenanceVo">
select id, name, type, is_activate, status, description, code, level,code_text, remark, create_by, create_time, update_by, update_time from engine_maintenance
</sql>
<select id="selectEngineMaintenanceList" parameterType="com.muyu.rule.engine.domain.EngineMaintenance" resultMap="EngineMaintenanceResult">
<include refid="selectEngineMaintenanceVo"/>
<where>
<if test="name != null and name != ''"> and name like concat('%', #{name}, '%')</if>
<if test="type != null and type != ''"> and type = #{type}</if>
<if test="isActivate != null and isActivate != ''"> and is_activate = #{isActivate}</if>
<if test="status != null and status != ''"> and status = #{status}</if>
<if test="description != null and description != ''"> and description = #{description}</if>
<if test="code != null and code != ''"> and code = #{code}</if>
<if test="level != null and level != ''"> and level = #{level}</if>
<if test="codeText != null and codeText != ''"> and code_text = #{codeText}</if>
</where>
</select>
<select id="selectEngineMaintenanceById" parameterType="Long" resultMap="EngineMaintenanceResult">
<include refid="selectEngineMaintenanceVo"/>
where id = #{id}
</select>
<insert id="insertEngineMaintenance" parameterType="com.muyu.rule.engine.domain.EngineMaintenance" useGeneratedKeys="true" keyProperty="id">
insert into engine_maintenance
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="name != null">name,</if>
<if test="type != null">type,</if>
<if test="isActivate != null">is_activate,</if>
<if test="status != null">status,</if>
<if test="description != null">description,</if>
<if test="code != null">code,</if>
<if test="level != null">level,</if>
<if test="codeText != null">code_text,</if>
<if test="remark != null">remark,</if>
<if test="createBy != null and createBy != ''">create_by,</if>
<if test="createTime != null">create_time,</if>
<if test="updateBy != null">update_by,</if>
<if test="updateTime != null">update_time,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="name != null">#{name},</if>
<if test="type != null">#{type},</if>
<if test="isActivate != null">#{isActivate},</if>
<if test="status != null">#{status},</if>
<if test="description != null">#{description},</if>
<if test="code != null">#{code},</if>
<if test="level != null">#{level},</if>
<if test="codeText != null">#{codeText},</if>
<if test="remark != null">#{remark},</if>
<if test="createBy != null and createBy != ''">#{createBy},</if>
<if test="createTime != null">#{createTime},</if>
<if test="updateBy != null">#{updateBy},</if>
<if test="updateTime != null">#{updateTime},</if>
</trim>
</insert>
<update id="updateEngineMaintenance" parameterType="com.muyu.rule.engine.domain.EngineMaintenance">
update engine_maintenance
<trim prefix="SET" suffixOverrides=",">
<if test="name != null">name = #{name},</if>
<if test="type != null">type = #{type},</if>
<if test="isActivate != null">is_activate = #{isActivate},</if>
<if test="status != null">status = #{status},</if>
<if test="description != null">description = #{description},</if>
<if test="code != null">code = #{code},</if>
<if test="level != null">level = #{level},</if>
<if test="codeText != null">code_text = #{codeText},</if>
<if test="remark != null">remark = #{remark},</if>
<if test="createBy != null and createBy != ''">create_by = #{createBy},</if>
<if test="createTime != null">create_time = #{createTime},</if>
<if test="updateBy != null">update_by = #{updateBy},</if>
<if test="updateTime != null">update_time = #{updateTime},</if>
</trim>
where id = #{id}
</update>
<delete id="deleteEngineMaintenanceById" parameterType="Long">
delete from engine_maintenance where id = #{id}
</delete>
<delete id="deleteEngineMaintenanceByIds" parameterType="String">
delete from engine_maintenance where id in
<foreach item="id" collection="array" open="(" separator="," close=")">
#{id}
</foreach>
</delete>
</mapper>

1
muyu-modules/pom.xml
View File

@ -14,6 +14,7 @@
<module>muyu-job</module>
<module>muyu-file</module>
<module>muyu-etl</module>
<module>muyu-rule-engine</module>
</modules>
<artifactId>muyu-modules</artifactId>