项目初始化

datax-modules/data-metadata-service-parent/data-metadata-service-api/src/main/java/cn/datax/service/data/metadata/api/entity/MetadataChangeRecordEntity.java

@@ -17,7 +17,7 @@ import lombok.experimental.Accessors;
 @Data
 @EqualsAndHashCode(callSuper = true)
 @Accessors(chain = true)
-@TableName("metadata_change_record")
+@TableName(value = "metadata_change_record", autoResultMap = true)
 public class MetadataChangeRecordEntity extends DataScopeBaseEntity {
 
     private static final long serialVersionUID=1L;
@@ -51,4 +51,16 @@ public class MetadataChangeRecordEntity extends DataScopeBaseEntity {
      * 该字段最新的值
      */
     private String fieldNewValue;
+
+    /**
+     * 数据源
+     */
+    private String sourceId;
+    private String sourceName;
+
+    /**
+     * 数据库表
+     */
+    private String tableId;
+    private String tableName;
 }

datax-modules/data-metadata-service-parent/data-metadata-service-api/src/main/java/cn/datax/service/data/metadata/api/vo/MetadataChangeRecordVo.java

@@ -29,4 +29,8 @@ public class MetadataChangeRecordVo implements Serializable {
     private String fieldName;
     private String fieldOldValue;
     private String fieldNewValue;
+    private String sourceId;
+    private String sourceName;
+    private String tableId;
+    private String tableName;
 }

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/controller/MetadataChangeRecordController.java

@@ -72,8 +72,8 @@ public class MetadataChangeRecordController extends BaseController {
     @GetMapping("/page")
     public R getMetadataChangeRecordPage(MetadataChangeRecordQuery metadataChangeRecordQuery) {
         QueryWrapper<MetadataChangeRecordEntity> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq(StrUtil.isNotBlank(metadataChangeRecordQuery.getObjectId()), "object_id", metadataChangeRecordQuery.getObjectId());
-        queryWrapper.like(StrUtil.isNotBlank(metadataChangeRecordQuery.getFieldName()), "field_name", metadataChangeRecordQuery.getFieldName());
+        queryWrapper.eq(StrUtil.isNotBlank(metadataChangeRecordQuery.getObjectId()), "r.object_id", metadataChangeRecordQuery.getObjectId());
+        queryWrapper.like(StrUtil.isNotBlank(metadataChangeRecordQuery.getFieldName()), "r.field_name", metadataChangeRecordQuery.getFieldName());
         IPage<MetadataChangeRecordEntity> page = metadataChangeRecordService.page(new Page<>(metadataChangeRecordQuery.getPageNum(), metadataChangeRecordQuery.getPageSize()), queryWrapper);
         List<MetadataChangeRecordVo> collect = page.getRecords().stream().map(metadataChangeRecordMapper::toVO).collect(Collectors.toList());
         JsonPage<MetadataChangeRecordVo> jsonPage = new JsonPage<>(page.getCurrent(), page.getSize(), page.getTotal(), collect);

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/dao/MetadataChangeRecordDao.java

@@ -2,7 +2,13 @@ package cn.datax.service.data.metadata.dao;
 
 import cn.datax.common.base.BaseDao;
 import cn.datax.service.data.metadata.api.entity.MetadataChangeRecordEntity;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.io.Serializable;
 
 /**
  * <p>
@@ -15,4 +21,9 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface MetadataChangeRecordDao extends BaseDao<MetadataChangeRecordEntity> {
 
+    @Override
+    MetadataChangeRecordEntity selectById(Serializable id);
+
+    @Override
+    <E extends IPage<MetadataChangeRecordEntity>> E selectPage(E page, @Param(Constants.WRAPPER) Wrapper<MetadataChangeRecordEntity> queryWrapper);
 }

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/resources/mapper/MetadataChangeRecordMapper.xml

@@ -18,6 +18,10 @@
         <result column="field_name" property="fieldName" />
         <result column="field_old_value" property="fieldOldValue" />
         <result column="field_new_value" property="fieldNewValue" />
+        <result column="source_id" property="sourceId" />
+        <result column="source_name" property="sourceName" />
+        <result column="table_id" property="tableId" />
+        <result column="table_name" property="tableName" />
     </resultMap>
 
     <!-- 通用查询结果列 -->
@@ -33,4 +37,36 @@
         version, object_type, object_id, field_name, field_old_value, field_new_value
     </sql>
 
+    <sql id="Record_Column_List">
+        ${alias}.id,
+        ${alias}.status,
+        ${alias}.create_by,
+        ${alias}.create_time,
+        ${alias}.create_dept,
+        ${alias}.update_by,
+        ${alias}.update_time,
+        ${alias}.remark,
+        ${alias}.version, ${alias}.object_type, ${alias}.object_id, ${alias}.field_name, ${alias}.field_old_value, ${alias}.field_new_value
+    </sql>
+
+    <select id="selectById" resultMap="BaseResultMap">
+        SELECT c.source_id, s.source_name, c.table_id, t.table_name
+        <include refid="Record_Column_List"><property name="alias" value="r"/></include>
+        FROM metadata_change_record r
+        LEFT JOIN metadata_column c ON c.id = r.object_id
+        LEFT JOIN metadata_source s ON s.id = c.source_id
+        LEFT JOIN metadata_table t ON t.id = c.table_id
+        WHERE 1 = 1 AND r.id = #{id}
+    </select>
+
+    <select id="selectPage" resultMap="BaseResultMap">
+        SELECT c.source_id, s.source_name, c.table_id, t.table_name
+        <include refid="Record_Column_List"><property name="alias" value="r"/></include>
+        FROM metadata_change_record r
+        LEFT JOIN metadata_column c ON c.id = r.object_id
+        LEFT JOIN metadata_source s ON s.id = c.source_id
+        LEFT JOIN metadata_table t ON t.id = c.table_id
+        ${ew.customSqlSegment}
+    </select>
+
 </mapper>

datax-ui/src/views/market/apimask/ApiMaskAdd.vue

@@ -100,7 +100,7 @@
 
 <script>
 import { addApiMask } from '@/api/market/apimask'
-import { listDataApi } from '@/api/market/dataapi'
+import { listDataApi, getDataApi } from '@/api/market/dataapi'
 
 export default {
   name: 'ApiMaskAdd',
@@ -213,9 +213,11 @@ export default {
       })
     },
     apiSelectChanged(val) {
-      this.resParamList = this.apiOptions.find(function(item) {
-        return item.id === val
-      }).resParams
+      getDataApi(val).then(response => {
+        if (response.success) {
+          this.resParamList = response.data.resParams
+        }
+      })
     },
     fieldRule(fieldName) {
       this.cipher.open = true

datax-ui/src/views/metadata/changerecord/ChangeRecordList.vue

@@ -176,6 +176,8 @@ export default {
       multiple: true,
       // 表格头
       tableColumns: [
+        { prop: 'sourceName', label: '数据源', show: true },
+        { prop: 'tableName', label: '数据库表', show: true },
         { prop: 'fieldName', label: '变更字段', show: true, formatter: this.fieldNameFormatter },
         { prop: 'fieldOldValue', label: '原来的值', show: true },
         { prop: 'fieldNewValue', label: '最新的值', show: true },