From e5b603417e8b0097ca9e90859d2b608b84a76140 Mon Sep 17 00:00:00 2001 From: yuan <1363654894@qq.com> Date: Mon, 9 Sep 2024 14:34:08 +0800 Subject: [PATCH] =?UTF-8?q?feat():=E9=9B=86=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cloud-rule-remote/pom.xml | 13 ++++++ .../muyu/remote/feign/SelectFeignService.java | 44 +++++++++++++++++++ .../remote/feign/impl/SelectFeignFactory.java | 34 ++++++++++++++ cloud-rule-server/pom.xml | 10 +++++ .../controller/RuleVersionController.java | 11 +++-- .../com/muyu/servier/RuleVersionService.java | 7 ++- .../servier/impl/RuleVersionServiceImpl.java | 8 ++++ 7 files changed, 119 insertions(+), 8 deletions(-) create mode 100644 cloud-rule-remote/src/main/java/com/muyu/remote/feign/SelectFeignService.java create mode 100644 cloud-rule-remote/src/main/java/com/muyu/remote/feign/impl/SelectFeignFactory.java diff --git a/cloud-rule-remote/pom.xml b/cloud-rule-remote/pom.xml index deefeda..c565c9c 100644 --- a/cloud-rule-remote/pom.xml +++ b/cloud-rule-remote/pom.xml @@ -17,4 +17,17 @@ UTF-8 + + + com.muyu + cloud-rule-common + 1.0.0 + + + com.muyu + cloud-property-common + 1.0.0 + + + diff --git a/cloud-rule-remote/src/main/java/com/muyu/remote/feign/SelectFeignService.java b/cloud-rule-remote/src/main/java/com/muyu/remote/feign/SelectFeignService.java new file mode 100644 index 0000000..d608721 --- /dev/null +++ b/cloud-rule-remote/src/main/java/com/muyu/remote/feign/SelectFeignService.java @@ -0,0 +1,44 @@ +package com.muyu.remote.feign; + + +import com.muyu.common.core.domain.Result; +import com.muyu.common.domain.DataName; +import com.muyu.common.domain.TableNames; +import com.muyu.remote.feign.impl.SelectFeignFactory; +import io.swagger.v3.oas.annotations.Operation; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestParam; + +import java.util.List; + +@FeignClient(name = "cloud-property",fallbackFactory = SelectFeignFactory.class) +public interface SelectFeignService { + + /** + * 查询表数据下所有表表 + * @param dataName 数据库名称 + * @return 反护试图 + */ + @PostMapping("/property/dataLink/findSelectDataShow") + public Result> findSelectDataShow( + @RequestParam("dataName") String dataName); + + /** + * 查询表数据dashuju表 + * @param dataTableName 查看表下的所有数据 + * @return 反护试图 + */ + @PostMapping("/property/dataLink/findSelectTableShow") + public Result> findSelectTableShow( + @RequestParam("dataTableName") String dataTableName); + + /** + * 获取数据库名 + * @return 返回试图 + */ + @PostMapping("/property/dataName/list") + @Operation(summary = "获取数据库名",description = "从数据库中抽取数据库名称") + public Result> extractDataName(); + +} diff --git a/cloud-rule-remote/src/main/java/com/muyu/remote/feign/impl/SelectFeignFactory.java b/cloud-rule-remote/src/main/java/com/muyu/remote/feign/impl/SelectFeignFactory.java new file mode 100644 index 0000000..9222370 --- /dev/null +++ b/cloud-rule-remote/src/main/java/com/muyu/remote/feign/impl/SelectFeignFactory.java @@ -0,0 +1,34 @@ +package com.muyu.remote.feign.impl; + +import com.muyu.common.core.domain.Result; +import com.muyu.common.domain.DataName; +import com.muyu.common.domain.TableNames; +import com.muyu.remote.feign.SelectFeignService; +import org.springframework.cloud.openfeign.FallbackFactory; +import org.springframework.stereotype.Component; + +import java.util.List; + + +@Component +public class SelectFeignFactory implements FallbackFactory { + @Override + public SelectFeignService create(Throwable cause) { + return new SelectFeignService() { + @Override + public Result> findSelectDataShow(String dataName) { + return null; + } + + @Override + public Result> findSelectTableShow(String dataTableName) { + return null; + } + + @Override + public Result> extractDataName() { + return null; + } + }; + } +} diff --git a/cloud-rule-server/pom.xml b/cloud-rule-server/pom.xml index 89d0fa8..1b2b7bf 100644 --- a/cloud-rule-server/pom.xml +++ b/cloud-rule-server/pom.xml @@ -86,6 +86,16 @@ cloud-rule-engine 1.0.0 + + com.muyu + cloud-rule-remote + 1.0.0 + + + com.muyu + cloud-property-common + 1.0.0 + diff --git a/cloud-rule-server/src/main/java/com/muyu/controller/RuleVersionController.java b/cloud-rule-server/src/main/java/com/muyu/controller/RuleVersionController.java index c33f5ce..36ce878 100644 --- a/cloud-rule-server/src/main/java/com/muyu/controller/RuleVersionController.java +++ b/cloud-rule-server/src/main/java/com/muyu/controller/RuleVersionController.java @@ -1,10 +1,7 @@ package com.muyu.controller; import com.muyu.common.core.domain.Result; -import com.muyu.common.domain.DataRecord; -import com.muyu.common.domain.DataSet; -import com.muyu.common.domain.RuleVersion; -import com.muyu.common.domain.ValueData; +import com.muyu.common.domain.*; import com.muyu.common.domain.req.RuleVersionAddReq; import com.muyu.common.domain.req.RuleVersionUpdCodeReq; import com.muyu.common.domain.req.RuleVersionUpdReq; @@ -179,4 +176,10 @@ public class RuleVersionController { return Result.success(null,"测试成功"); } + @PostMapping("/selectDatabase") + @Operation(summary = "查询数据库") + public Result> selectDatabase(){ + return Result.success(ruleVersionService.selectDatabase()); + } + } diff --git a/cloud-rule-server/src/main/java/com/muyu/servier/RuleVersionService.java b/cloud-rule-server/src/main/java/com/muyu/servier/RuleVersionService.java index 2eb7371..31fc95c 100644 --- a/cloud-rule-server/src/main/java/com/muyu/servier/RuleVersionService.java +++ b/cloud-rule-server/src/main/java/com/muyu/servier/RuleVersionService.java @@ -1,10 +1,7 @@ package com.muyu.servier; import com.baomidou.mybatisplus.extension.service.IService; -import com.muyu.common.domain.DataRecord; -import com.muyu.common.domain.DataSet; -import com.muyu.common.domain.RuleVersion; -import com.muyu.common.domain.ValueData; +import com.muyu.common.domain.*; import com.muyu.common.domain.req.RuleVersionUpdReq; import com.muyu.common.domain.resp.RuleVersionResp; @@ -39,4 +36,6 @@ public interface RuleVersionService extends IService { void setTest(DataSet dataSet); void valueTest(ValueData valueData); + + List selectDatabase(); } diff --git a/cloud-rule-server/src/main/java/com/muyu/servier/impl/RuleVersionServiceImpl.java b/cloud-rule-server/src/main/java/com/muyu/servier/impl/RuleVersionServiceImpl.java index daca673..e4ffb95 100644 --- a/cloud-rule-server/src/main/java/com/muyu/servier/impl/RuleVersionServiceImpl.java +++ b/cloud-rule-server/src/main/java/com/muyu/servier/impl/RuleVersionServiceImpl.java @@ -15,6 +15,7 @@ import com.muyu.constant.MethodSuffix; import com.muyu.engine.basic.BasicEngine; import com.muyu.load.OSSFileLoad; import com.muyu.mapper.RuleVersionMapper; +import com.muyu.remote.feign.SelectFeignService; import com.muyu.servier.RuleDataService; import com.muyu.servier.RuleVersionService; import com.muyu.upload.ALiYunUpload; @@ -43,6 +44,7 @@ public class RuleVersionServiceImpl @Autowired private RuleVersionMapper ruleVersionMapper; @Autowired private RuleDataService ruleDataService; + @Autowired private SelectFeignService selectFeignService; public static final String ClassPath = "/home/lib/com/muyu/generate/"; @@ -146,6 +148,12 @@ public class RuleVersionServiceImpl } + @Override + public List selectDatabase() { + Result> listResult = selectFeignService.extractDataName(); + return listResult.getData(); + } + @Override public void rowTest(DataRecord dataRecord) {