楚江ERP-审核配置

+package com.lframework.xingyun.basedata.bo.auditConfig;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.lframework.xingyun.basedata.entity.AuditConfig;
+import com.lframework.starter.common.constants.StringPool;
+import com.lframework.starter.web.core.bo.BaseBo;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModelProperty;
+
+import lombok.Data;
+
+/**
+ * <p>
+ * 审核流配置 GetBo
+ * </p>
+ *
+ */
+@Data
+public class GetAuditConfigBo extends BaseBo<AuditConfig> {
+
+    /**
+     * ID
+     */
+    @ApiModelProperty("ID")
+    private String id;
+
+    /**
+     * 类型
+     */
+    @ApiModelProperty("类型")
+    private String type;
+
+    /**
+     * 开启审核
+     */
+    @ApiModelProperty("开启审核")
+    private Boolean enableAudit;
+
+    /**
+     * 流程ID
+     */
+    @ApiModelProperty("流程ID")
+    private String processId;
+
+    /**
+     * 流程code
+     */
+    @ApiModelProperty("流程code")
+    private String processCode;
+
+    /**
+     * 流程名称
+     */
+    @ApiModelProperty("流程名称")
+    private String processName;
+
+    /**
+     * 创建人ID
+     */
+    @ApiModelProperty("创建人ID")
+    private String createById;
+
+    /**
+     * 创建人
+     */
+    @ApiModelProperty("创建人")
+    private String createBy;
+
+    /**
+     * 更新人ID
+     */
+    @ApiModelProperty("更新人ID")
+    private String updateById;
+
+    /**
+     * 更新人
+     */
+    @ApiModelProperty("更新人")
+    private String updateBy;
+
+    /**
+     * 创建时间
+     */
+    @ApiModelProperty("创建时间")
+    @JsonFormat(pattern = StringPool.DATE_TIME_PATTERN)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @ApiModelProperty("更新时间")
+    @JsonFormat(pattern = StringPool.DATE_TIME_PATTERN)
+    private LocalDateTime updateTime;
+
+    public GetAuditConfigBo() {
+
+    }
+
+    public GetAuditConfigBo(AuditConfig dto) {
+        super(dto);
+    }
+
+    @Override
+    public BaseBo<AuditConfig> convert(AuditConfig dto) {
+        return super.convert(dto, GetAuditConfigBo::getType);
+    }
+}

