修改数据源实体类

Dockerfile

@@ -1,11 +1,18 @@
+# 指定构建镜像的起始镜像
 FROM anolis-registry.cn-zhangjiakou.cr.aliyuncs.com/openanolis/dragonwell:17.0.4.0.4.8-standard-ga-8.6
 
+# 执行一些必须的条件
+# 定义时区参数
 ENV TZ=Asia/Shanghai
 
-RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo '$TZ' > /etc/timezone
+# 执行一些必备的条件
+RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo "$TZ" > /etc/timezone
 
-VOLUME ["/home/logs/cloud-etl"]
+# 挂载工作目录
+VOLUME ["/home/logs"]
 
+# 拷贝执行 jar 包文件
 COPY ./cloud-etl-server/target/cloud-etl.jar /home/app.jar
 
-ENTRYPOINT ["java","-jar"]CMD ["/home/app.jar"]
+# 构建启动命令
+ENTRYPOINT ["java", "-Dfile.encoding=utf-8", "-jar", "/home/app.jar"]

cloud-etl-common/src/main/java/com/muyu/domain/ActionScope.java

@@ -0,0 +1,31 @@
+package com.muyu.domain;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author：qdm
+ * @Package：com.muyu.domain
+ * @Project：cloud-etlw3123123
+ * @name：ActionScope
+ * @Date：2024/8/21 20:53
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ActionScope {
+    /**
+     * 规则作用域
+     */
+    private Integer id;
+    /**
+     * 规则作用域名称
+     */
+    @Schema(name = "规则作用域名称", type = "String", defaultValue = "数据字段", description = "规则作用域名称")
+    private String name;
+}

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

@@ -9,16 +9,16 @@ 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
 {
     private static final long serialVersionUID = 1L;
@@ -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;

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

@@ -7,16 +7,16 @@ 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,14 +100,40 @@ public class AssetImpower extends BaseEntity {
     @Excel(name = "用户id")
     private Long userId;
 
-    public static AssetImpower saveAssetImpower
-            (Long deptId,Long userId,AssetImpower assetImpower){
-        return AssetImpower.builder()
-                .basicId(assetImpower.getBasicId())
-                .tableId(assetImpower.getTableId())
-                .deptId(deptId)
-                .userId(userId)
-                .build();
+    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()
+//                .basicId(assetImpower.getBasicId())
+//                .tableId(assetImpower.getTableId())
+//                .deptId(deptId)
+//                .userId(userId)
+//                .build();
+//    }
+
 }

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

@@ -10,20 +10,30 @@ 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 +42,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;

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

@@ -14,14 +14,110 @@ 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;

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

@@ -13,11 +13,36 @@ 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;
+    }
 }

cloud-etl-common/src/main/java/com/muyu/domain/Rule.java

@@ -0,0 +1,56 @@
+package com.muyu.domain;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+/**
+ * @Author：qdm
+ * @Package：com.muyu.domain
+ * @Project ：cloud-etlw3123123
+ * @name：Rule
+ * @Date：2024/8/21 19:34
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Tag(name = "客户支付单", description = "客户支付单简略信息")
+public class Rule {
+    /**
+     * 规则引擎id
+     */
+    private Integer  id;
+    /**
+     * 规则引擎名称
+     */
+    @Schema(name = "规则名称", type = "String", defaultValue = "基础规则", description = "规则名称")
+    private String  name;
+    /**
+     * 规则类型
+     */
+    @Schema(name = "规则类型", type = "Integer", defaultValue = "1", description = "规则类型")
+    private Integer  type;
+    /**
+     * 规则作用域
+     */
+    @Schema(name = "规则作用域", type = "Integer", defaultValue = "1", description = "规则作用域")
+    private Integer  actionScope;
+    /**
+     * 规则邮编码
+     */
+    @Schema(name = "规则邮编码", type = "String", defaultValue = "123456", description = "规则邮编码")
+    private String  code;
+    /**
+     * 是否激活
+     */
+    @Schema(name = "是否激活", type = "Integer", defaultValue = "1", description = "是否激活")
+    private Integer  flag;
+    /**
+     * 规则状态
+     */
+    @Schema(name = "规则状态", type = "Integer", defaultValue = "1", description = "规则状态")
+    private Integer  status;
+}

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

@@ -3,6 +3,7 @@ package com.muyu.domain;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
+import com.muyu.common.core.annotation.Excel;
 import com.muyu.common.core.web.domain.BaseEntity;
 import lombok.AllArgsConstructor;
 import lombok.Data;
@@ -11,8 +12,8 @@ import lombok.NoArgsConstructor;
 import lombok.experimental.SuperBuilder;
 
 @Data
-@NoArgsConstructor
 @AllArgsConstructor
+@NoArgsConstructor
 @SuperBuilder
 @EqualsAndHashCode(callSuper = true)
 @TableName(value ="source",autoResultMap = true) //数据库表相关
