Merge remote-tracking branch 'origin/dev' into dev

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

@@ -0,0 +1,65 @@
+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.QualityConfigCategoryConvert;
+import net.srt.entity.QualityConfigCategoryEntity;
+import net.srt.framework.common.utils.Result;
+import net.srt.framework.common.utils.TreeNodeVo;
+import net.srt.service.QualityConfigCategoryService;
+import net.srt.vo.QualityConfigCategoryVo;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.List;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.controller
+ * @Author: jpz
+ * @CreateTime: 2023/12/23 13:31
+ */
+@RestController
+@RequestMapping("/quality-config-category")
+@AllArgsConstructor
+@Tag(name = "数据治理-规则配置")
+public class QualityConfigCategoryController {
+    private final QualityConfigCategoryService qualityConfigCategoryService;
+
+    @GetMapping("/list-tree")
+    @Operation(summary = "获取规则配置数")
+    public Result<List<TreeNodeVo>> listTree(){
+        List<TreeNodeVo> list=qualityConfigCategoryService.listTree();
+        return Result.ok(list);
+    }
+    @GetMapping("{id}")
+    @Operation(summary = "信息")
+    public Result<QualityConfigCategoryVo> get(@PathVariable("id") Long id){
+        QualityConfigCategoryEntity entity=qualityConfigCategoryService.getById(id);
+        return Result.ok(QualityConfigCategoryConvert.INSTANCE.convert(entity));
+    }
+
+    @GetMapping()
+    @Operation(summary = "修改")
+    public Result<String> update(@RequestBody @Valid QualityConfigCategoryVo vo){
+        qualityConfigCategoryService.update(vo);
+        return Result.ok();
+    }
+    @PostMapping
+    @Operation(summary = "保存")
+    public Result<String> save(@RequestBody  QualityConfigCategoryVo vo){
+        qualityConfigCategoryService.save(vo);
+        return Result.ok();
+    }
+
+    @DeleteMapping("{id}")
+    @Operation(summary = "删除")
+    public Result<String> delete(@PathVariable Long id){
+        qualityConfigCategoryService.delete(id);
+        return Result.ok();
+    }
+
+
+
+}

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

@@ -0,0 +1,20 @@
+package net.srt.convert;
+
+import net.srt.entity.QualityConfigCategoryEntity;
+import net.srt.vo.QualityConfigCategoryVo;
+import org.mapstruct.Mapper;
+import org.mapstruct.factory.Mappers;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.convert
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 10:27
+ */
+@Mapper
+public interface QualityConfigCategoryConvert {
+    QualityConfigCategoryConvert INSTANCE = Mappers.getMapper(QualityConfigCategoryConvert.class);
+
+    QualityConfigCategoryEntity convert(QualityConfigCategoryVo vo);
+    QualityConfigCategoryVo convert(QualityConfigCategoryEntity entity);
+}

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

@@ -0,0 +1,15 @@
+package net.srt.dao;
+
+import net.srt.entity.QualityConfigCategoryEntity;
+import net.srt.framework.mybatis.dao.BaseDao;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.dao
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 9:47
+ */
+@Mapper
+public interface QualityConfigCategoryDao extends BaseDao<QualityConfigCategoryEntity> {
+}

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

@@ -0,0 +1,15 @@
+package net.srt.dao;
+
+import net.srt.entity.QualityConfigEntity;
+import net.srt.framework.mybatis.dao.BaseDao;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.dao
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 11:36
+ */
+@Mapper
+public interface QualityConfigDao extends BaseDao<QualityConfigEntity> {
+}

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