+package com.lframework.xingyun.basedata.controller;
+
+import com.lframework.starter.web.core.annotations.security.HasPermission;
+import com.lframework.starter.web.core.controller.DefaultBaseController;
+import com.lframework.xingyun.basedata.bo.auditConfig.GetAuditConfigBo;
+import com.lframework.xingyun.basedata.vo.auditConfig.BatchAuditConfigVo;
+import com.lframework.xingyun.basedata.vo.auditConfig.QueryAuditConfigVo;
+import com.lframework.xingyun.basedata.service.auditConfig.AuditConfigService;
+import com.lframework.xingyun.basedata.vo.auditConfig.CreateAuditConfigVo;
+import com.lframework.xingyun.basedata.entity.AuditConfig;
+
+import javax.annotation.Resource;
+import javax.validation.constraints.NotBlank;
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import io.swagger.annotations.ApiOperation;
+import com.lframework.starter.common.utils.CollectionUtil;
+import io.swagger.annotations.Api;
+import org.springframework.util.Assert;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import com.lframework.starter.web.core.components.resp.InvokeResult;
+import io.swagger.annotations.ApiImplicitParam;
+import com.lframework.starter.web.core.components.resp.InvokeResultBuilder;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 审核流配置 Controller
+ *
+ */
+@Api(tags = "审核流配置")
+@Validated
+@RestController
+@RequestMapping("/baseData/auditConfig")
+public class AuditConfigController extends DefaultBaseController {
+
+
+    @Resource
+    private AuditConfigService auditConfigService;
+
+
+    /**
+     * 查询列表
+     */
+    @ApiOperation("查询列表")
+    @HasPermission({"base-data:auditConfig:query"})
+    @GetMapping("/query")
+    public InvokeResult<List<GetAuditConfigBo>> query(@Valid QueryAuditConfigVo vo) {
+        List<AuditConfig> dataList = auditConfigService.query(vo);
+        List<GetAuditConfigBo> results = null;
+        if (!CollectionUtil.isEmpty(dataList)) {
+            results = dataList.stream().map(GetAuditConfigBo::new).collect(Collectors.toList());
+        }
+        return InvokeResultBuilder.success(results);
+    }
+
+    /**
+     * 根据ID查询
+     */
+    @ApiOperation("根据ID查询")
+    @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true)
+    @HasPermission({"base-data:auditConfig:query"})
+    @GetMapping
+    public InvokeResult<GetAuditConfigBo> get(@NotBlank(message = "id不能为空！") String id) {
+        AuditConfig data = auditConfigService.findById(id);
+        if (data == null) {
+            throw new DefaultClientException("审核流配置不存在！");
+        }
+        GetAuditConfigBo result = new GetAuditConfigBo(data);
+
+        return InvokeResultBuilder.success(result);
+    }
+
+    /**
+     * 新增
+     */
+    @ApiOperation("新增")
+    @HasPermission({"base-data:auditConfig:add"})
+    @PostMapping
+    public InvokeResult<Void> create(@Valid @RequestBody BatchAuditConfigVo vo) {
+        Assert.notNull(vo, "voList is empty!");
+        List<CreateAuditConfigVo> voList = vo.getCreateVoList();
+        Assert.notEmpty(voList, "voList is empty!");
+
+        auditConfigService.batchInsert(voList);
+        return InvokeResultBuilder.success();
+    }
+
+    /**
+     * 修改
+     */
+    @ApiOperation("修改")
+    @HasPermission({"base-data:auditConfig:modify"})
+    @PutMapping
+    public InvokeResult<Void> update(@Valid @RequestBody BatchAuditConfigVo vo) {
+        auditConfigService.update(vo.getUpdateVoList());
+        return InvokeResultBuilder.success();
+    }
+
+    /**
+     * 根据ID删除
+     */
+    @ApiOperation("根据ID删除")
+    @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true)
+    @HasPermission({"base-data:auditConfig:delete"})
+    @DeleteMapping
+    public InvokeResult<Void> deleteById(@NotBlank(message = "id不能为空！") String id) {
+        auditConfigService.deleteById(id);
+        return InvokeResultBuilder.success();
+    }
+}