@@ -21,70 +22,54 @@ public class Source extends BaseEntity {
     @TableId(value = "id", type = IdType.AUTO)
     private Long id;
 
-
-    /**
-     *数据接入源
-     */
+    /** 接入源名称 */
+    @Excel(name = "接入源名称")
     private String dataResourceName;
 
-
-    /**
-     * 数据来源表
-     */
+    /** 数据来源系统名称 */
+    @Excel(name = "数据来源系统名称")
     private String dataSourcesSystemName;
 
-    /**
-     * 主机Ip地址
-     */
+    /** 主机ip地址 */
+    @Excel(name = "主机ip地址")
     private String host;
 
-    /**
-     * 端口
-     */
+    /** 端口 */
+    @Excel(name = "端口")
     private String port;
 
-
-    /**
-     * 数据类型
-     */
+    /** 数据接入类型 */
+    @Excel(name = "数据接入类型")
     private String databaseType;
 
-    /**
-     * 数据库名称
-     */
+    /** 数据库名称 */
+    @Excel(name = "数据库名称")
     private String databaseName;
 
-    /**
-     * 初始化连接数量
-     */
+    /** 初始化连接数量 */
+    @Excel(name = "初始化连接数量")
     private Long initLinkNum;
 
-    /**
-     * 多大连接数量
-     */
+    /** 最大连接数量 */
+    @Excel(name = "最大连接数量")
     private Long maxLinkNum;
 
-    /**
-     * 最长等待时间
-     */
+    /** 最大等待时间 */
+    @Excel(name = "最大等待时间")
     private Long maxWaitTime;
 
-    /**
-     * 最多连接数量
-     */
+    /** 最大等待次数 */
+    @Excel(name = "最大等待次数")
     private Long maxWaitTimes;
-    /**
-     * 连接参数
-     */
+
+    @Excel(name ="连接参数")
     private String connectionParams;
 
-    /**
-     * 用户名
-     */
+    @Excel(name ="用户名")
     private String username;
 
-    /**
-     * 密码
-     */
+    @Excel(name ="密码")
     private String password;
+
+
 }

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

@@ -1,5 +1,6 @@
 package com.muyu.domain;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.muyu.common.core.web.domain.BaseEntity;
 import lombok.AllArgsConstructor;
@@ -13,11 +14,20 @@ import lombok.experimental.SuperBuilder;
 @NoArgsConstructor
 @SuperBuilder
 @EqualsAndHashCode(callSuper = true)
-@TableName(value ="SourceType",autoResultMap = true) //数据库表相关
+@TableName(value ="sourcetype",autoResultMap = true) //数据库表相关
 public class SourceType extends BaseEntity {
     private static final long serialVersionUID = 1L;
     //数据源类型ID
     private Integer id;
+
     //数据源类型名称
     private String name;
+    //
+    @TableField(value = "driver_class")
+    private String driverClass;
+
+    //
+    private String prefix;
+
+    private String suffix;
 }

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

@@ -9,16 +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
 {
     private static final long serialVersionUID = 1L;
@@ -76,4 +75,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;
+    }
 }

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

@@ -9,16 +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
 {
     private static final long serialVersionUID = 1L;
@@ -29,6 +27,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;

cloud-etl-common/src/main/java/com/muyu/domain/Type.java

@@ -0,0 +1,30 @@
+package com.muyu.domain;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author：qdm
+ * @Package：com.muyu.domain
+ * @Project：cloud-etlw3123123
+ * @name：Type
+ * @Date：2024/8/21 20:54
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class Type {
+    /**
+     * 类型id
+     */
+    private Integer id;
+    /**
+     * 类型名称
+     */
+    @Schema(name = "类型名称", type = "String", defaultValue = "基础类型", description = "类型名称")
+    private String name;
+}

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

@@ -14,10 +14,7 @@ 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
      */

cloud-etl-common/src/main/java/com/muyu/domain/req/RuleReq.java

@@ -0,0 +1,38 @@
+package com.muyu.domain.req;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author：qdm
+ * @Package：com.muyu.domain.req
+ * @Project：cloud-etlw3123123
+ * @name：RuleReq
+ * @Date：2024/8/21 21:38
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class RuleReq {
+    /**
+     * 名称模糊查询
+     */
+    @Schema(name = "名称模糊查询", type = "String", defaultValue = "基础规则", description = "名称模糊查询")
+    private String  name;
+    /**
+     * 类型精确查询
+     */
+    private Integer type;
+    /**
+     * 是否激活精确查询
+     */
+    private Integer flag;
+    /**、
+     * 状态精确查询
+     */
+    private Integer status;
+}

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

@@ -2,78 +2,232 @@ package com.muyu.domain.req;
 
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.muyu.common.core.annotation.Excel;
 import com.muyu.common.core.web.domain.BaseEntity;
 import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.EqualsAndHashCode;
 import lombok.NoArgsConstructor;
 import lombok.experimental.SuperBuilder;
 
-//连接数据源
+import java.util.Date;
+import java.util.Map;
 
 @Data
 @AllArgsConstructor
 @NoArgsConstructor
 @SuperBuilder
-
+@EqualsAndHashCode(callSuper = true)
+@TableName(value ="source",autoResultMap = true) //数据库表相关
 public class SourceReq extends BaseEntity {
     /** 主键 */
     @TableId(value = "id", type = IdType.AUTO)
     private Long id;
-    /**
-     *
-     *数据接入源
-     */
+
+    /** 接入源名称 */
+    @Excel(name = "接入源名称")
     private String dataResourceName;
 
-
-    /**
-     * 数据来源表
-     */
+    /** 数据来源系统名称 */
+    @Excel(name = "数据来源系统名称")
     private String dataSourcesSystemName;
 
-    /**
-     * 主机Ip地址
-     */
+    /** 主机ip地址 */
+    @Excel(name = "主机ip地址")
     private String host;
 
-    /**
-     * 端口
-     */
+    /** 端口 */
+    @Excel(name = "端口")
     private String port;
 
-
-    /**
-     * 数据类型
-     */
+    /** 数据接入类型 */
+    @Excel(name = "数据接入类型")
     private String databaseType;
 
-    /**
-     * 数据库名称
-     */
+    /** 数据库名称 */
+    @Excel(name = "数据库名称")
     private String databaseName;
 
-    /**
-     * 初始化连接数量
-     */
+    /** 初始化连接数量 */
+    @Excel(name = "初始化连接数量")
     private Long initLinkNum;
 
-    /**
-     * 多大连接数量
-     */
+    /** 最大连接数量 */
+    @Excel(name = "最大连接数量")
     private Long maxLinkNum;
 
-    /**
-     * 最长等待时间
-     */
+    /** 最大等待时间 */
+    @Excel(name = "最大等待时间")
     private Long maxWaitTime;
 
-    /**
-     * 最多连接数量
-     */
+    /** 最大等待次数 */
+    @Excel(name = "最大等待次数")
     private Long maxWaitTimes;
-    /**
-     * 连接参数
-     */
+
+    @Excel(name ="连接参数")
     private String connectionParams;
 
+    @Excel(name ="用户名")
+    private String username;
+
+    @Excel(name ="密码")
+    private String password;
+
+
+    @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 +
+                '}';
+    }
+
+    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 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;
+
+    }
+
+    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;
+    }
+
+    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;
+
+    }
+
+
+
 }

