+ * 核查报告信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Api(tags = {"核查报告信息表"}) +@RestController +@RequestMapping("/quality/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 AjaxResult getCheckReportById(@PathVariable String id) { + CheckReportEntity checkReportEntity = checkReportService.getCheckReportById(id); + return AjaxResult.success(checkReportMapper.toVO(checkReportEntity)); + } + + /** + * 分页查询信息 + * + * @param checkReportQuery + * @return + */ + @ApiOperation(value = "分页查询", notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "checkReportQuery", value = "查询实体checkReportQuery", required = true, dataTypeClass = CheckReportQuery.class) + }) + @GetMapping("/page") + public AjaxResult getCheckReportPage(CheckReportQuery checkReportQuery) { + QueryWrapper+ * 核查规则信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Api(tags = {"核查规则信息表"}) +@RestController +@RequestMapping("/quality/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 AjaxResult getCheckRuleById(@PathVariable String id) { + CheckRuleEntity checkRuleEntity = checkRuleService.getCheckRuleById(id); + return AjaxResult.success(checkRuleMapper.toVO(checkRuleEntity)); + } + + /** + * 分页查询信息 + * + * @param checkRuleQuery + * @return + */ + @ApiOperation(value = "分页查询", notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "checkRuleQuery", value = "查询实体checkRuleQuery", required = true, dataTypeClass = CheckRuleQuery.class) + }) + @GetMapping("/page") + public AjaxResult getCheckRulePage(CheckRuleQuery checkRuleQuery) { + QueryWrapper+ * 规则核查项信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Api(tags = {"规则核查项信息表"}) +@RestController +@RequestMapping("/quality/ruleItems") +public class RuleItemController extends BaseController { + + @Autowired + private RuleItemService ruleItemService; + + @Autowired + private RuleItemMapper ruleItemMapper; + + /** + * 通过ID查询信息 + * + * @param id + * @return + */ + @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息") + @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path") + @GetMapping("/{id}") + public AjaxResult getRuleItemById(@PathVariable String id) { + RuleItemEntity ruleItemEntity = ruleItemService.getRuleItemById(id); + return AjaxResult.success(ruleItemMapper.toVO(ruleItemEntity)); + } + + @ApiOperation(value = "获取列表", notes = "") + @GetMapping("/list") + public AjaxResult getRuleTypeList(RuleItemQuery ruleItemQuery) { + QueryWrapper+ * 规则级别信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Api(tags = {"规则级别信息表"}) +@RestController +@RequestMapping("/quality/ruleLevels") +public class RuleLevelController extends BaseController { + + @Autowired + private RuleLevelService ruleLevelService; + + @Autowired + private RuleLevelMapper ruleLevelMapper; + + /** + * 通过ID查询信息 + * + * @param id + * @return + */ + @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息") + @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path") + @GetMapping("/{id}") + public AjaxResult getRuleLevelById(@PathVariable String id) { + RuleLevelEntity ruleLevelEntity = ruleLevelService.getRuleLevelById(id); + return AjaxResult.success(ruleLevelMapper.toVO(ruleLevelEntity)); + } + + @ApiOperation(value = "获取列表", notes = "") + @GetMapping("/list") + public AjaxResult getRuleTypeList() { + List+ * 规则类型信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Api(tags = {"规则类型信息表"}) +@RestController +@RequestMapping("/quality/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 AjaxResult getRuleTypeById(@PathVariable String id) { + RuleTypeEntity ruleTypeEntity = ruleTypeService.getRuleTypeById(id); + return AjaxResult.success(ruleTypeMapper.toVO(ruleTypeEntity)); + } + + @ApiOperation(value = "获取列表", notes = "") + @GetMapping("/list") + public AjaxResult getRuleTypeList() { + List+ * 对照表信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Api(tags = {"对照表信息表"}) +@RestController +@RequestMapping("/standard/contrasts") +public class ContrastController extends BaseController { + + @Autowired + private ContrastService contrastService; + + @Autowired + private ContrastMapper contrastMapper; + + /** + * 通过ID查询信息 + * + * @param id + * @return + */ + @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息") + @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path") + @GetMapping("/{id}") + public AjaxResult getContrastById(@PathVariable String id) { + ContrastEntity contrastEntity = contrastService.getContrastById(id); + return AjaxResult.success(contrastMapper.toVO(contrastEntity)); + } + + /** + * 分页查询信息 + * + * @param contrastQuery + * @return + */ + @ApiOperation(value = "分页查询", notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "contrastQuery", value = "查询实体contrastQuery", required = true, dataTypeClass = ContrastQuery.class) + }) + @GetMapping("/page") + public AjaxResult getContrastPage(ContrastQuery contrastQuery) { + QueryWrapper+ * 字典对照信息表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Api(tags = {"字典对照信息表"}) +@RestController +@RequestMapping("/standard/contrastDicts") +public class ContrastDictController extends BaseController { + + @Autowired + private ContrastDictService contrastDictService; + + @Autowired + private ContrastDictMapper contrastDictMapper; + + /** + * 通过ID查询信息 + * + * @param id + * @return + */ + @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息") + @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path") + @GetMapping("/{id}") + public AjaxResult getContrastDictById(@PathVariable String id) { + ContrastDictEntity contrastDictEntity = contrastDictService.getContrastDictById(id); + return AjaxResult.success(contrastDictMapper.toVO(contrastDictEntity)); + } + + /** + * 分页查询信息 + * + * @param contrastDictQuery + * @return + */ + @ApiOperation(value = "分页查询", notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "contrastDictQuery", value = "查询实体contrastDictQuery", required = true, dataTypeClass = ContrastDictQuery.class) + }) + @GetMapping("/page") + public AjaxResult getContrastDictPage(ContrastDictQuery contrastDictQuery) { + QueryWrapper+ * 数据标准字典表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Api(tags = {"数据标准字典表"}) +@RestController +@RequestMapping("/standard/dicts") +public class DictController extends BaseController { + + @Autowired + private DictService dictService; + + @Autowired + private DictMapper dictMapper; + + /** + * 通过ID查询信息 + * + * @param id + * @return + */ + @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息") + @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path") + @GetMapping("/{id}") + public AjaxResult getDictById(@PathVariable String id) { + DictEntity dictEntity = dictService.getDictById(id); + return AjaxResult.success(dictMapper.toVO(dictEntity)); + } + + /** + * 分页查询信息 + * + * @param dictQuery + * @return + */ + @ApiOperation(value = "分页查询", notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "dictQuery", value = "查询实体dictQuery", required = true, dataTypeClass = DictQuery.class) + }) + @GetMapping("/page") + public AjaxResult getDictPage(DictQuery dictQuery) { + QueryWrapper+ * 数据标准类别表 前端控制器 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Api(tags = {"标准类别信息表"}) +@RestController +@RequestMapping("/standard/types") +public class TypeController extends BaseController { + + @Autowired + private TypeService typeService; + + @Autowired + private TypeMapper typeMapper; + + /** + * 通过ID查询信息 + * + * @param id + * @return + */ + @ApiOperation(value = "获取详细信息", notes = "根据url的id来获取详细信息") + @ApiImplicitParam(name = "id", value = "ID", required = true, dataType = "String", paramType = "path") + @GetMapping("/{id}") + public AjaxResult getTypeById(@PathVariable String id) { + TypeEntity typeEntity = typeService.getTypeById(id); + return AjaxResult.success(typeMapper.toVO(typeEntity)); + } + + @ApiOperation(value = "获取列表", notes = "") + @GetMapping("/list") + public AjaxResult getTypeList() { + QueryWrapper+ * 核查规则信息表 实体DTO + *
+ * + * @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 = "核查类型") + private String ruleItemId; + @ApiModelProperty(value = "规则级别（3高、2中、1低）") + private String ruleLevelId; + @ApiModelProperty(value = "数据源类型") + private String ruleDbType; + @ApiModelProperty(value = "数据源主键") + private String ruleSourceId; + @ApiModelProperty(value = "数据源") + private String ruleSource; + @ApiModelProperty(value = "数据表主键") + private String ruleTableId; + @ApiModelProperty(value = "数据表") + private String ruleTable; + @ApiModelProperty(value = "数据表名称") + private String ruleTableComment; + @ApiModelProperty(value = "核查字段主键") + private String ruleColumnId; + @ApiModelProperty(value = "核查字段") + private String ruleColumn; + @ApiModelProperty(value = "核查字段名称") + private String ruleColumnComment; + @ApiModelProperty(value = "核查配置") + @Valid + private RuleConfig ruleConfig; + @ApiModelProperty(value = "状态") + @NotNull(message = "状态不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String status; + @ApiModelProperty(value = "备注") + private String remark; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/dto/Consistent.java b/czsj-system/src/main/java/com/czsj/quality/dto/Consistent.java new file mode 100644 index 0000000..87bddec --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/dto/Consistent.java @@ -0,0 +1,19 @@ +package com.czsj.quality.dto; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 一致性 + */ +@Data +public class Consistent implements Serializable { + + private static final long serialVersionUID = 1L; + + private String gbTypeId; + private String gbTypeCode; + private String gbTypeName; + private String bindGbColumn; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/dto/Relevance.java b/czsj-system/src/main/java/com/czsj/quality/dto/Relevance.java new file mode 100644 index 0000000..fd8cea7 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/dto/Relevance.java @@ -0,0 +1,21 @@ +package com.czsj.quality.dto; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 关联性 + */ +@Data +public class Relevance implements Serializable { + + private static final long serialVersionUID = 1L; + + private String relatedTableId; + private String relatedTable; + private String relatedTableComment; + private String relatedColumnId; + private String relatedColumn; + private String relatedColumnComment; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/dto/RuleConfig.java b/czsj-system/src/main/java/com/czsj/quality/dto/RuleConfig.java new file mode 100644 index 0000000..3f9eb10 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/dto/RuleConfig.java @@ -0,0 +1,35 @@ +package com.czsj.quality.dto; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.io.Serializable; + +@Data +public class RuleConfig implements Serializable { + + private static final long serialVersionUID=1L; + + @ApiModelProperty(value = "核查类型编码") + private String ruleItemCode; + + /** + * 一致性 + */ + private Consistent consistent; + + /** + * 关联性 + */ + private Relevance relevance; + + /** + * 及时性 + */ + private Timeliness timeliness; + + /** + * 准确性 + */ + private Accuracy accuracy; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/dto/ScheduleLogDto.java b/czsj-system/src/main/java/com/czsj/quality/dto/ScheduleLogDto.java new file mode 100644 index 0000000..b74d0ee --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/dto/ScheduleLogDto.java @@ -0,0 +1,41 @@ +package com.czsj.quality.dto; + +import com.czsj.metadata.validate.ValidationGroups; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + *+ * 数据质量监控任务日志信息表 实体DTO + *
+ * + * @author yuwei + * @since 2020-10-13 + */ +@ApiModel(value = "数据质量监控任务日志信息表Model") +@Data +public class ScheduleLogDto implements Serializable { + + private static final long serialVersionUID=1L; + + @ApiModelProperty(value = "主键ID") + @NotBlank(message = "主键ID不能为空", groups = {ValidationGroups.Update.class}) + private String id; + @ApiModelProperty(value = "状态（1成功 0失败）") + private String status; + @ApiModelProperty(value = "执行任务主键") + private String executeJobId; + @ApiModelProperty(value = "执行规则主键") + private String executeRuleId; + @ApiModelProperty(value = "执行时间") + private LocalDateTime executeDate; + @ApiModelProperty(value = "执行结果") + private String executeResult; + @ApiModelProperty(value = "执行批次号") + private String executeBatch; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/dto/Timeliness.java b/czsj-system/src/main/java/com/czsj/quality/dto/Timeliness.java new file mode 100644 index 0000000..3d0381d --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/dto/Timeliness.java @@ -0,0 +1,19 @@ +package com.czsj.quality.dto; + +import lombok.Data; + +import java.io.Serializable; + +/** + * 及时性 + */ +@Data +public class Timeliness implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 判定阀值 当前时间-业务时间>阀值 + */ + private Integer threshold; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/CheckReportEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/CheckReportEntity.java new file mode 100644 index 0000000..a32d81a --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/CheckReportEntity.java @@ -0,0 +1,93 @@ +package com.czsj.quality.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import lombok.experimental.Accessors; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + *+ * 核查报告信息表 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@Accessors(chain = true) +@TableName(value = "quality_check_report", autoResultMap = true) +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; + + /** + * 核查批次号 + */ + private String checkBatch; + + /** + * 规则名称 + */ + @TableField(exist = false) + private String ruleName; + + /** + * 规则类型 + */ + @TableField(exist = false) + private String ruleType; + + /** + * 数据源 + */ + @TableField(exist = false) + private String ruleSource; + + /** + * 数据表 + */ + @TableField(exist = false) + private String ruleTable; + + /** + * 核查字段 + */ + @TableField(exist = false) + private String ruleColumn; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/CheckRuleEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/CheckRuleEntity.java new file mode 100644 index 0000000..394768f --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/CheckRuleEntity.java @@ -0,0 +1,118 @@ +package com.czsj.quality.entity; + + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler; +import com.czsj.core.database.base.DataScopeBaseEntity; +import com.czsj.quality.dto.RuleConfig; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +/** + *+ * 核查规则信息表 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@Accessors(chain = true) +@TableName(value = "quality_check_rule", autoResultMap = true) +public class CheckRuleEntity extends DataScopeBaseEntity { + + private static final long serialVersionUID=1L; + + /** + * 规则名称 + */ + private String ruleName; + + /** + * 规则类型主键 + */ + private String ruleTypeId; + + /** + * 核查类型主键 + */ + private String ruleItemId; + + /** + * 规则类型 + */ + @TableField(exist = false) + private String ruleType; + + /** + * 规则级别（3高、2中、1低） + */ + private String ruleLevelId; + + @TableField(exist = false) + private String ruleLevel; + + /** + * 数据源类型 + */ + private String ruleDbType; + + /** + * 数据源主键 + */ + private String ruleSourceId; + + /** + * 数据源 + */ + private String ruleSource; + + /** + * 数据表主键 + */ + private String ruleTableId; + + /** + * 数据表 + */ + private String ruleTable; + + /** + * 数据表名称 + */ + private String ruleTableComment; + + /** + * 核查字段主键 + */ + private String ruleColumnId; + + /** + * 核查字段 + */ + private String ruleColumn; + + /** + * 核查字段名称 + */ + private String ruleColumnComment; + + /** + * 核查配置 + */ + @TableField(value = "config_json", typeHandler = JacksonTypeHandler.class) + private RuleConfig ruleConfig; + + /** + * 核查脚本 + */ + private String ruleSql; + + /** + * 最近核查批次号（关联确定唯一核查报告） + */ + private String lastCheckBatch; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/DataReportEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/DataReportEntity.java new file mode 100644 index 0000000..85ef269 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/DataReportEntity.java @@ -0,0 +1,28 @@ +package com.czsj.quality.entity; + +import lombok.Data; + +import java.io.Serializable; + +@Data +public class DataReportEntity implements Serializable { + + private static final long serialVersionUID=1L; + + private String ruleTypeId; + private String ruleTypeName; + private String ruleId; + private String ruleName; + private String ruleSourceId; + private String ruleSourceName; + private String ruleLevelId; + private String ruleLevelName; + private Integer checkErrorCount; + + private String ruleTypeCode; + private String ruleTableName; + private String ruleTableComment; + private String ruleColumnName; + private String ruleColumnComment; + private Integer checkTotalCount; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/RuleItemEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/RuleItemEntity.java new file mode 100644 index 0000000..1dea990 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/RuleItemEntity.java @@ -0,0 +1,46 @@ +package com.czsj.quality.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; + +/** + *+ * 规则核查类型信息表 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Data +@Accessors(chain = true) +@TableName("quality_rule_item") +public class RuleItemEntity implements Serializable { + + private static final long serialVersionUID=1L; + + /** + * 主键 + */ + @TableId(value = "id", type = IdType.ASSIGN_ID) + private String id; + + /** + * 规则类型 + */ + private String ruleTypeId; + + /** + * 核查类型编码 + */ + private String itemCode; + + /** + * 核查类型解释 + */ + private String itemExplain; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/RuleLevelEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/RuleLevelEntity.java new file mode 100644 index 0000000..4019ff8 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/RuleLevelEntity.java @@ -0,0 +1,41 @@ +package com.czsj.quality.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; + +/** + *+ * 规则级别信息表 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Data +@Accessors(chain = true) +@TableName("quality_rule_level") +public class RuleLevelEntity implements Serializable { + + private static final long serialVersionUID=1L; + + /** + * 主键 + */ + @TableId(value = "id", type = IdType.ASSIGN_ID) + private String id; + + /** + * 规则级别编码 + */ + private String code; + + /** + * 规则级别名称 + */ + private String name; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/RuleTypeEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/RuleTypeEntity.java new file mode 100644 index 0000000..ae39d4a --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/RuleTypeEntity.java @@ -0,0 +1,41 @@ +package com.czsj.quality.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; + +/** + *+ * 规则类型信息表 + *
+ * + * @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; + + /** + * 类型编码 + */ + private String code; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/RuleTypeReportEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/RuleTypeReportEntity.java new file mode 100644 index 0000000..b48654b --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/RuleTypeReportEntity.java @@ -0,0 +1,14 @@ +package com.czsj.quality.entity; + +import lombok.Data; + +@Data +public class RuleTypeReportEntity extends RuleTypeEntity { + + private static final long serialVersionUID=1L; + + /** + * 不合规数量 + */ + private Integer checkErrorCount; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/ScheduleJobEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/ScheduleJobEntity.java new file mode 100644 index 0000000..a80dd6c --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/ScheduleJobEntity.java @@ -0,0 +1,61 @@ +package com.czsj.quality.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; + +/** + *+ * 数据质量监控任务信息表 + *
+ * + * @author yuwei + * @since 2020-09-29 + */ +@Data +@Accessors(chain = true) +@TableName("quality_schedule_job") +public class ScheduleJobEntity implements Serializable { + + private static final long serialVersionUID=1L; + + /** + * 主键 + */ + @TableId(value = "id", type = IdType.ASSIGN_ID) + private String id; + + /** + * 任务名称 + */ + private String jobName; + + /** + * bean名称 + */ + private String beanName; + + /** + * 方法名称 + */ + private String methodName; + + /** + * 方法参数 + */ + private String methodParams; + + /** + * cron表达式 + */ + private String cronExpression; + + /** + * 状态（1运行 0暂停） + */ + private String status; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/entity/ScheduleLogEntity.java b/czsj-system/src/main/java/com/czsj/quality/entity/ScheduleLogEntity.java new file mode 100644 index 0000000..fb031be --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/entity/ScheduleLogEntity.java @@ -0,0 +1,72 @@ +package com.czsj.quality.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import lombok.experimental.Accessors; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + *+ * 数据质量监控任务日志信息表 + *
+ * + * @author yuwei + * @since 2020-10-13 + */ +@Data +@Accessors(chain = true) +@TableName(value = "quality_schedule_log") +public class ScheduleLogEntity implements Serializable { + + private static final long serialVersionUID=1L; + + /** + * 主键 + */ + @TableId(value = "id", type = IdType.ASSIGN_ID) + private String id; + + /** + * 状态（1成功 0失败） + */ + private String status; + + /** + * 执行任务主键 + */ + private String executeJobId; + + @TableField(exist = false) + private String executeJobName; + + /** + * 执行规则主键 + */ + private String executeRuleId; + + @TableField(exist = false) + private String executeRuleName; + + @TableField(exist = false) + private String executeRuleTypeName; + + /** + * 执行时间 + */ + private LocalDateTime executeDate; + + /** + * 执行结果 + */ + private String executeResult; + + /** + * 执行批次号 + */ + private String executeBatch; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/enums/RuleItem.java b/czsj-system/src/main/java/com/czsj/quality/enums/RuleItem.java new file mode 100644 index 0000000..b9b5a82 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/enums/RuleItem.java @@ -0,0 +1,36 @@ +package com.czsj.quality.enums; + + +public enum RuleItem { + + Unique("unique_key", "验证用户指定的字段是否具有唯一性"), + AccuracyLength("accuracy_key_length", "验证长度是否符合规定"), + Integrity("integrity_key", "验证表中必须出现的字段非空"), + Relevance("relevance_key", "验证关联性"), + Timeliness("timeliness_key", "验证及时性"), + Consistent("consistent_key", "验证用户指定的字段枚举值是否合乎要求"); + + private final String code; + + private final String desc; + + RuleItem(String code, String desc) { + this.code = code; + this.desc = desc; + } + + public String getCode() { + return code; + } + + public static RuleItem getRuleItem(String code) { + for (RuleItem item : RuleItem.values()) { + if (item.code.equals(code)) { + return item; + } + } + return null; + } + + +} diff --git a/czsj-system/src/main/java/com/czsj/quality/mapper/CheckReportDao.java b/czsj-system/src/main/java/com/czsj/quality/mapper/CheckReportDao.java new file mode 100644 index 0000000..00f207e --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/mapper/CheckReportDao.java @@ -0,0 +1,34 @@ +package com.czsj.quality.mapper; + + +import com.baomidou.mybatisplus.core.conditions.Wrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Constants; +import com.czsj.core.database.base.BaseDao; +import com.czsj.quality.entity.CheckReportEntity; +import com.czsj.quality.entity.DataReportEntity; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + *+ * 核查报告信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper +public interface CheckReportDao extends BaseDao+ * 核查规则信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper +public interface CheckRuleDao extends BaseDao+ * 规则核查项信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Mapper +public interface RuleItemDao extends BaseDao+ * 规则级别信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Mapper +public interface RuleLevelDao extends BaseDao+ * 规则类型信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper +public interface RuleTypeDao extends BaseDao+ * 数据质量监控任务信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-09-29 + */ +@Mapper +public interface ScheduleJobDao extends BaseDao+ * 数据质量监控任务日志信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-10-13 + */ +@Mapper +public interface ScheduleLogDao extends BaseDao+ * 核查报告信息表 Mapper 实体映射 + *
+ * + * @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+ * 核查规则信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper(componentModel = "spring") +public interface CheckRuleMapper extends EntityMapper+ * 规则核查项信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Mapper(componentModel = "spring") +public interface RuleItemMapper { + + /** + * 将源对象转换为VO对象 + * @param e + * @return D + */ + RuleItemVo toVO(RuleItemEntity e); + + /** + * 将源对象集合转换为VO对象集合 + * @param es + * @return List+ * 规则级别信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Mapper(componentModel = "spring") +public interface RuleLevelMapper { + + /** + * 将源对象转换为VO对象 + * @param e + * @return D + */ + RuleLevelVo toVO(RuleLevelEntity e); + + /** + * 将源对象集合转换为VO对象集合 + * @param es + * @return List+ * 规则类型信息表 Mapper 实体映射 + *
+ * + * @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+ * 数据质量监控任务信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-09-29 + */ +@Mapper(componentModel = "spring") +public interface ScheduleJobMapper { + + /** + * 将源对象转换为VO对象 + * @param e + * @return D + */ + ScheduleJobVo toVO(ScheduleJobEntity e); + + /** + * 将源对象集合转换为VO对象集合 + * @param es + * @return List+ * 数据质量监控任务日志信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-10-13 + */ +@Mapper(componentModel = "spring") +public interface ScheduleLogMapper { + + /** + * 将源对象转换为VO对象 + * @param e + * @return D + */ + ScheduleLogVo toVO(ScheduleLogEntity e); + + /** + * 将源对象集合转换为VO对象集合 + * @param es + * @return List+ * 核查报告信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class CheckReportQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String ruleTypeId; + private String ruleName; + private String ruleSource; + private String ruleTable; + private String ruleColumn; + @DateTimeFormat(pattern = "yyyy-MM-dd") + private LocalDate checkDate; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/query/CheckRuleQuery.java b/czsj-system/src/main/java/com/czsj/quality/query/CheckRuleQuery.java new file mode 100644 index 0000000..e43583e --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/query/CheckRuleQuery.java @@ -0,0 +1,26 @@ +package com.czsj.quality.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 核查规则信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class CheckRuleQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String ruleTypeId; + private String ruleName; + private String ruleSource; + private String ruleTable; + private String ruleColumn; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/query/RuleItemQuery.java b/czsj-system/src/main/java/com/czsj/quality/query/RuleItemQuery.java new file mode 100644 index 0000000..9237d91 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/query/RuleItemQuery.java @@ -0,0 +1,22 @@ +package com.czsj.quality.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 规则核查项信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class RuleItemQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String ruleTypeId; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/query/RuleLevelQuery.java b/czsj-system/src/main/java/com/czsj/quality/query/RuleLevelQuery.java new file mode 100644 index 0000000..7e6d2a7 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/query/RuleLevelQuery.java @@ -0,0 +1,20 @@ +package com.czsj.quality.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 规则级别信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class RuleLevelQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/query/RuleTypeQuery.java b/czsj-system/src/main/java/com/czsj/quality/query/RuleTypeQuery.java new file mode 100644 index 0000000..3f6d230 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/query/RuleTypeQuery.java @@ -0,0 +1,22 @@ +package com.czsj.quality.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 规则类型信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class RuleTypeQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String name; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/query/ScheduleJobQuery.java b/czsj-system/src/main/java/com/czsj/quality/query/ScheduleJobQuery.java new file mode 100644 index 0000000..832fed4 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/query/ScheduleJobQuery.java @@ -0,0 +1,20 @@ +package com.czsj.quality.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 数据质量监控任务信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-09-29 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class ScheduleJobQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/query/ScheduleLogQuery.java b/czsj-system/src/main/java/com/czsj/quality/query/ScheduleLogQuery.java new file mode 100644 index 0000000..7aa9a80 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/query/ScheduleLogQuery.java @@ -0,0 +1,23 @@ +package com.czsj.quality.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 数据质量监控任务日志信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-10-13 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class ScheduleLogQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String executeJobId; + private String ruleTypeId; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/schedule/CheckRuleFactory.java b/czsj-system/src/main/java/com/czsj/quality/schedule/CheckRuleFactory.java new file mode 100644 index 0000000..5912097 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/schedule/CheckRuleFactory.java @@ -0,0 +1,21 @@ +package com.czsj.quality.schedule; + + + +import com.aspose.words.net.System.Data.DataException; +import com.czsj.quality.schedule.rules.RuleItem; +import com.czsj.quality.schedule.rules.RuleItemRegistry; + +import java.util.Optional; + +public class CheckRuleFactory { + + private static final RuleItemRegistry RULE_ITEM_REGISTRY = new RuleItemRegistry(); + + public CheckRuleFactory() { + } + + public static RuleItem getRuleItem(String code) { + return Optional.ofNullable(RULE_ITEM_REGISTRY.getRuleItem(code)).orElseThrow(() -> new DataException(String.format("%s not supported.", code))); + } +} diff --git a/czsj-system/src/main/java/com/czsj/quality/schedule/rules/AccuracyLengthRule.java b/czsj-system/src/main/java/com/czsj/quality/schedule/rules/AccuracyLengthRule.java new file mode 100644 index 0000000..e149463 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/schedule/rules/AccuracyLengthRule.java @@ -0,0 +1,29 @@ +package com.czsj.quality.schedule.rules; + + + +import com.czsj.common.database.constants.DbType; + +import java.util.Map; + +/** + * 准确性核查 + * 核查项:最大长度 + * select sum(case when length(column) > 15 then 1 else 0 end), count(*) from table; + */ +public class AccuracyLengthRule implements RuleItem { + + private static String MAX_LENGTH = "max_length"; + + @Override + public String parse(DbType dbType, String table, String column, Map+ * 核查报告信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +public interface CheckReportService extends BaseService+ * 核查规则信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +public interface CheckRuleService extends BaseService+ * 规则核查项信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +public interface RuleItemService extends BaseService+ * 规则级别信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +public interface RuleLevelService extends BaseService+ * 规则类型信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +public interface RuleTypeService extends BaseService+ * 核查报告信息表 服务实现类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Service +@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) +public class CheckReportServiceImpl extends BaseServiceImpl+ * 核查规则信息表 服务实现类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Service +@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) +public class CheckRuleServiceImpl extends BaseServiceImpl+ * 规则核查项信息表 服务实现类 + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Service +@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) +public class RuleItemServiceImpl extends BaseServiceImpl+ * 规则级别信息表 服务实现类 + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Service +@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) +public class RuleLevelServiceImpl extends BaseServiceImpl+ * 规则类型信息表 服务实现类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Service +@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) +public class RuleTypeServiceImpl extends BaseServiceImpl+ * 核查报告信息表 实体VO + *
+ * + * @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; + private String ruleName; + private String ruleType; + private String ruleSource; + private String ruleTable; + private String ruleColumn; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/vo/CheckRuleVo.java b/czsj-system/src/main/java/com/czsj/quality/vo/CheckRuleVo.java new file mode 100644 index 0000000..344dade --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/vo/CheckRuleVo.java @@ -0,0 +1,44 @@ +package com.czsj.quality.vo; + +import com.fasterxml.jackson.annotation.JsonFormat; +import com.czsj.quality.dto.RuleConfig; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + *+ * 核查规则信息表 实体VO + *
+ * + * @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 Date createTime; + private String remark; + private String ruleName; + private String ruleTypeId; + private String ruleItemId; + private String ruleType; + private String ruleLevelId; + private String ruleLevel; + private String ruleDbType; + private String ruleSourceId; + private String ruleSource; + private String ruleTableId; + private String ruleTable; + private String ruleTableComment; + private String ruleColumnId; + private String ruleColumn; + private String ruleColumnComment; + private RuleConfig ruleConfig; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/vo/RuleItemVo.java b/czsj-system/src/main/java/com/czsj/quality/vo/RuleItemVo.java new file mode 100644 index 0000000..3c8a253 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/vo/RuleItemVo.java @@ -0,0 +1,24 @@ +package com.czsj.quality.vo; + +import lombok.Data; + +import java.io.Serializable; + +/** + *+ * 规则核查项信息表 实体VO + *
+ * + * @author yuwei + * @since 2020-10-15 + */ +@Data +public class RuleItemVo implements Serializable { + + private static final long serialVersionUID=1L; + + private String id; + private String ruleTypeId; + private String itemCode; + private String itemExplain; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/vo/RuleLevelVo.java b/czsj-system/src/main/java/com/czsj/quality/vo/RuleLevelVo.java new file mode 100644 index 0000000..a17710f --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/vo/RuleLevelVo.java @@ -0,0 +1,23 @@ +package com.czsj.quality.vo; + +import lombok.Data; + +import java.io.Serializable; + +/** + *+ * 规则级别信息表 实体VO + *
+ * + * @author yuwei + * @since 2020-10-14 + */ +@Data +public class RuleLevelVo implements Serializable { + + private static final long serialVersionUID=1L; + + private String id; + private String code; + private String name; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/vo/RuleTypeVo.java b/czsj-system/src/main/java/com/czsj/quality/vo/RuleTypeVo.java new file mode 100644 index 0000000..971dc74 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/vo/RuleTypeVo.java @@ -0,0 +1,23 @@ +package com.czsj.quality.vo; + +import lombok.Data; + +import java.io.Serializable; + +/** + *+ * 规则类型信息表 实体VO + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +public class RuleTypeVo implements Serializable { + + private static final long serialVersionUID=1L; + + private String id; + private String name; + private String code; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/vo/ScheduleJobVo.java b/czsj-system/src/main/java/com/czsj/quality/vo/ScheduleJobVo.java new file mode 100644 index 0000000..b66005a --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/vo/ScheduleJobVo.java @@ -0,0 +1,27 @@ +package com.czsj.quality.vo; + +import lombok.Data; + +import java.io.Serializable; + +/** + *+ * 数据质量监控任务信息表 实体VO + *
+ * + * @author yuwei + * @since 2020-09-29 + */ +@Data +public class ScheduleJobVo implements Serializable { + + private static final long serialVersionUID=1L; + + private String id; + private String status; + private String jobName; + private String beanName; + private String methodName; + private String methodParams; + private String cronExpression; +} diff --git a/czsj-system/src/main/java/com/czsj/quality/vo/ScheduleLogVo.java b/czsj-system/src/main/java/com/czsj/quality/vo/ScheduleLogVo.java new file mode 100644 index 0000000..9e629f0 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/quality/vo/ScheduleLogVo.java @@ -0,0 +1,33 @@ +package com.czsj.quality.vo; + +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + *+ * 数据质量监控任务日志信息表 实体VO + *
+ * + * @author yuwei + * @since 2020-10-13 + */ +@Data +public class ScheduleLogVo implements Serializable { + + private static final long serialVersionUID=1L; + + private String id; + private String status; + private String executeJobId; + private String executeRuleId; + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private LocalDateTime executeDate; + private String executeResult; + private String executeBatch; + private String executeJobName; + private String executeRuleName; + private String executeRuleTypeName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/dto/ContrastDictDto.java b/czsj-system/src/main/java/com/czsj/standard/dto/ContrastDictDto.java new file mode 100644 index 0000000..a35dec0 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/dto/ContrastDictDto.java @@ -0,0 +1,40 @@ +package com.czsj.standard.dto; + +import com.czsj.metadata.validate.ValidationGroups; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; +import java.io.Serializable; + +/** + *+ * 字典对照信息表 实体DTO + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@ApiModel(value = "字典对照信息表Model") +@Data +public class ContrastDictDto 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 contrastId; + @ApiModelProperty(value = "字典编码") + private String colCode; + @ApiModelProperty(value = "字典名称") + private String colName; + @ApiModelProperty(value = "状态") + @NotNull(message = "状态不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String status; + @ApiModelProperty(value = "备注") + private String remark; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/dto/ContrastDto.java b/czsj-system/src/main/java/com/czsj/standard/dto/ContrastDto.java new file mode 100644 index 0000000..df0b056 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/dto/ContrastDto.java @@ -0,0 +1,48 @@ +package com.czsj.standard.dto; + +import com.czsj.metadata.validate.ValidationGroups; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import java.io.Serializable; + +/** + *+ * 对照表信息表 实体DTO + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@ApiModel(value = "对照表信息表Model") +@Data +public class ContrastDto 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 sourceId; + @ApiModelProperty(value = "数据源") + private String sourceName; + @ApiModelProperty(value = "数据表主键") + private String tableId; + @ApiModelProperty(value = "数据表") + private String tableName; + @ApiModelProperty(value = "数据表名称") + private String tableComment; + @ApiModelProperty(value = "对照字段主键") + private String columnId; + @ApiModelProperty(value = "对照字段") + private String columnName; + @ApiModelProperty(value = "对照字段名称") + private String columnComment; + @ApiModelProperty(value = "标准类别主键") + private String gbTypeId; + @ApiModelProperty(value = "绑定标准字段") + private String bindGbColumn; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/dto/DictDto.java b/czsj-system/src/main/java/com/czsj/standard/dto/DictDto.java new file mode 100644 index 0000000..86fd7b4 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/dto/DictDto.java @@ -0,0 +1,43 @@ +package com.czsj.standard.dto; + + +import com.czsj.metadata.validate.ValidationGroups; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; +import java.io.Serializable; +/** + *+ * 数据标准字典表 实体DTO + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@ApiModel(value = "数据标准字典表Model") +@Data +public class DictDto implements Serializable { + + private static final long serialVersionUID = 1L; + + @ApiModelProperty(value = "主键ID") + @NotBlank(message = "主键ID不能为空", groups = {ValidationGroups.Update.class}) + private String id; + @ApiModelProperty(value = "所属类别") + @NotBlank(message = "所属类别不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String typeId; + @ApiModelProperty(value = "标准编码") + @NotBlank(message = "标准编码不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String gbCode; + @ApiModelProperty(value = "标准名称") + @NotBlank(message = "标准名称不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String gbName; + @ApiModelProperty(value = "状态") + @NotNull(message = "状态不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String status; + @ApiModelProperty(value = "备注") + private String remark; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/dto/Endpoint.java b/czsj-system/src/main/java/com/czsj/standard/dto/Endpoint.java new file mode 100644 index 0000000..51e18c3 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/dto/Endpoint.java @@ -0,0 +1,18 @@ +package com.czsj.standard.dto; + +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import java.io.Serializable; + +@Data +public class Endpoint implements Serializable { + + private static final long serialVersionUID=1L; + + @NotBlank(message = "源端点不能为空") + private String sourceId; + + @NotBlank(message = "目标端点不能为空") + private String targetId; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/dto/ManualMappingDto.java b/czsj-system/src/main/java/com/czsj/standard/dto/ManualMappingDto.java new file mode 100644 index 0000000..61548d0 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/dto/ManualMappingDto.java @@ -0,0 +1,20 @@ +package com.czsj.standard.dto; + +import lombok.Data; + +import javax.validation.Valid; +import javax.validation.constraints.NotEmpty; +import javax.validation.constraints.Size; +import java.io.Serializable; +import java.util.List; + +@Data +public class ManualMappingDto implements Serializable { + + private static final long serialVersionUID=1L; + + @Valid + @NotEmpty(message = "对照关系不能为空") + @Size(min = 1, message="对照关系长度不能少于{min}位") + private List+ * 数据标准类别表 实体DTO + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@ApiModel(value = "数据标准类别表Model") +@Data +public class TypeDto implements Serializable { + + private static final long serialVersionUID=1L; + + @ApiModelProperty(value = "主键ID") + @NotBlank(message = "主键ID不能为空", groups = {ValidationGroups.Update.class}) + private String id; + @ApiModelProperty(value = "标准类别编码") + @NotBlank(message = "标准类别编码不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String gbTypeCode; + @ApiModelProperty(value = "标准类别名称") + @NotBlank(message = "标准类别名称不能为空", groups = {ValidationGroups.Insert.class, ValidationGroups.Update.class}) + private String gbTypeName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/entity/ContrastDictEntity.java b/czsj-system/src/main/java/com/czsj/standard/entity/ContrastDictEntity.java new file mode 100644 index 0000000..6184392 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/entity/ContrastDictEntity.java @@ -0,0 +1,88 @@ +package com.czsj.standard.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.czsj.core.database.base.DataScopeBaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +/** + *+ * 字典对照信息表 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@Accessors(chain = true) +@TableName(value = "standard_contrast_dict", autoResultMap = true) +public class ContrastDictEntity extends DataScopeBaseEntity { + + private static final long serialVersionUID=1L; + + /** + * 字典对照主键 + */ + private String contrastId; + + /** + * 数据源 + */ + @TableField(exist = false) + private String sourceName; + + /** + * 数据表 + */ + @TableField(exist = false) + private String tableName; + + /** + * 对照字段 + */ + @TableField(exist = false) + private String columnName; + + /** + * 标准类别编码 + */ + @TableField(exist = false) + private String gbTypeCode; + + /** + * 标准类别名称 + */ + @TableField(exist = false) + private String gbTypeName; + + /** + * 字典编码 + */ + private String colCode; + + /** + * 字典名称 + */ + private String colName; + + /** + * 对照的标准字典 + */ + private String contrastGbId; + + /** + * 对照的标准编码 + */ + @TableField(exist = false) + private String contrastGbCode; + + /** + * 对照的标准名称 + */ + @TableField(exist = false) + private String contrastGbName; + +} diff --git a/czsj-system/src/main/java/com/czsj/standard/entity/ContrastEntity.java b/czsj-system/src/main/java/com/czsj/standard/entity/ContrastEntity.java new file mode 100644 index 0000000..8b01376 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/entity/ContrastEntity.java @@ -0,0 +1,99 @@ +package com.czsj.standard.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.czsj.core.database.base.DataScopeBaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +/** + *+ * 对照表信息表 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@Accessors(chain = true) +@TableName(value = "standard_contrast", autoResultMap = true) +public class ContrastEntity extends DataScopeBaseEntity { + + private static final long serialVersionUID=1L; + + /** + * 数据源主键 + */ + private String sourceId; + + /** + * 数据源 + */ + private String sourceName; + + /** + * 数据表主键 + */ + private String tableId; + + /** + * 数据表 + */ + private String tableName; + + /** + * 数据表名称 + */ + private String tableComment; + + /** + * 对照字段主键 + */ + private String columnId; + + /** + * 对照字段 + */ + private String columnName; + + /** + * 对照字段名称 + */ + private String columnComment; + + /** + * 标准类别主键 + */ + private String gbTypeId; + + /** + * 标准类别编码 + */ + @TableField(exist = false) + private String gbTypeCode; + + /** + * 标准类别名称 + */ + @TableField(exist = false) + private String gbTypeName; + + /** + * 绑定标准字段 + */ + private String bindGbColumn; + + /** + * 对照数量 + */ + @TableField(exist = false) + private Integer mappingCount; + + /** + * 未对照数量 + */ + @TableField(exist = false) + private Integer unMappingCount; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/entity/DictEntity.java b/czsj-system/src/main/java/com/czsj/standard/entity/DictEntity.java new file mode 100644 index 0000000..30a0cb7 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/entity/DictEntity.java @@ -0,0 +1,52 @@ +package com.czsj.standard.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.czsj.core.database.base.DataScopeBaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +/** + *+ * 数据标准字典表 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@Accessors(chain = true) +@TableName("standard_dict") +public class DictEntity extends DataScopeBaseEntity { + + private static final long serialVersionUID=1L; + + /** + * 所属类别 + */ + private String typeId; + + /** + * 标准类别编码 + */ + @TableField(exist = false) + private String gbTypeCode; + + /** + * 标准类别名称 + */ + @TableField(exist = false) + private String gbTypeName; + + /** + * 标准编码 + */ + private String gbCode; + + /** + * 标准名称 + */ + private String gbName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/entity/TypeEntity.java b/czsj-system/src/main/java/com/czsj/standard/entity/TypeEntity.java new file mode 100644 index 0000000..6360b50 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/entity/TypeEntity.java @@ -0,0 +1,34 @@ +package com.czsj.standard.entity; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.czsj.core.database.base.DataScopeBaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +/** + *+ * 数据标准类别表 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@Accessors(chain = true) +@TableName("standard_type") +public class TypeEntity extends DataScopeBaseEntity { + + private static final long serialVersionUID=1L; + + /** + * 标准类别编码 + */ + private String gbTypeCode; + + /** + * 标准类别名称 + */ + private String gbTypeName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/mapper/ContrastDao.java b/czsj-system/src/main/java/com/czsj/standard/mapper/ContrastDao.java new file mode 100644 index 0000000..35ef510 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/mapper/ContrastDao.java @@ -0,0 +1,29 @@ +package com.czsj.standard.mapper; + + +import com.baomidou.mybatisplus.core.conditions.Wrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.Constants; +import com.czsj.core.database.base.BaseDao; +import com.czsj.standard.entity.ContrastEntity; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.io.Serializable; + +/** + *+ * 对照表信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper +public interface ContrastDao extends BaseDao+ * 字典对照信息表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper +public interface ContrastDictDao extends BaseDao+ * 数据标准字典表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Mapper +public interface DictDao extends BaseDao+ * 数据标准类别表 Mapper 接口 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Mapper +public interface TypeDao extends BaseDao+ * 字典对照信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper(componentModel = "spring") +public interface ContrastDictMapper extends EntityMapper+ * 对照表信息表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Mapper(componentModel = "spring") +public interface ContrastMapper extends EntityMapper+ * 数据标准字典表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Mapper(componentModel = "spring") +public interface DictMapper extends EntityMapper+ * 数据标准类别表 Mapper 实体映射 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Mapper(componentModel = "spring") +public interface TypeMapper extends EntityMapper+ * 字典对照信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class ContrastDictQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String contrastId; + private String colCode; + private String colName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/query/ContrastQuery.java b/czsj-system/src/main/java/com/czsj/standard/query/ContrastQuery.java new file mode 100644 index 0000000..58c89d6 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/query/ContrastQuery.java @@ -0,0 +1,24 @@ +package com.czsj.standard.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 对照表信息表 查询实体 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class ContrastQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String sourceName; + private String tableName; + private String columnName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/query/DictQuery.java b/czsj-system/src/main/java/com/czsj/standard/query/DictQuery.java new file mode 100644 index 0000000..d92a310 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/query/DictQuery.java @@ -0,0 +1,24 @@ +package com.czsj.standard.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 数据标准字典表 查询实体 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class DictQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String typeId; + private String gbCode; + private String gbName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/query/TypeQuery.java b/czsj-system/src/main/java/com/czsj/standard/query/TypeQuery.java new file mode 100644 index 0000000..4d48fe7 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/query/TypeQuery.java @@ -0,0 +1,23 @@ +package com.czsj.standard.query; + +import com.czsj.core.database.base.BaseQueryParams; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *+ * 数据标准类别表 查询实体 + *
+ * + * @author yuwei + * @since 2020-08-26 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class TypeQuery extends BaseQueryParams { + + private static final long serialVersionUID=1L; + + private String gbTypeCode; + private String gbTypeName; +} diff --git a/czsj-system/src/main/java/com/czsj/standard/service/ContrastDictService.java b/czsj-system/src/main/java/com/czsj/standard/service/ContrastDictService.java new file mode 100644 index 0000000..7b79309 --- /dev/null +++ b/czsj-system/src/main/java/com/czsj/standard/service/ContrastDictService.java @@ -0,0 +1,30 @@ +package com.czsj.standard.service; + + + +import com.czsj.core.database.base.BaseService; +import com.czsj.standard.dto.ContrastDictDto; +import com.czsj.standard.entity.ContrastDictEntity; + +import java.util.List; + +/** + *+ * 字典对照信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +public interface ContrastDictService extends BaseService+ * 对照表信息表 服务类 + *
+ * + * @author yuwei + * @since 2020-09-27 + */ +public interface ContrastService extends BaseService