feat: 绑定零部件PDM相关部分

This commit is contained in:
2024-04-29 17:42:41 +08:00
parent d2de22b6eb
commit 55a820a5de
16 changed files with 335 additions and 48 deletions
@@ -1,177 +0,0 @@
package com.jero.modules.laws.bindPart.controller;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jero.common.api.vo.Result;
import com.jero.common.api.vo.ResultCommon;
import com.jero.common.aspect.annotation.AutoLog;
import com.jero.common.exception.JeroBootException;
import com.jero.common.util.MessageUtils;
import com.jero.modules.laws.bindPart.entity.BindPartStandardVO;
import com.jero.modules.laws.bindPart.entity.LawsBindPart;
import com.jero.modules.laws.bindPart.service.ILawsBindPartService;
import com.jero.modules.laws.documenttool.service.IDocumentSplitService;
import com.jero.modules.split.entity.SarFileSplitMenuEO;
import com.jero.modules.split.page.SarFileSplitMenuEOPage;
import com.jero.modules.split.service.ISarFileSplitMenuEOService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.formula.functions.T;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@Slf4j
@Api(tags="绑定零部件")
@RestController
@RequestMapping("/laws/bindPart")
public class LawsBindPartController {
@Autowired
private ILawsBindPartService lawsBindPartService;
@Resource
private IDocumentSplitService documentSplitService;
@Resource
private ISarFileSplitMenuEOService sarFileSplitMenuEOService;
@AutoLog(value = "绑定零部件-分页列表查询")
@ApiOperation(value="绑定零部件-分页列表查询", notes="绑定零部件-分页列表查询")
@GetMapping(value = "/page")
@RequiresPermissions("sys:bindingPart:search")
public Result<IPage<LawsBindPart>> queryPageList(LawsBindPart lawsBindPart,
@RequestParam(name="pageNo", defaultValue="1") @ApiParam("页码") Integer pageNo,
@RequestParam(name="pageSize", defaultValue="10") @ApiParam("页面显示数量") Integer pageSize,
HttpServletRequest req) {
IPage<LawsBindPart> pageList= lawsBindPartService.queryPage(lawsBindPart, pageNo, pageSize, req);
return Result.OK(pageList);
}
/**
* 添加
*
* @param lawsBindPart
* @return
*/
@AutoLog(value = "绑定零部件-添加")
@ApiOperation(value="绑定零部件-添加", notes="绑定零部件-添加")
@PostMapping(value = "/add")
@RequiresPermissions("sys:bindingPart:add")
public Result<T> add(@Validated @RequestBody LawsBindPart lawsBindPart) {
lawsBindPartService.add(lawsBindPart);
return Result.OK("操作成功!");
}
/**
* 编辑
*
* @param lawsBindPart
* @return
*/
@AutoLog(value = "绑定零部件-编辑")
@ApiOperation(value="绑定零部件-编辑", notes="绑定零部件-编辑")
@PostMapping(value = "/edit")
@RequiresPermissions("sys:bindingPart:edit")
public Result<T> edit(@Validated @RequestBody LawsBindPart lawsBindPart) {
lawsBindPartService.editById(lawsBindPart);
return Result.OK("操作成功!");
}
/**
* 通过id删除
*
* @param map
* @return
*/
@AutoLog(value = "绑定零部件-通过id删除")
@ApiOperation(value="绑定零部件-通过id删除", notes="绑定零部件-通过id删除")
@PostMapping(value = "/delete")
@RequiresPermissions("sys:bindingPart:delete")
public Result<T> delete(@RequestBody Map<String, String> map) {
if(!map.containsKey("id") || StringUtils.isEmpty(map.get("id"))){
return Result.error("请选择数据!");
}
lawsBindPartService.deleteById(map.get("id"));
return Result.OK("删除成功!");
}
/**
* 批量删除
*
* @param map
* @return
*/
@AutoLog(value = "绑定零部件-批量删除")
@ApiOperation(value="绑定零部件-批量删除", notes="绑定零部件-批量删除")
@PostMapping(value = "/deleteBatch")
@RequiresPermissions("sys:bindingPart:batchDel")
public Result<T> deleteBatch(@RequestBody Map<String, String> map) {
if(!map.containsKey("ids") || StringUtils.isEmpty(map.get("ids"))){
return Result.error("请选择数据!");
}
this.lawsBindPartService.deleteByIds(Arrays.asList(map.get("ids").split(",")));
return Result.OK("批量删除成功!");
}
/**
* 选择标准
*
* @return
*/
@AutoLog(value = "绑定零部件-选择标准")
@ApiOperation(value="绑定零部件-选择标准", notes="绑定零部件-选择标准")
@GetMapping(value = "/selectStandard")
public Result<IPage<BindPartStandardVO>> selectStandard(BindPartStandardVO bindPartStandardVO,
@RequestParam(name="pageNo", defaultValue="1") @ApiParam("页码") Integer pageNo,
@RequestParam(name="pageSize", defaultValue="10") @ApiParam("页面显示数量") Integer pageSize) {
IPage<BindPartStandardVO> pageList= lawsBindPartService.selectStandard(bindPartStandardVO, pageNo, pageSize);
return Result.OK(pageList);
}
/**
* 选择条款
*
* @return
*/
@AutoLog(value = "绑定零部件-条款列表")
@ApiOperation(value="绑定零部件-条款列表", notes="绑定零部件-条款列表")
@PostMapping(value = "/selectClause")
public Result<IPage<Map<String, Object>>> selectClause(@RequestBody Map<String, Object> parameter) {
try {
IPage<Map<String, Object>> data = documentSplitService.queryDocumentSplitDetail(parameter, false);
return Result.OK(data);
} catch (JeroBootException e){
return Result.error(e.getMessage());
} catch (Exception e){
return Result.error(MessageUtils.getMessage(ResultCommon.ERROR));
}
}
/**
* 选择条款
*
* @return
*/
@AutoLog(value = "绑定零部件-条款目录树")
@ApiOperation(value="绑定零部件-条款目录树", notes="绑定零部件-条款目录树")
@GetMapping(value = "/clauseTree")
public Result<List<SarFileSplitMenuEO>> clauseTree(SarFileSplitMenuEOPage page) {
page.setValidFlag("0");
page.setOrderBy("display_seq asc");
List<SarFileSplitMenuEO> getList = sarFileSplitMenuEOService.queryByList(page);
return Result.OK(getList);
}
}
@@ -1,70 +0,0 @@
package com.jero.modules.laws.bindPart.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.jero.common.aspect.annotation.Dict;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.Date;
/**
* @author: Mzaxd
* @Date: 2024/4/18 10:09
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class BindPartStandardVO implements Serializable {
/**
* id
*/
@ApiModelProperty(value = "id")
private String id;
/**
* 标准号
*/
@ApiModelProperty(value = "标准号")
private String standardNumber;
/**
* 标准名称
*/
@ApiModelProperty(value = "标准名称")
private String standardName;
/**
* 标准状态
*/
@ApiModelProperty(value = "标准状态")
@Dict(dicCode = "standard_state")
private String standardState;
/**
* 标准状态
*/
@ApiModelProperty(value = "企标标准状态")
@Dict(dicCode = "es_status")
private String esStandardState;
/**
* 发布日期
*/
@ApiModelProperty(value = "发布日期")
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd")
private Date releaseDate;
/**
* 标准类型(1:国内,2:海外,3:企业)
*/
@ApiModelProperty(value = "标准类型(1:国内,2:海外,3:企业)")
@Dict(dicCode = "standard_source")
private String standardType;
/**
* 拆分条款记录Id(选择条款用)
*/
@ApiModelProperty(value = "拆分条款记录Id(选择条款用)")
private String infoId;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}
@@ -1,135 +0,0 @@
package com.jero.modules.laws.bindPart.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 java.io.Serializable;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.jero.common.aspect.annotation.Dict;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
/**
*
* @TableName laws_bind_part
*/
@TableName(value ="laws_bind_part")
@Data
public class LawsBindPart implements Serializable {
/**
* 主键ID
*/
@TableId(type = IdType.ASSIGN_ID)
@ApiModelProperty(value = "主键ID")
private String id;
/**
* 创建人
*/
@ApiModelProperty(value = "创建人")
private String createBy;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
private Date createTime;
/**
* 更新人
*/
@ApiModelProperty(value = "更新人")
private String updateBy;
/**
* 更新时间
*/
@ApiModelProperty(value = "更新时间")
private Date updateTime;
/**
* 所属部门
*/
@ApiModelProperty(value = "所属部门")
private String orgCode;
/**
* 标准Id
*/
@ApiModelProperty(value = "标准Id")
private String standardId;
/**
* 标准类型
*/
@ApiModelProperty(value = "标准类型")
private String standardType;
/**
* 零部件号
*/
@ApiModelProperty(value = "零部件号")
private String partNo;
/**
* 零部件名称
*/
@ApiModelProperty(value = "零部件名称")
private String partName;
/**
* 文档拆分Id
*/
@ApiModelProperty(value = "文档拆分Id")
private String docSplitId;
/**
* 绑定人员
*/
@ApiModelProperty(value = "绑定人员")
@Dict(dicCode = "id", dictTable = "sys_user", dicText = "realname")
private String bindUser;
/**
* 绑定时间
*/
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm")
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm")
@ApiModelProperty(value = "绑定时间")
private Date bindTime;
/**
* 条款Id
*/
@ApiModelProperty(value = "条款Id(多个逗号拼接)")
@TableField(exist = false)
private String clauseIds;
/**
* 条款号
*/
@ApiModelProperty(value = "条款号(多个逗号拼接)")
@TableField(exist = false)
private String clauseNos;
/**
* 标准编号
*/
@ApiModelProperty(value = "标准编号")
@TableField(exist = false)
private String standardNo;
/**
* 标准名称
*/
@ApiModelProperty(value = "标准名称")
@TableField(exist = false)
private String standardName;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}
@@ -1,70 +0,0 @@
package com.jero.modules.laws.bindPart.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 java.io.Serializable;
import java.util.Date;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
*
* @TableName laws_bind_part_doc
*/
@TableName(value ="laws_bind_part_doc")
@Data
public class LawsBindPartDoc implements Serializable {
/**
* 主键ID
*/
@TableId(type = IdType.ASSIGN_ID)
@ApiModelProperty(value = "主键ID")
private String id;
/**创建人*/
@ApiModelProperty(value = "创建人")
private String createBy;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
private Date createTime;
/**
* 更新人
*/
@ApiModelProperty(value = "更新人")
private String updateBy;
/**
* 更新时间
*/
@ApiModelProperty(value = "更新时间")
private Date updateTime;
/**
* 所属部门
*/
@ApiModelProperty(value = "所属部门")
private String orgCode;
/**
* 绑定id
*/
@ApiModelProperty(value = "绑定id")
private String bindId;
/**
* 条款id
*/
@ApiModelProperty(value = "条款id")
private String clauseId;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}
@@ -1,18 +0,0 @@
package com.jero.modules.laws.bindPart.mapper;
import com.jero.modules.laws.bindPart.entity.LawsBindPartDoc;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* @author ThinkBook
* @description 针对表【laws_bind_part_doc】的数据库操作Mapper
* @createDate 2024-04-15 11:27:29
* @Entity com.jero.modules.laws.bindPart.entity.LawsBindPartDoc
*/
public interface LawsBindPartDocMapper extends BaseMapper<LawsBindPartDoc> {
}
@@ -1,22 +0,0 @@
package com.jero.modules.laws.bindPart.mapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jero.modules.laws.bindPart.entity.BindPartStandardVO;
import com.jero.modules.laws.bindPart.entity.LawsBindPart;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
/**
* @author ThinkBook
* @description 针对表【laws_bind_part】的数据库操作Mapper
* @createDate 2024-04-15 11:27:06
* @Entity com.jero.modules.laws.bindPart.entity.LawsBindPart
*/
public interface LawsBindPartMapper extends BaseMapper<LawsBindPart> {
IPage<LawsBindPart> page(IPage<LawsBindPart> page, @Param("param") LawsBindPart lawsBindPart);
}
@@ -1,23 +0,0 @@
<?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.jero.modules.laws.bindPart.mapper.LawsBindPartDocMapper">
<resultMap id="BaseResultMap" type="com.jero.modules.laws.bindPart.entity.LawsBindPartDoc">
<id property="id" column="id" jdbcType="VARCHAR"/>
<result property="createBy" column="create_by" jdbcType="VARCHAR"/>
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
<result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
<result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
<result property="orgCode" column="org_code" jdbcType="VARCHAR"/>
<result property="bindId" column="bind_id" jdbcType="VARCHAR"/>
<result property="docId" column="doc_id" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
id,create_by,create_time,
update_by,update_time,org_code,
bind_id,doc_id
</sql>
</mapper>
@@ -1,80 +0,0 @@
<?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.jero.modules.laws.bindPart.mapper.LawsBindPartMapper">
<resultMap id="BaseResultMap" type="com.jero.modules.laws.bindPart.entity.LawsBindPart">
<id property="id" column="id" jdbcType="VARCHAR"/>
<result property="createBy" column="create_by" jdbcType="VARCHAR"/>
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
<result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
<result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
<result property="orgCode" column="org_code" jdbcType="VARCHAR"/>
<result property="standardId" column="standard_id" jdbcType="VARCHAR"/>
<result property="standardType" column="standard_type" jdbcType="VARCHAR"/>
<result property="partNo" column="part_no" jdbcType="VARCHAR"/>
<result property="partName" column="part_name" jdbcType="VARCHAR"/>
<result property="docSplitId" column="doc_split_id" jdbcType="VARCHAR"/>
<result property="bindUser" column="bind_user" jdbcType="VARCHAR"/>
<result property="bindTime" column="bind_time" jdbcType="TIMESTAMP"/>
</resultMap>
<sql id="Base_Column_List">
id,create_by,create_time,
update_by,update_time,org_code,
part_no,part_name,standard_id,
bind_user,bind_time
</sql>
<select id="page" resultType="com.jero.modules.laws.bindPart.entity.LawsBindPart">
SELECT
bp.id,
bp.part_no,
bp.part_name,
bp.doc_split_id,
bp.standard_id,
bp.standard_type,
standard.standard_number AS standardNo,
standard.standard_name,
GROUP_CONCAT(lbpd.clause_id ORDER BY split.item_num SEPARATOR ',') AS clauseIds,
GROUP_CONCAT(split.item_num ORDER BY split.item_num SEPARATOR ',') AS clauseNos,
bp.bind_user,
bp.bind_time
FROM
`laws_bind_part` AS bp
LEFT JOIN (
select id, standard_number, standard_name from laws_enterprise_standard where del_flag = 0
UNION ALL
select id, standard_number, standard_name from laws_domestic_standard where del_flag = 0
UNION ALL
select id, standard_number, standard_name from laws_overseas_standard where del_flag = 0
) AS standard ON bp.standard_id = standard.id
LEFT JOIN sar_file_split_info AS sfsi ON bp.doc_split_id = sfsi.id
LEFT JOIN laws_bind_part_doc AS lbpd ON lbpd.bind_id = bp.id
LEFT JOIN laws_document_split AS split ON split.id = lbpd.clause_id
LEFT JOIN sys_user AS u ON u.id = bp.bind_user
<where>
<!--零部件号-->
<if test="param.partNo != null and param.partNo != ''">
AND bp.part_no LIKE CONCAT('%',#{param.partNo},'%')
</if>
<!--零部件名称-->
<if test="param.partName != null and param.partName != ''">
AND bp.part_name LIKE CONCAT('%',#{param.partName},'%')
</if>
<!--标准编号-->
<if test="param.standardNo != null and param.standardNo != ''">
AND standard.standard_number LIKE CONCAT('%',#{param.standardNo},'%')
</if>
<!--标准名称-->
<if test="param.standardName != null and param.standardName != ''">
AND standard.standard_name LIKE CONCAT('%',#{param.standardName},'%')
</if>
<!--绑定人员-->
<if test="param.bindUser != null and param.bindUser != ''">
AND CONCAT(u.realname, '(', u.username, ')') LIKE CONCAT('%',#{param.bindUser},'%')
</if>
</where>
GROUP BY
bp.id
</select>
</mapper>
@@ -1,13 +0,0 @@
package com.jero.modules.laws.bindPart.service;
import com.jero.modules.laws.bindPart.entity.LawsBindPartDoc;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* @author ThinkBook
* @description 针对表【laws_bind_part_doc】的数据库操作Service
* @createDate 2024-04-15 11:27:29
*/
public interface ILawsBindPartDocService extends IService<LawsBindPartDoc> {
}
@@ -1,78 +0,0 @@
package com.jero.modules.laws.bindPart.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jero.modules.laws.bindPart.entity.BindPartStandardVO;
import com.jero.modules.laws.bindPart.entity.LawsBindPart;
import com.baomidou.mybatisplus.extension.service.IService;
import com.jero.modules.laws.system.entity.LawsContactManage;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
/**
* @author ThinkBook
* @description 针对表【laws_bind_part】的数据库操作Service
* @createDate 2024-04-15 11:27:06
*/
public interface ILawsBindPartService extends IService<LawsBindPart> {
/**
* 分页查询
*
* @param lawsBindPart
* @param pageNo
* @param pageSize
* @param req
* @return
*/
IPage<LawsBindPart> queryPage(LawsBindPart lawsBindPart, Integer pageNo, Integer pageSize, HttpServletRequest req);
/**
* 保存
*
* @param lawsBindPart
* @return
*/
void add(LawsBindPart lawsBindPart);
/**
* 更新
*
* @param lawsBindPart
* @return
*/
void editById(LawsBindPart lawsBindPart);
/**
* 通过id删除
*
* @param id
* @return
*/
void deleteById(String id);
/**
* 批量删除
*
* @param ids
* @return
*/
void deleteByIds(List<String> ids);
/**
* 通过id查询
*
* @param id
* @return
*/
LawsBindPart queryById(String id);
/**
* 选择标准
* @param bindPartStandardVO
* @param pageNo
* @param pageSize
* @return
*/
IPage<BindPartStandardVO> selectStandard(BindPartStandardVO bindPartStandardVO, Integer pageNo, Integer pageSize);
}
@@ -1,22 +0,0 @@
package com.jero.modules.laws.bindPart.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jero.modules.laws.bindPart.entity.LawsBindPartDoc;
import com.jero.modules.laws.bindPart.service.ILawsBindPartDocService;
import com.jero.modules.laws.bindPart.mapper.LawsBindPartDocMapper;
import org.springframework.stereotype.Service;
/**
* @author ThinkBook
* @description 针对表【laws_bind_part_doc】的数据库操作Service实现
* @createDate 2024-04-15 11:27:29
*/
@Service
public class LawsBindPartDocServiceImpl extends ServiceImpl<LawsBindPartDocMapper, LawsBindPartDoc>
implements ILawsBindPartDocService {
}
@@ -1,233 +0,0 @@
package com.jero.modules.laws.bindPart.service.impl;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jero.common.constant.enums.TableEnum;
import com.jero.common.exception.JeroBootException;
import com.jero.modules.activiti.process.common.enums.StandardStateEnum;
import com.jero.modules.laws.bindPart.entity.BindPartStandardVO;
import com.jero.modules.laws.bindPart.entity.LawsBindPart;
import com.jero.modules.laws.bindPart.entity.LawsBindPartDoc;
import com.jero.modules.laws.bindPart.service.ILawsBindPartDocService;
import com.jero.modules.laws.bindPart.service.ILawsBindPartService;
import com.jero.modules.laws.bindPart.mapper.LawsBindPartMapper;
import com.jero.modules.laws.enterprise.util.BeanCopyUtils;
import com.jero.modules.laws.standard.controller.LawsDomesticController;
import com.jero.modules.laws.standard.controller.LawsOverseasController;
import com.jero.modules.laws.standard.entity.LawsDomesticStandard;
import com.jero.modules.laws.standard.entity.LawsEnterpriseStandard;
import com.jero.modules.laws.standard.entity.LawsOverseasStandard;
import com.jero.modules.laws.standard.service.ILawsDomesticStandardService;
import com.jero.modules.laws.standard.service.ILawsEnterpriseStandardService;
import com.jero.modules.laws.standard.service.ILawsOverseasStandardService;
import com.jero.modules.onlyoffice.entity.StandardFileType;
import com.jero.modules.split.entity.SarFileSplitInfoEO;
import com.jero.modules.split.service.ISarFileSplitInfoService;
import com.jero.modules.tag.enums.TableNameEnum;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.*;
import java.util.stream.Collectors;
import static com.jero.common.constant.CommonConstant.HAS_SEND;
/**
* @author ThinkBook
* @description 针对表【laws_bind_part】的数据库操作Service实现
* @createDate 2024-04-15 11:27:06
*/
@Service
public class LawsBindPartServiceImpl extends ServiceImpl<LawsBindPartMapper, LawsBindPart>
implements ILawsBindPartService {
@Resource
private LawsBindPartMapper lawsBindPartMapper;
@Resource
private ISarFileSplitInfoService fileSplitInfoService;
@Resource
private ILawsBindPartDocService lawsBindPartDocService;
@Resource
private ILawsDomesticStandardService gbService;
@Resource
private ILawsOverseasStandardService fbService;
@Resource
private ILawsEnterpriseStandardService esService;
@Override
public IPage<LawsBindPart> queryPage(LawsBindPart lawsBindPart, Integer pageNo, Integer pageSize, HttpServletRequest req) {
IPage<LawsBindPart> page = new Page<>(pageNo, pageSize);
lawsBindPartMapper.page(page, lawsBindPart);
return page;
}
@Override
public void add(LawsBindPart lawsBindPart) {
lawsBindPart.setBindTime(new Date());
save(lawsBindPart);
String clauseIds = lawsBindPart.getClauseIds();
this.saveBindPartDoc(clauseIds, lawsBindPart.getId());
}
private void saveBindPartDoc(String clauseIds, String bindId) {
if (StrUtil.isBlank(clauseIds)) {
return;
}
String[] clauseIdList = clauseIds.split(",");
List<LawsBindPartDoc> lawsBindPartDocList = new ArrayList<>();
for (String clause : clauseIdList) {
LawsBindPartDoc lawsBindPartDoc = new LawsBindPartDoc();
lawsBindPartDoc.setBindId(bindId);
lawsBindPartDoc.setClauseId(clause);
lawsBindPartDocList.add(lawsBindPartDoc);
}
lawsBindPartDocService.saveBatch(lawsBindPartDocList);
}
@Override
public void editById(LawsBindPart lawsBindPart) {
if (StrUtil.isBlank(lawsBindPart.getId())) {
throw new JeroBootException("id不能为空");
}
updateById(lawsBindPart);
// 清空关联关系
removeBindPartDoc(lawsBindPart.getId());
// 保存新关系
String clauseIds = lawsBindPart.getClauseIds();
this.saveBindPartDoc(clauseIds, lawsBindPart.getId());
}
private void removeBindPartDoc(String bindIds) {
if (StrUtil.isBlank(bindIds)) {
return;
}
List<String> bindIdList = Arrays.asList(bindIds.split(","));
LambdaQueryWrapper<LawsBindPartDoc> lawsBindPartDocLambdaQueryWrapper = new LambdaQueryWrapper<>();
lawsBindPartDocLambdaQueryWrapper.in(LawsBindPartDoc::getBindId, bindIdList);
lawsBindPartDocService.remove(lawsBindPartDocLambdaQueryWrapper);
}
@Override
public void deleteById(String id) {
removeById(id);
removeBindPartDoc(id);
}
@Override
public void deleteByIds(List<String> ids) {
removeByIds(ids);
removeBindPartDoc(ids.stream().map(String::valueOf).collect(Collectors.joining(",")));
}
@Override
public LawsBindPart queryById(String id) {
return getById(id);
}
@Override
public IPage<BindPartStandardVO> selectStandard(BindPartStandardVO bindPartStandardVO, Integer pageNo, Integer pageSize) {
String standardType = bindPartStandardVO.getStandardType();
String standardName = bindPartStandardVO.getStandardName();
IPage<BindPartStandardVO> resultPage = new Page<>(pageNo, pageSize);
List<BindPartStandardVO> records = new ArrayList<>();
if (StrUtil.isBlank(standardType) || standardType.equals(TableNameEnum.DOMESTIC_REGULATIONS.getValue())) {
IPage<LawsDomesticStandard> page = new Page<>(pageNo, pageSize);
LambdaQueryWrapper<LawsDomesticStandard> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.ne(LawsDomesticStandard::getStandardState, "7");
queryWrapper.like(StrUtil.isNotBlank(standardName), LawsDomesticStandard::getStandardNumber, standardName).or()
.like(StrUtil.isNotBlank(standardName),LawsDomesticStandard::getStandardName, standardName);
IPage<LawsDomesticStandard> lawsDomesticStandardIPage = gbService.page(page, queryWrapper);
records = BeanCopyUtils.copyBeanList(lawsDomesticStandardIPage.getRecords(), BindPartStandardVO.class);
records.forEach(r -> {
r.setStandardType(TableNameEnum.DOMESTIC_REGULATIONS.getValue());
});
resultPage.setPages(page.getPages())
.setCurrent(page.getCurrent())
.setSize(page.getSize())
.setTotal(page.getTotal())
.setRecords(records);
}
if (standardType.equals(TableNameEnum.FOREIGN_REGULATIONS.getValue())){
IPage<LawsOverseasStandard> page = new Page<>(pageNo, pageSize);
LambdaQueryWrapper<LawsOverseasStandard> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.ne(LawsOverseasStandard::getStandardState, "7");
queryWrapper.like(StrUtil.isNotBlank(standardName), LawsOverseasStandard::getStandardNumber, standardName).or()
.like(StrUtil.isNotBlank(standardName), LawsOverseasStandard::getStandardName, standardName);
IPage<LawsOverseasStandard> lawsOverseasStandardIPage = fbService.page(page, queryWrapper);
records = BeanCopyUtils.copyBeanList(lawsOverseasStandardIPage.getRecords(), BindPartStandardVO.class);
records.forEach(r -> {
r.setStandardType(TableNameEnum.FOREIGN_REGULATIONS.getValue());
});
resultPage.setPages(page.getPages())
.setCurrent(page.getCurrent())
.setSize(page.getSize())
.setTotal(page.getTotal())
.setRecords(records);
}
if (standardType.equals(TableNameEnum.ENTERPRISE_STANDARDS.getValue())){
IPage<LawsEnterpriseStandard> page = new Page<>(pageNo, pageSize);
LambdaQueryWrapper<LawsEnterpriseStandard> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.ne(LawsEnterpriseStandard::getStandardState, StandardStateEnum.ABOLISH);
queryWrapper.like(StrUtil.isNotBlank(standardName), LawsEnterpriseStandard::getStandardNumber, standardName).or()
.like(StrUtil.isNotBlank(standardName), LawsEnterpriseStandard::getStandardName, standardName);
IPage<LawsEnterpriseStandard> lawsEnterpriseStandardIPage = esService.page(page, queryWrapper);
records = BeanCopyUtils.copyBeanList(lawsEnterpriseStandardIPage.getRecords(), BindPartStandardVO.class);
records.forEach(r -> {
r.setEsStandardState(r.getStandardState());
r.setStandardType(TableNameEnum.ENTERPRISE_STANDARDS.getValue());
});
resultPage.setPages(page.getPages())
.setCurrent(page.getCurrent())
.setSize(page.getSize())
.setTotal(page.getTotal())
.setRecords(records);
}
// 获取所有标准Id
List<String> standardIdList = records.stream().map(BindPartStandardVO::getId).collect(Collectors.toList());
LambdaQueryWrapper<SarFileSplitInfoEO> sarFileSplitInfoEOLambdaQueryWrapper = new LambdaQueryWrapper<>();
sarFileSplitInfoEOLambdaQueryWrapper.isNotNull(SarFileSplitInfoEO::getStandardId);
sarFileSplitInfoEOLambdaQueryWrapper.in(!standardIdList.isEmpty(), SarFileSplitInfoEO::getStandardId, standardIdList);
sarFileSplitInfoEOLambdaQueryWrapper.eq(SarFileSplitInfoEO::getSplitStatus, HAS_SEND);
// 设置拆分信息id
List<SarFileSplitInfoEO> splitInfoEOList = fileSplitInfoService.list(sarFileSplitInfoEOLambdaQueryWrapper);
Map<String, List<SarFileSplitInfoEO>> map = splitInfoEOList.stream().collect(Collectors.groupingBy(SarFileSplitInfoEO::getStandardId));
// 创建映射:枚举的value到order的映射
Map<String, Integer> orderMap = java.util.Arrays.stream(StandardFileType.values())
.collect(Collectors.toMap(StandardFileType::getValue, StandardFileType::getOrder));
records.forEach(standard -> {
List<SarFileSplitInfoEO> sarFileSplitInfoEOS = map.get(standard.getId());
if (sarFileSplitInfoEOS == null || sarFileSplitInfoEOS.isEmpty()) {
return;
}
if (sarFileSplitInfoEOS.size() == 1) {
standard.setInfoId(sarFileSplitInfoEOS.get(0).getId());
}
// 需要对所有拆分信息按照文件类型排序
sarFileSplitInfoEOS.sort((file1, file2) -> {
Integer order1 = orderMap.get(file1.getFileType());
Integer order2 = orderMap.get(file2.getFileType());
return Integer.compare(order1, order2);
});
standard.setInfoId(sarFileSplitInfoEOS.get(0).getId());
});
// 设置编辑Id
return resultPage;
}
}