cloud-etl-server/pom.xml

@@ -3,18 +3,26 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
+
     <parent>
         <groupId>com.muyu</groupId>
         <artifactId>cloud-etl</artifactId>
         <version>1.0.0</version>
     </parent>
 
+    <groupId>com.muyu</groupId>
+
     <artifactId>cloud-etl-server</artifactId>
+    <version>1.0.0</version>
 
 
     <dependencies>
 
 
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-core</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>com.muyu</groupId>
@@ -65,11 +73,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,17 +86,60 @@
             <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>-->
 
+
+<!--        <dependency>-->
+<!--            <groupId>com.baomidou</groupId>-->
+<!--            <artifactId>mybatis-plus-boot-starter</artifactId>-->
+<!--            <version>3.5.3.1</version>-->
+<!--        </dependency>-->
+
+<!--        <dependency>-->
+<!--            <groupId>com.baomidou</groupId>-->
+<!--            <artifactId>mybatis-plus-core</artifactId>-->
+<!--            <version>3.5.3</version> &lt;!&ndash; 请根据实际需要选择版本 &ndash;&gt;-->
+<!--        </dependency>-->
+
+
     </dependencies>
 
+
+    <build>
+        <finalName>cloud-etl</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <!-- 加入maven deploy插件，当在deploy时，忽略些model-->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-deploy-plugin</artifactId>
+                <configuration>
+                    <skip>true</skip>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+
 </project>

cloud-etl-server/src/main/java/com/muyu/cloud/etl/MuYuEtlApplication.java

@@ -2,13 +2,16 @@ package com.muyu.cloud.etl;
 
 import com.muyu.common.security.annotation.EnableCustomConfig;
 import com.muyu.common.security.annotation.EnableMyFeignClients;
+import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 
+
 @EnableCustomConfig
 @EnableMyFeignClients
 @SpringBootApplication
