最新一版11.0

srt-cloud-data-governance/src/main/java/net/srt/controller/DatastandardController.java

@@ -9,10 +9,7 @@ import net.srt.framework.common.utils.Result;
 import net.srt.query.DatastandrdQuery;
 import net.srt.service.DatastandardService;
 import net.srt.vo.DatastandardVo;
-import net.srt.vo.MetamodelPropertyVO;
-import net.srt.vo.StandardManagementVo;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 
 import javax.validation.Valid;

srt-cloud-data-governance/src/main/java/net/srt/controller/MetadataCollectRecordController.java

@@ -4,7 +4,6 @@ import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.AllArgsConstructor;
 import net.srt.convert.MetadataCollectRecordConvert;
-import net.srt.entity.MetadataCollectQuery;
 import net.srt.entity.MetadataCollectRecordEntity;
 import net.srt.framework.common.page.PageResult;
 import net.srt.framework.common.utils.Result;

srt-cloud-data-governance/src/main/java/net/srt/controller/MetadataStandarRelController.java

@@ -0,0 +1,47 @@
+package net.srt.controller;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import net.srt.convert.MetadataStandardRelConvert;
+import net.srt.entity.MetadataStandardRelEntity;
+import net.srt.framework.common.utils.Result;
+import net.srt.service.MetadataStandardRelService;
+import net.srt.vo.MetadataStandardRelVO;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("standard-rel")
+@Tag(name = "数据治理-元数据标准关联表")
+@AllArgsConstructor
+public class MetadataStandarRelController {
+    private final MetadataStandardRelService metadataStandardRelService;
+
+    @GetMapping("/{metadataId}/{metadata-rel}")
+    @Operation(summary = "根据metadataId获取标准字段")
+    public Result<MetadataStandardRelVO> getMetadataRel(@PathVariable("metadataId") Long metadataId){
+        MetadataStandardRelVO standardRelVO = metadataStandardRelService.getMetadataRel(metadataId);
+        return Result.ok(standardRelVO);
+    }
+
+    @GetMapping("{id}")
+    @Operation(summary = "信息")
+    public Result<MetadataStandardRelVO> get(@PathVariable("id") Long id) {
+        MetadataStandardRelEntity entity = metadataStandardRelService.getById(id);
+        return Result.ok(MetadataStandardRelConvert.INSTANCE.convert(entity));
+    }
+
+    @PostMapping
+    @Operation(summary = "保存")
+    public Result<String> save(@RequestBody MetadataStandardRelVO vo){
+        metadataStandardRelService.save(vo);
+        return Result.ok();
+    }
+
+    @DeleteMapping("/{metadataId}/{standardId}")
+    @Operation(summary = "删除")
+    public Result<String> delete(@PathVariable Long metadataId,@PathVariable Long standardId){
+        metadataStandardRelService.delete(metadataId,standardId);
+        return Result.ok();
+    }
+}

srt-cloud-data-governance/src/main/java/net/srt/controller/MetamodelController.java

@@ -2,7 +2,6 @@ package net.srt.controller;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
-import io.swagger.v3.oas.annotations.tags.Tags;
 import lombok.AllArgsConstructor;
 import net.srt.convert.MetamodelConvert;
 import net.srt.entity.MetamodelEntity;

srt-cloud-data-governance/src/main/java/net/srt/controller/QualityRuleController.java

@@ -1,6 +1,5 @@
 package net.srt.controller;
 
-import cn.hutool.db.Page;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.AllArgsConstructor;

srt-cloud-data-governance/src/main/java/net/srt/controller/QualityTaskColumnController.java

@@ -1,6 +1,5 @@
 package net.srt.controller;
 
-import cn.hutool.db.Page;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.AllArgsConstructor;

srt-cloud-data-governance/src/main/java/net/srt/controller/QualityTaskController.java

@@ -2,7 +2,6 @@ package net.srt.controller;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
-import io.swagger.v3.oas.annotations.tags.Tags;
 import lombok.AllArgsConstructor;
 import net.srt.convert.QualityTaskConvert;
 import net.srt.entity.QualityTaskEntity;

srt-cloud-data-governance/src/main/java/net/srt/controller/StandardController.java

