利用Java的动态编译、动态加载结合EasyRules实现业务规则的动态性的项目源码

package com.hauxsoft.service.impl; import java.text.ParseException; import java.util.Arrays; import java.util.Date; import java.util.Map; import java.util.Objects; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.core.env.Environment; import org.springframework.data.domain.Page; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.hauxsoft.core.constant.Consts; import com.hauxsoft.core.constant.Errors; import com.hauxsoft.core.mvc.dao.BaseDao; import com.hauxsoft.core.mvc.dao.NativeQuery; import com.hauxsoft.core.mvc.dao.SqlParamValueParser; import com.hauxsoft.core.mvc.dao.SqlWhereLogicEnum; import com.hauxsoft.core.mvc.service.impl.BaseFlatCrudServiceImpl; import com.hauxsoft.core.util.BeanUtils2; import com.hauxsoft.core.util.StringUtils2; import com.hauxsoft.core.util.result.Result; import com.hauxsoft.core.util.result.Results; import com.hauxsoft.dao.JavaRuleDao; import com.hauxsoft.data.CompileResult; import com.hauxsoft.data.JavaRuleDTO; import com.hauxsoft.entity.JavaRuleDO; import com.hauxsoft.service.JavaRuleService; import com.hauxsoft.utils.BaseRule; import com.hauxsoft.utils.JavaRuleStorage; import com.hauxsoft.utils.DynamicRuleUtils; import lombok.extern.slf4j.Slf4j; @Slf4j @Service public class JavaRuleServiceImpl extends BaseFlatCrudServiceImpl<JavaRuleDO, Long> implements JavaRuleService{ @Override protected BaseDao<JavaRuleDO, Long> dao() { return dao; } /** * return jpa entity by id * @param id * @return entity in JAVA_RULE */ @Override public JavaRuleDO get(Long id) { return dao.findById(id).orElse(null); } /** * insert or update jpa entity * @param entity */ @Override @Transactional public void save(JavaRuleDO entity) { Date now = new Date(); boolean isNew = entity.getId() == null; if(isNew) { entity.setCreateTime(now); } else { entity.setUpdateTime(now); } dao.save(entity); } /** * delete jpa entity by id * @param id * @return Results.SUCCESS_RESULT if success, or ErrorResult instance if error */ @Override @Transactional public Result<?> delete(Long id) { JavaRuleDO entity = get(id); return delete(entity); } /** * delete jpa entity by id * @param id * @return Results.SUCCESS_RESULT if success, or ErrorResult instance if error */ @Override @Transactional public Result<?> delete(JavaRuleDO entity) { return Results.when(entity) .map(e -> e == null, "entity is not exist", Errors.Entity.NOT_EXIST) .map(e -> e.getIsDeleted().equals(Consts.Entity.IS_DELETED), "entity is deleted", Errors.Entity.IS_DELETED) // 设定正在使用的规则不能删除，必须先停掉 .map(e -> Objects.equals(e.getStatus(), Consts.Entity.IS_VALID), "规则处于启用状态，不能删除！") .run(e -> { e.setIsDeleted(Consts.Entity.IS_DELETED); dao.save(e); }) // 从容器移除 /*.then(entity2 -> { String groupName = entity2.getGroupName(); try { BaseRule rule = RuleUtils.getRuleInstance(entity2); if (javaRuleStorage.contains(groupName, rule) && !javaRuleStorage.remove(groupName, rule)) { return Results.error("从容器移除规则失败！"); } } catch (Exception e) { log.error("从容器移除规则{}异常！", entity2.getName(), e); return Results.error("从容器移除规则异常！"); } return Results.success(); })*/; } /** * execute native sql query by conditions in query html page * @param conditions 查询条件 * @pageNo 页码，从0开始 * @pageSize 每页数据量，必须 > 0 * @sort 排序方式 * @return Results.SUCCESS_RESULT if success, or ErrorResult instance if error */ @Override public Page<Map<String, Object>> query(Map<String, Object> conditions, int pageNo, int pageSize, String sort) throws ParseException { NativeQuery query = dao.createNativeQuery() .select("t.id, t.TARGET, t.GROUP_NAME, t.SIMPLE_CLASS_NAME, t.NAME, t.SORT, t.CREATE_TIME, t.STATUS") .from("JAVA_RULE t") .where("t.TARGET like :target") .where("t.GROUP_NAME like :groupName") .where("t.SIMPLE_CLASS_NAME like :simpleClassName") .where("t.NAME like :name") .where("t.STATUS = :status") .where("t.IS_DELETED = " + Consts.Entity.NOT_DELETED) .registParameterValueParser("target", SqlParamValueParser.LEFT_LIKE_PARSER) .registParameterValueParser("groupName", SqlParamValueParser.LEFT_LIKE_PARSER) .registParameterValueParser("simpleClassName", SqlParamValueParser.LEFT_LIKE_PARSER) .registParameterValueParser("name", SqlParamValueParser.CONTAIN_PARSER) .sort(sort) .setParameters(conditions); // 系统筛选 if (StringUtils2.notEmpty(ruleTarget)) { query.where("target in :targets") .setParameter("targets", Arrays.asList(ruleTarget.split(","))); } return query.listPage(pageNo, pageSize); } /** * 返回dto对象 * @param id * @return success result if entity exist, or error result if entity not exist */ @Override public Result<JavaRuleDTO> getDTO(Long id) { return getOne(id).map(JavaRuleDTO::of); } /** * 根据dto对象insert一条数据，dto对象的内容一般来自新增页面 * @param id * @return success or error result */ @Override @Transactional public Result<?> insertDTO(JavaRuleDTO dto){ return Results.when(dto.toEntity("id", "createTime", "updateTime")) // 编译 .then(this::compiler) // 保存 .run(this::save) // 添加到bean容器或者移除 .then(entity -> { // 如果是启动状态，顺便添加规则到容器 if (Objects.equals(entity.getStatus(), Consts.Entity.IS_VALID)) { return addRuleToStorage(entity); } else if (Objects.equals(entity.getStatus(), Consts.Entity.NOT_VALID)) { String groupName = entity.getGroupName(); try { BaseRule rule = DynamicRuleUtils.getRuleInstance(entity); if (javaRuleStorage.contains(groupName, rule) && !javaRuleStorage.remove(groupName, rule)) { return Results.error("从容器移除规则失败！"); } } catch (Exception e) { log.error("从容器移除规则{}异常！", entity.getName(), e); return Results.error("从容器移除规则异常！"); } } return Results.success(entity); }) .map(e -> { dto.setId(e.getId()); dto.setUpdateTime(e.getCreateTime()); return dto; }); } /** * 根据dto对象update一条数据，dto对象的内容一般来自修改页面 * @param id * @return success or error result */ @Override @Transactional public Result<?> updateDTO(JavaRuleDTO dto){ return getOne(dto.getId()) .then(e -> { BeanUtils2.copyProperties(dto.toEntity(), e, "id", "createTime", "updateTime", "createUserId", "createUserName"); return Results.success(e); }) // 编译 .then(this::compiler) // 保存 .run(this::save)