feat(企标稽查流程): 基础模块添加

(cherry picked from commit 295aaaadfe)
This commit is contained in:
yjz
2023-11-23 13:43:38 +08:00
parent d78bc5dd4e
commit c5b2ccf545
21 changed files with 990 additions and 49 deletions
@@ -0,0 +1,112 @@
package com.jero.modules.activiti.process.esinspect.controller;
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.aspect.annotation.Translation;
import com.jero.common.util.MessageUtils;
import com.jero.common.util.SnowflakeUtils;
import com.jero.modules.activiti.process.esinspect.service.IEsInspectFlowService;
import com.jero.modules.activiti.process.esinspect.vo.EsInspectFlowVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.context.annotation.Lazy;
import org.springframework.web.bind.annotation.*;
/**
* @ClassName: EsInspectFlowController
* @Description:
* @Author: yjz
* @Date: 2023-11-23 09:22
* @Version: 1.0
**/
@Api(tags="企标稽查流程")
@RestController
@RequestMapping("/esinspect/esInspectFlowController")
@Slf4j
public class EsInspectFlowController {
private final IEsInspectFlowService esInspectFlowService;
public EsInspectFlowController(@Lazy IEsInspectFlowService esInspectFlowService) {
this.esInspectFlowService = esInspectFlowService;
}
/**
* 企标稽查流程-生成项目id
* @return 项目id
*/
@AutoLog(value = "企标稽查流程-生成项目id")
@ApiOperation(value="企标稽查流程-生成项目id", notes="企标稽查流程-生成项目id")
@GetMapping(value = "/getProjectId")
public String getProjectId() {
return String.valueOf(SnowflakeUtils.snowflake());
}
/**
* 企标稽查流程-流程发起
* @param esInspectFlowVO 企标稽查流程VO对象
* @return 结果对象
*/
@AutoLog(value = "企标稽查流程-流程发起")
@ApiOperation(value="企标稽查流程-流程发起", notes="企标稽查流程-流程发起")
@PostMapping(value = "/flowStart")
public Result<T> flowStart(@RequestBody EsInspectFlowVO esInspectFlowVO) {
esInspectFlowService.flowStart(esInspectFlowVO);
return Result.OK(MessageUtils.getMessage(ResultCommon.OK));
}
/**
* 企标稽查流程-流程保存
* @param esInspectFlowVO 企标稽查流程VO对象
* @return 结果对象
*/
@AutoLog(value = "企标稽查流程-流程保存")
@ApiOperation(value="企标稽查流程-流程保存", notes="企标稽查流程-流程保存")
@PostMapping(value = "/flowSave")
public Result<T> flowSave(@RequestBody EsInspectFlowVO esInspectFlowVO) {
esInspectFlowService.flowSave(esInspectFlowVO);
return Result.OK(MessageUtils.getMessage(ResultCommon.OK));
}
/**
* 企标稽查流程-办理详情
* @param projectId 项目id
* @return 结果对象
*/
@AutoLog(value = "企标稽查流程-办理详情")
@ApiOperation(value="企标稽查流程-办理详情", notes="企标稽查流程-办理详情")
@GetMapping(value = "/queryDetailByProjectId")
@Translation
public Result<EsInspectFlowVO> queryDetailByProjectId(@ApiParam("项目id") String projectId, @ApiParam("任务id") String taskId) {
return Result.OK(esInspectFlowService.queryDetailByProjectId(projectId, taskId));
}
/**
* 企标稽查流程-流程审批
* @param esInspectFlowVO 企标稽查流程VO对象
* @return 结果对象
*/
@AutoLog(value = "企标稽查流程-流程审批")
@ApiOperation(value="企标稽查流程-流程审批", notes="企标稽查流程-流程审批")
@PostMapping(value = "/flowApproval")
public Result<T> flowApproval(@RequestBody EsInspectFlowVO esInspectFlowVO) {
esInspectFlowService.flowApproval(esInspectFlowVO);
return Result.OK(MessageUtils.getMessage(ResultCommon.OK));
}
/**
* 企标稽查流程-流程转办
* @return 结果对象
*/
@AutoLog(value = "企标稽查流程-流程转办")
@ApiOperation(value="企标稽查流程-流程转办", notes="企标稽查流程-流程转办")
@GetMapping(value = "/flowTransfer")
public Result<T> flowTransfer(@ApiParam("任务id") String taskId, @ApiParam("用户id") String userId) {
esInspectFlowService.flowTransfer(taskId, userId);
return Result.OK(MessageUtils.getMessage(ResultCommon.OK));
}
}
@@ -0,0 +1,177 @@
package com.jero.modules.activiti.process.esinspect.controller;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.jero.common.api.vo.Result;
import com.jero.common.aspect.annotation.AutoLog;
import com.jero.common.system.base.controller.JeroController;
import com.jero.modules.activiti.process.esinspect.entity.ProcessEsInspect;
import com.jero.modules.activiti.process.esinspect.service.IProcessEsInspectService;
import com.jero.modules.activiti.process.esinspect.vo.ProcessEsInspectVO;
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.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
/**
* @Description: 企标稽查流程业务表
* @Author: jero-boot
* @Date: 2023-11-22
* @Version: V1.0
*/
@Api(tags="企标稽查流程业务表")
@RestController
@RequestMapping("/esinspect/processEsInspect")
@Slf4j
public class ProcessEsInspectController extends JeroController<ProcessEsInspect, IProcessEsInspectService> {
private final IProcessEsInspectService processEsInspectService;
public ProcessEsInspectController(IProcessEsInspectService processEsInspectService) {
this.processEsInspectService = processEsInspectService;
}
/**
* 分页列表查询
*
* @param processEsInspect
* @param pageNo
* @param pageSize
* @param req
* @return
*/
@AutoLog(value = "企标稽查流程业务表-分页列表查询")
@ApiOperation(value="企标稽查流程业务表-分页列表查询", notes="企标稽查流程业务表-分页列表查询")
@GetMapping(value = "/queryByPage")
public Result<IPage<ProcessEsInspectVO>> queryByPage(ProcessEsInspectVO processEsInspectVO,
@ApiParam("当前页") @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
@ApiParam("每页条数") @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
return Result.OK(processEsInspectService.queryByPage(processEsInspectVO, pageNo, pageSize));
}
/**
* 列表查询
*
* @param processEsInspectVO
* @return
*/
@AutoLog(value = "企标稽查流程业务表-列表查询")
@ApiOperation(value="企标稽查流程业务表-列表查询", notes="企标稽查流程业务表-列表查询")
@GetMapping(value = "/queryByList")
public Result<List<ProcessEsInspectVO>> queryByList(ProcessEsInspectVO processEsInspectVO) {
return Result.OK(processEsInspectService.queryByList(processEsInspectVO));
}
/**
* 添加
*
* @param processEsInspect
* @return
*/
@AutoLog(value = "企标稽查流程业务表-添加")
@ApiOperation(value="企标稽查流程业务表-添加", notes="企标稽查流程业务表-添加")
@PostMapping(value = "/add")
public Result<T> add(@Validated @RequestBody ProcessEsInspect processEsInspect) {
processEsInspectService.add(processEsInspect);
return Result.OK("操作成功!");
}
/**
* 编辑
*
* @param processEsInspect
* @return
*/
@AutoLog(value = "企标稽查流程业务表-编辑")
@ApiOperation(value="企标稽查流程业务表-编辑", notes="企标稽查流程业务表-编辑")
@PostMapping(value = "/edit")
public Result<T> edit(@Validated @RequestBody ProcessEsInspect processEsInspect) {
processEsInspectService.editById(processEsInspect);
return Result.OK("操作成功!");
}
/**
* 通过id删除
*
* @param map
* @return
*/
@AutoLog(value = "企标稽查流程业务表-通过id删除")
@ApiOperation(value="企标稽查流程业务表-通过id删除", notes="企标稽查流程业务表-通过id删除")
@PostMapping(value = "/delete")
public Result<T> delete(@RequestBody Map<String, String> map) {
if(!map.containsKey("id") || StringUtils.isEmpty(map.get("id"))){
return Result.error("请选择数据!");
}
processEsInspectService.deleteById(map.get("id"));
return Result.OK("删除成功!");
}
/**
* 批量删除
*
* @param map
* @return
*/
@AutoLog(value = "企标稽查流程业务表-批量删除")
@ApiOperation(value="企标稽查流程业务表-批量删除", notes="企标稽查流程业务表-批量删除")
@PostMapping(value = "/deleteBatch")
public Result<T> deleteBatch(@RequestBody Map<String, String> map) {
if(!map.containsKey("ids") || StringUtils.isEmpty(map.get("ids"))){
return Result.error("请选择数据!");
}
this.processEsInspectService.deleteByIds(Arrays.asList(map.get("ids").split(",")));
return Result.OK("批量删除成功!");
}
/**
* 通过id查询
*
* @param id
* @return
*/
@AutoLog(value = "企标稽查流程业务表-通过id查询")
@ApiOperation(value="企标稽查流程业务表-通过id查询", notes="企标稽查流程业务表-通过id查询")
@GetMapping(value = "/queryById")
public Result<ProcessEsInspect> queryById(@RequestParam(name="id",required=true) String id) {
ProcessEsInspect processEsInspect = processEsInspectService.queryById(id);
if(processEsInspect==null) {
return Result.error("未找到对应数据");
}
return Result.OK(processEsInspect);
}
/**
* 导出excel
*
* @param request
* @param processEsInspect
*/
@RequestMapping(value = "/exportXls")
public ModelAndView exportXls(HttpServletRequest request, ProcessEsInspect processEsInspect) {
return super.exportXls(request, processEsInspect, ProcessEsInspect.class, "企标稽查流程业务表");
}
/**
* 通过excel导入数据
*
* @param request
* @param response
* @return
*/
@RequestMapping(value = "/importExcel", method = RequestMethod.POST)
public Result<ProcessEsInspect> importExcel(HttpServletRequest request, HttpServletResponse response) {
return super.importExcel(request, response, ProcessEsInspect.class);
}
}
@@ -0,0 +1,33 @@
package com.jero.modules.activiti.process.esinspect.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import com.jero.modules.laws.documenttool.entity.BaseEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.jeecgframework.poi.excel.annotation.Excel;
/**
* @Description: 企标稽查流程业务表
* @Author: jero-boot
* @Date: 2023-11-22
* @Version: V1.0
*/
@Data
@TableName("process_es_inspect")
@Accessors(chain = true)
@EqualsAndHashCode(callSuper = false)
@ApiModel(value="process_es_inspect对象", description="企标稽查流程业务表")
public class ProcessEsInspect extends BaseEntity {
/**项目id*/
@Excel(name = "项目id", width = 15)
@ApiModelProperty(value = "项目id")
private java.lang.String projectId;
/**企标稽查id*/
@Excel(name = "企标稽查id", width = 15)
@ApiModelProperty(value = "企标稽查id")
private java.lang.String inspect;
}
@@ -0,0 +1,35 @@
package com.jero.modules.activiti.process.esinspect.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.jero.modules.activiti.process.esinspect.entity.ProcessEsInspect;
import com.jero.modules.activiti.process.esinspect.vo.ProcessEsInspectVO;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @Description: 企标稽查流程业务表
* @Author: jero-boot
* @Date: 2023-11-22
* @Version: V1.0
*/
public interface ProcessEsInspectMapper extends BaseMapper<ProcessEsInspect> {
/**
* 企标稽查流程业务表-分页查询
* @param page
* @param queryWrapper
* @return
*/
IPage<ProcessEsInspectVO> queryByPage(IPage<ProcessEsInspectVO> page, @Param(Constants.WRAPPER) QueryWrapper<ProcessEsInspectVO> queryWrapper);
/**
* 企标稽查流程业务表-列表查询
* @param queryWrapper
* @return
*/
List<ProcessEsInspectVO> queryByList(@Param(Constants.WRAPPER) QueryWrapper<ProcessEsInspectVO> queryWrapper);
}
@@ -0,0 +1,45 @@
<?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.activiti.process.esinspect.mapper.ProcessEsInspectMapper">
<select id="queryByPage" resultType="com.jero.modules.activiti.process.esinspect.vo.ProcessEsInspectVO">
<include refid="select_process_es_inspect"/>
</select>
<select id="queryByList" resultType="com.jero.modules.activiti.process.esinspect.vo.ProcessEsInspectVO">
<include refid="select_process_es_inspect"/>
</select>
<sql id="select_process_es_inspect">
select pesi.id,
pesi.create_by,
pesi.create_time,
pesi.update_by,
pesi.update_time,
pesi.del_flag,
pesi.project_id,
pesi.inspect_id,
lesi.id,
lesi.create_by,
lesi.create_time,
lesi.update_by,
lesi.update_time,
inspect_no,
(IF(les.standard_number is not null, les.standard_name, inspect_name)) inspect_name,
standardization_work_group,
belong_dept,
plan_inspect_date,
inspect_user,
standardization_docking_user,
complete_date,
actual_inspect_user,
inspect_status,
group_concat(lesio.plan_inspect_object separator ',') plan_inspect_object
from process_es_inspect pesi
left join laws_enterprise_standard_inspect lesi on pesi.inspect_id = lesi.id
left join laws_enterprise_standard les on lesi.inspect_no = les.standard_number and les.del_flag = '0'
left join laws_enterprise_standard_inspect_object lesio on lesi.id = lesio.inspect_id
${ew.customSqlSegment}
group by lesi.id
</sql>
</mapper>
@@ -0,0 +1,46 @@
package com.jero.modules.activiti.process.esinspect.service;
import com.jero.modules.activiti.process.esinspect.vo.EsInspectFlowVO;
/**
* @InterfaceName: IEsInspectFlowService
* @Description:
* @Author: yjz
* @Date: 2023-11-23 09:23
* @Version: 1.0
**/
public interface IEsInspectFlowService {
/**
* 企标稽查流程-流程发起
* @param esInspectFlowVO
*/
void flowStart(EsInspectFlowVO esInspectFlowVO);
/**
* 企标稽查流程-流程保存
* @param esInspectFlowVO
*/
void flowSave(EsInspectFlowVO esInspectFlowVO);
/**
* 企标稽查流程-办理详情
* @param projectId
* @param taskId
* @return
*/
EsInspectFlowVO queryDetailByProjectId(String projectId, String taskId);
/**
* 企标稽查流程-流程审批
* @param esInspectFlowVO
*/
void flowApproval(EsInspectFlowVO esInspectFlowVO);
/**
* 企标稽查流程-流程转办
* @param taskId
* @param userId
*/
void flowTransfer(String taskId, String userId);
}
@@ -0,0 +1,94 @@
package com.jero.modules.activiti.process.esinspect.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
import com.jero.modules.activiti.process.esinspect.entity.ProcessEsInspect;
import com.jero.modules.activiti.process.esinspect.vo.ProcessEsInspectVO;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
/**
* @Description: 企标稽查流程业务表
* @Author: jero-boot
* @Date: 2023-11-22
* @Version: V1.0
*/
public interface IProcessEsInspectService extends IService<ProcessEsInspect> {
/**
* 分页查询
*
* @param processEsInspect
* @param pageNo
* @param pageSize
* @param req
* @return
*/
IPage<ProcessEsInspect> queryPage(ProcessEsInspect processEsInspect, Integer pageNo, Integer pageSize, HttpServletRequest req);
/**
* 列表查询
*
* @param processEsInspect
* @param req
* @return
*/
List<ProcessEsInspect> queryList(ProcessEsInspect processEsInspect, HttpServletRequest req);
/**
* 保存
*
* @param processEsInspect
* @return
*/
void add(ProcessEsInspect processEsInspect);
/**
* 更新
*
* @param processEsInspect
* @return
*/
void editById(ProcessEsInspect processEsInspect);
/**
* 通过id删除
*
* @param id
* @return
*/
void deleteById(String id);
/**
* 批量删除
*
* @param ids
* @return
*/
void deleteByIds(List<String> ids);
/**
* 通过id查询
*
* @param id
* @return
*/
ProcessEsInspect queryById(String id);
/**
* 企标稽查流程业务表-分页查询
* @param processEsInspectVO
* @param pageNo
* @param pageSize
* @return
*/
IPage<ProcessEsInspectVO> queryByPage(ProcessEsInspectVO processEsInspectVO, Integer pageNo, Integer pageSize);
/**
* 企标稽查流程业务表-列表查询
* @param processEsInspectVO
* @return
*/
List<ProcessEsInspectVO> queryByList(ProcessEsInspectVO processEsInspectVO);
}
@@ -0,0 +1,38 @@
package com.jero.modules.activiti.process.esinspect.service.impl;
import com.jero.modules.activiti.process.esinspect.service.IEsInspectFlowService;
import com.jero.modules.activiti.process.esinspect.vo.EsInspectFlowVO;
/**
* @ClassName: EsInspectFlowServiceImpl
* @Description:
* @Author: yjz
* @Date: 2023-11-23 09:25
* @Version: 1.0
**/
public class EsInspectFlowServiceImpl implements IEsInspectFlowService {
@Override
public void flowStart(EsInspectFlowVO esInspectFlowVO) {
}
@Override
public void flowSave(EsInspectFlowVO esInspectFlowVO) {
}
@Override
public EsInspectFlowVO queryDetailByProjectId(String projectId, String taskId) {
return null;
}
@Override
public void flowApproval(EsInspectFlowVO esInspectFlowVO) {
}
@Override
public void flowTransfer(String taskId, String userId) {
}
}
@@ -0,0 +1,149 @@
package com.jero.modules.activiti.process.esinspect.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
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.exception.JeroBootException;
import com.jero.common.system.query.QueryGenerator;
import com.jero.modules.activiti.process.esinspect.entity.ProcessEsInspect;
import com.jero.modules.activiti.process.esinspect.mapper.ProcessEsInspectMapper;
import com.jero.modules.activiti.process.esinspect.service.IProcessEsInspectService;
import com.jero.modules.activiti.process.esinspect.vo.ProcessEsInspectVO;
import org.apache.commons.lang3.StringUtils;
import org.jetbrains.annotations.NotNull;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
import java.util.List;
/**
* @Description: 企标稽查流程业务表
* @Author: jero-boot
* @Date: 2023-11-22
* @Version: V1.0
*/
@Service
@Transactional(rollbackFor = JeroBootException.class)
public class ProcessEsInspectServiceImpl extends ServiceImpl<ProcessEsInspectMapper, ProcessEsInspect> implements IProcessEsInspectService {
private final ProcessEsInspectMapper processEsInspectMapper;
public ProcessEsInspectServiceImpl(ProcessEsInspectMapper processEsInspectMapper) {
this.processEsInspectMapper = processEsInspectMapper;
}
/**
* 分页查询
*
* @param processEsInspect
* @param pageNo
* @param pageSize
* @param req
* @return
*/
@Override
public IPage<ProcessEsInspect> queryPage(ProcessEsInspect processEsInspect, Integer pageNo, Integer pageSize,
HttpServletRequest req) {
QueryWrapper<ProcessEsInspect> queryWrapper = QueryGenerator.initQueryWrapper(processEsInspect, req.getParameterMap());
Page<ProcessEsInspect> page = new Page<>(pageNo, pageSize);
return page(page, queryWrapper);
}
/**
* 列表查询
*
* @param processEsInspect
* @param req
* @return
*/
@Override
public List<ProcessEsInspect> queryList(ProcessEsInspect processEsInspect, HttpServletRequest req) {
return list(QueryGenerator.initQueryWrapper(processEsInspect, req.getParameterMap()));
}
/**
* 保存
*
* @param processEsInspect
* @return
*/
@Override
public void add(ProcessEsInspect processEsInspect) {
Date now = new Date();
processEsInspect.setCreateTime(now);
processEsInspect.setUpdateTime(now);
save(processEsInspect);
}
/**
* 更新
*
* @param processEsInspect
* @return
*/
@Override
public void editById(ProcessEsInspect processEsInspect) {
Date now = new Date();
processEsInspect.setUpdateTime(now);
saveOrUpdate(processEsInspect);
}
/**
* 通过id删除
*
* @param id
* @return
*/
@Override
public void deleteById(String id) {
removeById(id);
}
/**
* 批量删除
*
* @param ids
* @return
*/
@Override
public void deleteByIds(List<String> ids) {
removeByIds(ids);
}
/**
* 通过id查询
*
* @param id
* @return
*/
@Override
public ProcessEsInspect queryById(String id) {
return getById(id);
}
@Override
public IPage<ProcessEsInspectVO> queryByPage(ProcessEsInspectVO processEsInspectVO, Integer pageNo, Integer pageSize) {
QueryWrapper<ProcessEsInspectVO> queryWrapper = getProcessEsInspectVOQueryWrapper(processEsInspectVO);
return processEsInspectMapper.queryByPage(new Page<>(pageNo, pageSize), queryWrapper);
}
@Override
public List<ProcessEsInspectVO> queryByList(ProcessEsInspectVO processEsInspectVO) {
QueryWrapper<ProcessEsInspectVO> queryWrapper = getProcessEsInspectVOQueryWrapper(processEsInspectVO);
return processEsInspectMapper.queryByList(queryWrapper);
}
@NotNull
private static QueryWrapper<ProcessEsInspectVO> getProcessEsInspectVOQueryWrapper(ProcessEsInspectVO processEsInspectVO) {
QueryWrapper<ProcessEsInspectVO> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(StringUtils.isNotBlank(processEsInspectVO.getProjectId()), "pesi.project_id", processEsInspectVO.getProjectId());
queryWrapper.eq("pesi.del_flag", 0);
queryWrapper.orderByDesc("pesi.create_time");
return queryWrapper;
}
}
@@ -0,0 +1,33 @@
package com.jero.modules.activiti.process.esinspect.vo;
import com.jero.modules.activiti.entity.ProcessAll;
import com.jero.modules.activiti.entity.ProcessApprovalRecord;
import com.jero.modules.activiti.process.esinspect.entity.ProcessEsInspect;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
import java.util.Map;
/**
* @ClassName: 企标稽查流程VO
* @Description:
* @Author: yjz
* @Date: 2023-11-09 11:51
* @Version: 1.0
**/
@Data
public class EsInspectFlowVO {
/**流程信息*/
@ApiModelProperty(value = "流程信息")
private ProcessAll processAll;
/**流程审批信息*/
@ApiModelProperty(value = "流程审批信息")
private ProcessApprovalRecord processApprovalRecord;
/**业务基本信息*/
@ApiModelProperty(value = "业务基本信息")
private List<ProcessEsInspect> processEsInspectList;
/**map*/
@ApiModelProperty(value = "map")
private Map<String, Object> map;
}
@@ -0,0 +1,25 @@
package com.jero.modules.activiti.process.esinspect.vo;
import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectVo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.jeecgframework.poi.excel.annotation.Excel;
/**
* @ClassName: ProcessEsInspectVO
* @Description:
* @Author: yjz
* @Date: 2023-11-23 09:20
* @Version: 1.0
**/
@Data
public class ProcessEsInspectVO extends EnterpriseStandardInspectVo {
/**项目id*/
@Excel(name = "项目id", width = 15)
@ApiModelProperty(value = "项目id")
private java.lang.String projectId;
/**企标稽查id*/
@Excel(name = "企标稽查id", width = 15)
@ApiModelProperty(value = "企标稽查id")
private java.lang.String inspect;
}
@@ -42,4 +42,21 @@ public class EsInspectPlanCommon {
* 企业稽查计划流程开始节点: 1:稽查联络人发起计划,2:稽查征求意见对象填写意见,3:稽查联络人汇总,4:相关人员会签,5:联络人主管级领导批准
*/
public static final String PROCESS_NODE_5 = "leader_approval";
/**
* 稽查状态: 1:进行中,2:稽查中,3:已完成,4:拖期
*/
public static final String INSPECT_STATUS_1 = "1";
/**
* 稽查状态: 1:进行中,2:稽查中,3:已完成,4:拖期
*/
public static final String INSPECT_STATUS_2 = "2";
/**
* 稽查状态: 1:进行中,2:稽查中,3:已完成,4:拖期
*/
public static final String INSPECT_STATUS_3 = "3";
/**
* 稽查状态: 1:进行中,2:稽查中,3:已完成,4:拖期
*/
public static final String INSPECT_STATUS_4 = "4";
}
@@ -43,11 +43,8 @@ public class ProcessEsInspectPlan extends BaseEntity {
/**计划稽查对象*/
@Excel(name = "计划稽查对象", width = 15)
@ApiModelProperty(value = "计划稽查对象")
@Dict(dictTable ="sys_depart",dicText = "depart_name",dicCode = "id")
private String inspectObject;
/**计划稽查对象 翻译*/
@ApiModelProperty(value = "计划稽查对象 翻译")
@TableField(exist = false)
private String inspectObjectDictText;
/**主责标准化工作组*/
@Excel(name = "主责标准化工作组", width = 15)
@ApiModelProperty(value = "主责标准化工作组")
@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.jero.common.api.dto.message.SendMessageDTO;
import com.jero.common.api.vo.SendMessageAPI;
import com.jero.common.system.vo.LoginUser;
import com.jero.common.util.SnowflakeUtils;
import com.jero.modules.activiti.entity.ProcessAll;
import com.jero.modules.activiti.entity.ProcessApprovalRecord;
import com.jero.modules.activiti.entity.ProcessNode;
@@ -154,8 +155,8 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
public void flowSave(EsInspectPlanFlowVO esInspectPlanFlowVO) {
// 流程信息
ProcessAll processAll = esInspectPlanFlowVO.getProcessAll();
// 企标稽查计划业务表
List<ProcessEsInspectPlan> processEsInspectPlanList = esInspectPlanFlowVO.getProcessEsInspectPlanList();
// // 企标稽查计划业务表
// List<ProcessEsInspectPlan> processEsInspectPlanList = esInspectPlanFlowVO.getProcessEsInspectPlanList();
// 流程审批信息
ProcessApprovalRecord processApprovalRecord = esInspectPlanFlowVO.getProcessApprovalRecord();
@@ -187,25 +188,25 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
processDraftService.save(processDraft);
// 处理企标稽查计划业务表
List<ProcessEsInspectPlan> newInspectPlanList = processEsInspectPlanList.stream().filter(v -> StringUtils.isBlank(v.getId())).collect(Collectors.toList());
List<ProcessEsInspectPlan> oldInspectPlanList = processEsInspectPlanList.stream().filter(v -> StringUtils.isNotBlank(v.getId())).collect(Collectors.toList());
// List<ProcessEsInspectPlan> newInspectPlanList = processEsInspectPlanList.stream().filter(v -> StringUtils.isBlank(v.getId())).collect(Collectors.toList());
// List<ProcessEsInspectPlan> oldInspectPlanList = processEsInspectPlanList.stream().filter(v -> StringUtils.isNotBlank(v.getId())).collect(Collectors.toList());
// 设置项目id
newInspectPlanList.forEach(v -> v.setProjectId(processAll.getProjectId()));
// 保存新数据
processEsInspectPlanService.saveBatch(newInspectPlanList);
// 旧数据ids
List<String> oldIds = oldInspectPlanList.stream().map(ProcessEsInspectPlan::getId).collect(Collectors.toList());
//删除旧数据
if (oldIds.isEmpty()){
processEsInspectPlanService.remove(new LambdaQueryWrapper<ProcessEsInspectPlan>()
.eq(ProcessEsInspectPlan::getProjectId, processAll.getProjectId()));
}else {
processEsInspectPlanService.remove(new LambdaQueryWrapper<ProcessEsInspectPlan>()
.eq(ProcessEsInspectPlan::getProjectId, processAll.getProjectId())
.notIn(ProcessEsInspectPlan::getId, oldIds));
}
// newInspectPlanList.forEach(v -> v.setProjectId(processAll.getProjectId()));
// // 保存新数据
// processEsInspectPlanService.saveBatch(newInspectPlanList);
//
// // 旧数据ids
// List<String> oldIds = oldInspectPlanList.stream().map(ProcessEsInspectPlan::getId).collect(Collectors.toList());
//
// //删除旧数据
// if (oldIds.isEmpty()){
// processEsInspectPlanService.remove(new LambdaQueryWrapper<ProcessEsInspectPlan>()
// .eq(ProcessEsInspectPlan::getProjectId, processAll.getProjectId()));
// }else {
// processEsInspectPlanService.remove(new LambdaQueryWrapper<ProcessEsInspectPlan>()
// .eq(ProcessEsInspectPlan::getProjectId, processAll.getProjectId())
// .notIn(ProcessEsInspectPlan::getId, oldIds));
// }
}
private Map<String, Object> listToString(Map<String, Object> map) {
@@ -233,7 +234,13 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
.eq(ProcessDraft::getProjectId, projectId)
.eq(ProcessDraft::getUserId, loginUser.getId()));
if (!processDraftList.isEmpty()){
String id = processAll.getId();
String id = "";
if(Objects.isNull(processAll)){
processAll = new ProcessAll();
id = String.valueOf(SnowflakeUtils.snowflake());
}else {
id = processAll.getId();
}
// 存在草稿
ProcessDraft processDraft = processDraftList.get(0);
// 属性拷贝
@@ -280,8 +287,7 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
List<ProcessNodeLink>processNodeLinkList = processNodeLinkService.list(
new LambdaQueryWrapper<ProcessNodeLink>()
.eq(ProcessNodeLink::getProcessDefinitionId, processDefinition.getId())
.eq(ProcessNodeLink::getProcessNodeId, processNode.getId())
.eq(ProcessNodeLink::getProcessInstanceId, processInstanceId));
.eq(ProcessNodeLink::getProcessNodeId, processNode.getId()));
if (!processNodeLinkList.isEmpty()){
List<String> userIdList = processNodeLinkList.stream().map(ProcessNodeLink::getUserId).collect(Collectors.toList());
List<SysUser> sysUserList = sysUserService.listByIds(userIdList);
@@ -334,7 +340,7 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
sendMessageDTO.setToUserId(v.getLinkUserIds());
Map<String, String> sendMap = new HashMap<>();
ProcessAll process = processAllService.getByProcessInstanceId(processAll.getProcessInstanceId());
sendMap.put("prcNum", process.getPrcNum());
sendMap.put("prcNum", StringUtils.isNotBlank(process.getPrcNum()) ? process.getPrcNum() : "");
sendMap.put("prcName", process.getPrcName());
sendMessageDTO.setMap(sendMap);
sendMessageAPI.sendMessage(sendMessageDTO);
@@ -356,6 +362,8 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
EnterpriseStandardInspect enterpriseStandardInspect = new EnterpriseStandardInspect();
// 属性拷贝
BeanUtils.copyProperties(processEsInspectPlan, enterpriseStandardInspect);
// 稽查状态
enterpriseStandardInspect.setInspectStatus(EsInspectPlanCommon.INSPECT_STATUS_1);
// 计划稽查对象
String inspectObject = processEsInspectPlan.getInspectObject();
String[] inspectObjectList = inspectObject.split(",");
@@ -363,6 +371,7 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
EnterpriseStandardInspectObject enterpriseStandardInspectObject = new EnterpriseStandardInspectObject();
enterpriseStandardInspectObject.setInspectId(processEsInspectPlan.getId());
enterpriseStandardInspectObject.setPlanInspectObject(object);
objectList.add(enterpriseStandardInspectObject);
}
list.add(enterpriseStandardInspect);
}
@@ -100,20 +100,23 @@ public class ProcessEsInspectPlanServiceImpl extends ServiceImpl<ProcessEsInspec
}
private void fillProperty(List<ProcessEsInspectPlan> list) {
LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
for (ProcessEsInspectPlan processEsInspectPlan : list) {
List<ProcessEsInspectPlanOpinion> opinionList = iProcessEsInspectPlanOpinionService.list(
new LambdaQueryWrapper<ProcessEsInspectPlanOpinion>()
.eq(ProcessEsInspectPlanOpinion::getInspectPlanId, processEsInspectPlan.getId()));
LambdaQueryWrapper<ProcessEsInspectPlanOpinion> queryWrapper = new LambdaQueryWrapper<ProcessEsInspectPlanOpinion>()
.eq(ProcessEsInspectPlanOpinion::getInspectPlanId, processEsInspectPlan.getId());
if (StringUtils.isNotBlank(processEsInspectPlan.getNodeId()) && "Activity_0mnt8n8".equals(processEsInspectPlan.getNodeId())){
queryWrapper.eq(ProcessEsInspectPlanOpinion::getCreateBy, loginUser.getUsername());
}
List<ProcessEsInspectPlanOpinion> opinionList = iProcessEsInspectPlanOpinionService.list(queryWrapper);
for (ProcessEsInspectPlanOpinion processEsInspectPlanOpinion : opinionList) {
processEsInspectPlanOpinion.setCreateByDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlanOpinion.getCreateBy(), ""));
processEsInspectPlanOpinion.setUpdateByDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlanOpinion.getUpdateBy(), ""));
// 用户翻译
processEsInspectPlanOpinion.setCreateByDictText(sysUserService.dictByIdsOrUserNames("", processEsInspectPlanOpinion.getCreateBy()));
processEsInspectPlanOpinion.setUpdateByDictText(sysUserService.dictByIdsOrUserNames("", processEsInspectPlanOpinion.getUpdateBy()));
}
processEsInspectPlan.setProcessEsInspectPlanOpinionList(opinionList);
// 用户翻译
processEsInspectPlan.setInspectObjectDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlan.getInspectObject(), ""));
processEsInspectPlan.setInspectUserDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlan.getInspectUser(), ""));
processEsInspectPlan.setStandardizationDockingUserDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlan.getStandardizationDockingUser(), ""));
processEsInspectPlan.setStandardizationDockingUserDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlan.getStandardizationDockingUser(), ""));
processEsInspectPlan.setObjectOfConsultationDictText(sysUserService.dictByIdsOrUserNames(processEsInspectPlan.getObjectOfConsultation(), ""));
processEsInspectPlan.setCreateByDictText(sysUserService.dictByIdsOrUserNames("", processEsInspectPlan.getCreateBy()));
processEsInspectPlan.setUpdateByDictText(sysUserService.dictByIdsOrUserNames("", processEsInspectPlan.getUpdateBy()));
@@ -126,7 +129,9 @@ public class ProcessEsInspectPlanServiceImpl extends ServiceImpl<ProcessEsInspec
QueryWrapper<ProcessEsInspectPlan> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(StringUtils.isNotBlank(processEsInspectPlan.getProjectId()), "project_id", processEsInspectPlan.getProjectId());
if (StringUtils.isNotBlank(processEsInspectPlan.getNodeId()) && "Activity_0mnt8n8".equals(processEsInspectPlan.getNodeId())){
queryWrapper.like(StringUtils.isNotBlank(processEsInspectPlan.getNodeId()), "object_of_consultation", loginUser.getId());
queryWrapper.and(qw ->
qw.eq("object_of_consultation", loginUser.getId())
.or().eq("create_by", loginUser.getUsername()));
}
queryWrapper.orderByDesc("create_time");
return queryWrapper;
@@ -27,6 +27,7 @@ import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.List;
/**
@@ -69,6 +70,33 @@ public class EnterpriseStandardInspectController extends JeroController<Enterpri
return Result.OK(pageList);
}
/**
* 企标稽查-分页列表查询2
*
* @return
*/
@AutoLog(value = "企标稽查-分页列表查询2")
@ApiOperation(value="企标稽查-分页列表查询2", notes="企标稽查-分页列表查询2")
@GetMapping(value = "/queryByPage")
public Result<IPage<EnterpriseStandardInspectVo>> queryByPage(EnterpriseStandardInspectVo enterpriseStandardInspectVo,
@ApiParam("当前页") @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
@ApiParam("每页条数") @RequestParam(name="pageSize", defaultValue="10") Integer pageSize) {
IPage<EnterpriseStandardInspectVo> pageList = esInspectService.queryByPage(enterpriseStandardInspectVo, pageNo, pageSize);
return Result.OK(pageList);
}
/**
* 企标稽查-列表查询2
*
* @return
*/
@AutoLog(value = "企标稽查-列表查询2")
@ApiOperation(value="企标稽查-列表查询2", notes="企标稽查-列表查询2")
@GetMapping(value = "/queryByList")
public Result<List<EnterpriseStandardInspectVo>> queryByList(EnterpriseStandardInspectVo enterpriseStandardInspectVo) {
return Result.OK(esInspectService.queryByList(enterpriseStandardInspectVo));
}
/**
* 延期稽查
*
@@ -1,5 +1,6 @@
package com.jero.modules.laws.enterprise.entity.vo;
import com.baomidou.mybatisplus.annotation.TableField;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.jero.common.aspect.annotation.Dict;
import io.swagger.annotations.ApiModelProperty;
@@ -43,6 +44,7 @@ public class EnterpriseStandardInspectVo {
/** 所属部门 */
@Excel(name = "所属部门", width = 15, orderNum = "1")
@ApiModelProperty(value = "所属部门")
@Dict(dictTable ="sys_depart",dicText = "depart_name",dicCode = "id")
private String belongDept;
/** 计划稽查日期 */
@@ -55,11 +57,13 @@ public class EnterpriseStandardInspectVo {
/** 稽查负责人 */
@Excel(name = "稽查负责人", width = 15, orderNum = "1")
@ApiModelProperty(value = "稽查负责人")
@Dict(dictTable = "sys_user", dicCode = "id", dicText = "realname")
private String inspectUser;
/** 标准化组对接人 */
@Excel(name = "标准化组对接人", width = 15, orderNum = "1")
@ApiModelProperty(value = "标准化组对接人")
@Dict(dictTable = "sys_user", dicCode = "id", dicText = "realname")
private String standardizationDockingUser;
/** 实际稽查完成日期 */
@@ -72,6 +76,7 @@ public class EnterpriseStandardInspectVo {
/** 实际稽查人 */
@Excel(name = "实际稽查人", width = 15, orderNum = "1")
@ApiModelProperty(value = "实际稽查人")
@Dict(dictTable = "sys_user", dicCode = "id", dicText = "realname")
private String actualInspectUser;
/** 稽查状态 */
@@ -91,4 +96,9 @@ public class EnterpriseStandardInspectVo {
@ApiModelProperty(value = "延期稽查标识")
private boolean delayFlag;
//=================================
/**ids 查询用*/
@ApiModelProperty(value = "ids 查询用")
@TableField(exist = false)
private String ids;
}
@@ -1,6 +1,9 @@
package com.jero.modules.laws.enterprise.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.jero.modules.laws.enterprise.entity.EnterpriseStandardInspect;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.jero.modules.laws.enterprise.entity.dto.ESQueryCommonDTO;
@@ -8,6 +11,8 @@ import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectDelay
import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectVo;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @author ThinkBook
* @description 针对表【laws_enterprise_standard_inspect(企业标准)】的数据库操作Mapper
@@ -31,6 +36,21 @@ public interface EnterpriseStandardInspectMapper extends BaseMapper<EnterpriseSt
* @return
*/
IPage<EnterpriseStandardInspectDelayVo> pageWithDelay(IPage<EnterpriseStandardInspectDelayVo> page, @Param("param") ESQueryCommonDTO esQueryCommonDTO);
/**
* 企标稽查-分页列表查询2
* @param page
* @param queryWrapper
* @return
*/
IPage<EnterpriseStandardInspectVo> queryByPage(Page<EnterpriseStandardInspectVo> page, @Param(Constants.WRAPPER) QueryWrapper<EnterpriseStandardInspectVo> queryWrapper);
/**
* 企标稽查-列表查询2
* @param queryWrapper
* @return
*/
List<EnterpriseStandardInspectVo> queryByList(@Param(Constants.WRAPPER) QueryWrapper<EnterpriseStandardInspectVo> queryWrapper);
}
@@ -167,4 +167,38 @@
</if>
ORDER BY i.create_time DESC
</select>
<select id="queryByPage"
resultType="com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectVo">
<include refid="select_laws_enterprise_standard_inspect"/>
</select>
<select id="queryByList"
resultType="com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectVo">
<include refid="select_laws_enterprise_standard_inspect"/>
</select>
<sql id="select_laws_enterprise_standard_inspect">
select lesi.id,
lesi.create_by,
lesi.create_time,
lesi.update_by,
lesi.update_time,
inspect_no,
(IF(les.standard_number is not null, les.standard_name, inspect_name)) inspect_name,
standardization_work_group,
belong_dept,
plan_inspect_date,
inspect_user,
standardization_docking_user,
complete_date,
actual_inspect_user,
inspect_status,
group_concat(lesio.plan_inspect_object separator ',') plan_inspect_object
from laws_enterprise_standard_inspect lesi
left join laws_enterprise_standard les on lesi.inspect_no = les.standard_number and les.del_flag = '0'
left join laws_enterprise_standard_inspect_object lesio on lesi.id = lesio.inspect_id
${ew.customSqlSegment}
group by lesi.id
</sql>
</mapper>
@@ -8,6 +8,7 @@ import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectVo;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.List;
/**
* @author ThinkBook
@@ -53,4 +54,20 @@ public interface EnterpriseStandardInspectService extends IService<EnterpriseSta
* @param fileName
*/
void exportDataRectifyPlan(HttpServletResponse response, ESQueryCommonDTO esQueryCommonDTO, String sheetName, String fileName) throws IOException;
/**
* 企标稽查-分页列表查询2
* @param enterpriseStandardInspectVo
* @param pageNo
* @param pageSize
* @return
*/
IPage<EnterpriseStandardInspectVo> queryByPage(EnterpriseStandardInspectVo enterpriseStandardInspectVo, Integer pageNo, Integer pageSize);
/**
* 企标稽查-列表查询2
* @param enterpriseStandardInspectVo
* @return
*/
List<EnterpriseStandardInspectVo> queryByList(EnterpriseStandardInspectVo enterpriseStandardInspectVo);
}
@@ -1,41 +1,34 @@
package com.jero.modules.laws.enterprise.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
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.exception.JeroBootException;
import com.jero.common.system.api.ISysBaseAPI;
import com.jero.common.system.vo.DictModel;
import com.jero.modules.laws.enterprise.entity.EnterpriseStandardInspect;
import com.jero.modules.laws.enterprise.entity.EnterpriseStandardInspectRectifyPlan;
import com.jero.modules.laws.enterprise.entity.dto.ESQueryCommonDTO;
import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardDeclareVo;
import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectDelayVo;
import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardInspectVo;
import com.jero.modules.laws.enterprise.entity.vo.EnterpriseStandardRecheckPlanVo;
import com.jero.modules.laws.enterprise.mapper.EnterpriseStandardInspectRectifyPlanMapper;
import com.jero.modules.laws.enterprise.service.EnterpriseStandardInspectRectifyPlanService;
import com.jero.modules.laws.enterprise.service.EnterpriseStandardInspectService;
import com.jero.modules.laws.enterprise.mapper.EnterpriseStandardInspectMapper;
import com.jero.modules.laws.enterprise.mapper.EnterpriseStandardInspectRectifyPlanMapper;
import com.jero.modules.laws.enterprise.service.EnterpriseStandardInspectService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.usermodel.Workbook;
import org.jeecgframework.poi.excel.ExcelExportUtil;
import org.jeecgframework.poi.excel.entity.ExportParams;
import org.jetbrains.annotations.NotNull;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;
@@ -176,6 +169,30 @@ public class EnterpriseStandardInspectServiceImpl extends ServiceImpl<Enterprise
log.error("写入响应流时发生错误", e);
}
}
@Override
public IPage<EnterpriseStandardInspectVo> queryByPage(EnterpriseStandardInspectVo enterpriseStandardInspectVo, Integer pageNo, Integer pageSize) {
QueryWrapper<EnterpriseStandardInspectVo> queryWrapper = getEnterpriseStandardInspectVoQueryWrapper(enterpriseStandardInspectVo);
return esInspectMapper.queryByPage(new Page<>(pageNo, pageSize), queryWrapper);
}
@Override
public List<EnterpriseStandardInspectVo> queryByList(EnterpriseStandardInspectVo enterpriseStandardInspectVo) {
QueryWrapper<EnterpriseStandardInspectVo> queryWrapper = getEnterpriseStandardInspectVoQueryWrapper(enterpriseStandardInspectVo);
return esInspectMapper.queryByList(queryWrapper);
}
@NotNull
private static QueryWrapper<EnterpriseStandardInspectVo> getEnterpriseStandardInspectVoQueryWrapper(EnterpriseStandardInspectVo enterpriseStandardInspectVo) {
QueryWrapper<EnterpriseStandardInspectVo> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(StringUtils.isNotBlank(enterpriseStandardInspectVo.getId()), "lesi.id", enterpriseStandardInspectVo.getId());
if (StringUtils.isNotBlank(enterpriseStandardInspectVo.getIds())){
List<String> list = Arrays.asList(enterpriseStandardInspectVo.getIds().split(","));
queryWrapper.in("lesi.id", list);
}
queryWrapper.orderByDesc("lesi.createTime");
return queryWrapper;
}
}