+package com.lframework.xingyun.basedata.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.lframework.starter.web.core.dto.BaseDto;
+import java.time.LocalDateTime;
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.lframework.starter.web.core.entity.BaseEntity;
+import com.baomidou.mybatisplus.annotation.TableField;
+import lombok.Data;
+
+/**
+ * <p>
+ * 审核流配置
+ * </p>
+ *
+ */
+@Data
+@TableName("base_data_audit_config")
+public class AuditConfig extends BaseEntity implements BaseDto {
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String CACHE_NAME = "AuditConfig";
+
+    /**
+     * ID
+     */
+    private String id;
+
+    /**
+     * 类型
+     */
+    private String type;
+
+    /**
+     * 开启审核
+     */
+    private Boolean enableAudit;
+
+    /**
+     * 流程ID
+     */
+    private String processId;
+
+    /**
+     * 流程code
+     */
+    private String processCode;
+
+    /**
+     * 流程名称
+     */
+    private String processName;
+
+    /**
+     * 创建人ID
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private String createById;
+
+    /**
+     * 创建人
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private String createBy;
+
+    /**
+     * 更新人ID
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateById;
+
+    /**
+     * 更新人
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+
+}

+package com.lframework.xingyun.basedata.impl.auditConfig;
+
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.pagehelper.PageInfo;
+import com.lframework.xingyun.basedata.entity.AuditConfig;
+import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.utils.OpLogUtil;
+import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import com.lframework.starter.web.core.utils.IdUtil;
+import com.lframework.starter.common.utils.ObjectUtil;
+import com.lframework.starter.web.core.annotations.oplog.OpLog;
+import com.lframework.starter.web.core.utils.PageHelperUtil;
+import com.lframework.starter.common.utils.Assert;
+import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.BooleanUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.transaction.annotation.Transactional;
+import com.lframework.xingyun.basedata.mappers.AuditConfigMapper;
+import com.lframework.xingyun.basedata.service.auditConfig.AuditConfigService;
+import com.lframework.xingyun.basedata.vo.auditConfig.CreateAuditConfigVo;
+import com.lframework.xingyun.basedata.vo.auditConfig.QueryAuditConfigVo;
+import com.lframework.xingyun.basedata.vo.auditConfig.UpdateAuditConfigVo;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class AuditConfigServiceImpl extends BaseMpServiceImpl<AuditConfigMapper, AuditConfig> implements AuditConfigService {
+
+    @Override
+    public PageResult<AuditConfig> query(Integer pageIndex, Integer pageSize, QueryAuditConfigVo vo) {
+        Assert.greaterThanZero(pageIndex);
+        Assert.greaterThanZero(pageSize);
+
+        PageHelperUtil.startPage(pageIndex, pageSize);
+        List<AuditConfig> dataList = this.query(vo);
+
+        return PageResultUtil.convert(new PageInfo<>(dataList));
+    }
+
+    @Override
+    public List<AuditConfig> query(QueryAuditConfigVo vo) {
+        return getBaseMapper().query(vo);
+    }
+
+    @Override
+    public AuditConfig findById(String id) {
+        return getBaseMapper().selectById(id);
+    }
+
+    @OpLog(type = OtherOpLogType.class, name = "新增审核流配置，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void batchInsert(List<CreateAuditConfigVo> voList) {
+        List<AuditConfig> dataList = new ArrayList<>();
+        if (CollectionUtils.isEmpty(voList)) {
+            return;
+        }
+        for (CreateAuditConfigVo vo : voList) {
+            AuditConfig data = new AuditConfig();
+            data.setId(IdUtil.getId());
+            data.setType(vo.getType());
+            data.setEnableAudit(vo.getEnableAudit());
+            if (BooleanUtils.isTrue(vo.getEnableAudit()) && StringUtils.isBlank(vo.getProcessId())) {
+                throw new DefaultClientException("流程ID不能为空！");
+            }
+            if (!StringUtil.isBlank(vo.getProcessId())) {
+                data.setProcessId(vo.getProcessId());
+            }
+            dataList.add(data);
+        }
+        getBaseMapper().batchAdd(dataList);
+    }
+
+    @OpLog(type = OtherOpLogType.class, name = "修改审核流配置，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void update(UpdateAuditConfigVo vo) {
+        AuditConfig data = getBaseMapper().selectOne(
+                Wrappers.<AuditConfig>query()
+                        .eq("id", vo.getId())
+                        .select("id", "type", "enable_audit", "process_id")
+        );
+        if (ObjectUtil.isNull(data)) {
+            throw new DefaultClientException("审核流配置不存在！");
+        }
+        if (BooleanUtils.isTrue(vo.getEnableAudit()) && StringUtils.isBlank(vo.getProcessId())) {
+            throw new DefaultClientException("流程ID不能为空！");
+        }
+        LambdaUpdateWrapper<AuditConfig> updateWrapper = Wrappers.lambdaUpdate(AuditConfig.class)
+                .set(AuditConfig::getEnableAudit, vo.getEnableAudit())
+                .set(AuditConfig::getProcessId, BooleanUtils.isTrue(vo.getEnableAudit()) ? vo.getProcessId() : null)
+                .eq(AuditConfig::getId, vo.getId());
+
+        getBaseMapper().update(updateWrapper);
+
+        OpLogUtil.setVariable("id", data.getId());
+        OpLogUtil.setExtra(vo);
+    }
+
+    @OpLog(type = OtherOpLogType.class, name = "修改审核流配置，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void update(List<UpdateAuditConfigVo> voList) {
+        if (CollectionUtils.isEmpty(voList)) {
+            return;
+        }
+        // todo 此处后续可能需要优化（批量更新）
+        for (UpdateAuditConfigVo vo : voList) {
+            update(vo);
+        }
+    }
+
+    @OpLog(type = OtherOpLogType.class, name = "删除审核流配置，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void deleteById(String id) {
+        getBaseMapper().deleteById(id);
+    }
+}

+package com.lframework.xingyun.basedata.mappers;
+
+import com.lframework.xingyun.basedata.entity.AuditConfig;
+import com.lframework.starter.web.core.mapper.BaseMapper;
+import com.lframework.xingyun.basedata.vo.auditConfig.QueryAuditConfigVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 审核流配置 Mapper 接口
+ * </p>
+ *
+ */
+public interface AuditConfigMapper extends BaseMapper<AuditConfig> {
+
+	/**
+     * 查询列表
+     *
+     * @param vo 查询条件
+     * @return  List<AuditConfig>
+     */
+    List<AuditConfig> query(@Param("vo") QueryAuditConfigVo vo);
+
+
+    int batchAdd(@Param("list") List<AuditConfig> configList);
+}

+package com.lframework.xingyun.basedata.service.auditConfig;
+
+import com.lframework.xingyun.basedata.vo.auditConfig.CreateAuditConfigVo;
+import com.lframework.xingyun.basedata.vo.auditConfig.QueryAuditConfigVo;
+import com.lframework.xingyun.basedata.vo.auditConfig.UpdateAuditConfigVo;
+import com.lframework.xingyun.basedata.entity.AuditConfig;
+import com.lframework.starter.web.core.service.BaseMpService;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import java.util.List;
+
+/**
+ * 审核流配置 Service
+ */
+public interface AuditConfigService extends BaseMpService<AuditConfig> {
+
+    /**
+     * 查询列表
+     *
+     * @return  PageResult<AuditConfig>
+     */
+    PageResult<AuditConfig> query(Integer pageIndex, Integer pageSize, QueryAuditConfigVo vo);
+
+    /**
+     * 查询列表
+     *
+     * @param vo    查询条件
+     * @return  List<AuditConfig>
+     */
+    List<AuditConfig> query(QueryAuditConfigVo vo);
+
+    /**
+     * 根据ID查询
+     *
+     * @param id    主键ID
+     * @return  AuditConfig
+     */
+    AuditConfig findById(String id);
+
+    /**
+     * 创建
+     *
+     * @param voList    数据集
+     */
+    void batchInsert(List<CreateAuditConfigVo> voList);
+
+    /**
+     * 修改
+     *
+     * @param vo    数据实体
+     */
+    void update(UpdateAuditConfigVo vo);
+
+    /**
+     * 批量修改
+     *
+     * @param voList    数据集
+     */
+    void update(List<UpdateAuditConfigVo> voList);
+
+    /**
+     * 根据ID删除
+     *
+     * @param id    主键ID
+     */
+    void deleteById(String id);
+}

+package com.lframework.xingyun.basedata.vo.auditConfig;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import lombok.Data;
+
+import javax.validation.Valid;
+import java.io.Serializable;
+import java.util.List;
+
+@Data
+public class BatchAuditConfigVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @Valid
+    private List<CreateAuditConfigVo> createVoList;
+
+    @Valid
+    private List<UpdateAuditConfigVo> updateVoList;
+}