@@ -2,9 +2,6 @@ package net.srt.controller;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
-import net.srt.entity.DatastandardEntity;
-import net.srt.entity.StandardEntity;
-import net.srt.framework.common.utils.BeanUtil;
 import net.srt.framework.common.utils.Result;
 import net.srt.framework.common.utils.TreeNodeVo;
 import net.srt.service.StandardService;
@@ -12,8 +9,6 @@ import net.srt.vo.StandardManagementVo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import javax.validation.Valid;
-import java.util.ArrayList;
 import java.util.List;
 
 /**

srt-cloud-data-governance/src/main/java/net/srt/convert/DatastandardConvert.java

@@ -2,7 +2,6 @@ package net.srt.convert;
 
 import net.srt.entity.DatastandardEntity;
 import net.srt.vo.DatastandardVo;
-import net.srt.vo.StandardManagementVo;
 import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;
 

srt-cloud-data-governance/src/main/java/net/srt/convert/MetadataPropertyConvert.java

@@ -3,7 +3,7 @@ package net.srt.convert;
 import net.srt.api.module.data.governance.dto.DataGovernanceMetadataPropertyDto;
 import net.srt.entity.MetadataPropertyEntity;
 import net.srt.vo.MetadataPropertyVo;
-import org.apache.ibatis.annotations.Mapper;
+import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;
 
 import java.util.List;

srt-cloud-data-governance/src/main/java/net/srt/convert/MetadataStandardRelConvert.java

@@ -0,0 +1,20 @@
+package net.srt.convert;
+
+import net.srt.entity.MetadataStandardRelEntity;
+import net.srt.vo.MetadataStandardRelVO;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
+@Mapper
+public interface MetadataStandardRelConvert {
+    MetadataStandardRelConvert INSTANCE = Mappers.getMapper(MetadataStandardRelConvert.class);
+
+    MetadataStandardRelEntity convert(MetadataStandardRelVO vo);
+
+    MetadataStandardRelVO convert(MetadataStandardRelEntity entity);
+
+    List<MetadataStandardRelVO> convertList(List<MetadataStandardRelEntity> list);
+
+}

srt-cloud-data-governance/src/main/java/net/srt/convert/MetamodelConvert.java

@@ -4,7 +4,6 @@ import net.srt.entity.MetamodelEntity;
 import net.srt.vo.MetamodelVO;
 import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;
-import org.springframework.stereotype.Component;
 
 import java.util.List;
 @Mapper

srt-cloud-data-governance/src/main/java/net/srt/convert/QualityTaskColumnConvert.java

@@ -1,8 +1,6 @@
 package net.srt.convert;
 
-import net.srt.entity.QualityQueryEntity;
 import net.srt.entity.QualityTaskColumnEntity;
-import net.srt.vo.QualityRuleVo;
 import net.srt.vo.QualityTaskColumnVo;
 import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;

srt-cloud-data-governance/src/main/java/net/srt/convert/QualityTaskConvert.java

@@ -1,13 +1,10 @@
 package net.srt.convert;
 
-import net.srt.controller.QualityTaskController;
 import net.srt.entity.QualityTaskEntity;
 import net.srt.vo.QualityTaskVo;
 import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;
-import org.springframework.stereotype.Component;
 
-import javax.swing.*;
 import java.util.List;
 
 /**

srt-cloud-data-governance/src/main/java/net/srt/dao/MetadataStandardRelDao.java

@@ -0,0 +1,9 @@
+package net.srt.dao;
+
+import net.srt.entity.MetadataStandardRelEntity;
+import net.srt.framework.mybatis.dao.BaseDao;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface MetadataStandardRelDao extends BaseDao<MetadataStandardRelEntity> {
+}

srt-cloud-data-governance/src/main/java/net/srt/dao/QualityTaskColumnDao.java

@@ -1,8 +1,6 @@
 package net.srt.dao;
 
 import net.srt.entity.QualityTaskColumnEntity;
-import net.srt.entity.QualityTaskEntity;
-import net.srt.entity.QualityTaskTableEntity;
 import net.srt.framework.mybatis.dao.BaseDao;
 import org.apache.ibatis.annotations.Mapper;
 

srt-cloud-data-governance/src/main/java/net/srt/dao/QualityTaskTableDao.java

@@ -1,6 +1,5 @@
 package net.srt.dao;
 
-import net.srt.entity.QualityTaskEntity;
 import net.srt.entity.QualityTaskTableEntity;
 import net.srt.framework.mybatis.dao.BaseDao;
 import org.apache.ibatis.annotations.Mapper;

srt-cloud-data-governance/src/main/java/net/srt/entity/DatastandardEntity.java

@@ -1,6 +1,5 @@
 package net.srt.entity;
 
-import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.Data;
 import lombok.EqualsAndHashCode;

srt-cloud-data-governance/src/main/java/net/srt/entity/MetadataStandardEntity.java

@@ -0,0 +1,76 @@
+package net.srt.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import net.srt.framework.mybatis.entity.BaseEntity;
+
+@EqualsAndHashCode(callSuper = false)
+@Data
+@TableName("data_governance_standard")
+public class MetadataStandardEntity extends BaseEntity {
+
+    /**
+     * 所属目录id
+     */
+    private Long categoryId;
+
+    /**
+     * 标准英文名称
+     */
+    private String engName;
+
+    /**
+     * 标准中文名称
+     */
+    private String cnName;
+
+    /**
+     * 编码数
+     */
+    private Integer codeNum;
+
+    /**
+     * 数据类型 数字，字符串，日期，小数
+     */
+    private String dataType;
+
+    /**
+     * 长度
+     */
+    private Integer dataLength;
+
+    /**
+     * 精度
+     */
+    private Integer dataPrecision;
+
+    /**
+     * 非空 0-否 1-是
+     */
+    private Integer nullable;
+
+    /**
+     * 标准码表id
+     */
+    private Integer standardCodeId;
+
+    /**
+     * 1-标准字段 2-标准码表
+     */
+    private Integer type;
+
+    /**
+     * 描述
+     */
+    private String note;
+
+    /**
+     * 项目（租户）id
+     */
+    private Long projectId;
+
+    private Integer status;
+
+
+}

srt-cloud-data-governance/src/main/java/net/srt/entity/MetadataStandardRelEntity.java

@@ -0,0 +1,29 @@
+package net.srt.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import net.srt.framework.mybatis.entity.BaseEntity;
+
+@EqualsAndHashCode(callSuper = false)
+@Data
+@TableName("data_governance_metadata_standard_rel")
+public class MetadataStandardRelEntity extends BaseEntity {
+
+    /**
+     * 元数据id
+     */
+    private Long metadataId;
+
+    /**
+     * 标准字段id
+     */
+    private Long standardId;
+
+    /**
+     * 真删除
+     */
+    private Integer deleted;
+
+
+}

srt-cloud-data-governance/src/main/java/net/srt/service/MetadataStandardRelService.java

@@ -0,0 +1,13 @@
+package net.srt.service;
+
+import net.srt.entity.MetadataStandardRelEntity;
+import net.srt.framework.mybatis.service.BaseService;
+import net.srt.vo.MetadataStandardRelVO;
+
+public interface MetadataStandardRelService extends BaseService<MetadataStandardRelEntity> {
+    void delete(Long metadataId, Long standardId);
+
+    MetadataStandardRelVO getMetadataRel(Long metadataId);
+
+    void save(MetadataStandardRelVO vo);
+}

srt-cloud-data-governance/src/main/java/net/srt/service/impl/MetadataStandardRelServiceImpl.java

@@ -0,0 +1,57 @@
+package net.srt.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import lombok.AllArgsConstructor;
+import net.srt.convert.MetadataStandardRelConvert;
+import net.srt.dao.MetadataStandardRelDao;
+import net.srt.dao.StandardDao;
+import net.srt.entity.MetadataStandardRelEntity;
+import net.srt.entity.StandardEntity;
+import net.srt.framework.mybatis.service.impl.BaseServiceImpl;
+import net.srt.service.MetadataStandardRelService;
+import net.srt.vo.MetadataStandardRelVO;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@AllArgsConstructor
+public class MetadataStandardRelServiceImpl extends BaseServiceImpl<MetadataStandardRelDao, MetadataStandardRelEntity> implements MetadataStandardRelService {
+    private final StandardDao standardDao;
+
+    @Override
+    public MetadataStandardRelVO getMetadataRel(Long metadataId) {
+        LambdaQueryWrapper<MetadataStandardRelEntity> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(MetadataStandardRelEntity::getMetadataId,metadataId).last("limit 1");
+        MetadataStandardRelEntity relEntity = baseMapper.selectOne(wrapper);
+        if(relEntity!=null){
+            StandardEntity standardEntity = standardDao.selectById(relEntity.getStandardId());
+            MetadataStandardRelVO convert = MetadataStandardRelConvert.INSTANCE.convert(relEntity);
+            convert.setStandardCategoryId(standardEntity.getParentId());
+            return convert;
+        }
+        return null;
+    }
+
+    @Override
+    public void save(MetadataStandardRelVO vo) {
+        MetadataStandardRelEntity entity = MetadataStandardRelConvert.INSTANCE.convert(vo);
+        LambdaQueryWrapper<MetadataStandardRelEntity> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(MetadataStandardRelEntity::getMetadataId,vo.getMetadataId()).eq(MetadataStandardRelEntity::getStandardId,vo.getStandardId()).last("limit 1");
+        MetadataStandardRelEntity relEntity = baseMapper.selectOne(wrapper);
+        if(relEntity!=null) {
+            entity.setId(relEntity.getId());
+            baseMapper.updateById(entity);
+        }else {
+            baseMapper.insert(entity);
+        }
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void delete(Long metadataId, Long standardId) {
+        LambdaQueryWrapper<MetadataStandardRelEntity> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(MetadataStandardRelEntity::getMetadataId,metadataId).eq(MetadataStandardRelEntity::getStandardId,standardId);
+        baseMapper.delete(wrapper);
+    }
+}

srt-cloud-data-governance/src/main/java/net/srt/vo/MetadataCollectRecordRelVO.java

@@ -0,0 +1,49 @@
+package net.srt.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import net.srt.framework.common.utils.DateUtils;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+@Schema(description = "数据治理-元数据标准关联表")
+public class MetadataCollectRecordRelVO implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+
+    @Schema(description = "主键id")
+    private Long id;
+
+    @Schema(description = "元数据id")
+    private Long metadataId;
+
+    @Schema(description = "标准字段id")
+    private Long standardId;
+
+    @Schema(description = "版本号")
+    private Integer version;
+
+    @Schema(description = "删除标识  0：正常   1：已删除")
+    private Integer deleted;
+
+    @Schema(description = "创建者")
+    private Long creator;
+
+    @Schema(description = "创建时间")
+    @JsonFormat(pattern = DateUtils.DATE_TIME_PATTERN)
+    private Date createTime;
+
+    @Schema(description = "更新者")
+    private Long updater;
+
+    @Schema(description = "更新时间")
+    @JsonFormat(pattern = DateUtils.DATE_TIME_PATTERN)
+    private Date updateTime;
+
+    private Long standardCategoryId;
+
+
+}

srt-cloud-data-governance/src/main/java/net/srt/vo/MetadataStandardRelVO.java

@@ -0,0 +1,48 @@
+package net.srt.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import net.srt.framework.common.utils.DateUtils;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+@Schema(description = "数据治理-元数据标准关联表")
+public class MetadataStandardRelVO implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @Schema(description = "主键id")
+    private Long id;
+
+    @Schema(description = "元数据id")
+    private Long metadataId;
+
+    @Schema(description = "标准字段id")
+    private Long standardId;
+
+    @Schema(description = "版本号")
+    private Integer version;
+
+    @Schema(description = "删除标识  0：正常   1：已删除")
+    private Integer deleted;
+
+    @Schema(description = "创建者")
+    private Long creator;
+
+    @Schema(description = "创建时间")
+    @JsonFormat(pattern = DateUtils.DATE_TIME_PATTERN)
+    private Date createTime;
+
+    @Schema(description = "更新者")
+    private Long updater;
+
+    @Schema(description = "更新时间")
+    @JsonFormat(pattern = DateUtils.DATE_TIME_PATTERN)
+    private Date updateTime;
+
+    private Long standardCategoryId;
+
+
+}