From c6dab25cada6b493232cb633462332adca104a04 Mon Sep 17 00:00:00 2001 From: Saisai Liu <1374434128@qq.com> Date: Tue, 14 May 2024 22:14:03 +0800 Subject: [PATCH] =?UTF-8?q?feat():=E6=B7=BB=E5=8A=A0=E7=BC=93=E5=AD=98?= =?UTF-8?q?=EF=BC=8C=E4=BF=AE=E6=94=B9=E8=BF=9C=E7=A8=8B=E7=9A=84=E8=B0=83?= =?UTF-8?q?=E7=94=A8=E6=97=A0=E6=9D=83=E9=99=90bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- muyu-common/muyu-common-cache/pom.xml | 2 +- .../java/com/muyu/cache/abs/CacheAbs.java | 45 +++++++++++++++ .../main/java/com/muyu/cache/redis/Cache.java | 18 ++++++ .../java/com/muyu/cache/redis/RedisCache.java | 20 ------- .../common/redis/service/RedisService.java | 55 +++++++------------ muyu-modules/muyu-etl/muyu-etl-cache/pom.xml | 30 ++++++++++ .../main/java/com/muyu/cache/AssetCache.java | 35 ++++++++++++ muyu-modules/muyu-etl/muyu-etl-common/pom.xml | 9 +++ .../com/muyu/etl/domain/cache/AssetCache.java | 15 +++++ .../etl/domain/scope/model/DataSetModel.java | 15 +++-- .../etl/domain/scope/model/RecordModel.java | 18 ++++-- .../domain/scope/scope/DataModelContext.java | 2 +- .../java/com/muyu/EtlApplicationRunner.java | 30 ++++++++++ .../impl/BasicConfigInfoServiceImpl.java | 10 +--- muyu-modules/muyu-etl/pom.xml | 1 + .../engine_custom_PhotoTest_DATARULE.java | 21 +++++++ .../impl/RuleEngineVersionServiceImpl.java | 35 +++++++++++- pom.xml | 7 +++ 18 files changed, 289 insertions(+), 79 deletions(-) create mode 100644 muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java create mode 100644 muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/Cache.java delete mode 100644 muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/RedisCache.java create mode 100644 muyu-modules/muyu-etl/muyu-etl-cache/pom.xml create mode 100644 muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java create mode 100644 muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/cache/AssetCache.java create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java create mode 100644 muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/domain/test/custom/engine_custom_PhotoTest_DATARULE.java diff --git a/muyu-common/muyu-common-cache/pom.xml b/muyu-common/muyu-common-cache/pom.xml index b3bc591..0f84556 100644 --- a/muyu-common/muyu-common-cache/pom.xml +++ b/muyu-common/muyu-common-cache/pom.xml @@ -22,7 +22,7 @@ com.muyu - muyu-common-security + muyu-common-redis diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java new file mode 100644 index 0000000..64cb350 --- /dev/null +++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/CacheAbs.java @@ -0,0 +1,45 @@ +package com.muyu.cache.abs; + +import com.alibaba.fastjson2.JSON; +import com.muyu.cache.redis.Cache; +import com.muyu.common.redis.service.RedisService; +import org.springframework.beans.factory.annotation.Autowired; + +import javax.annotation.Resource; + +/** + * @ClassName CacheAbs + * @Description 描述 + * @Author SaiSai.Liu + * @Date 2024/5/14 17:05 + */ +public abstract class CacheAbs implements Cache { + @Resource + private RedisService redisService; + + + /** + * 根据key获取值 + * @param key + * @return + */ + protected abstract V get(K key); + + /** + * 存入值 + * @param k + * @param v + */ + void put(K k, V v) { + String key = enCode(k); + redisService.setCacheObject(key, JSON.toJSONString(v)); + } + + /** + * 删除值 + * @param k + */ + void remove(K k){ + redisService.deleteObject(enCode(k)); + }; +} diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/Cache.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/Cache.java new file mode 100644 index 0000000..4b31c05 --- /dev/null +++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/Cache.java @@ -0,0 +1,18 @@ +package com.muyu.cache.redis; + +/** + * @ClassName Cache + * @Description 描述 + * @Author SaiSai.Liu + * @Date 2024/5/10 19:01 + */ +public interface Cache { + + + String preKey(K key); + + String enCode(K key); + + String unCode(String string); + +} diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/RedisCache.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/RedisCache.java deleted file mode 100644 index 953dbd7..0000000 --- a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/redis/RedisCache.java +++ /dev/null @@ -1,20 +0,0 @@ -package com.muyu.cache.redis; - -/** - * @ClassName RedisCache - * @Description 描述 - * @Author SaiSai.Liu - * @Date 2024/5/10 19:01 - */ -public interface RedisCache { - K getKey(T t); - - V get(K key); - - void put(K k ,V v); - - void remove(K k); - - - -} diff --git a/muyu-common/muyu-common-redis/src/main/java/com/muyu/common/redis/service/RedisService.java b/muyu-common/muyu-common-redis/src/main/java/com/muyu/common/redis/service/RedisService.java index db90c1e..656f604 100644 --- a/muyu-common/muyu-common-redis/src/main/java/com/muyu/common/redis/service/RedisService.java +++ b/muyu-common/muyu-common-redis/src/main/java/com/muyu/common/redis/service/RedisService.java @@ -27,7 +27,7 @@ public class RedisService { * @param key 缓存的键值 * @param value 缓存的值 */ - public void setCacheObject (final String key, final T value) { + public void setCacheObject(final String key, final T value) { redisTemplate.opsForValue().set(key, value); } @@ -39,7 +39,7 @@ public class RedisService { * @param timeout 时间 * @param timeUnit 时间颗粒度 */ - public void setCacheObject (final String key, final T value, final Long timeout, final TimeUnit timeUnit) { + public void setCacheObject(final String key, final T value, final Long timeout, final TimeUnit timeUnit) { redisTemplate.opsForValue().set(key, value, timeout, timeUnit); } @@ -48,10 +48,9 @@ public class RedisService { * * @param key Redis键 * @param timeout 超时时间 - * * @return true=设置成功；false=设置失败 */ - public boolean expire (final String key, final long timeout) { + public boolean expire(final String key, final long timeout) { return expire(key, timeout, TimeUnit.SECONDS); } @@ -61,10 +60,9 @@ public class RedisService { * @param key Redis键 * @param timeout 超时时间 * @param unit 时间单位 - * * @return true=设置成功；false=设置失败 */ - public boolean expire (final String key, final long timeout, final TimeUnit unit) { + public boolean expire(final String key, final long timeout, final TimeUnit unit) { return redisTemplate.expire(key, timeout, unit); } @@ -72,10 +70,9 @@ public class RedisService { * 获取有效时间 * * @param key Redis键 - * * @return 有效时间 */ - public long getExpire (final String key) { + public long getExpire(final String key) { return redisTemplate.getExpire(key); } @@ -83,10 +80,9 @@ public class RedisService { * 判断 key是否存在 * * @param key 键 - * * @return true 存在 false不存在 */ - public Boolean hasKey (String key) { + public Boolean hasKey(String key) { return redisTemplate.hasKey(key); } @@ -94,10 +90,9 @@ public class RedisService { * 获得缓存的基本对象。 * * @param key 缓存键值 - * * @return 缓存键值对应的数据 */ - public T getCacheObject (final String key) { + public T getCacheObject(final String key) { ValueOperations operation = redisTemplate.opsForValue(); return operation.get(key); } @@ -107,7 +102,7 @@ public class RedisService { * * @param key */ - public boolean deleteObject (final String key) { + public boolean deleteObject(final String key) { return redisTemplate.delete(key); } @@ -115,10 +110,9 @@ public class RedisService { * 删除集合对象 * * @param collection 多个对象 - * * @return */ - public boolean deleteObject (final Collection collection) { + public boolean deleteObject(final Collection collection) { return redisTemplate.delete(collection) > 0; } @@ -127,10 +121,9 @@ public class RedisService { * * @param key 缓存的键值 * @param dataList 待缓存的List数据 - * * @return 缓存的对象 */ - public long setCacheList (final String key, final List dataList) { + public long setCacheList(final String key, final List dataList) { Long count = redisTemplate.opsForList().rightPushAll(key, dataList); return count == null ? 0 : count; } @@ -139,10 +132,9 @@ public class RedisService { * 获得缓存的list对象 * * @param key 缓存的键值 - * * @return 缓存键值对应的数据 */ - public List getCacheList (final String key) { + public List getCacheList(final String key) { return redisTemplate.opsForList().range(key, 0, -1); } @@ -151,10 +143,9 @@ public class RedisService { * * @param key 缓存键值 * @param dataSet 缓存的数据 - * * @return 缓存数据的对象 */ - public BoundSetOperations setCacheSet (final String key, final Set dataSet) { + public BoundSetOperations setCacheSet(final String key, final Set dataSet) { BoundSetOperations setOperation = redisTemplate.boundSetOps(key); Iterator it = dataSet.iterator(); while (it.hasNext()) { @@ -167,10 +158,9 @@ public class RedisService { * 获得缓存的set * * @param key - * * @return */ - public Set getCacheSet (final String key) { + public Set getCacheSet(final String key) { return redisTemplate.opsForSet().members(key); } @@ -180,7 +170,7 @@ public class RedisService { * @param key * @param dataMap */ - public void setCacheMap (final String key, final Map dataMap) { + public void setCacheMap(final String key, final Map dataMap) { if (dataMap != null) { redisTemplate.opsForHash().putAll(key, dataMap); } @@ -190,10 +180,9 @@ public class RedisService { * 获得缓存的Map * * @param key - * * @return */ - public Map getCacheMap (final String key) { + public Map getCacheMap(final String key) { return redisTemplate.opsForHash().entries(key); } @@ -204,7 +193,7 @@ public class RedisService { * @param hKey Hash键 * @param value 值 */ - public void setCacheMapValue (final String key, final String hKey, final T value) { + public void setCacheMapValue(final String key, final String hKey, final T value) { redisTemplate.opsForHash().put(key, hKey, value); } @@ -213,10 +202,9 @@ public class RedisService { * * @param key Redis键 * @param hKey Hash键 - * * @return Hash中的对象 */ - public T getCacheMapValue (final String key, final String hKey) { + public T getCacheMapValue(final String key, final String hKey) { HashOperations opsForHash = redisTemplate.opsForHash(); return opsForHash.get(key, hKey); } @@ -226,10 +214,9 @@ public class RedisService { * * @param key Redis键 * @param hKeys Hash键集合 - * * @return Hash对象集合 */ - public List getMultiCacheMapValue (final String key, final Collection hKeys) { + public List getMultiCacheMapValue(final String key, final Collection hKeys) { return redisTemplate.opsForHash().multiGet(key, hKeys); } @@ -238,10 +225,9 @@ public class RedisService { * * @param key Redis键 * @param hKey Hash键 - * * @return 是否成功 */ - public boolean deleteCacheMapValue (final String key, final String hKey) { + public boolean deleteCacheMapValue(final String key, final String hKey) { return redisTemplate.opsForHash().delete(key, hKey) > 0; } @@ -249,10 +235,9 @@ public class RedisService { * 获得缓存的基本对象列表 * * @param pattern 字符串前缀 - * * @return 对象列表 */ - public Collection keys (final String pattern) { + public Collection keys(final String pattern) { return redisTemplate.keys(pattern); } } diff --git a/muyu-modules/muyu-etl/muyu-etl-cache/pom.xml b/muyu-modules/muyu-etl/muyu-etl-cache/pom.xml new file mode 100644 index 0000000..aad063a --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-cache/pom.xml @@ -0,0 +1,30 @@ + + + 4.0.0 + + com.muyu + muyu-etl + 3.6.3 + + + muyu-etl-cache + + + 17 + 17 + UTF-8 + + + + com.muyu + muyu-etl-common + + + com.muyu + muyu-common-cache + + + + diff --git a/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java b/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java new file mode 100644 index 0000000..acc5bda --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-cache/src/main/java/com/muyu/cache/AssetCache.java @@ -0,0 +1,35 @@ +package com.muyu.cache; + +import com.muyu.cache.abs.CacheAbs; +import com.muyu.etl.domain.BasicConfigInfo; + +import java.util.List; + +/** + * @ClassName AssetCache + * @Description 描述 + * @Author SaiSai.Liu + * @Date 2024/5/14 21:03 + */ +public class AssetCache extends CacheAbs> { + + @Override + protected List get(String key) { + return null; + } + + @Override + public String preKey(String key) { + return null; + } + + @Override + public String enCode(String key) { + return "etl-cache:" + key; + } + + @Override + public String unCode(String string) { + return null; + } +} diff --git a/muyu-modules/muyu-etl/muyu-etl-common/pom.xml b/muyu-modules/muyu-etl/muyu-etl-common/pom.xml index 98239e9..c1290a1 100644 --- a/muyu-modules/muyu-etl/muyu-etl-common/pom.xml +++ b/muyu-modules/muyu-etl/muyu-etl-common/pom.xml @@ -22,19 +22,28 @@ com.muyu muyu-common-core + com.muyu muyu-common-security + mysql mysql-connector-java + com.alibaba druid 1.2.8 + + com.muyu + muyu-common-cache + + + diff --git a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/cache/AssetCache.java b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/cache/AssetCache.java new file mode 100644 index 0000000..cee9f05 --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/cache/AssetCache.java @@ -0,0 +1,15 @@ +//package com.muyu.etl.domain.cache; +// +////import com.muyu.etl.domain.BasicConfigInfo; +// +//import com.muyu.etl.domain.BasicConfigInfo; +// +///** +// * @ClassName AssetCache +// * @Description 描述 +// * @Author SaiSai.Liu +// * @Date 2024/5/14 21:03 +// */ +//public class AssetCache extends CacheAbs{ +//} +//// diff --git a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/DataSetModel.java b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/DataSetModel.java index 9fa2b14..677bf4b 100644 --- a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/DataSetModel.java +++ b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/DataSetModel.java @@ -3,6 +3,8 @@ package com.muyu.etl.domain.scope.model; import lombok.Data; import java.io.Serializable; +import java.util.ArrayList; +import java.util.List; /** * 一页 @@ -12,24 +14,25 @@ import java.io.Serializable; * @Version: 1.0 */ @Data -public class DataSetModel implements Serializable { +public class DataSetModel { // [[DataModel,DataModel,DataModel],[DataModel,DataModel,DataModel]] - private RecordModel[] recordModelArr = null; + private List recordModelArr = null; private DataSetModel(int recordModelLength){ - recordModelArr = new RecordModel[recordModelLength]; + recordModelArr = new ArrayList(); } - private DataSetModel(RecordModel[] recordModelArr){ - recordModelArr = recordModelArr; + + private DataSetModel(List recordModelArr){ + this.recordModelArr = recordModelArr; } public static DataSetModel build(int recordModelLength){ return new DataSetModel(recordModelLength); } - public static DataSetModel build(RecordModel[] recordModelArr){ + public static DataSetModel build(List recordModelArr){ return new DataSetModel(recordModelArr); } diff --git a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/RecordModel.java b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/RecordModel.java index ab9127d..f0d53ce 100644 --- a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/RecordModel.java +++ b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/model/RecordModel.java @@ -1,5 +1,10 @@ package com.muyu.etl.domain.scope.model; +import lombok.Data; + +import java.util.ArrayList; +import java.util.List; + /** * 记录模型 * @Author: DongZeLiang @@ -7,23 +12,24 @@ package com.muyu.etl.domain.scope.model; * @Description: 记录模型 * @Version: 1.0 */ +@Data public class RecordModel { // [DataModel,DataModel,DataModel] + private List dataModelArr = null; private RecordModel(int dataModelLength){ - dataModelArr = new DataModel[dataModelLength]; - } - private RecordModel(DataModel[] dataModelArr){ - dataModelArr = dataModelArr; + dataModelArr = new ArrayList<>(); } - private DataModel[] dataModelArr = null; + private RecordModel(List dataModelArr){ + this.dataModelArr = dataModelArr; + } public static RecordModel build(int dataModelLength){ return new RecordModel(dataModelLength); } - public static RecordModel build(DataModel[] dataModelArr){ + public static RecordModel build(List dataModelArr){ return new RecordModel(dataModelArr); } } diff --git a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/scope/DataModelContext.java b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/scope/DataModelContext.java index 7b1bf57..10891fc 100644 --- a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/scope/DataModelContext.java +++ b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/scope/scope/DataModelContext.java @@ -4,7 +4,7 @@ package com.muyu.etl.domain.scope.scope; import com.muyu.etl.domain.scope.scope.model.DataProcessModel; /** - * @Author: DongZeLiang + * @Author: Saisai.Liu * @date: 2024/4/29 * @Description: 数据模型 * @Version: 1.0 diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java new file mode 100644 index 0000000..ede69b7 --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/EtlApplicationRunner.java @@ -0,0 +1,30 @@ +package com.muyu; + +import com.muyu.etl.domain.BasicConfigInfo; +import com.muyu.etl.service.BasicConfigInfoService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.ApplicationArguments; +import org.springframework.boot.ApplicationRunner; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @ClassName EtlApplicationRunner + * @Description 描述 + * @Author SaiSai.Liu + * @Date 2024/5/14 20:54 + */ +@Component +public class EtlApplicationRunner implements ApplicationRunner { + @Autowired + private BasicConfigInfoService basicConfigInfoService; + + + @Override + public void run(ApplicationArguments args) throws Exception { + List basicConfigInfos = basicConfigInfoService.selectBasicConfigInfoList(new BasicConfigInfo() {{ + setIsTest("1"); + }}); + } +} diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BasicConfigInfoServiceImpl.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BasicConfigInfoServiceImpl.java index c406743..82b1c49 100644 --- a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BasicConfigInfoServiceImpl.java +++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BasicConfigInfoServiceImpl.java @@ -18,6 +18,7 @@ import com.muyu.etl.domain.scope.model.DataModel; import com.muyu.etl.domain.scope.model.DataSetModel; import com.muyu.etl.domain.scope.model.RecordModel; import com.muyu.etl.domain.scope.scope.DataModelContext; +import com.muyu.etl.domain.scope.scope.model.RecordProcessModel; import com.muyu.etl.mapper.BasicConfigInfoMapper; import com.muyu.etl.service.BasicConfigInfoService; import com.muyu.etl.service.StructureService; @@ -467,20 +468,15 @@ public class BasicConfigInfoServiceImpl extends ServiceImplmuyu-etl-remote muyu-etl-service muyu-etl-client + muyu-etl-cache diff --git a/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/domain/test/custom/engine_custom_PhotoTest_DATARULE.java b/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/domain/test/custom/engine_custom_PhotoTest_DATARULE.java new file mode 100644 index 0000000..ec952ec --- /dev/null +++ b/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/domain/test/custom/engine_custom_PhotoTest_DATARULE.java @@ -0,0 +1,21 @@ +package com.muyu.engine.domain.test.custom; + +import com.muyu.etl.domain.scope.engine.action.ActionDiscard; +import com.muyu.etl.domain.scope.engine.scope.DataModelEngine; + +/** + * @Author: Saisai + * @date: 2024/4/5 + * @Description: 数据字段-DATARULE + * @Version: 1.0 + */ + public class engine_custom_PhotoTest_DATARULE extends DataModelEngine { + @Override + public void execution () { + Object value = getValue(); + + if (value == null || "".equals(value) || "null".equals(value)) { + throw new ActionDiscard(); + } + } + } diff --git a/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/service/impl/RuleEngineVersionServiceImpl.java b/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/service/impl/RuleEngineVersionServiceImpl.java index 9791947..208f5d7 100644 --- a/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/service/impl/RuleEngineVersionServiceImpl.java +++ b/muyu-modules/muyu-ruleEngine/muyu-ruleEngine-service/src/main/java/com/muyu/engine/service/impl/RuleEngineVersionServiceImpl.java @@ -132,7 +132,7 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl aClass = classLoader.loadClass(name); + Object o = aClass.newInstance(); + Method[] methods = aClass.getMethods(); + for (Method method : methods) { + method.invoke(0,obj); + } + } catch (Exception e) { + log.error("报错信息：{}",e.getMessage()); + throw new RuntimeException(e); + } + return true; + } + /** * 测试引擎版本 * @@ -178,8 +207,8 @@ public class RuleEngineVersionServiceImpl extends ServiceImpl${muyu.version} + + + com.muyu + muyu-common-cache + ${muyu.version} + + com.muyu