+package com.lframework.xingyun.basedata.vo.auditConfig;
+
+import javax.validation.constraints.NotBlank;
+import com.lframework.starter.web.core.vo.BaseVo;
+import javax.validation.constraints.NotNull;
+import io.swagger.annotations.ApiModelProperty;
+import com.lframework.starter.web.core.components.validation.TypeMismatch;
+import org.hibernate.validator.constraints.Length;
+import java.io.Serializable;
+import lombok.Data;
+
+@Data
+public class CreateAuditConfigVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 类型
+     */
+    @ApiModelProperty(value = "类型", required = true)
+    @NotBlank(message = "请选择类型！")
+    private String type;
+
+    /**
+     * 开启审核
+     */
+    @ApiModelProperty(value = "开启审核", required = true)
+    @NotNull(message = "请输入开启审核！")
+    @TypeMismatch(message = "开启审核格式有误！")
+    private Boolean enableAudit;
+
+    /**
+     * 流程ID
+     */
+    @ApiModelProperty("流程ID")
+    @Length(message = "流程ID最多允许32个字符！")
+    private String processId;
+}

+package com.lframework.xingyun.basedata.vo.auditConfig;
+
+import lombok.Data;
+import com.lframework.starter.web.core.vo.PageVo;
+import com.lframework.starter.web.core.vo.BaseVo;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+
+@Data
+public class QueryAuditConfigVo extends PageVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 类型
+     */
+    @ApiModelProperty("类型")
+    private String type;
+
+}

