From 20c771be2cfe6ecd0cbf0258aff77b9d5be69067 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E7=86=99=E6=9C=9D?= <13694051+wangxizhao123@user.noreply.gitee.com> Date: Fri, 10 May 2024 22:11:04 +0800 Subject: [PATCH] =?UTF-8?q?fase()=E8=BF=9C=E7=A8=8B=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../muyu-goods-edition-clinet/pom.xml | 7 ++ .../efition/clinet/MuyuClinetApplication.java | 11 ++ .../efition/clinet/config/AccessConfig.java | 3 + .../clinet/config/AccessConfigRunner.java | 84 ++++++++++++- .../com/muyu/edition/domain/vo/UnitVo.java | 18 +++ .../remote/RemoteDataManagerService.java | 7 ++ .../remote/factory/DataMangFacrory.java | 7 +- .../controller/RuleEngineController.java | 1 - muyu-modules/muyu-goods-edition/pom.xml | 1 + muyu-modules/muyu-goods-unit/pom.xml | 90 +++++++++++++- .../goods/unit/MuyuGoodsUnitApplication.java | 23 ++++ .../src/main/resources/bootstrap.yml | 28 +++++ .../src/main/resources/logback.xml | 74 +++++++++++ .../resources/mapper/goods/ConfigMapper.xml | 74 ----------- .../resources/mapper/goods/CopeMapper.xml | 11 -- .../resources/mapper/goods/EditionMapper.xml | 85 ------------- .../mapper/goods/RuleEngineMapper.xml | 115 ------------------ .../remote/RemoteSystemManageService.java | 27 ++++ .../remote/factory/DataMangSystemFactory.java | 26 ++++ 19 files changed, 401 insertions(+), 291 deletions(-) create mode 100644 muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/MuyuClinetApplication.java create mode 100644 muyu-modules/muyu-goods-edition/muyu-goods-edition-common/src/main/java/com/muyu/edition/domain/vo/UnitVo.java create mode 100644 muyu-modules/muyu-goods-unit/src/main/java/com/muyu/goods/unit/MuyuGoodsUnitApplication.java create mode 100644 muyu-modules/muyu-goods-unit/src/main/resources/bootstrap.yml create mode 100644 muyu-modules/muyu-goods-unit/src/main/resources/logback.xml delete mode 100644 muyu-modules/muyu-goods/src/main/resources/mapper/goods/ConfigMapper.xml delete mode 100644 muyu-modules/muyu-goods/src/main/resources/mapper/goods/CopeMapper.xml delete mode 100644 muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml delete mode 100644 muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml create mode 100644 muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/RemoteSystemManageService.java create mode 100644 muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/factory/DataMangSystemFactory.java diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/pom.xml b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/pom.xml index e330ac6..e71c17f 100644 --- a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/pom.xml +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/pom.xml @@ -29,6 +29,13 @@ muyu-goods-edition-remote 3.6.3 + + + com.muyu + muyu-modules-system + 3.6.3 + + diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/MuyuClinetApplication.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/MuyuClinetApplication.java new file mode 100644 index 0000000..4dea964 --- /dev/null +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/MuyuClinetApplication.java @@ -0,0 +1,11 @@ +package com.muyu.efition.clinet; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class MuyuClinetApplication { + public static void main(String[] args) { + SpringApplication.run(MuyuClinetApplication.class); + } +} diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfig.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfig.java index 9082985..6ec2668 100644 --- a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfig.java +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfig.java @@ -3,6 +3,9 @@ package com.muyu.efition.clinet.config; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Import; +/** + * 规则引擎客户端配置类 + */ @ComponentScan @Import(value = AccessConfigRunner.class) public class AccessConfig { diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfigRunner.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfigRunner.java index f472874..818a1cd 100644 --- a/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfigRunner.java +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-clinet/src/main/java/com/muyu/efition/clinet/config/AccessConfigRunner.java @@ -1,24 +1,102 @@ package com.muyu.efition.clinet.config; +import com.alibaba.druid.pool.DruidDataSource; +import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.muyu.common.core.domain.Result; +import com.muyu.common.core.utils.StringUtils; import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.edition.domain.RuleEngine; +import com.muyu.edition.domain.vo.UnitVo; import com.muyu.goods.edition.remote.RemoteDataManagerService; +import com.muyu.system.domain.DataAccess; +import com.muyu.system.domain.vo.FrimaryVo; +import com.muyu.system.remote.RemoteSystemManageService; +import com.muyu.system.remote.factory.DataMangSystemFactory; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; +import javax.sql.DataSource; +import java.sql.Connection; +import java.sql.DriverManager; +import java.util.HashMap; +import java.util.List; +import java.util.Optional; +import java.util.function.Function; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +/** + * 初始化加载 + */ @Log4j2 public class AccessConfigRunner implements ApplicationRunner { @Autowired - private RemoteDataManagerService remoteDataManagerService; + private RemoteSystemManageService remoteSystemManageService; @Override public void run(ApplicationArguments args) throws Exception { - Result> list = remoteDataManagerService.list(null); + //远程调用 + Result> listed = remoteSystemManageService.list(null); + //判断非空 + if (listed.getData().getRows() == null || listed.getData().getRows().isEmpty()){ + log.error("数据为空"); + return; + } + //获取数据源集合 + List listResultData = listed.getData().getRows(); + //存入map + //创建map + HashMap frimaryVoHashMap = new HashMap<>(); + //遍历循环存入map + listResultData.forEach(res -> { + frimaryVoHashMap.put(res.getId(),res); + }); + HashMap hashMap = new HashMap<>(); + //遍历添加到hashMap + for (DataAccess listResultDatum : listResultData) { + if (listResultDatum.getType() == "MySql"){ + //主机地址 + String host = listResultDatum.getHost(); + //端口号 + String port = listResultDatum.getPort(); + //数据库名 + String databaseName = listResultDatum.getDatabaseName(); + // url + String url = String.format("jdbc:mysql://"+ host+":"+port+":"+databaseName); + log.info("集成化的url:{}",url); + //连接对象 url/用户名/密码 + Connection connection = DriverManager.getConnection(url,listResultDatum.getUsername(),listResultDatum.getPassword()); + log.info("连接对象：{}",connection); + DruidDataSource dataSource = new DruidDataSource(); + //初始化链接池数量 + dataSource.setInitialSize(listResultDatum.getInitNum().intValue()); + //最大线程池 + dataSource.setMaxActive(listResultDatum.getMaxNum().intValue()); + //最大等待时间 + dataSource.setMaxWait(listResultDatum.getMaxWaitTime()); + //配置数据库的基本信息 + dataSource.setDriverClassName("com.mysql/jdbc.Driver"); + //数据库连接池 + dataSource.setUrl("jdbc:mysql://"+ + listResultDatum.getHost()+":"+listResultDatum.getPort()+":"+listResultDatum.getDatabaseName()); + //数据库用户名 + dataSource.setUsername(listResultDatum.getUsername()); + //数据库密码 + dataSource.setPassword(listResultDatum.getPassword()); + log.info("获取连接池对象：{}",dataSource); + //封装对象 + //SuperBuilder方法 + UnitVo build = UnitVo.builder() + .connection(connection) + .dataSource(dataSource) + .build(); + //存入map + hashMap.put(host+"_"+port+"_"+databaseName,build); + } - log.info("远程调用成功,效果为：{}", list); + } } } diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-common/src/main/java/com/muyu/edition/domain/vo/UnitVo.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-common/src/main/java/com/muyu/edition/domain/vo/UnitVo.java new file mode 100644 index 0000000..889af9e --- /dev/null +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-common/src/main/java/com/muyu/edition/domain/vo/UnitVo.java @@ -0,0 +1,18 @@ +package com.muyu.edition.domain.vo; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +import javax.sql.DataSource; +import java.sql.Connection; + +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class UnitVo { + private Connection connection; + private DataSource dataSource; +} diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/RemoteDataManagerService.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/RemoteDataManagerService.java index 6a708d7..b03e973 100644 --- a/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/RemoteDataManagerService.java +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/RemoteDataManagerService.java @@ -6,14 +6,21 @@ import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.edition.domain.RuleEngine; import com.muyu.goods.edition.remote.factory.DataMangFacrory; import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.stereotype.Service; import org.springframework.web.bind.annotation.GetMapping; +import java.util.List; + +/** + * 远程调用 + */ @FeignClient( contextId = "RemoteSys", value = ServiceNameConstants.EDITION_MUYU, fallbackFactory = DataMangFacrory.class, path = "/engine" ) +@Service public interface RemoteDataManagerService { @GetMapping("/list") public Result> list(RuleEngine ruleEngine); diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/factory/DataMangFacrory.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/factory/DataMangFacrory.java index bd72533..e567315 100644 --- a/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/factory/DataMangFacrory.java +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-remote/src/main/java/com/muyu/goods/edition/remote/factory/DataMangFacrory.java @@ -5,9 +5,14 @@ import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.edition.domain.RuleEngine; import com.muyu.goods.edition.remote.RemoteDataManagerService; import org.springframework.cloud.openfeign.FallbackFactory; +import org.w3c.dom.stylesheets.LinkStyle; -//熔断 +import java.util.List; + +/** + * 熔断 + */ public class DataMangFacrory implements FallbackFactory { @Override public RemoteDataManagerService create(Throwable cause) { diff --git a/muyu-modules/muyu-goods-edition/muyu-goods-edition-server/src/main/java/com/muyu/edition/controller/RuleEngineController.java b/muyu-modules/muyu-goods-edition/muyu-goods-edition-server/src/main/java/com/muyu/edition/controller/RuleEngineController.java index 2b8757d..d1209ae 100644 --- a/muyu-modules/muyu-goods-edition/muyu-goods-edition-server/src/main/java/com/muyu/edition/controller/RuleEngineController.java +++ b/muyu-modules/muyu-goods-edition/muyu-goods-edition-server/src/main/java/com/muyu/edition/controller/RuleEngineController.java @@ -33,7 +33,6 @@ public class RuleEngineController extends BaseController { @RequiresPermissions("goods:engine:list") @GetMapping("/list") public Result> list(RuleEngine ruleEngine) { - startPage(); List list = ruleEngineService.selectRuleEngineList(ruleEngine); return getDataTable(list); } diff --git a/muyu-modules/muyu-goods-edition/pom.xml b/muyu-modules/muyu-goods-edition/pom.xml index 2c0dd1c..1a09b0c 100644 --- a/muyu-modules/muyu-goods-edition/pom.xml +++ b/muyu-modules/muyu-goods-edition/pom.xml @@ -25,4 +25,5 @@ UTF-8 + diff --git a/muyu-modules/muyu-goods-unit/pom.xml b/muyu-modules/muyu-goods-unit/pom.xml index 1c4ca93..95839cd 100644 --- a/muyu-modules/muyu-goods-unit/pom.xml +++ b/muyu-modules/muyu-goods-unit/pom.xml @@ -28,9 +28,97 @@ com.muyu - muyu-goods + muyu-goods-edition 3.6.3 + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-sentinel + + + + + org.springframework.boot + spring-boot-starter-actuator + + + + + io.springfox + springfox-swagger-ui + ${swagger.fox.version} + + + + + com.mysql + mysql-connector-j + + + + + com.muyu + muyu-common-datasource + + + + + com.muyu + muyu-common-datascope + + + + + com.muyu + muyu-common-log + + + + + com.muyu + muyu-common-swagger + + + + ${project.artifactId} + + + org.springframework.boot + spring-boot-maven-plugin + + + + repackage + + + + + + + org.apache.maven.plugins + maven-deploy-plugin + + true + + + + + + + diff --git a/muyu-modules/muyu-goods-unit/src/main/java/com/muyu/goods/unit/MuyuGoodsUnitApplication.java b/muyu-modules/muyu-goods-unit/src/main/java/com/muyu/goods/unit/MuyuGoodsUnitApplication.java new file mode 100644 index 0000000..4406199 --- /dev/null +++ b/muyu-modules/muyu-goods-unit/src/main/java/com/muyu/goods/unit/MuyuGoodsUnitApplication.java @@ -0,0 +1,23 @@ +package com.muyu.goods.unit; + +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; +import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.scheduling.annotation.EnableAsync; + +/** + * 测试启动类 + */ +@SpringBootApplication(exclude = DataSourceAutoConfiguration.class) +@EnableCustomConfig +@EnableCustomSwagger2 +@EnableMyFeignClients +@EnableAsync +public class MuyuGoodsUnitApplication { + public static void main(String[] args) { + SpringApplication.run(MuyuGoodsUnitApplication.class); + } +} diff --git a/muyu-modules/muyu-goods-unit/src/main/resources/bootstrap.yml b/muyu-modules/muyu-goods-unit/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..41cf597 --- /dev/null +++ b/muyu-modules/muyu-goods-unit/src/main/resources/bootstrap.yml @@ -0,0 +1,28 @@ +# Tomcat +server: + port: 9505 + +# Spring +spring: + application: + # 应用名称 + name: muyu-test + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 129.211.23.219:8848 + config: + # 配置中心地址 + server-addr: 129.211.23.219:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} +logging: + level: + com.muyu.edition.mapper: DEBUG diff --git a/muyu-modules/muyu-goods-unit/src/main/resources/logback.xml b/muyu-modules/muyu-goods-unit/src/main/resources/logback.xml new file mode 100644 index 0000000..66e0d25 --- /dev/null +++ b/muyu-modules/muyu-goods-unit/src/main/resources/logback.xml @@ -0,0 +1,74 @@ + + + + + + + + + + + ${log.pattern} + + + + + + ${log.path}/info.log + + + + ${log.path}/info.%d{yyyy-MM-dd}.log + + 60 + + + ${log.pattern} + + + + INFO + + ACCEPT + + DENY + + + + + ${log.path}/error.log + + + + ${log.path}/error.%d{yyyy-MM-dd}.log + + 60 + + + ${log.pattern} + + + + ERROR + + ACCEPT + + DENY + + + + + + + + + + + + + + + + + + diff --git a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/ConfigMapper.xml b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/ConfigMapper.xml deleted file mode 100644 index 4fef7a7..0000000 --- a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/ConfigMapper.xml +++ /dev/null @@ -1,74 +0,0 @@ - - - - - - - - - - - - - - select id, version_code, rule_content, remark, rule_id - from config - - - - - - - - - insert into config - - version_code, - rule_content, - rule_id, - - - #{versionCode}, - #{ruleContent}, - #{ruleId}, - - - - - update config - - version_code = #{versionCode}, - rule_content = #{ruleContent}, - rule_id = #{ruleId}, - - where id = #{id} - - - - delete - from config - where id = #{id} - - - - delete from config where id in - - #{id} - - - diff --git a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/CopeMapper.xml b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/CopeMapper.xml deleted file mode 100644 index 7e87475..0000000 --- a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/CopeMapper.xml +++ /dev/null @@ -1,11 +0,0 @@ - - - - - - diff --git a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml deleted file mode 100644 index 795bf5a..0000000 --- a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml +++ /dev/null @@ -1,85 +0,0 @@ - - - - - - - - - - - - - - - - - - - select id, - rule_id, - version_class, - name, - version_code, - edition_status, - rule_status, - rule_is_test, - edition_content, - rule_content - from edition - - - - - - - - insert into edition - - rule_id, - version_class, - name, - version_code, - edition_content, - rule_content, - - - #{ruleId}, - #{versionClass}, - #{name}, - #{versionCode}, - #{editionContent}, - #{ruleContent}, - - - - - update edition - - name = #{name}, - edition_content = #{editionContent}, - rule_content = #{ruleContent}, - - where id = #{id} - - - - delete - from edition - where id = #{id} - - - - delete from edition where id in - - #{id} - - - diff --git a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml deleted file mode 100644 index cb7f878..0000000 --- a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml +++ /dev/null @@ -1,115 +0,0 @@ - - - - - - - - - - - - - - - - - - select rule_id, - rule_name, - rule_code, - rule_level, - rule_type, - rule_is_activate, - rule_status, - description, - remark - from rule_engine - - - - - - - - - insert into rule_engine - - rule_name, - rule_code, - rule_level, - rule_type, - rule_is_activate, - rule_status, - description, - remark, - - - #{ruleName}, - #{ruleCode}, - #{ruleLevel}, - #{ruleType}, - #{ruleIsActivate}, - #{ruleStatus}, - #{description}, - #{remark}, - - - - - update rule_engine - - rule_name = #{ruleName}, - rule_code = #{ruleCode}, - rule_level = #{ruleLevel}, - rule_type = #{ruleType}, - rule_is_activate = #{ruleIsActivate}, - rule_status = #{ruleStatus}, - description = #{description}, - remark = #{remark}, - - where rule_id = #{ruleId} - - - update rule_engine - set rule_is_activate = #{ruleIsActivate} - where rule_id = #{ruleId}; - - - update rule_engine - set rule_status = #{ruleStatus} - where rule_id = #{ruleId}; - - - - delete - from rule_engine - where rule_id = #{ruleId} - - - - delete from rule_engine where rule_id in - - #{ruleId} - - - diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/RemoteSystemManageService.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/RemoteSystemManageService.java new file mode 100644 index 0000000..e8724ff --- /dev/null +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/RemoteSystemManageService.java @@ -0,0 +1,27 @@ +package com.muyu.system.remote; + +import com.muyu.common.core.constant.ServiceNameConstants; +import com.muyu.common.core.domain.Result; +import com.muyu.common.core.web.page.TableDataInfo; +import com.muyu.system.domain.DataAccess; +import com.muyu.system.domain.vo.FrimaryVo; +import com.muyu.system.remote.factory.DataMangSystemFactory; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; + +import java.util.List; + +/** + * 远程调用 + */ +@FeignClient( + contextId = "RemoteSys", + value = ServiceNameConstants.SYSTEM_SERVICE, + fallbackFactory = DataMangSystemFactory.class, + path = "/access" +) +public interface RemoteSystemManageService { + @GetMapping("/list") + public Result> list(DataAccess dataAccess); +} diff --git a/muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/factory/DataMangSystemFactory.java b/muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/factory/DataMangSystemFactory.java new file mode 100644 index 0000000..83fba32 --- /dev/null +++ b/muyu-modules/muyu-system/src/main/java/com/muyu/system/remote/factory/DataMangSystemFactory.java @@ -0,0 +1,26 @@ +package com.muyu.system.remote.factory; + +import com.muyu.common.core.domain.Result; +import com.muyu.common.core.web.page.TableDataInfo; +import com.muyu.system.domain.DataAccess; +import com.muyu.system.domain.vo.FrimaryVo; +import com.muyu.system.remote.RemoteSystemManageService; +import org.springframework.cloud.openfeign.FallbackFactory; + +import java.util.List; + +/** + * 熔断 + */ +public class DataMangSystemFactory implements FallbackFactory { + @Override + public RemoteSystemManageService create(Throwable cause) { + return new RemoteSystemManageService() { + + @Override + public Result> list(DataAccess dataAccess) { + return Result.error(cause.getMessage()); + } + }; + } +}