TreeData
/
cloud-etl
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

字典 开启 关闭

master
Qin Dong Ming 2024-08-21 14:43:02 +08:00
parent 6fd13535e1
commit 478763cc63
12 changed files with 1118 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
cloud-etl-common/src/main/java/com/muyu/domain/AssetDataDict.java
View File

@ -9,15 +9,15 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.Map;
/**
* 资产数据字典对象 asset_data_dict
*
* @author Saisai
* @date 2024-04-24
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class AssetDataDict extends BaseEntity
{
@ -31,6 +31,72 @@ public class AssetDataDict extends BaseEntity
@Excel(name = "数据接入id")
private Long basicId;
@Override
public String toString() {
return "AssetDataDict{" +
"id=" + id +
", basicId=" + basicId +
", dictName='" + dictName + '\'' +
", dictType='" + dictType + '\'' +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getBasicId() {
return basicId;
}
public void setBasicId(Long basicId) {
this.basicId = basicId;
}
public String getDictName() {
return dictName;
}
public void setDictName(String dictName) {
this.dictName = dictName;
}
public String getDictType() {
return dictType;
}
public void setDictType(String dictType) {
this.dictType = dictType;
}
public AssetDataDict(BaseEntityBuilder<?, ?> b, Long id, Long basicId, String dictName, String dictType) {
super(b);
this.id = id;
this.basicId = basicId;
this.dictName = dictName;
this.dictType = dictType;
}
public AssetDataDict(Long id, Long basicId, String dictName, String dictType) {
this.id = id;
this.basicId = basicId;
this.dictName = dictName;
this.dictType = dictType;
}
public AssetDataDict(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, Long basicId, String dictName, String dictType) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.basicId = basicId;
this.dictName = dictName;
this.dictType = dictType;
}
/** 字典名称 */
@Excel(name = "字典名称")
private String dictName;

83
cloud-etl-common/src/main/java/com/muyu/domain/AssetImpower.java
View File