@@ -0,0 +1,53 @@
+package net.srt.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import net.srt.framework.mybatis.entity.BaseEntity;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.entity
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 9:20
+ */
+@EqualsAndHashCode(callSuper = false)
+@Data
+@TableName("data_governance_quality_config_category")
+public class QualityConfigCategoryEntity extends BaseEntity {
+    /**
+     * 0-普通目录 1-规则配置目录
+     */
+    private Integer type;
+
+    /**
+     * 父级id（顶级为0）
+     */
+    private Long parentId;
+
+    /**
+     * 目录名称
+     */
+    private String name;
+
+    /**
+     * 目录路径
+     */
+    private String path;
+
+    /**
+     * 序号
+     */
+    private Integer orderNo;
+
+    /**
+     * 描述
+     */
+    private String note;
+
+    /**
+     * 项目(租户)id
+     */
+    private Long projectId;
+
+}

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

@@ -0,0 +1,73 @@
+package net.srt.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldStrategy;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import net.srt.api.module.data.governance.dto.quality.QualityConfigParam;
+import net.srt.framework.mybatis.entity.BaseEntity;
+
+import java.util.List;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.entity
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 11:32
+ */
+@EqualsAndHashCode(callSuper = false)
+@Data
+@TableName(value = "data_governance_quality_config",autoResultMap = true)
+public class QualityConfigEntity extends BaseEntity {
+    /**
+     * 名称
+     */
+    private String name;
+
+    private Long categoryId;
+
+    /**
+     * 规则id
+     */
+    private Integer ruleId;
+
+    /**
+     * 个性化参数json
+     */
+    @TableField(typeHandler = JacksonTypeHandler.class)
+    private QualityConfigParam param;
+
+    /**
+     * 元数据字段列表
+     */
+    @TableField(typeHandler = JacksonTypeHandler.class)
+    private List<Integer> metadataIds;
+
+    /**
+     * 状态，1-启用，0-关闭
+     */
+    private Integer status;
+
+    /**
+     * 任务类型，1-一次性任务，2-周期任务
+     */
+    private Integer taskType;
+
+    /**
+     * cron表达式
+     */
+    @TableField(updateStrategy = FieldStrategy.IGNORED)
+    private String cron;
+
+    /**
+     * 备注
+     */
+    private String note;
+
+    /**
+     * 项目id
+     */
+    private Long projectId;
+}

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

@@ -0,0 +1,25 @@
+package net.srt.service;
+
+import net.srt.entity.QualityConfigCategoryEntity;
+import net.srt.framework.common.utils.TreeNodeVo;
+import net.srt.framework.mybatis.service.BaseService;
+import net.srt.vo.QualityConfigCategoryVo;
+
+import java.util.List;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.service
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 9:19
+ */
+
+public interface QualityConfigCategoryService extends BaseService<QualityConfigCategoryEntity> {
+    List<TreeNodeVo> listTree();
+
+    void update(QualityConfigCategoryVo vo);
+
+    void save(QualityConfigCategoryVo vo);
+
+    void delete(Long id);
+}

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

@@ -0,0 +1,101 @@
+package net.srt.service.impl;
+
+import com.alibaba.spring.util.BeanUtils;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import net.srt.convert.QualityConfigCategoryConvert;
+import net.srt.dao.QualityConfigCategoryDao;
+import net.srt.dao.QualityConfigDao;
+import net.srt.entity.QualityConfigCategoryEntity;
+import net.srt.entity.QualityConfigEntity;
+import net.srt.framework.common.exception.ServerException;
+import net.srt.framework.common.utils.BeanUtil;
+import net.srt.framework.common.utils.BuildTreeUtils;
+import net.srt.framework.common.utils.TreeNodeVo;
+import net.srt.framework.mybatis.service.impl.BaseServiceImpl;
+import net.srt.service.QualityConfigCategoryService;
+import net.srt.vo.QualityConfigCategoryVo;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import srt.cloud.framework.dbswitch.common.util.StringUtil;
+import srt.cloud.framework.dbswitch.pgwriter.util.StringUtils;
+
+import java.util.List;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.service.impl
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 9:46
+ */
+@Service
+@AllArgsConstructor
+public class QualityConfigCategoryServiceimpl extends BaseServiceImpl<QualityConfigCategoryDao, QualityConfigCategoryEntity> implements QualityConfigCategoryService {
+    private final QualityConfigDao qualityConfigDao;
+    @Override
+    public List<TreeNodeVo> listTree() {
+        LambdaQueryWrapper<QualityConfigCategoryEntity> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(QualityConfigCategoryEntity::getProjectId, getProjectId()).orderByAsc(QualityConfigCategoryEntity::getOrderNo);
+        List<QualityConfigCategoryEntity> list = baseMapper.selectList(wrapper);
+        List<TreeNodeVo> tree = BeanUtil.copyListProperties(list,TreeNodeVo::new,(oldItem,newItem)->{
+            newItem.setLabel(oldItem.getName());
+            newItem.setValue(oldItem.getId());
+            if (newItem.getPath().contains("/")){
+                newItem.setParentPath(newItem.getPath().substring(0, newItem.getPath().lastIndexOf("/")));
+            }
+        });
+
+
+        return BuildTreeUtils.buildTree(tree);
+    }
+
+    @Override
+    public void update(QualityConfigCategoryVo vo) {
+        QualityConfigCategoryEntity entity= QualityConfigCategoryConvert.INSTANCE.convert(vo);
+        entity.setProjectId(getProjectId());
+        entity.setPath(recursionPath(entity,null));
+        updateById(entity);
+    }
+
+    @Override
+    public void save(QualityConfigCategoryVo vo) {
+        QualityConfigCategoryEntity entity= QualityConfigCategoryConvert.INSTANCE.convert(vo);
+        entity.setProjectId(getProjectId());
+        entity.setPath(recursionPath(entity,null));
+        baseMapper.insert(entity);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void delete(Long id) {
+        LambdaQueryWrapper<QualityConfigCategoryEntity> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(QualityConfigCategoryEntity::getParentId,id).last("'limit 1");
+        QualityConfigCategoryEntity oneChild=baseMapper.selectOne(wrapper);
+        if (oneChild!=null){
+            throw new ServerException("存在子项,不可删除");
+        }
+        LambdaQueryWrapper<QualityConfigEntity> wrapper1 = Wrappers.lambdaQuery();
+        wrapper1.eq(QualityConfigEntity::getCategoryId,id).last("limit 1");
+        QualityConfigEntity qualityConfigEntity=qualityConfigDao.selectOne(wrapper1);
+        if (qualityConfigEntity!=null){
+            throw new ServerException("目录下存在规则配置,不可删除!");
+        }
+        removeById(id);
+
+
+    }
+
+    private String recursionPath(QualityConfigCategoryEntity entity, String path) {
+        if (StringUtil.isBlank(path)){
+            path=entity.getName();
+        }
+        if (entity.getParentId()!=0){
+            QualityConfigCategoryEntity parent=getById(entity.getParentId());
+            path=parent.getName()+"/"+path;
+            return recursionPath(parent,path);
+        }
+        return path;
+    }
+}

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

@@ -0,0 +1,66 @@
+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;
+
+/**
+ * @BelongsProject: srt_cloud
+ * @BelongsPackage: net.srt.vo
+ * @Author: jpz
+ * @CreateTime: 2023/12/24 10:22
+ */
+@Data
+@Schema(description = "数据治理-规则配置目录")
+public class QualityConfigCategoryVo implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    @Schema(description = "主键id")
+    private Long id;
+
+    @Schema(description = "0-普通目录 1-规则配置目录")
+    private Integer type;
+
+    @Schema(description = "父级id（顶级为0）")
+    private Long parentId;
+
+    @Schema(description = "目录名称")
+    private String name;
+
+    @Schema(description = "目录路径")
+    private String path;
+
+    @Schema(description = "序号")
+    private Integer orderNo;
+
+    @Schema(description = "描述")
+    private String note;
+
+    @Schema(description = "项目(租户)id")
+    private Long projectId;
+
+    @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;
+
+}