+package com.lframework.xingyun.basedata.vo.auditConfig;
+
+import lombok.Data;
+import javax.validation.constraints.NotBlank;
+import com.lframework.starter.web.core.vo.BaseVo;
+import javax.validation.constraints.NotNull;
+import com.lframework.starter.web.core.components.validation.TypeMismatch;
+import io.swagger.annotations.ApiModelProperty;
+import org.hibernate.validator.constraints.Length;
+import java.io.Serializable;
+
+@Data
+public class UpdateAuditConfigVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @ApiModelProperty(value = "ID", required = true)
+    @NotBlank(message = "id不能为空！")
+    private String id;
+
+    /**
+     * 开启审核
+     */
+    @ApiModelProperty(value = "开启审核", required = true)
+    @TypeMismatch(message = "开启审核格式有误！")
+    @NotNull(message = "请输入开启审核！")
+    private Boolean enableAudit;
+
+    /**
+     * 流程ID
+     */
+    @ApiModelProperty("流程ID")
+    @Length(message = "流程ID最多允许32个字符！")
+    private String processId;
+}

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.lframework.xingyun.basedata.mappers.AuditConfigMapper">
+
+    <resultMap id="AuditConfig" type="com.lframework.xingyun.basedata.entity.AuditConfig">
+        <id column="id" property="id"/>
+        <result column="type" property="type"/>
+        <result column="enable_audit" property="enableAudit"/>
+        <result column="process_id" property="processId"/>
+        <result column="flow_code" property="processCode"/>
+        <result column="flow_name" property="processName"/>
+        <result column="create_by_id" property="createById"/>
+        <result column="create_by" property="createBy"/>
+        <result column="update_by_id" property="updateById"/>
+        <result column="update_by" property="updateBy"/>
+        <result column="create_time" property="createTime"/>
+        <result column="update_time" property="updateTime"/>
+    </resultMap>
+
+    <sql id="AuditConfig_sql">
+        SELECT
+            tb.id,
+            tb.type,
+            tb.enable_audit,
+            tb.process_id,
+            tb.create_by_id,
+            tb.create_by,
+            tb.update_by_id,
+            tb.update_by,
+            tb.create_time,
+            tb.update_time,
+            f.flow_code,
+            f.flow_name
+        FROM base_data_audit_config AS tb
+        LEFT JOIN flow_definition f ON tb.process_id = f.id
+    </sql>
+
+    <select id="query" resultMap="AuditConfig">
+        <include refid="AuditConfig_sql"/>
+        <where>
+            <if test="vo.type != null">
+                AND tb.type = #{vo.type}
+            </if>
+        </where>
+    </select>
+
+    <insert id="batchAdd">
+        INSERT INTO base_data_audit_config (
+        id,
+        type,
+        enable_audit,
+        process_id,
+        create_by_id,
+        create_by,
+        update_by_id,
+        update_by,
+        create_time,
+        update_time
+        ) VALUES
+        <foreach collection="list" item="item" separator=",">
+            (
+            #{item.id},
+            #{item.type},
+            #{item.enableAudit},
+            #{item.processId},
+            #{item.createById},
+            #{item.createBy},
+            #{item.updateById},
+            #{item.updateBy},
+            #{item.createTime},
+            #{item.updateTime}
+            )
+        </foreach>
+    </insert>
+
+
+</mapper>