+@MapperScan("com.muyu.cloud.etl.mapper")
 public class MuYuEtlApplication {
     public static void main (String[] args) {
         SpringApplication.run(MuYuEtlApplication.class, args);

cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/DictionaryController.java

@@ -1,33 +0,0 @@
-package com.muyu.cloud.etl.controller;
-
-import com.muyu.cloud.etl.service.DictionaryService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.xml.transform.Result;
-
-/**
- * @Author：qdm
- * @Package：com.muyu.cloud.etl.controller
- * @Project：cloud-etlsdadawd
- * @name：DictionaryController
- * @Date：2024/8/21 10:34
- */
-@RestController
-@RequestMapping("/etl")
-public class DictionaryController {
-    @Autowired
-    private DictionaryService dictionaryService;
-    @PostMapping("/open/{id}")
-    public Result open(@PathVariable Long id){
-        return dictionaryService.open(id);
-    }
-
-    @PostMapping("/close/{id}")
-    public Result close(@PathVariable Long id){
-        return dictionaryService.close(id);
-    }
-}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceController.java

@@ -2,15 +2,15 @@ package com.muyu.cloud.etl.controller;
 
 import com.muyu.cloud.etl.service.SourceService;
 import com.muyu.common.core.domain.Result;
+import com.muyu.common.core.utils.poi.ExcelUtil;
 import com.muyu.common.core.web.controller.BaseController;
 import com.muyu.common.core.web.page.TableDataInfo;
-import com.muyu.common.security.annotation.RequiresPermissions;
 import com.muyu.domain.Source;
 import com.muyu.domain.req.SourceReq;
+import jakarta.servlet.ServletException;
+import jakarta.servlet.http.HttpServletResponse;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 
@@ -21,13 +21,77 @@ public class SourceController extends BaseController {
     @Autowired
     private SourceService sourceService;
 
+
     //列表
-    @RequiresPermissions("etl:info:list")
-    @GetMapping("/list")
-    public Result<TableDataInfo<Source>> list(SourceReq sourceReq) {
+    @PostMapping("/list")
+    public Result<TableDataInfo<Source>> list(@RequestBody SourceReq sourceReq) {
         startPage();
         List<Source> list = sourceService.selectSourceList(sourceReq);
         return getDataTable(list);
     }
 
+    /*
+     * 导出
+     */
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, SourceReq sourceReq) {
+        List<Source> list=   sourceService.selectSourceList(sourceReq);
+        ExcelUtil<Source> util = new ExcelUtil<>(Source.class);
+        util.exportExcel(response,list,"基础信息");
+    }
+
+
+    /**
+     * 获取基础信息详细信息
+     */
+    @GetMapping(value = "/{id}")
+    public Result getInfo(@PathVariable("id") Long id) {
+      Source source=  sourceService.getInfo(id);
+      return success(source);
+    }
+
+
+    /**
+     * 新增基础信息
+     */
+    @PostMapping("/insert")
+    public Result add(@RequestBody Source sourceReq) {
+
+        return toAjax(sourceService.insertBasicConfigInfo(sourceReq));
+    }
+
+    //批量删除
+    @DeleteMapping("{ids}")
+    public Integer delete(@PathVariable("ids") String ids) {
+        return sourceService.deleteByIds(ids);
+    }
+
+    /**
+     * 修改
+     */
+    @PostMapping("/update")
+    public Result update(@RequestBody Source sourceReq) {
+
+        return toAjax(sourceService.updataSource(sourceReq));
+    }
+
+
+    /**
+     * 测试连接
+     */
+
+    @PostMapping("/connectionTest")
+    public Result connectionTest(@RequestBody Source source) throws ServletException {
+        return toAjax(sourceService.connectionTest(source));
+    }
+
+
+
+
+
+
+
+
+
+
 }

cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceTypeController.java

@@ -4,7 +4,6 @@ package com.muyu.cloud.etl.controller;
 import com.muyu.cloud.etl.service.SourceTypeService;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.core.web.controller.BaseController;
-import com.muyu.common.security.annotation.RequiresPermissions;
 import com.muyu.domain.SourceType;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -19,8 +18,7 @@ public class SourceTypeController extends BaseController {
     @Autowired
     private SourceTypeService sourceTypeService;
 
-    //查询数据源类型
-    @RequiresPermissions("etl:type:list")
+
     @GetMapping("/findSourceType")
     public Result<List<SourceType>> findSourceType() {
         List<SourceType> sourceTypeList=sourceTypeService.findSourceType();

cloud-etl-server/src/main/java/com/muyu/cloud/etl/mapper/DictionaryMapper.java

@@ -1,20 +0,0 @@
-package com.muyu.cloud.etl.mapper;
-
-import feign.Param;
-import org.apache.ibatis.annotations.Mapper;
-
-import javax.xml.transform.Result;
-
-/**
- * @Author：qdm
- * @Package：com.muyu.cloud.etl.mapper
- * @Project：cloud-etlsdadawd
- * @name：DictionaryMapper
- * @Date：2024/8/21 10:39
- */
-@Mapper
-public interface DictionaryMapper {
-    Result open(@Param("id") Long id);
-
-    Result close(@Param("id") Long id);
-}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/mapper/EtlMapper.java

@@ -15,7 +15,7 @@ import java.util.List;
  * @Date：2024/8/20 20:47
  */
 @Mapper
-public interface EtlMapper {
+public interface EtlMapper{
     List<AssetImpower> list(AssetImpower assetImpower);
 
     Result deleteAssetImpowerByIds(@Param("ids") Long[] ids);

cloud-etl-server/src/main/java/com/muyu/cloud/etl/mapper/SourceMapper.java

@@ -10,4 +10,7 @@ import java.util.List;
 @Mapper
 public interface SourceMapper  extends BaseMapper<Source> {
     List<Source> selectSourceList(SourceReq sourceReq);
+
+    Integer updataSource(Source sourceReq);
+
 }

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/DictionaryService.java

@@ -1,16 +0,0 @@
-package com.muyu.cloud.etl.service;
-
-import javax.xml.transform.Result;
-
-/**
- * @Author：qdm
- * @Package：com.muyu.cloud.etl.service
- * @Project：cloud-etlsdadawd
- * @name：DictionaryService
- * @Date：2024/8/21 10:35
- */
-public interface DictionaryService {
-    Result open(Long id);
-
-    Result close(Long id);
-}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/SourceService.java

@@ -8,4 +8,14 @@ import java.util.List;
 
 public interface SourceService extends IService<Source> {
     List<Source> selectSourceList(SourceReq sourceReq);
+
+    Source getInfo(Long id);
+
+    int insertBasicConfigInfo(Source sourceReq);
+
+    Integer deleteByIds(String ids);
+
+    int updataSource(Source sourceReq);
+
+    int connectionTest(Source source);
 }

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/SourceTypeService.java

@@ -8,6 +8,4 @@ import java.util.List;
 public interface SourceTypeService extends IService<SourceType> {
 
     List<SourceType> findSourceType();
-
-
 }

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/DictionaryServiceImpl.java

@@ -1,32 +0,0 @@
-package com.muyu.cloud.etl.service.impl;
-
-import com.muyu.cloud.etl.mapper.DictionaryMapper;
-import com.muyu.cloud.etl.service.DictionaryService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import javax.xml.transform.Result;
-import java.util.List;
-
-/**
- * @Author：qdm
- * @Package：com.muyu.cloud.etl.service.impl
- * @Project：cloud-etlsdadawd
- * @name：DictionaryServiceImpl
- * @Date：2024/8/21 10:35
- */
-@Service
-public class DictionaryServiceImpl implements DictionaryService {
-    @Autowired
-    private DictionaryMapper dictionaryMapper;
-
-    @Override
-    public Result open(Long id) {
-        return dictionaryMapper.open(id);
-    }
-
-    @Override
-    public Result close(Long id) {
-        return dictionaryMapper.close(id);
-    }
-}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java

@@ -1,5 +1,6 @@
 package com.muyu.cloud.etl.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.cloud.etl.mapper.SourceMapper;
 import com.muyu.cloud.etl.service.SourceService;
@@ -8,6 +9,9 @@ import com.muyu.domain.req.SourceReq;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
 import java.util.List;
 
 @Service
@@ -19,4 +23,55 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
     public List<Source> selectSourceList(SourceReq sourceReq) {
        return sourceMapper.selectSourceList(sourceReq);
     }
+
+    @Override
+    public Source getInfo(Long id) {
+        LambdaQueryWrapper<Source> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(Source::getId, id);
+        return this.sourceMapper.selectOne(lambdaQueryWrapper);
+    }
+
+    //新增
+    @Override
+    public int insertBasicConfigInfo(Source sourceReq) {
+        int insert = sourceMapper.insert(sourceReq);
+        return insert;
+    }
+
+    @Override
+    public Integer deleteByIds(String ids) {
+        LambdaQueryWrapper<Source> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.in(Source::getId, ids);
+        int delete = sourceMapper.delete(lambdaQueryWrapper);
+        return delete;
+    }
+
+    @Override
+    public int updataSource(Source sourceReq) {
+      Integer i=  sourceMapper.updataSource(sourceReq);
+        return i;
+    }
+
+    @Override
+    public int connectionTest(Source source) {
+        String host = source.getHost();
+        String port = source.getPort();
+        String databaseName = source.getDatabaseName();
+        String databaseType = source.getDatabaseType();
+        String url = "jdbc:" + databaseType + "://" + host + ":" + port + "/" + databaseName + "?" + source.getConnectionParams();
+        String user = source.getUsername();
+        String password = source.getPassword();
+        Connection conn = null;
+
+        try {
+            conn = DriverManager.getConnection(url, user, password);
+
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+
+
+        return  1;
+    }
+
 }

cloud-etl-server/src/main/resources/bootstrap.yml

@@ -10,6 +10,7 @@ nacos:
   namespace: cloud-2112
 # Spring
 spring:
+
   application:
     # 应用名称
     name: cloud-etl
@@ -45,3 +46,16 @@ spring:
           # 系统环境Config共享配置
           - application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
 
+          - application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+            # rabbit 配置文件
+          - application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 配置 MyBatis 的日志输出实现类，这里是输出到控制台
+  mapper-locations: classpath:/mapper/*.xml # MyBatis Mapper 文件的位置，这里假设是 XML 形式的 Mapper
+  global-config:
+    db-config:
+      id-type: auto # 主键生成策略，这里设置为自动增长
+      logic-delete-value: 1 # 逻辑删除标记值，例如设置为 1 表示已删除
+      logic-not-delete-value: 0 # 逻辑未删除标记值，例如设置为 0 表示未删除
+    banner: false # 关闭控制台打印的 MyBatis-Plus Banner

cloud-etl-server/src/main/resources/mapper/DictionaryMapper.xml

@@ -1,12 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper
-        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
-        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.muyu.cloud.etl.mapper.DictionaryMapper">
-    <update id="open">
-        update dictionary set status = 1 where id = #{id}
-    </update>
-    <update id="close">
-        update dictionary set status = 2 where id = #{id}
-    </update>
-</mapper>

cloud-etl-server/src/main/resources/mapper/EtlMapper.xml

@@ -4,7 +4,7 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.muyu.cloud.etl.mapper.EtlMapper">
     <sql id="selectAssetDataDictVo">
-        select id, basic_id, dict_name, dict_type, remark, create_by, create_time, update_by, update_time from asset_data_dict
+            select id, basic_id, dict_name, dict_type, remark, create_by, create_time, update_by, update_time from asset_data_dict
     </sql>
     <sql id="list">
         select id, basic_id, dict_name, dict_type, remark, create_by, create_time, update_by, update_time from asset_data_dict

cloud-etl-server/src/main/resources/mapper/SourceMapper.xml

@@ -21,7 +21,27 @@
     <sql id="selectSourceList">
         select id, data_resource_name,username,password, data_sources_system_name, host, port, database_type, database_name, init_link_num, max_link_num, max_wait_time, max_wait_times,connection_params, remark from source
     </sql>
-<!--    <select id="selectSourceList" resultType="com.muyu.domain.Source">-->
+    <update id="updataSource">
+        update source
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="dataResourceName != null">data_resource_name = #{dataResourceName},</if>
+            <if test="dataSourcesSystemName != null">data_sources_system_name = #{dataSourcesSystemName},</if>
+            <if test="host != null">host = #{host},</if>
+            <if test="port != null">port = #{port},</if>
+            <if test="databaseType != null">database_type = #{databaseType},</if>
+            <if test="databaseName != null">database_name = #{databaseName},</if>
+            <if test="username != null">username = #{username},</if>
+            <if test="password != null">password = #{password},</if>
+            <if test="initLinkNum != null">init_link_num = #{initLinkNum},</if>
+            <if test="maxLinkNum != null">max_link_num = #{maxLinkNum},</if>
+            <if test="maxWaitTime != null">max_wait_time = #{maxWaitTime},</if>
+            <if test="maxWaitTimes != null">max_wait_times = #{maxWaitTimes},</if>
+            <if test="connectionParams != null">connection_params = #{connectionParams},</if>
+            <if test="remark != null">remark = #{remark},</if>
+        </trim>
+        where id = #{id}
+    </update>
+    <!--    <select id="selectSourceList" resultType="com.muyu.domain.Source">-->
 <!--        -->
 <!--    </select>-->
 

logs/cloud-etl/info.log

@@ -94,3 +94,400 @@
 11:33:55.452 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
 11:33:55.453 [Druid-ConnectionPool-Create-1932244125] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
 11:33:55.454 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+15:17:02.164 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+15:17:05.037 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+15:17:05.038 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+15:17:05.119 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+15:17:06.027 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+15:17:06.029 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+15:18:27.316 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+15:18:29.968 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+15:18:29.968 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+15:18:30.048 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+15:18:33.181 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+15:18:33.182 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+15:18:33.182 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+15:18:33.255 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+15:18:33.257 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+15:18:33.263 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+15:18:33.263 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+15:18:33.263 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+15:18:33.264 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+16:53:52.848 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:53:55.631 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:53:55.631 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:53:55.716 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:54:05.735 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+16:54:05.736 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+16:54:05.736 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+16:54:05.804 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+16:54:05.807 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+16:54:05.811 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+16:54:05.812 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+16:54:05.812 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+16:54:05.813 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+16:55:49.373 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:55:52.273 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:55:52.273 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:55:52.358 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:56:03.814 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+16:56:03.815 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+16:56:03.815 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+16:56:03.883 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+16:56:03.885 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+16:56:03.891 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+16:56:03.892 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+16:56:03.892 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+16:56:03.893 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:01:50.788 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:01:53.569 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:01:53.570 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:01:53.657 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:02:05.835 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:02:05.836 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+17:02:05.836 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+17:02:05.904 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+17:02:05.907 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+17:02:05.912 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+17:02:05.912 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+17:02:05.912 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+17:02:05.914 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:05:20.380 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:05:23.079 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:05:23.080 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:05:23.161 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:05:33.934 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:05:33.935 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+17:05:33.935 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+17:05:34.004 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+17:05:34.006 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+17:05:34.012 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+17:05:34.012 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+17:05:34.012 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+17:05:34.013 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:06:26.192 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:06:29.039 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:06:29.040 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:06:29.126 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:06:37.510 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:06:37.511 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+17:06:37.511 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+17:06:37.580 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+17:06:37.583 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+17:06:37.588 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+17:06:37.588 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+17:06:37.588 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+17:06:37.589 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:12:21.416 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:12:24.221 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:12:24.221 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:12:24.305 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:12:32.095 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:12:32.096 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+17:12:32.096 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+17:12:32.165 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+17:12:32.167 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+17:12:32.173 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+17:12:32.174 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+17:12:32.174 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+17:12:32.174 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:17:52.953 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:17:55.827 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:17:55.828 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:17:55.910 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:18:06.484 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:18:06.485 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+17:18:06.485 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+17:18:06.552 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+17:18:06.556 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+17:18:06.561 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+17:18:06.561 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+17:18:06.561 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+17:18:06.562 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+19:37:03.323 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+19:37:04.066 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:06.272 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+19:37:06.272 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+19:37:06.345 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+19:37:07.073 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 1 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:07.274 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:10.290 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 2 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:10.600 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:13.612 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 3 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:14.019 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:17.024 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 4 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:17.538 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:20.552 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 5 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:21.154 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:24.162 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 6 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:24.865 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+19:37:27.882 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 7 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
+19:37:27.958 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+19:37:27.963 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+19:59:32.809 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+19:59:35.165 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+19:59:35.166 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+19:59:35.239 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+19:59:56.790 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+19:59:56.793 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+20:00:53.771 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+20:00:55.989 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+20:00:55.989 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+20:00:56.060 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+20:00:59.314 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+20:00:59.315 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+20:00:59.315 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+20:00:59.398 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+20:00:59.404 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+20:00:59.407 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+20:00:59.412 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+20:00:59.412 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+20:00:59.412 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+20:00:59.412 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+20:03:41.058 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+20:03:43.435 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+20:03:43.435 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+20:03:43.512 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+20:03:54.179 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+20:03:54.180 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+20:03:54.181 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+20:03:54.285 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+20:03:54.292 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+20:03:54.294 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+20:03:54.301 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+20:03:54.301 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+20:03:54.301 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+20:03:54.302 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+20:05:54.859 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+20:05:56.983 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+20:05:56.984 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+20:05:57.055 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+20:05:59.710 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+20:05:59.711 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+20:05:59.711 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+20:05:59.797 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+20:06:00.570 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+20:06:04.726 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+20:06:06.977 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@2baf9c62[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+20:06:06.977 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@57202722[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+20:06:07.235 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
+20:06:08.227 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+20:06:08.228 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+20:06:08.228 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+20:06:08.233 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+20:06:08.237 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+20:06:08.238 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+20:06:08.600 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of c7efe9cc-dfbc-44af-87d5-67cf323feb9a
+20:06:08.601 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->c7efe9cc-dfbc-44af-87d5-67cf323feb9a
+20:06:08.602 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+20:06:08.602 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+20:06:08.602 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+20:06:08.603 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Try to connect to server on start up, server: {serverIp = '47.116.184.54', server main port = 8848}
+20:06:08.603 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+20:06:08.766 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Success to connect to server [47.116.184.54:8848] on start up, connectionId = 1724241970687_139.224.212.27_63406
+20:06:08.766 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+20:06:08.766 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$632/0x0000017b81524078
+20:06:08.766 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Notify connected event to listeners.
+20:06:08.766 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+20:06:08.767 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] text registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:8f05:857f:85b2:f98e:707c:9340], preserved.register.source=SPRING_CLOUD}}
+20:06:08.814 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.43.160:10005 register finished
+20:06:09.976 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStarted,56] - Started MuYuEtlApplication in 20.045 seconds (process running for 20.759)
+20:06:09.985 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+20:06:09.986 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+20:06:09.987 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl+DEFAULT_GROUP+text
+20:06:09.996 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
+20:06:09.996 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
+20:06:09.997 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+text
+20:06:09.998 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
+20:06:09.998 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
+20:06:09.998 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+text
+20:06:09.998 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
+20:06:09.998 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
+20:06:10.500 [RMI TCP Connection(2)-172.16.0.8] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+20:38:54.807 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+20:38:57.222 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+20:38:57.222 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+20:38:57.293 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+20:39:00.311 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+20:39:00.312 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+20:39:00.313 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+20:39:00.409 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+20:39:01.316 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+20:39:07.499 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+20:39:09.861 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@3e0e2a80[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+20:39:09.861 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@4d696bac[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+20:39:09.889 [main] INFO  c.x.j.c.util.NetUtil - [isPortUsed,56] - >>>>>>>>>>> xxl-job, port[9999] is in use.
+20:39:09.963 [main] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+20:39:09.964 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+20:39:09.964 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+20:39:09.964 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+20:39:09.980 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+20:39:09.983 [main] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+20:39:09.991 [main] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+20:39:09.991 [main] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+20:39:09.991 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+20:39:09.992 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+20:39:10.180 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+20:39:58.483 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+20:39:58.527 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
+20:39:58.528 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
+20:39:58.528 [SpringApplicationShutdownHook] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+20:39:58.529 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+20:39:58.530 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+20:39:58.530 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+20:39:58.544 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+20:39:58.545 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] text deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+20:39:58.620 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+20:39:58.621 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+20:39:58.621 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+20:39:58.622 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+20:39:58.624 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+20:39:58.624 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->c7efe9cc-dfbc-44af-87d5-67cf323feb9a
+20:39:58.624 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@78a38d9[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 674]
+20:39:58.624 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+20:39:58.624 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@638eba84[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+20:39:58.624 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724241970687_139.224.212.27_63406
+20:39:58.632 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@780e9f6e[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 402]
+20:39:58.632 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->c7efe9cc-dfbc-44af-87d5-67cf323feb9a
+20:39:58.632 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+20:39:58.634 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+20:39:58.634 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+20:39:58.638 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+20:39:58.644 [SpringApplicationShutdownHook] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+20:39:58.661 [SpringApplicationShutdownHook] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+20:39:58.661 [SpringApplicationShutdownHook] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+20:39:58.661 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+20:42:42.803 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+20:42:45.239 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+20:42:45.239 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+20:42:45.314 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+20:42:48.806 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+20:42:48.808 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+20:42:48.808 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+20:42:48.897 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+20:42:49.768 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+20:42:55.783 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+20:42:58.171 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@1290fc6a[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+20:42:58.171 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@6ee7c941[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+20:42:58.473 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
+20:42:59.463 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+20:42:59.464 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+20:42:59.464 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+20:42:59.468 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+20:42:59.473 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+20:42:59.473 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+20:42:59.616 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 7029ce54-e10d-4364-bd06-101eb297d003
+20:42:59.619 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->7029ce54-e10d-4364-bd06-101eb297d003
+20:42:59.619 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+20:42:59.619 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+20:42:59.620 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+20:42:59.620 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Try to connect to server on start up, server: {serverIp = '47.116.184.54', server main port = 8848}
+20:42:59.621 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+20:42:59.769 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Success to connect to server [47.116.184.54:8848] on start up, connectionId = 1724244181676_139.224.212.27_62378
+20:42:59.770 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Notify connected event to listeners.
+20:42:59.770 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+20:42:59.770 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+20:42:59.770 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$632/0x0000021a55523c70
+20:42:59.772 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] text registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:8f05:857f:85b2:f98e:707c:9340], preserved.register.source=SPRING_CLOUD}}
+20:42:59.820 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.43.160:10005 register finished
+20:43:01.014 [main] INFO  c.m.c.e.MuYuEtlApplication - [logStarted,56] - Started MuYuEtlApplication in 23.385 seconds (process running for 24.118)
+20:43:01.026 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+20:43:01.027 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+20:43:01.028 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl+DEFAULT_GROUP+text
+20:43:01.037 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
+20:43:01.037 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
+20:43:01.039 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+text
+20:43:01.039 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
+20:43:01.039 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
+20:43:01.039 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+text
+20:43:01.039 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
+20:43:01.040 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
+20:43:01.397 [RMI TCP Connection(2)-172.16.0.8] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+21:09:14.357 [lettuce-eventExecutorLoop-1-1] INFO  i.l.c.p.ConnectionWatchdog - [log,171] - Reconnecting, last destination was /172.13.1.1:6379
+21:09:21.342 [lettuce-eventExecutorLoop-1-4] INFO  i.l.c.p.ConnectionWatchdog - [log,171] - Reconnecting, last destination was 172.13.1.1/<unresolved>:6379
+21:09:33.746 [lettuce-eventExecutorLoop-1-6] INFO  i.l.c.p.ConnectionWatchdog - [log,171] - Reconnecting, last destination was 172.13.1.1/<unresolved>:6379
+21:09:35.729 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:09:38.728 [lettuce-nioEventLoop-6-8] INFO  i.l.c.p.ReconnectionHandler - [lambda$null$3,174] - Reconnected to 172.13.1.1/<unresolved>:6379
+21:10:07.940 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:10:40.203 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:11:12.443 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:11:44.714 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:12:16.956 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:12:49.167 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:13:21.405 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:13:53.653 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:14:25.875 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:14:58.116 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:15:30.354 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:16:02.604 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:16:34.869 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:17:07.092 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:17:39.293 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:18:11.564 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:18:43.789 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:19:16.083 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:19:48.299 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:20:20.529 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:20:52.780 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:21:24.998 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:21:57.204 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:22:29.424 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:23:01.875 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:23:34.114 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:24:06.368 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:24:38.574 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:25:10.913 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:25:43.195 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:26:15.610 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:26:47.973 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:27:20.369 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:27:52.878 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:28:25.844 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:28:58.044 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:29:30.279 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:30:03.286 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:30:35.544 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
+21:32:11.252 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Read timed out), for url : http://172.13.1.1:20800/api/registry, content=null]
+22:22:12.195 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+22:22:12.434 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
+22:22:12.434 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
+22:22:12.434 [SpringApplicationShutdownHook] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+22:22:12.436 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+22:22:12.437 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+22:22:12.438 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+22:22:12.452 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+22:22:12.453 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] text deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+22:22:12.535 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+22:22:12.536 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+22:22:12.537 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+22:22:12.537 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+22:22:12.537 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->7029ce54-e10d-4364-bd06-101eb297d003
+22:22:12.538 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@48684456[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 1979]
+22:22:12.539 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+22:22:12.539 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@3dcebe53[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+22:22:12.540 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724244181676_139.224.212.27_62378
+22:22:12.548 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@d9f0312[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 1145]
+22:22:12.548 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->7029ce54-e10d-4364-bd06-101eb297d003
+22:22:12.549 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+22:22:12.549 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+22:22:12.550 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+22:22:12.554 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+22:22:12.562 [SpringApplicationShutdownHook] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+22:22:12.581 [SpringApplicationShutdownHook] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+22:22:12.581 [SpringApplicationShutdownHook] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+22:22:12.581 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye