项目初始化

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/config/RabbitMqListenerConfig.java

@@ -25,7 +25,7 @@ public class RabbitMqListenerConfig {
     private ModelDao modelDao;
 
     /**
-     * 消费工作流 业务编码 6011
+     * 消费工作流 业务编码 5011
      * @param map
      * @param channel
      * @param message
@@ -33,7 +33,7 @@ public class RabbitMqListenerConfig {
      * @throws Exception
      */
     @RabbitListener(bindings = @QueueBinding(exchange = @Exchange(name = RabbitMqConstant.TOPIC_EXCHANGE_WORKFLOW, type = "topic", durable = "true", autoDelete = "false"),
-            key = { RabbitMqConstant.TOPIC_WORKFLOW_KEY + "6011" },
+            key = { RabbitMqConstant.TOPIC_WORKFLOW_KEY + "5011" },
             value = @Queue(value = RabbitMqConstant.TOPIC_WORKFLOW_QUEUE, durable = "true", exclusive = "false", autoDelete = "false")))
     public void fanoutQueueRelease(Map map, Channel channel, Message message) throws Exception {
         try {

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/service/impl/ModelServiceImpl.java

@@ -70,7 +70,7 @@ public class ModelServiceImpl extends BaseServiceImpl<ModelDao, ModelEntity> imp
     private static String BIND_GB_CODE = "gb_code";
     private static String BIND_GB_NAME = "gb_name";
 
-    private static String DEFAULT_BUSINESS_CODE = "6011";
+    private static String DEFAULT_BUSINESS_CODE = "5011";
 
     @Override
     @Transactional(rollbackFor = Exception.class)

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/async/AsyncTask.java

@@ -85,7 +85,7 @@ public class AsyncTask {
                 });
             }
         }
-        dataSource.setSourceSync(Integer.valueOf(DataConstant.TrueOrFalse.TRUE.getKey()));
+        dataSource.setIsSync(DataConstant.TrueOrFalse.TRUE.getKey());
         metadataSourceDao.updateById(dataSource);
         log.info("异步任务执行完成！耗时{}秒", (System.currentTimeMillis() - start  / 1000));
     }

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/dto/CheckRuleDto.java

+package cn.datax.service.data.quality.api.dto;
+
+import cn.datax.common.validate.ValidationGroups;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * <p>
+ * 核查规则信息表 实体DTO
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@ApiModel(value = "核查规则信息表Model")
+@Data
+public class CheckRuleDto implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    @ApiModelProperty(value = "主键ID")
+    @NotBlank(message = "主键ID不能为空", groups = {ValidationGroups.Update.class})
+    private String id;
+    @ApiModelProperty(value = "规则名称")
+    private String ruleName;
+    @ApiModelProperty(value = "规则类型")
+    private String ruleTypeId;
+    @ApiModelProperty(value = "规则级别（3高、2中、1低）")
+    private String ruleLevel;
+    @ApiModelProperty(value = "数据源主键")
+    private String ruleSourceId;
+    @ApiModelProperty(value = "数据源")
+    private String ruleSource;
+    @ApiModelProperty(value = "数据表主键")
+    private String ruleTableId;
+    @ApiModelProperty(value = "数据表")
+    private String ruleTable;
+    @ApiModelProperty(value = "字段主键")
+    private String ruleColumnId;
+    @ApiModelProperty(value = "字段")
+    private String ruleColumn;
+    @ApiModelProperty(value = "核查脚本")
+    private String ruleSql;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/entity/CheckReportEntity.java

+package cn.datax.service.data.quality.api.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 核查报告信息表
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+@Accessors(chain = true)
+@TableName("quality_check_report")
+public class CheckReportEntity implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private String id;
+
+    /**
+     * 核查规则主键
+     */
+    private String checkRuleId;
+
+    /**
+     * 核查时间
+     */
+    private LocalDateTime checkDate;
+
+    /**
+     * 核查结果
+     */
+    private String checkResult;
+
+    /**
+     * 核查数量
+     */
+    private Integer checkTotalCount;
+
+    /**
+     * 报错数量
+     */
+    private Integer checkErrorCount;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/entity/CheckRuleEntity.java

+package cn.datax.service.data.quality.api.entity;
+
+import cn.datax.common.base.DataScopeBaseEntity;
+import com.baomidou.mybatisplus.annotation.TableName;
+import cn.datax.common.base.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 核查规则信息表
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("quality_check_rule")
+public class CheckRuleEntity extends DataScopeBaseEntity {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 规则名称
+     */
+    private String ruleName;
+
+    /**
+     * 规则类型
+     */
+    private String ruleTypeId;
+
+    /**
+     * 规则级别（3高、2中、1低）
+     */
+    private String ruleLevel;
+
+    /**
+     * 数据源主键
+     */
+    private String ruleSourceId;
+
+    /**
+     * 数据源
+     */
+    private String ruleSource;
+
+    /**
+     * 数据表主键
+     */
+    private String ruleTableId;
+
+    /**
+     * 数据表
+     */
+    private String ruleTable;
+
+    /**
+     * 字段主键
+     */
+    private String ruleColumnId;
+
+    /**
+     * 字段
+     */
+    private String ruleColumn;
+
+    /**
+     * 核查脚本
+     */
+    private String ruleSql;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/entity/RuleTypeEntity.java

+package cn.datax.service.data.quality.api.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * <p>
+ * 规则类型信息表
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+@Accessors(chain = true)
+@TableName("quality_rule_type")
+public class RuleTypeEntity implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private String id;
+
+    /**
+     * 类型名称
+     */
+    private String name;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/query/CheckReportQuery.java

+package cn.datax.service.data.quality.api.query;
+
+import cn.datax.common.base.BaseQueryParams;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 核查报告信息表 查询实体
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class CheckReportQuery extends BaseQueryParams {
+
+    private static final long serialVersionUID=1L;
+
+    private String checkRuleId;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/query/CheckRuleQuery.java

+package cn.datax.service.data.quality.api.query;
+
+import cn.datax.common.base.BaseQueryParams;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 核查规则信息表 查询实体
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class CheckRuleQuery extends BaseQueryParams {
+
+    private static final long serialVersionUID=1L;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/query/RuleTypeQuery.java

+package cn.datax.service.data.quality.api.query;
+
+import cn.datax.common.base.BaseQueryParams;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 规则类型信息表 查询实体
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RuleTypeQuery extends BaseQueryParams {
+
+    private static final long serialVersionUID=1L;
+
+    private String name;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/vo/CheckReportVo.java

+package cn.datax.service.data.quality.api.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 核查报告信息表 实体VO
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+public class CheckReportVo implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    private String id;
+    private String checkRuleId;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private LocalDateTime checkDate;
+    private String checkResult;
+    private Integer checkTotalCount;
+    private Integer checkErrorCount;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/vo/CheckRuleVo.java

+package cn.datax.service.data.quality.api.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 核查规则信息表 实体VO
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+public class CheckRuleVo implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    private String id;
+    private String status;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private LocalDateTime createTime;
+    private String ruleName;
+    private String ruleTypeId;
+    private String ruleLevel;
+    private String ruleSourceId;
+    private String ruleSource;
+    private String ruleTableId;
+    private String ruleTable;
+    private String ruleColumnId;
+    private String ruleColumn;
+    private String ruleSql;
+}

datax-modules/data-quality-service-parent/data-quality-service-api/src/main/java/cn/datax/service/data/quality/api/vo/RuleTypeVo.java

+package cn.datax.service.data.quality.api.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * <p>
+ * 规则类型信息表 实体VO
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Data
+public class RuleTypeVo implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    private String id;
+    private String name;
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/controller/CheckReportController.java

+package cn.datax.service.data.quality.controller;
+
+import cn.datax.common.core.JsonPage;
+import cn.datax.common.core.R;
+import cn.datax.service.data.quality.api.entity.CheckReportEntity;
+import cn.datax.service.data.quality.api.vo.CheckReportVo;
+import cn.datax.service.data.quality.api.query.CheckReportQuery;
+import cn.datax.service.data.quality.mapstruct.CheckReportMapper;
+import cn.datax.service.data.quality.service.CheckReportService;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import cn.datax.common.base.BaseController;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * <p>
+ * 核查报告信息表 前端控制器
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Api(tags = {"核查报告信息表"})
+@RestController
+@RequestMapping("/checkReports")
+public class CheckReportController extends BaseController {
+
+    @Autowired
+    private CheckReportService checkReportService;
+
+    @Autowired
+    private CheckReportMapper checkReportMapper;
+
+    /**
+     * 通过ID查询信息
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息")
+    @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path")
+    @GetMapping("/{id}")
+    public R getCheckReportById(@PathVariable String id) {
+        CheckReportEntity checkReportEntity = checkReportService.getCheckReportById(id);
+        return R.ok().setData(checkReportMapper.toVO(checkReportEntity));
+    }
+
+    /**
+     * 分页查询信息
+     *
+     * @param checkReportQuery
+     * @return
+     */
+    @ApiOperation(value = "分页查询", notes = "")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "checkReportQuery", value = "查询实体checkReportQuery", required = true, dataTypeClass = CheckReportQuery.class)
+    })
+    @GetMapping("/page")
+    public R getCheckReportPage(CheckReportQuery checkReportQuery) {
+        QueryWrapper<CheckReportEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq(StrUtil.isNotBlank(checkReportQuery.getCheckRuleId()), "check_rule_id", checkReportQuery.getCheckRuleId());
+        IPage<CheckReportEntity> page = checkReportService.page(new Page<>(checkReportQuery.getPageNum(), checkReportQuery.getPageSize()), queryWrapper);
+        List<CheckReportVo> collect = page.getRecords().stream().map(checkReportMapper::toVO).collect(Collectors.toList());
+        JsonPage<CheckReportVo> jsonPage = new JsonPage<>(page.getCurrent(), page.getSize(), page.getTotal(), collect);
+        return R.ok().setData(jsonPage);
+    }
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/controller/CheckRuleController.java

+package cn.datax.service.data.quality.controller;
+
+import cn.datax.common.core.JsonPage;
+import cn.datax.common.core.R;
+import cn.datax.common.validate.ValidationGroups;
+import cn.datax.service.data.quality.api.dto.CheckRuleDto;
+import cn.datax.service.data.quality.api.entity.CheckRuleEntity;
+import cn.datax.service.data.quality.api.vo.CheckRuleVo;
+import cn.datax.service.data.quality.api.query.CheckRuleQuery;
+import cn.datax.service.data.quality.mapstruct.CheckRuleMapper;
+import cn.datax.service.data.quality.service.CheckRuleService;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import cn.datax.common.base.BaseController;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * <p>
+ * 核查规则信息表 前端控制器
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Api(tags = {"核查规则信息表"})
+@RestController
+@RequestMapping("/checkRules")
+public class CheckRuleController extends BaseController {
+
+    @Autowired
+    private CheckRuleService checkRuleService;
+
+    @Autowired
+    private CheckRuleMapper checkRuleMapper;
+
+    /**
+     * 通过ID查询信息
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息")
+    @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path")
+    @GetMapping("/{id}")
+    public R getCheckRuleById(@PathVariable String id) {
+        CheckRuleEntity checkRuleEntity = checkRuleService.getCheckRuleById(id);
+        return R.ok().setData(checkRuleMapper.toVO(checkRuleEntity));
+    }
+
+    /**
+     * 分页查询信息
+     *
+     * @param checkRuleQuery
+     * @return
+     */
+    @ApiOperation(value = "分页查询", notes = "")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "checkRuleQuery", value = "查询实体checkRuleQuery", required = true, dataTypeClass = CheckRuleQuery.class)
+    })
+    @GetMapping("/page")
+    public R getCheckRulePage(CheckRuleQuery checkRuleQuery) {
+        QueryWrapper<CheckRuleEntity> queryWrapper = new QueryWrapper<>();
+        IPage<CheckRuleEntity> page = checkRuleService.page(new Page<>(checkRuleQuery.getPageNum(), checkRuleQuery.getPageSize()), queryWrapper);
+        List<CheckRuleVo> collect = page.getRecords().stream().map(checkRuleMapper::toVO).collect(Collectors.toList());
+        JsonPage<CheckRuleVo> jsonPage = new JsonPage<>(page.getCurrent(), page.getSize(), page.getTotal(), collect);
+        return R.ok().setData(jsonPage);
+    }
+
+    /**
+     * 添加
+     * @param checkRule
+     * @return
+     */
+    @ApiOperation(value = "添加信息", notes = "根据checkRule对象添加信息")
+    @ApiImplicitParam(name = "checkRule", value = "详细实体checkRule", required = true, dataType = "CheckRuleDto")
+    @PostMapping()
+    public R saveCheckRule(@RequestBody @Validated({ValidationGroups.Insert.class}) CheckRuleDto checkRule) {
+        CheckRuleEntity checkRuleEntity = checkRuleService.saveCheckRule(checkRule);
+        return R.ok().setData(checkRuleMapper.toVO(checkRuleEntity));
+    }
+
+    /**
+     * 修改
+     * @param checkRule
+     * @return
+     */
+    @ApiOperation(value = "修改信息", notes = "根据url的id来指定修改对象，并根据传过来的信息来修改详细信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path"),
+            @ApiImplicitParam(name = "checkRule", value = "详细实体checkRule", required = true, dataType = "CheckRuleDto")
+    })
+    @PutMapping("/{id}")
+    public R updateCheckRule(@PathVariable String id, @RequestBody @Validated({ValidationGroups.Update.class}) CheckRuleDto checkRule) {
+        CheckRuleEntity checkRuleEntity = checkRuleService.updateCheckRule(checkRule);
+        return R.ok().setData(checkRuleMapper.toVO(checkRuleEntity));
+    }
+
+    /**
+     * 删除
+     * @param id
+     * @return
+     */
+    @ApiOperation(value = "删除", notes = "根据url的id来指定删除对象")
+    @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path")
+    @DeleteMapping("/{id}")
+    public R deleteCheckRuleById(@PathVariable String id) {
+        checkRuleService.deleteCheckRuleById(id);
+        return R.ok();
+    }
+
+    /**
+     * 批量删除
+     * @param ids
+     * @return
+     */
+    @ApiOperation(value = "批量删除角色", notes = "根据url的ids来批量删除对象")
+    @ApiImplicitParam(name = "ids", value = "ID集合", required = true, dataType = "List", paramType = "path")
+    @DeleteMapping("/batch/{ids}")
+    public R deleteCheckRuleBatch(@PathVariable List<String> ids) {
+        checkRuleService.deleteCheckRuleBatch(ids);
+        return R.ok();
+    }
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/controller/RuleTypeController.java

+package cn.datax.service.data.quality.controller;
+
+import cn.datax.common.core.JsonPage;
+import cn.datax.common.core.R;
+import cn.datax.service.data.quality.api.entity.RuleTypeEntity;
+import cn.datax.service.data.quality.api.vo.RuleTypeVo;
+import cn.datax.service.data.quality.api.query.RuleTypeQuery;
+import cn.datax.service.data.quality.mapstruct.RuleTypeMapper;
+import cn.datax.service.data.quality.service.RuleTypeService;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import cn.datax.common.base.BaseController;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * <p>
+ * 规则类型信息表 前端控制器
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Api(tags = {"规则类型信息表"})
+@RestController
+@RequestMapping("/ruleTypes")
+public class RuleTypeController extends BaseController {
+
+    @Autowired
+    private RuleTypeService ruleTypeService;
+
+    @Autowired
+    private RuleTypeMapper ruleTypeMapper;
+
+    /**
+     * 通过ID查询信息
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息")
+    @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path")
+    @GetMapping("/{id}")
+    public R getRuleTypeById(@PathVariable String id) {
+        RuleTypeEntity ruleTypeEntity = ruleTypeService.getRuleTypeById(id);
+        return R.ok().setData(ruleTypeMapper.toVO(ruleTypeEntity));
+    }
+
+    @ApiOperation(value = "获取列表", notes = "")
+    @GetMapping("/list")
+    public R getVisualDataSetList() {
+        List<RuleTypeEntity> list = ruleTypeService.list(Wrappers.emptyWrapper());
+        List<RuleTypeVo> collect = list.stream().map(ruleTypeMapper::toVO).collect(Collectors.toList());
+        return R.ok().setData(collect);
+    }
+
+    /**
+     * 分页查询信息
+     *
+     * @param ruleTypeQuery
+     * @return
+     */
+    @ApiOperation(value = "分页查询", notes = "")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "ruleTypeQuery", value = "查询实体ruleTypeQuery", required = true, dataTypeClass = RuleTypeQuery.class)
+    })
+    @GetMapping("/page")
+    public R getRuleTypePage(RuleTypeQuery ruleTypeQuery) {
+        QueryWrapper<RuleTypeEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.like(StrUtil.isNotBlank(ruleTypeQuery.getName()), "name", ruleTypeQuery.getName());
+        IPage<RuleTypeEntity> page = ruleTypeService.page(new Page<>(ruleTypeQuery.getPageNum(), ruleTypeQuery.getPageSize()), queryWrapper);
+        List<RuleTypeVo> collect = page.getRecords().stream().map(ruleTypeMapper::toVO).collect(Collectors.toList());
+        JsonPage<RuleTypeVo> jsonPage = new JsonPage<>(page.getCurrent(), page.getSize(), page.getTotal(), collect);
+        return R.ok().setData(jsonPage);
+    }
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/dao/CheckReportDao.java