@ -7,15 +7,15 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.Map;
/**
* 资产赋权对象 asset_impower
*
* @author Saisai
* @date 2024-04-28
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class AssetImpower extends BaseEntity {
private static final long serialVersionUID = 1L;
@ -25,6 +25,57 @@ public class AssetImpower extends BaseEntity {
*/
private Long id;
@Override
public String toString() {
return "AssetImpower{" +
"id=" + id +
", tableId=" + tableId +
", deptId=" + deptId +
", basicId=" + basicId +
", userId=" + userId +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getTableId() {
return tableId;
}
public void setTableId(Long tableId) {
this.tableId = tableId;
}
public Long getDeptId() {
return deptId;
}
public void setDeptId(Long deptId) {
this.deptId = deptId;
}
public Long getBasicId() {
return basicId;
}
public void setBasicId(Long basicId) {
this.basicId = basicId;
}
public Long getUserId() {
return userId;
}
public void setUserId(Long userId) {
this.userId = userId;
}
/**
* 表id
*/
@ -49,6 +100,32 @@ public class AssetImpower extends BaseEntity {
@Excel(name = "用户id")
private Long userId;
public AssetImpower(BaseEntityBuilder<?, ?> b, Long id, Long tableId, Long deptId, Long basicId, Long userId) {
super(b);
this.id = id;
this.tableId = tableId;
this.deptId = deptId;
this.basicId = basicId;
this.userId = userId;
}
public AssetImpower(Long id, Long tableId, Long deptId, Long basicId, Long userId) {
this.id = id;
this.tableId = tableId;
this.deptId = deptId;
this.basicId = basicId;
this.userId = userId;
}
public AssetImpower(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, Long tableId, Long deptId, Long basicId, Long userId) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.tableId = tableId;
this.deptId = deptId;
this.basicId = basicId;
this.userId = userId;
}
public static AssetImpower saveAssetImpower
(Long deptId,Long userId,AssetImpower assetImpower){
return AssetImpower.builder()

83
cloud-etl-common/src/main/java/com/muyu/domain/DictInfo.java
View File

@ -10,20 +10,31 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.Map;
/**
* 字典详细内容对象 dict_info
*
* @author Saisai
* @date 2024-04-24
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class DictInfo extends BaseEntity
{
private static final long serialVersionUID = 1L;
@Override
public String toString() {
return "DictInfo{" +
"id=" + id +
", dictId=" + dictId +
", infoName='" + infoName + '\'' +
", infoValue='" + infoValue + '\'' +
", isEdit=" + isEdit +
'}';
}
/** 主键 */
@TableId(value = "id",type = IdType.AUTO)
private Long id;
@ -32,6 +43,72 @@ public class DictInfo extends BaseEntity
@Excel(name = "字典id")
private Long dictId;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getDictId() {
return dictId;
}
public void setDictId(Long dictId) {
this.dictId = dictId;
}
public String getInfoName() {
return infoName;
}
public void setInfoName(String infoName) {
this.infoName = infoName;
}
public String getInfoValue() {
return infoValue;
}
public void setInfoValue(String infoValue) {
this.infoValue = infoValue;
}
public boolean isEdit() {
return isEdit;
}
public void setEdit(boolean edit) {
isEdit = edit;
}
public DictInfo(BaseEntityBuilder<?, ?> b, Long id, Long dictId, String infoName, String infoValue, boolean isEdit) {
super(b);
this.id = id;
this.dictId = dictId;
this.infoName = infoName;
this.infoValue = infoValue;
this.isEdit = isEdit;
}
public DictInfo(Long id, Long dictId, String infoName, String infoValue, boolean isEdit) {
this.id = id;
this.dictId = dictId;
this.infoName = infoName;
this.infoValue = infoValue;
this.isEdit = isEdit;
}
public DictInfo(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, Long dictId, String infoName, String infoValue, boolean isEdit) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.dictId = dictId;
this.infoName = infoName;
this.infoValue = infoValue;
this.isEdit = isEdit;
}
/** 字典名称 */
@Excel(name = "字典名称")
private String infoName;

103
cloud-etl-common/src/main/java/com/muyu/domain/Dictionary.java
View File

@ -14,14 +14,111 @@ import java.util.Date;
* @name：Dictionary
* @Date：2024/8/21 10:31
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class Dictionary {
private Integer createBy;
private Date createTime;
private Integer updateBy;
@Override
public String toString() {
return "Dictionary{" +
"createBy=" + createBy +
", createTime=" + createTime +
", updateBy=" + updateBy +
", updateTime=" + updateTime +
", remark='" + remark + '\'' +
", id=" + id +
", code='" + code + '\'' +
", descriotion='" + descriotion + '\'' +
", typeId=" + typeId +
'}';
}
public Integer getCreateBy() {
return createBy;
}
public void setCreateBy(Integer createBy) {
this.createBy = createBy;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Integer getUpdateBy() {
return updateBy;
}
public void setUpdateBy(Integer updateBy) {
this.updateBy = updateBy;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getDescriotion() {
return descriotion;
}
public void setDescriotion(String descriotion) {
this.descriotion = descriotion;
}
public Integer getTypeId() {
return typeId;
}
public void setTypeId(Integer typeId) {
this.typeId = typeId;
}
public Dictionary(Integer createBy, Date createTime, Integer updateBy, Date updateTime, String remark, Long id, String code, String descriotion, Integer typeId) {
this.createBy = createBy;
this.createTime = createTime;
this.updateBy = updateBy;
this.updateTime = updateTime;
this.remark = remark;
this.id = id;
this.code = code;
this.descriotion = descriotion;
this.typeId = typeId;
}
private Date updateTime;
private String remark;
private Long id;

32
cloud-etl-common/src/main/java/com/muyu/domain/DictionaryTYpe.java
View File

@ -13,11 +13,37 @@ import lombok.experimental.SuperBuilder;
* @name：DictionaryTYpe
* @Date：2024/8/21 10:32
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class DictionaryTYpe {
private Long id;
private String typeName;
@Override
public String toString() {
return "DictionaryTYpe{" +
"id=" + id +
", typeName='" + typeName + '\'' +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getTypeName() {
return typeName;
}
public void setTypeName(String typeName) {
this.typeName = typeName;
}
public DictionaryTYpe(Long id, String typeName) {
this.id = id;
this.typeName = typeName;
}
}

190
cloud-etl-common/src/main/java/com/muyu/domain/Source.java
View File

@ -10,9 +10,9 @@ import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
@Data
@NoArgsConstructor
@AllArgsConstructor
import java.util.Date;
import java.util.Map;
@SuperBuilder
@EqualsAndHashCode(callSuper = true)
@TableName(value ="source",autoResultMap = true) //数据库表相关
@ -27,6 +27,190 @@ public class Source extends BaseEntity {
*/
private String dataResourceName;
@Override
public String toString() {
return "Source{" +
"id=" + id +
", dataResourceName='" + dataResourceName + '\'' +
", dataSourcesSystemName='" + dataSourcesSystemName + '\'' +
", host='" + host + '\'' +
", port='" + port + '\'' +
", databaseType='" + databaseType + '\'' +
", databaseName='" + databaseName + '\'' +
", initLinkNum=" + initLinkNum +
", maxLinkNum=" + maxLinkNum +
", maxWaitTime=" + maxWaitTime +
", maxWaitTimes=" + maxWaitTimes +
", connectionParams='" + connectionParams + '\'' +
", username='" + username + '\'' +
", password='" + password + '\'' +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getDataResourceName() {
return dataResourceName;
}
public void setDataResourceName(String dataResourceName) {
this.dataResourceName = dataResourceName;
}
public String getDataSourcesSystemName() {
return dataSourcesSystemName;
}
public void setDataSourcesSystemName(String dataSourcesSystemName) {
this.dataSourcesSystemName = dataSourcesSystemName;
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public String getPort() {
return port;
}
public void setPort(String port) {
this.port = port;
}
public String getDatabaseType() {
return databaseType;
}
public void setDatabaseType(String databaseType) {
this.databaseType = databaseType;
}
public String getDatabaseName() {
return databaseName;
}
public void setDatabaseName(String databaseName) {
this.databaseName = databaseName;
}
public Long getInitLinkNum() {
return initLinkNum;
}
public void setInitLinkNum(Long initLinkNum) {
this.initLinkNum = initLinkNum;
}
public Long getMaxLinkNum() {
return maxLinkNum;
}
public void setMaxLinkNum(Long maxLinkNum) {
this.maxLinkNum = maxLinkNum;
}
public Long getMaxWaitTime() {
return maxWaitTime;
}
public void setMaxWaitTime(Long maxWaitTime) {
this.maxWaitTime = maxWaitTime;
}
public Long getMaxWaitTimes() {
return maxWaitTimes;
}
public void setMaxWaitTimes(Long maxWaitTimes) {
this.maxWaitTimes = maxWaitTimes;
}
public String getConnectionParams() {
return connectionParams;
}
public void setConnectionParams(String connectionParams) {
this.connectionParams = connectionParams;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public Source(BaseEntityBuilder<?, ?> b, Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams, String username, String password) {
super(b);
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
this.connectionParams = connectionParams;
this.username = username;
this.password = password;
}
public Source(Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams, String username, String password) {
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
this.connectionParams = connectionParams;
this.username = username;
this.password = password;
}
public Source(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams, String username, String password) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
this.connectionParams = connectionParams;
this.username = username;
this.password = password;
}
/**
* 数据来源表

48
cloud-etl-common/src/main/java/com/muyu/domain/SourceType.java
View File

@ -8,9 +8,9 @@ import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
@Data
@AllArgsConstructor
@NoArgsConstructor
import java.util.Date;
import java.util.Map;
@SuperBuilder
@EqualsAndHashCode(callSuper = true)
@TableName(value ="SourceType",autoResultMap = true) //数据库表相关
@ -18,6 +18,48 @@ public class SourceType extends BaseEntity {
private static final long serialVersionUID = 1L;
//数据源类型ID
private Integer id;
@Override
public String toString() {
return "SourceType{" +
"id=" + id +
", name='" + name + '\'' +
'}';
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public SourceType(BaseEntityBuilder<?, ?> b, Integer id, String name) {
super(b);
this.id = id;
this.name = name;
}
public SourceType(Integer id, String name) {
this.id = id;
this.name = name;
}
public SourceType(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Integer id, String name) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.name = name;
}
//数据源类型名称
private String name;
}

178
cloud-etl-common/src/main/java/com/muyu/domain/Structure.java
View File

@ -9,15 +9,15 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.Map;
/**
* 结构对象 structure
*
* @author Saisai
* @date 2024-04-22
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class Structure extends BaseEntity
{
@ -76,4 +76,176 @@ public class Structure extends BaseEntity
private String dictionaryTable;
@Override
public String toString() {
return "Structure{" +
"id=" + id +
", tableId=" + tableId +
", columnName='" + columnName + '\'' +
", columnRemark='" + columnRemark + '\'' +
", isPrimary='" + isPrimary + '\'' +
", columnType='" + columnType + '\'' +
", javaType='" + javaType + '\'' +
", columnLength='" + columnLength + '\'' +
", columnDecimals='" + columnDecimals + '\'' +
", isNull='" + isNull + '\'' +
", defaultValue='" + defaultValue + '\'' +
", isDictionary='" + isDictionary + '\'' +
", dictionaryTable='" + dictionaryTable + '\'' +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getTableId() {
return tableId;
}
public void setTableId(Long tableId) {
this.tableId = tableId;
}
public String getColumnName() {
return columnName;
}
public void setColumnName(String columnName) {
this.columnName = columnName;
}
public String getColumnRemark() {
return columnRemark;
}
public void setColumnRemark(String columnRemark) {
this.columnRemark = columnRemark;
}
public String getIsPrimary() {
return isPrimary;
}
public void setIsPrimary(String isPrimary) {
this.isPrimary = isPrimary;
}
public String getColumnType() {
return columnType;
}
public void setColumnType(String columnType) {
this.columnType = columnType;
}
public String getJavaType() {
return javaType;
}
public void setJavaType(String javaType) {
this.javaType = javaType;
}
public String getColumnLength() {
return columnLength;
}
public void setColumnLength(String columnLength) {
this.columnLength = columnLength;
}
public String getColumnDecimals() {
return columnDecimals;
}
public void setColumnDecimals(String columnDecimals) {
this.columnDecimals = columnDecimals;
}
public String getIsNull() {
return isNull;
}
public void setIsNull(String isNull) {
this.isNull = isNull;
}
public String getDefaultValue() {
return defaultValue;
}
public void setDefaultValue(String defaultValue) {
this.defaultValue = defaultValue;
}
public String getIsDictionary() {
return isDictionary;
}
public void setIsDictionary(String isDictionary) {
this.isDictionary = isDictionary;
}
public String getDictionaryTable() {
return dictionaryTable;
}
public void setDictionaryTable(String dictionaryTable) {
this.dictionaryTable = dictionaryTable;
}
public Structure(BaseEntityBuilder<?, ?> b, Long id, Long tableId, String columnName, String columnRemark, String isPrimary, String columnType, String javaType, String columnLength, String columnDecimals, String isNull, String defaultValue, String isDictionary, String dictionaryTable) {
super(b);
this.id = id;
this.tableId = tableId;
this.columnName = columnName;
this.columnRemark = columnRemark;
this.isPrimary = isPrimary;
this.columnType = columnType;
this.javaType = javaType;
this.columnLength = columnLength;
this.columnDecimals = columnDecimals;
this.isNull = isNull;
this.defaultValue = defaultValue;
this.isDictionary = isDictionary;
this.dictionaryTable = dictionaryTable;
}
public Structure(Long id, Long tableId, String columnName, String columnRemark, String isPrimary, String columnType, String javaType, String columnLength, String columnDecimals, String isNull, String defaultValue, String isDictionary, String dictionaryTable) {
this.id = id;
this.tableId = tableId;
this.columnName = columnName;
this.columnRemark = columnRemark;
this.isPrimary = isPrimary;
this.columnType = columnType;
this.javaType = javaType;
this.columnLength = columnLength;
this.columnDecimals = columnDecimals;
this.isNull = isNull;
this.defaultValue = defaultValue;
this.isDictionary = isDictionary;
this.dictionaryTable = dictionaryTable;
}
public Structure(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, Long tableId, String columnName, String columnRemark, String isPrimary, String columnType, String javaType, String columnLength, String columnDecimals, String isNull, String defaultValue, String isDictionary, String dictionaryTable) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.tableId = tableId;
this.columnName = columnName;
this.columnRemark = columnRemark;
this.isPrimary = isPrimary;
this.columnType = columnType;
this.javaType = javaType;
this.columnLength = columnLength;
this.columnDecimals = columnDecimals;
this.isNull = isNull;
this.defaultValue = defaultValue;
this.isDictionary = isDictionary;
this.dictionaryTable = dictionaryTable;
}
}

120
cloud-etl-common/src/main/java/com/muyu/domain/TableInfo.java
View File

@ -9,15 +9,14 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.List;
/**
* 库表基础信息对象 table_info
*
* @author Saisai
* @date 2024-04-22
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class TableInfo extends TreeEntity
{
@ -29,6 +28,121 @@ public class TableInfo extends TreeEntity
private Long basicId;
@Override
public String toString() {
return "TableInfo{" +
"id=" + id +
", basicId=" + basicId +
", tableName='" + tableName + '\'' +
", tableRemark='" + tableRemark + '\'' +
", type='" + type + '\'' +
", dataNum=" + dataNum +
", center='" + center + '\'' +
", parentId=" + parentId +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getBasicId() {
return basicId;
}
public void setBasicId(Long basicId) {
this.basicId = basicId;
}
public String getTableName() {
return tableName;
}
public void setTableName(String tableName) {
this.tableName = tableName;
}
public String getTableRemark() {
return tableRemark;
}
public void setTableRemark(String tableRemark) {
this.tableRemark = tableRemark;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public Long getDataNum() {
return dataNum;
}
public void setDataNum(Long dataNum) {
this.dataNum = dataNum;
}
public String getCenter() {
return center;
}
public void setCenter(String center) {
this.center = center;
}
@Override
public Long getParentId() {
return parentId;
}
@Override
public void setParentId(Long parentId) {
this.parentId = parentId;
}
public TableInfo(TreeEntityBuilder<?, ?> b, Long id, Long basicId, String tableName, String tableRemark, String type, Long dataNum, String center, Long parentId) {
super(b);
this.id = id;
this.basicId = basicId;
this.tableName = tableName;
this.tableRemark = tableRemark;
this.type = type;
this.dataNum = dataNum;
this.center = center;
this.parentId = parentId;
}
public TableInfo(Long id, Long basicId, String tableName, String tableRemark, String type, Long dataNum, String center, Long parentId) {
this.id = id;
this.basicId = basicId;
this.tableName = tableName;
this.tableRemark = tableRemark;
this.type = type;
this.dataNum = dataNum;
this.center = center;
this.parentId = parentId;
}
public TableInfo(String parentName, Long parentId, Integer orderNum, String ancestors, List<?> children, Long id, Long basicId, String tableName, String tableRemark, String type, Long dataNum, String center, Long parentId1) {
super(parentName, parentId, orderNum, ancestors, children);
this.id = id;
this.basicId = basicId;
this.tableName = tableName;
this.tableRemark = tableRemark;
this.type = type;
this.dataNum = dataNum;
this.center = center;
this.parentId = parentId1;
}
/** 表名称/数据库 */
@Excel(name = "表名称/数据库")
private String tableName;

62
cloud-etl-common/src/main/java/com/muyu/domain/req/AssetImpowerReq.java
View File

@ -14,9 +14,6 @@ import lombok.experimental.SuperBuilder;
* @Author SaiSai.Liu
* @Date 2024/4/29 14:04
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class AssetImpowerReq {
private static final long serialVersionUID = 1L;
@ -34,6 +31,65 @@ public class AssetImpowerReq {
@Excel(name = "表id")
private Long tableId;
@Override
public String toString() {
return "AssetImpowerReq{" +
"id=" + id +
", tableId=" + tableId +
", basicId=" + basicId +
", deptId=" + deptId +
", userId=" + userId +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getTableId() {
return tableId;
}
public void setTableId(Long tableId) {
this.tableId = tableId;
}
public Long getBasicId() {
return basicId;
}
public void setBasicId(Long basicId) {
this.basicId = basicId;
}
public Long getDeptId() {
return deptId;
}
public void setDeptId(Long deptId) {
this.deptId = deptId;
}
public Long getUserId() {
return userId;
}
public void setUserId(Long userId) {
this.userId = userId;
}
public AssetImpowerReq(Long id, Long tableId, Long basicId, Long deptId, Long userId) {
this.id = id;
this.tableId = tableId;
this.basicId = basicId;
this.deptId = deptId;
this.userId = userId;
}
/**
* 接入id
*/

167
cloud-etl-common/src/main/java/com/muyu/domain/req/SourceReq.java
View File

@ -8,13 +8,12 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.Map;
//连接数据源
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
public class SourceReq extends BaseEntity {
/** 主键 */
@TableId(value = "id", type = IdType.AUTO)
@ -25,6 +24,166 @@ public class SourceReq extends BaseEntity {
*/
private String dataResourceName;
@Override
public String toString() {
return "SourceReq{" +
"id=" + id +
", dataResourceName='" + dataResourceName + '\'' +
", dataSourcesSystemName='" + dataSourcesSystemName + '\'' +
", host='" + host + '\'' +
", port='" + port + '\'' +
", databaseType='" + databaseType + '\'' +
", databaseName='" + databaseName + '\'' +
", initLinkNum=" + initLinkNum +
", maxLinkNum=" + maxLinkNum +
", maxWaitTime=" + maxWaitTime +
", maxWaitTimes=" + maxWaitTimes +
", connectionParams='" + connectionParams + '\'' +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getDataResourceName() {
return dataResourceName;
}
public void setDataResourceName(String dataResourceName) {
this.dataResourceName = dataResourceName;
}
public String getDataSourcesSystemName() {
return dataSourcesSystemName;
}
public void setDataSourcesSystemName(String dataSourcesSystemName) {
this.dataSourcesSystemName = dataSourcesSystemName;
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public String getPort() {
return port;
}
public void setPort(String port) {
this.port = port;
}
public String getDatabaseType() {
return databaseType;
}
public void setDatabaseType(String databaseType) {
this.databaseType = databaseType;
}
public String getDatabaseName() {
return databaseName;
}
public void setDatabaseName(String databaseName) {
this.databaseName = databaseName;
}
public Long getInitLinkNum() {
return initLinkNum;
}
public void setInitLinkNum(Long initLinkNum) {
this.initLinkNum = initLinkNum;
}
public Long getMaxLinkNum() {
return maxLinkNum;
}
public void setMaxLinkNum(Long maxLinkNum) {
this.maxLinkNum = maxLinkNum;
}
public Long getMaxWaitTime() {
return maxWaitTime;
}
public void setMaxWaitTime(Long maxWaitTime) {
this.maxWaitTime = maxWaitTime;
}
public Long getMaxWaitTimes() {
return maxWaitTimes;
}
public void setMaxWaitTimes(Long maxWaitTimes) {
this.maxWaitTimes = maxWaitTimes;
}
public String getConnectionParams() {
return connectionParams;
}
public void setConnectionParams(String connectionParams) {
this.connectionParams = connectionParams;
}
public SourceReq(BaseEntityBuilder<?, ?> b, Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams) {
super(b);
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
this.connectionParams = connectionParams;
}
public SourceReq(Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams) {
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
this.connectionParams = connectionParams;
}
public SourceReq(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
this.connectionParams = connectionParams;
}
/**
* 数据来源表

24
cloud-etl-server/pom.xml
View File

@ -10,6 +10,7 @@
</parent>
<artifactId>cloud-etl-server</artifactId>
<version>1.0.0</version>
<dependencies>
@ -65,11 +66,12 @@
<artifactId>cloud-common-datascope</artifactId>
</dependency>
<!-- MuYu Common Log -->
<!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>-->
<!-- <artifactId>cloud-common-log</artifactId>-->
<!-- </dependency>-->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-log</artifactId>
<version>3.6.3</version>
</dependency>
<!-- 接口模块 -->
<dependency>
@ -77,15 +79,17 @@
<artifactId>cloud-common-api-doc</artifactId>
</dependency>
<!-- &lt;!&ndash; XllJob定时任务 &ndash;&gt;-->
<!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>-->
<!-- <artifactId>cloud-common-xxl</artifactId>-->
<!-- </dependency>-->
<!-- XllJob定时任务 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-xxl</artifactId>
<version>3.6.3</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>-->
<!-- <artifactId>cloud-common-rabbit</artifactId>-->
<!-- <version>1.0.0</version>-->
<!-- </dependency>-->
</dependencies>