From 7aa8e7559e5124e2613abcef1755e8e32288155e Mon Sep 17 00:00:00 2001 From: rouchen <3133657697@qq.com> Date: Tue, 30 Apr 2024 11:27:34 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E8=B5=84=E4=BA=A7=E5=B1=95=E7=A4=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dataStructure/OverallDataStructure.java | 38 +++++++ .../com/muyu/kvt/datadisplay/DataDisplay.java | 39 +++++++ .../java/com/muyu/kvt/dept/DataSource.java | 56 ++++++++++ .../java/com/muyu/kvt/dept/DeptUserKvt.java | 23 ++++ .../com/muyu/kvt/domain/Synchronization.java | 102 ++++++++++++++++++ .../com/muyu/kvt/remote/RemoteUserSer.java | 32 ++++++ .../muyu/kvt/remote/factory/RemoteUser.java | 28 +++++ ...ot.autoconfigure.AutoConfiguration.imports | 1 + 8 files changed, 319 insertions(+) create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dataStructure/OverallDataStructure.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/datadisplay/DataDisplay.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DataSource.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DeptUserKvt.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/domain/Synchronization.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/RemoteUserSer.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/factory/RemoteUser.java create mode 100644 muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports diff --git a/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dataStructure/OverallDataStructure.java b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dataStructure/OverallDataStructure.java new file mode 100644 index 0000000..2e8e47d --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dataStructure/OverallDataStructure.java @@ -0,0 +1,38 @@ +package com.muyu.kvt.dataStructure; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * 整体数据结构 overallDataStructure + * + * @author LeYang + * on 2024/4/28 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class OverallDataStructure { + /** + * 数据接入 + */ + private Integer kvt; + + /** + * 资产模型 + */ + private Integer table; + + /** + * 数据模型 + */ + + private Integer datas; + + + + +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/datadisplay/DataDisplay.java b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/datadisplay/DataDisplay.java new file mode 100644 index 0000000..5ea7cb3 --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/datadisplay/DataDisplay.java @@ -0,0 +1,39 @@ +package com.muyu.kvt.datadisplay; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * 资产展示 DataDisplay + * + * @author LeYang + * on 2024/4/29 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class DataDisplay { + /** + * id + */ + private Integer id; + /** + * 库名 + */ + private String warName; + /** + * 类型 + */ + private String type; + /** + * 值 + */ + private Object value; + + + + +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DataSource.java b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DataSource.java new file mode 100644 index 0000000..846c207 --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DataSource.java @@ -0,0 +1,56 @@ +package com.muyu.kvt.dept; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * DataSource + * + * @author LeYang + * on 2024/4/27 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class DataSource { + /** + * 数据接入名称 + */ + private Integer name; + /** + * 系统名称 + */ + private String systemName; + + /** + * 数据库名称 + */ + private String databaseName; + /** + * 表名称 + */ + private String tableName; + + /** + * 表中文名 + */ + private String tableAsName; + + /** + * 数据量 + */ + private String total; + + + + + + + + + + +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DeptUserKvt.java b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DeptUserKvt.java new file mode 100644 index 0000000..1fb7797 --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/dept/DeptUserKvt.java @@ -0,0 +1,23 @@ +package com.muyu.kvt.dept; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * 用户部门接口 DeptUserKvt + * + * @author LeYang + * on 2024/4/27 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class DeptUserKvt { + private Integer id; + private Long userId; + private Long kvtId; + private Long deptId; +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/domain/Synchronization.java b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/domain/Synchronization.java new file mode 100644 index 0000000..d9d8fae --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-common/src/main/java/com/muyu/kvt/domain/Synchronization.java @@ -0,0 +1,102 @@ +package com.muyu.kvt.domain; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +import java.util.Date; + +/** + * 同步对象 Synchronization + * + * @author LeYang + * on 2024/4/28 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@SuperBuilder +public class Synchronization { + + + /** + * 主键 + */ + private Integer id; + /** + * 接入源名称 + */ + private String name; + /** + * 数据来源系统名称 + */ + private String systemName; + /** + * 数据接入类型 + */ + private String type; + /** + * 主机地址 + */ + private String host; + /** + * 端口地址 + */ + private String port; + /** + * 数据库名称 + */ + private String databaseName; + /** + * 数据连接参数 + */ + private String connectionParam; + /** + * 初始连接数量 + */ + private Integer initNum; + /** + * 最大连接数量 + */ + private Integer maxNum; + /** + * 最大等待时间 + */ + private Date maxWaitTime; + /** + * 最大等待次数 + */ + private Integer maxWaitSize; + /** + * 备注 + */ + private String remark; + /** + * 创建人 + */ + private String create_by; + /** + * 创建时间 + */ + private Date createTime; + /** + * 更新人 + */ + private String update_by; + /** + * 更新时间 + */ + private Date updateTime; + /** + * 用户名 + */ + private String username; + /** + * 密码 + */ + private String password; + + + +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/RemoteUserSer.java b/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/RemoteUserSer.java new file mode 100644 index 0000000..c2f4f9d --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/RemoteUserSer.java @@ -0,0 +1,32 @@ +package com.muyu.kvt.remote; + +import com.muyu.common.core.constant.ServiceNameConstants; +import com.muyu.common.core.domain.Result; +import com.muyu.common.system.domain.SysUser; +import com.muyu.kvt.remote.factory.RemoteUser; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestParam; + +/** + * RemoteUser + * + * @author LeYang + * on 2024/4/27 + */ +@FeignClient( + contextId = "RemoteUserSer", + value = ServiceNameConstants.SYSTEM_SERVICE, + fallbackFactory = RemoteUser.class, + path = "/user" +) +public interface RemoteUserSer { + /** + * 根据用户id查询用户信息 + * @return 结果 + */ + @PostMapping("/selectUserId") + public Result selectUserId(@RequestParam("userId") Long userId); + +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/factory/RemoteUser.java b/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/factory/RemoteUser.java new file mode 100644 index 0000000..4ba7b09 --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/java/com/muyu/kvt/remote/factory/RemoteUser.java @@ -0,0 +1,28 @@ +package com.muyu.kvt.remote.factory; + + +import com.muyu.common.core.domain.Result; +import com.muyu.common.system.domain.SysUser; +import com.muyu.kvt.remote.RemoteUserSer; +import org.springframework.cloud.openfeign.FallbackFactory; +import org.springframework.stereotype.Component; + +/** + * 用户服务降级处理 + * + * @author muyu + */ +@Component +public class RemoteUser implements FallbackFactory { + + @Override + public RemoteUserSer create(Throwable cause) { + + return new RemoteUserSer() { + @Override + public Result selectUserId(Long userId) { + return Result.error(cause.getMessage()); + } + }; + } +} diff --git a/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports new file mode 100644 index 0000000..db235cc --- /dev/null +++ b/muyu-modules/muyu-kvt/muyu-kvt-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -0,0 +1 @@ +com.muyu.kvt.remote.factory.RemoteUser