+package cn.datax.service.data.quality.dao;
+
+import cn.datax.common.base.BaseDao;
+import cn.datax.service.data.quality.api.entity.CheckReportEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 核查报告信息表 Mapper 接口
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Mapper
+public interface CheckReportDao extends BaseDao<CheckReportEntity> {
+
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/dao/CheckRuleDao.java

+package cn.datax.service.data.quality.dao;
+
+import cn.datax.common.base.BaseDao;
+import cn.datax.service.data.quality.api.entity.CheckRuleEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 核查规则信息表 Mapper 接口
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Mapper
+public interface CheckRuleDao extends BaseDao<CheckRuleEntity> {
+
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/dao/RuleTypeDao.java

+package cn.datax.service.data.quality.dao;
+
+import cn.datax.common.base.BaseDao;
+import cn.datax.service.data.quality.api.entity.RuleTypeEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 规则类型信息表 Mapper 接口
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Mapper
+public interface RuleTypeDao extends BaseDao<RuleTypeEntity> {
+
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/mapstruct/CheckReportMapper.java

+package cn.datax.service.data.quality.mapstruct;
+
+import cn.datax.service.data.quality.api.entity.CheckReportEntity;
+import cn.datax.service.data.quality.api.vo.CheckReportVo;
+import org.mapstruct.Mapper;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 核查报告信息表 Mapper 实体映射
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Mapper(componentModel = "spring")
+public interface CheckReportMapper {
+
+    /**
+     * 将源对象转换为VO对象
+     * @param e
+     * @return D
+     */
+    CheckReportVo toVO(CheckReportEntity e);
+
+    /**
+     * 将源对象集合转换为VO对象集合
+     * @param es
+     * @return List<D>
+     */
+    List<CheckReportVo> toVO(List<CheckReportEntity> es);
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/mapstruct/CheckRuleMapper.java

+package cn.datax.service.data.quality.mapstruct;
+
+import cn.datax.common.mapstruct.EntityMapper;
+import cn.datax.service.data.quality.api.dto.CheckRuleDto;
+import cn.datax.service.data.quality.api.entity.CheckRuleEntity;
+import cn.datax.service.data.quality.api.vo.CheckRuleVo;
+import org.mapstruct.Mapper;
+
+/**
+ * <p>
+ * 核查规则信息表 Mapper 实体映射
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Mapper(componentModel = "spring")
+public interface CheckRuleMapper extends EntityMapper<CheckRuleDto, CheckRuleEntity, CheckRuleVo> {
+
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/mapstruct/RuleTypeMapper.java

+package cn.datax.service.data.quality.mapstruct;
+
+import cn.datax.service.data.quality.api.entity.RuleTypeEntity;
+import cn.datax.service.data.quality.api.vo.RuleTypeVo;
+import org.mapstruct.Mapper;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 规则类型信息表 Mapper 实体映射
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Mapper(componentModel = "spring")
+public interface RuleTypeMapper {
+
+
+    /**
+     * 将源对象转换为VO对象
+     * @param e
+     * @return D
+     */
+    RuleTypeVo toVO(RuleTypeEntity e);
+
+    /**
+     * 将源对象集合转换为VO对象集合
+     * @param es
+     * @return List<D>
+     */
+    List<RuleTypeVo> toVO(List<RuleTypeEntity> es);
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/service/CheckReportService.java

+package cn.datax.service.data.quality.service;
+
+import cn.datax.service.data.quality.api.entity.CheckReportEntity;
+import cn.datax.common.base.BaseService;
+
+/**
+ * <p>
+ * 核查报告信息表 服务类
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+public interface CheckReportService extends BaseService<CheckReportEntity> {
+
+    CheckReportEntity getCheckReportById(String id);
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/service/CheckRuleService.java

+package cn.datax.service.data.quality.service;
+
+import cn.datax.service.data.quality.api.entity.CheckRuleEntity;
+import cn.datax.service.data.quality.api.dto.CheckRuleDto;
+import cn.datax.common.base.BaseService;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 核查规则信息表 服务类
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+public interface CheckRuleService extends BaseService<CheckRuleEntity> {
+
+    CheckRuleEntity saveCheckRule(CheckRuleDto checkRule);
+
+    CheckRuleEntity updateCheckRule(CheckRuleDto checkRule);
+
+    CheckRuleEntity getCheckRuleById(String id);
+
+    void deleteCheckRuleById(String id);
+
+    void deleteCheckRuleBatch(List<String> ids);
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/service/RuleTypeService.java

+package cn.datax.service.data.quality.service;
+
+import cn.datax.service.data.quality.api.entity.RuleTypeEntity;
+import cn.datax.common.base.BaseService;
+
+/**
+ * <p>
+ * 规则类型信息表 服务类
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+public interface RuleTypeService extends BaseService<RuleTypeEntity> {
+
+    RuleTypeEntity getRuleTypeById(String id);
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/service/impl/CheckReportServiceImpl.java

+package cn.datax.service.data.quality.service.impl;
+
+import cn.datax.service.data.quality.api.entity.CheckReportEntity;
+import cn.datax.service.data.quality.service.CheckReportService;
+import cn.datax.service.data.quality.mapstruct.CheckReportMapper;
+import cn.datax.service.data.quality.dao.CheckReportDao;
+import cn.datax.common.base.BaseServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * <p>
+ * 核查报告信息表 服务实现类
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public class CheckReportServiceImpl extends BaseServiceImpl<CheckReportDao, CheckReportEntity> implements CheckReportService {
+
+    @Autowired
+    private CheckReportDao checkReportDao;
+
+    @Autowired
+    private CheckReportMapper checkReportMapper;
+
+    @Override
+    public CheckReportEntity getCheckReportById(String id) {
+        CheckReportEntity checkReportEntity = super.getById(id);
+        return checkReportEntity;
+    }
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/service/impl/CheckRuleServiceImpl.java

+package cn.datax.service.data.quality.service.impl;
+
+import cn.datax.service.data.quality.api.entity.CheckRuleEntity;
+import cn.datax.service.data.quality.api.dto.CheckRuleDto;
+import cn.datax.service.data.quality.service.CheckRuleService;
+import cn.datax.service.data.quality.mapstruct.CheckRuleMapper;
+import cn.datax.service.data.quality.dao.CheckRuleDao;
+import cn.datax.common.base.BaseServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 核查规则信息表 服务实现类
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public class CheckRuleServiceImpl extends BaseServiceImpl<CheckRuleDao, CheckRuleEntity> implements CheckRuleService {
+
+    @Autowired
+    private CheckRuleDao checkRuleDao;
+
+    @Autowired
+    private CheckRuleMapper checkRuleMapper;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public CheckRuleEntity saveCheckRule(CheckRuleDto checkRuleDto) {
+        CheckRuleEntity checkRule = checkRuleMapper.toEntity(checkRuleDto);
+        checkRuleDao.insert(checkRule);
+        return checkRule;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public CheckRuleEntity updateCheckRule(CheckRuleDto checkRuleDto) {
+        CheckRuleEntity checkRule = checkRuleMapper.toEntity(checkRuleDto);
+        checkRuleDao.updateById(checkRule);
+        return checkRule;
+    }
+
+    @Override
+    public CheckRuleEntity getCheckRuleById(String id) {
+        CheckRuleEntity checkRuleEntity = super.getById(id);
+        return checkRuleEntity;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteCheckRuleById(String id) {
+        checkRuleDao.deleteById(id);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteCheckRuleBatch(List<String> ids) {
+        checkRuleDao.deleteBatchIds(ids);
+    }
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/java/cn/datax/service/data/quality/service/impl/RuleTypeServiceImpl.java

+package cn.datax.service.data.quality.service.impl;
+
+import cn.datax.service.data.quality.api.entity.RuleTypeEntity;
+import cn.datax.service.data.quality.service.RuleTypeService;
+import cn.datax.service.data.quality.mapstruct.RuleTypeMapper;
+import cn.datax.service.data.quality.dao.RuleTypeDao;
+import cn.datax.common.base.BaseServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * <p>
+ * 规则类型信息表 服务实现类
+ * </p>
+ *
+ * @author yuwei
+ * @since 2020-09-27
+ */
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public class RuleTypeServiceImpl extends BaseServiceImpl<RuleTypeDao, RuleTypeEntity> implements RuleTypeService {
+
+    @Autowired
+    private RuleTypeDao ruleTypeDao;
+
+    @Autowired
+    private RuleTypeMapper ruleTypeMapper;
+
+    @Override
+    public RuleTypeEntity getRuleTypeById(String id) {
+        RuleTypeEntity ruleTypeEntity = super.getById(id);
+        return ruleTypeEntity;
+    }
+}

datax-modules/data-quality-service-parent/data-quality-service/src/main/resources/mapper/CheckReportMapper.xml

+<?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="cn.datax.service.data.quality.dao.CheckReportDao">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="cn.datax.service.data.quality.api.entity.CheckReportEntity">
+        <result column="id" property="id" />
+        <result column="check_rule_id" property="checkRuleId" />
+        <result column="check_date" property="checkDate" />
+        <result column="check_result" property="checkResult" />
+        <result column="check_total_count" property="checkTotalCount" />
+        <result column="check_error_count" property="checkErrorCount" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id,
+        check_rule_id, check_date, check_result, check_total_count, check_error_count
+    </sql>
+
+</mapper>

datax-modules/data-quality-service-parent/data-quality-service/src/main/resources/mapper/CheckRuleMapper.xml

+<?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="cn.datax.service.data.quality.dao.CheckRuleDao">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="cn.datax.service.data.quality.api.entity.CheckRuleEntity">
+        <result column="id" property="id" />
+        <result column="status" property="status" />
+        <result column="create_by" property="createBy" />
+        <result column="create_time" property="createTime" />
+        <result column="create_dept" property="createDept" />
+        <result column="update_by" property="updateBy" />
+        <result column="update_time" property="updateTime" />
+        <result column="remark" property="remark" />
+        <result column="rule_name" property="ruleName" />
+        <result column="rule_type_id" property="ruleTypeId" />
+        <result column="rule_level" property="ruleLevel" />
+        <result column="rule_source_id" property="ruleSourceId" />
+        <result column="rule_source" property="ruleSource" />
+        <result column="rule_table_id" property="ruleTableId" />
+        <result column="rule_table" property="ruleTable" />
+        <result column="rule_column_id" property="ruleColumnId" />
+        <result column="rule_column" property="ruleColumn" />
+        <result column="rule_sql" property="ruleSql" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id,
+        status,
+        create_by,
+        create_time,
+        create_dept,
+        update_by,
+        update_time,
+        remark,
+        rule_name, rule_type_id, rule_level, rule_source_id, rule_source, rule_table_id, rule_table, rule_column_id, rule_column, rule_sql
+    </sql>
+
+</mapper>

datax-modules/data-quality-service-parent/data-quality-service/src/main/resources/mapper/RuleTypeMapper.xml

+<?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="cn.datax.service.data.quality.dao.RuleTypeDao">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="cn.datax.service.data.quality.api.entity.RuleTypeEntity">
+        <result column="id" property="id" />
+        <result column="name" property="name" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id,
+        name
+    </sql>
+
+</mapper>

datax-ui/src/api/quality/checkreport.js

+import request from '@/utils/request'
+
+export function listRuleType(data) {
+  return request({
+    url: '/data/quality/ruleTypes/list',
+    method: 'get',
+    params: data
+  })
+}
+
+export function pageCheckReport(data) {
+  return request({
+    url: '/data/quality/checkReports/page',
+    method: 'get',
+    params: data
+  })
+}

datax-ui/src/api/quality/checkrule.js

+import request from '@/utils/request'
+
+export function listRuleType(data) {
+  return request({
+    url: '/data/quality/ruleTypes/list',
+    method: 'get',
+    params: data
+  })
+}
+
+export function pageCheckRule(data) {
+  return request({
+    url: '/data/quality/checkRules/page',
+    method: 'get',
+    params: data
+  })
+}
+
+export function getCheckRule(id) {
+  return request({
+    url: '/data/quality/checkRules/' + id,
+    method: 'get'
+  })
+}
+
+export function delCheckRule(id) {
+  return request({
+    url: '/data/quality/checkRules/' + id,
+    method: 'delete'
+  })
+}
+
+export function delCheckRules(ids) {
+  return request({
+    url: '/data/quality/checkRules/batch/' + ids,
+    method: 'delete'
+  })
+}
+
+export function addCheckRule(data) {
+  return request({
+    url: '/data/quality/checkRules',
+    method: 'post',
+    data: data
+  })
+}
+
+export function updateCheckRule(data) {
+  return request({
+    url: '/data/quality/checkRules/' + data.id,
+    method: 'put',
+    data: data
+  })
+}

datax-ui/src/views/metadata/dataanalyse/index.vue → datax-ui/src/views/masterdata/dataapply/index.vue

 <template>
   <div class="app-container">
-    DataAnalyse
+    DataApply
   </div>
 </template>
 
 <script>
 export default {
-  name: 'DataAnalyse'
+  name: 'DataApply'
 }
 </script>
 

datax-ui/src/views/metadata/dataauthorize/index.vue

+<template>
+  <div class="app-container">
+    DataAuthorize
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'DataAuthorize'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/metadata/datablood/index.vue

+<template>
+  <div class="app-container">
+    DataBlood
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'DataBlood'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/quality/analysisreport/index.vue

+<template>
+  <div class="app-container">
+    AnalysisReport
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'AnalysisReport'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/quality/checkjob/index.vue

+<template>
+  <div class="app-container">
+    CheckJob
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'CheckJob'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/quality/checkreport/index.vue

+<template>
+  <div class="app-container">
+    CheckReport
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'CheckReport'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/quality/checkrule/index.vue

+<template>
+  <div class="app-container">
+    CheckRule
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'CheckRule'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/quality/index.vue

+<template>
+  <div class="app-container">
+    Quality
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'Quality'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/standard/contrastrelease/index.vue

+<template>
+  <div class="app-container">
+    ContrastRelease
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'ContrastRelease'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/standard/contrastresult/index.vue

+<template>
+  <div class="app-container">
+    ContrastResult
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'ContrastResult'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/standard/datacontrast/index.vue

+<template>
+  <div class="app-container">
+    DataContrast
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'DataContrast'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/standard/dictcontrast/index.vue

+<template>
+  <div class="app-container">
+    DictContrast
+  </div>
+</template>
+
+<script>
+export default {
+  name: 'DictContrast'
+}
+</script>
+
+<style lang="scss" scoped>
+
+</style>

datax-ui/src/views/workflow/definition/DefinitionList.vue

@@ -40,15 +40,6 @@
               @keyup.enter.native="handleQuery"
             />
           </el-form-item>
-          <el-form-item label="流程定义KEY" prop="key">
-            <el-input
-              v-model="queryParams.key"
-              placeholder="请输入流程定义KEY"
-              clearable
-              size="small"
-              @keyup.enter.native="handleQuery"
-            />
-          </el-form-item>
           <el-form-item>
             <el-button type="primary" icon="el-icon-search" size="mini" @click="handleQuery">搜索</el-button>
             <el-button icon="el-icon-refresh" size="mini" @click="resetQuery">重置</el-button>
@@ -233,7 +224,6 @@ export default {
         pageNum: 1,
         pageSize: 20,
         name: '',
-        key: '',
         categoryId: ''
       },
       // 左侧树
@@ -354,7 +344,6 @@ export default {
         pageNum: 1,
         pageSize: 20,
         name: '',
-        key: '',
         categoryId: ''
       }
       this.handleQuery()