package com.ruoyi.process.service.impl; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.context.AnalysisContext; import com.alibaba.excel.event.AnalysisEventListener; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.deepoove.poi.XWPFTemplate; import com.deepoove.poi.config.Configure; import com.deepoove.poi.config.ConfigureBuilder; import com.deepoove.poi.data.PictureRenderData; import com.deepoove.poi.data.Pictures; import com.ruoyi.common.constant.MenuJumpPathConstants; import com.ruoyi.common.core.domain.entity.InformationNotification; import com.ruoyi.common.core.domain.entity.User; import com.ruoyi.common.utils.DateImageUtil; import com.ruoyi.common.utils.QueryWrappers; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.common.utils.WxCpUtils; import com.ruoyi.framework.exception.ErrorException; import com.ruoyi.inspect.util.HackLoopTableRenderPolicy; import com.ruoyi.inspect.util.UserUtils; import com.ruoyi.process.dto.QualitySuperviseDetailsAccordingDto; import com.ruoyi.process.dto.QualitySuperviseDetailsCorrectDto; import com.ruoyi.process.dto.QualitySuperviseDetailsDto; import com.ruoyi.process.excel.QualitySuperviseDetailsUpload; import com.ruoyi.process.mapper.*; import com.ruoyi.process.pojo.*; import com.ruoyi.process.service.QualitySuperviseDetailsService; import com.ruoyi.process.service.QualitySuperviseService; import com.ruoyi.system.mapper.UserMapper; import com.ruoyi.system.service.InformationNotificationService; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.URLEncoder; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; /** * 质量监督主表 * * @author zhuo * @since 2024-11-07 */ @Service @Transactional(rollbackFor = Exception.class) public class QualitySuperviseServiceImpl extends ServiceImpl implements QualitySuperviseService { @Resource private QualitySuperviseDetailsService qualitySuperviseDetailsService; @Resource private QualitySuperviseDetailsMapper qualitySuperviseDetailsMapper; @Resource private QualitySuperviseDetailsRecordMapper qualitySuperviseDetailsRecordMapper; @Resource private QualitySuperviseDetailsAccordingMapper qualitySuperviseDetailsAccordingMapper; @Resource private QualitySuperviseDetailsCorrectMapper qualitySuperviseDetailsCorrectMapper; @Resource private QualitySuperviseDetailsCorrectFileMapper qualitySuperviseDetailsCorrectFileMapper; @Resource private InformationNotificationService informationNotificationService; @Resource private ThreadPoolTaskExecutor threadPoolTaskExecutor; @Resource private UserMapper userMapper; @Value("${file.path}") private String imgUrl; @Value("${wordUrl}") private String wordUrl; /** * 导入监督计划 * @param file * @return */ @Override public boolean importQualitySupervise(MultipartFile file, QualitySupervise supervise) { if (supervise.getRatifyUserId() == null) { throw new ErrorException("缺少批准人"); } User ratifyUser = userMapper.selectById(supervise.getRatifyUserId()); // 当前登录用户 Integer userId = SecurityUtils.getUserId().intValue(); User user = userMapper.selectById(userId); // 文件名称 String fileName = file.getOriginalFilename().substring(0, file.getOriginalFilename().lastIndexOf(".")); QualitySupervise qualitySupervise = new QualitySupervise(); qualitySupervise.setSuperviseName(fileName); qualitySupervise.setSuperviseYear(supervise.getSuperviseYear()); qualitySupervise.setRecordUserIds(supervise.getRecordUserIds()); qualitySupervise.setWriteUserId(userId); qualitySupervise.setWriteUserName(user.getName()); qualitySupervise.setWriteTime(LocalDateTime.now()); qualitySupervise.setRatifyUserId(supervise.getRatifyUserId()); qualitySupervise.setRatifyUserName(ratifyUser.getName()); baseMapper.insert(qualitySupervise); // 消息发送 InformationNotification info = new InformationNotification(); // 发送人 info.setCreateUser(user.getName()); info.setMessageType("6"); info.setTheme("CNAS质量监督计划审核通知"); info.setContent("您有一条质量监督计划待批准"); info.setSenderId(userId); // 接收人 info.setConsigneeId(supervise.getRatifyUserId()); info.setJumpPath(MenuJumpPathConstants.QUALITY_SUPERVISE); informationNotificationService.addInformationNotification(info); // 发送企业微信通知 threadPoolTaskExecutor.execute(() -> { // 查询发送人 User people = userMapper.selectById(supervise.getRatifyUserId()); String message = ""; message += "CNAS质量监督计划批准通知"; message += "\n请去过程要求-质量监督计划"; message += "\n" + fileName + "质量监督计划待批准"; //发送企业微信消息通知 try { WxCpUtils.inform(people.getAccount(), message, null); } catch (Exception e) { throw new RuntimeException(e); } }); List detailsUploadList = new ArrayList<>(); // 导入附件内容 try { // excel解析 EasyExcel.read(file.getInputStream(), QualitySuperviseDetailsUpload.class, new AnalysisEventListener() { @Override public void invoke(QualitySuperviseDetailsUpload detailsUpload, AnalysisContext analysisContext) { // 判断是否为空 if (StringUtils.isBlank(detailsUpload.getSuperviseTime())) { throw new ErrorException("监督日期不能为空"); } // 对象复制 QualitySuperviseDetails superviseDetails = new QualitySuperviseDetails(); BeanUtils.copyProperties(detailsUpload, superviseDetails); superviseDetails.setSuperviseId(qualitySupervise.getSuperviseId()); User user = userMapper.selectOne(Wrappers.lambdaQuery() .eq(User::getName, superviseDetails.getSupervisee())); if (ObjectUtils.isEmpty(user)) { throw new ErrorException("未找到被监督员：" + superviseDetails.getSupervisee()); } superviseDetails.setSupervisedUserId(user.getId()); // 格式化时间 superviseDetails.setSuperviseTime(detailsUpload.getSuperviseTime()); detailsUploadList.add(superviseDetails); } @Override public void doAfterAllAnalysed(AnalysisContext analysisContext) { } }).sheet().doRead(); qualitySuperviseDetailsService.saveBatch(detailsUploadList); } catch (IOException e) { throw new RuntimeException(e); } return true; } /** * 监督计划批准 * @param qualitySupervise * @return */ @Override public boolean ratifyQualitySupervise(QualitySupervise qualitySupervise) { // 当前登录用户 baseMapper.update(null, Wrappers.lambdaUpdate() .eq(QualitySupervise::getSuperviseId, qualitySupervise.getSuperviseId()) .set(QualitySupervise::getRatifyRemark, qualitySupervise.getRatifyRemark()) .set(QualitySupervise::getRatifyStatus, qualitySupervise.getRatifyStatus()) .set(QualitySupervise::getRatifyTime, LocalDateTime.now()) ); return true; } /** * 监督计划列表 * @param page * @param qualitySupervise * @return */ @Override public IPage pageQualitySupervise(Page page, QualitySupervise qualitySupervise) { return baseMapper.pageQualitySupervise(page, QueryWrappers.queryWrappers(qualitySupervise)); } /** * 监督计划详情列表 * @return */ @Override public IPage pageQualitySuperviseDetail(Page page, QualitySuperviseDetailsDto qualitySuperviseDetails) { if (qualitySuperviseDetails.getSuperviseId() == null) { return new Page(); } Integer causeType = qualitySuperviseDetails.getCauseType(); qualitySuperviseDetails.setCauseType(null); return qualitySuperviseDetailsMapper.pageQualitySuperviseDetail(page, QueryWrappers.queryWrappers(qualitySuperviseDetails), causeType); } /** * 查询该计划监督员 * @param superviseDetailsId * @return */ @Override public List> getRecordUser(Integer superviseDetailsId) { List> recordUser = baseMapper.getRecordUser(superviseDetailsId); return baseMapper.getRecordUser(superviseDetailsId); } /** * 导出监督计划 * @param superviseId * @param response */ @Override public void exportQualitySupervise(Integer superviseId, HttpServletResponse response) { QualitySupervise qualitySupervise = baseMapper.selectById(superviseId); //获取提交人的签名地址 String writeUrl = userMapper.selectById(qualitySupervise.getWriteUserId()).getSignatureUrl(); if (ObjectUtils.isEmpty(writeUrl) || writeUrl.equals("")) { throw new ErrorException("找不到检验人的签名"); } //获取批准人的签名地址 String ratifyUrl = null; if (qualitySupervise.getRatifyUserId() != null) { ratifyUrl = userMapper.selectById(qualitySupervise.getRatifyUserId()).getSignatureUrl(); if (StringUtils.isBlank(ratifyUrl)) { throw new ErrorException("找不到复核人的签名"); } } // 定义一个集合存放人员签名 ArrayList recordUserDataList = new ArrayList<>(); // TODO:确认最多会有5个人 String recordUserIds = qualitySupervise.getRecordUserIds(); if (StringUtils.isNotBlank(recordUserIds)) { // 对人员id字符串进行分割成数组 String[] userIds = recordUserIds.split(","); // 循环获取人员签名 for (String userIdStr : userIds) { // 转换为int类型 Integer userId = Integer.valueOf(userIdStr); // 获取人员签名对象 PictureRenderData finalUserSignatureUrl = UserUtils.getFinalUserSignatureUrl(userId); // 将人员签名对象添加到集合中 recordUserDataList.add(finalUserSignatureUrl); } } // 判断集合长度，并补null到2个 while (recordUserDataList.size() < 2) { recordUserDataList.add(null); } // 查询详情 List qualitySuperviseDetails = qualitySuperviseDetailsMapper.selectList(Wrappers.lambdaQuery() .eq(QualitySuperviseDetails::getSuperviseId, superviseId)); int index = 1; for (QualitySuperviseDetails qualitySuperviseDetail : qualitySuperviseDetails) { qualitySuperviseDetail.setIndex(index); index++; } // 获取路径 InputStream inputStream = this.getClass().getResourceAsStream("/static/quality-supervise.docx"); String finalRatifyUrl = ratifyUrl; Configure configure = Configure.builder() .bind("superviseDetailList", new HackLoopTableRenderPolicy()) .build(); XWPFTemplate template = XWPFTemplate.compile(inputStream, configure).render( new HashMap() {{ put("year", qualitySupervise.getSuperviseYear()); put("superviseDetailList", qualitySuperviseDetails); put("writeUrl", StringUtils.isNotBlank(writeUrl) ? Pictures.ofLocal(imgUrl + "/" + writeUrl).create() : null); put("ratifyUrl", StringUtils.isNotBlank(finalRatifyUrl) ? Pictures.ofLocal(imgUrl + "/" + finalRatifyUrl).create() : null); put("writeDateUrl", qualitySupervise.getWriteTime() != null ? Pictures.ofStream(DateImageUtil.createDateImage(qualitySupervise.getWriteTime())).create() : null); put("ratifyDateUrl", qualitySupervise.getRatifyTime() != null ? Pictures.ofStream(DateImageUtil.createDateImage(qualitySupervise.getRatifyTime())).create() : null); put("recordUserUrl1", recordUserDataList.get(0)); put("recordUserUrl2", recordUserDataList.get(1)); }}); try { response.setContentType("application/msword"); String fileName = URLEncoder.encode( qualitySupervise.getSuperviseName(), "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".docx"); OutputStream os = response.getOutputStream(); template.write(os); os.flush(); os.close(); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException("导出失败"); } } /************************************************ 记录 ******************************************************/ /** * 查询监督记录信息 * @param superviseDetailsId * @return */ @Override public QualitySuperviseDetailsRecord getSuperviseDetailRecord(Integer superviseDetailsId) { QualitySuperviseDetailsRecord detailsRecord; detailsRecord = qualitySuperviseDetailsRecordMapper.selectOne(Wrappers.lambdaQuery() .eq(QualitySuperviseDetailsRecord::getSuperviseDetailsId, superviseDetailsId)); if (detailsRecord == null) { detailsRecord = new QualitySuperviseDetailsRecord(); } // 添加批准人名称 if (detailsRecord.getRatifyUserId() != null) { User user = userMapper.selectById(SecurityUtils.getUserId().intValue()); detailsRecord.setRatifyUserName(user.getName()); } return detailsRecord; } /** * 新增监督记录信息 * @param qualitySuperviseDetailsRecord * @return */ @Override public boolean addSuperviseDetailRecord(QualitySuperviseDetailsRecord qualitySuperviseDetailsRecord) { if (qualitySuperviseDetailsRecord.getSuperviseDetailsId() == null) { throw new ErrorException("缺少监督详细信息id"); } qualitySuperviseDetailsRecordMapper.insert(qualitySuperviseDetailsRecord); if (qualitySuperviseDetailsRecord.getRatifyUserId() != null) { // 查询详情信息 QualitySuperviseDetails superviseDetails = qualitySuperviseDetailsMapper.selectById(qualitySuperviseDetailsRecord.getSuperviseDetailsId()); Integer userId = SecurityUtils.getUserId().intValue(); User user = userMapper.selectById(userId); // 消息发送 InformationNotification info = new InformationNotification(); // 发送人 info.setCreateUser(user.getName()); info.setMessageType("6"); info.setTheme("CNAS质量监督记录审批通知"); info.setContent("监督项目为: " + superviseDetails.getSuperviseProject() + " 监督记录带审批"); info.setSenderId(userId); // 接收人 info.setConsigneeId(qualitySuperviseDetailsRecord.getRatifyUserId()); info.setJumpPath(MenuJumpPathConstants.QUALITY_SUPERVISE); informationNotificationService.addInformationNotification(info); // 发送企业微信通知 threadPoolTaskExecutor.execute(() -> { // 查询发送人 User people = userMapper.selectById(qualitySuperviseDetailsRecord.getRatifyUserId()); String message = ""; message += "CNAS质量监督记录审批通知"; message += "\n请去过程要求-质量监督计划"; message += "\n" + "监督项目为: " + superviseDetails.getSuperviseProject() + " 监督记录带审批"; //发送企业微信消息通知 try { WxCpUtils.inform(people.getAccount(), message, null); } catch (Exception e) { throw new RuntimeException(e); } }); } return true; } /** * 监督记录批准 * @param qualitySuperviseDetailsRecord * @return */ @Override public boolean addSuperviseRecordOpinion(QualitySuperviseDetailsRecord qualitySuperviseDetailsRecord) { if (qualitySuperviseDetailsRecord.getIsAccording() == null) { throw new ErrorException("缺少最终结果"); } qualitySuperviseDetailsRecordMapper.update(null, Wrappers.lambdaUpdate() .eq(QualitySuperviseDetailsRecord::getSuperviseDetailsId, qualitySuperviseDetailsRecord.getSuperviseDetailsId()) .set(QualitySuperviseDetailsRecord::getRatifyOpinion, qualitySuperviseDetailsRecord.getRatifyOpinion()) .set(QualitySuperviseDetailsRecord::getRatifyTime, LocalDateTime.now()) .set(QualitySuperviseDetailsRecord::getIsAccording, qualitySuperviseDetailsRecord.getIsAccording()) .set(QualitySuperviseDetailsRecord::getIsFinish, 1)); return true; } /** * 导出监督记录表 * @param superviseDetailsId * @param response */ @Override public void exportSuperviseDetailRecord(Integer superviseDetailsId, HttpServletResponse response) { QualitySuperviseDetailsRecord recordDto = qualitySuperviseDetailsRecordMapper.selectSuperviseDetailRecord(superviseDetailsId); //获取技术负责人的签名地址 String ratifyUrl = null; if (recordDto.getRatifyUserId() != null) { ratifyUrl = userMapper.selectById(recordDto.getRatifyUserId()).getSignatureUrl(); if (StringUtils.isBlank(ratifyUrl)) { throw new ErrorException("找不到技术负责人的签名"); } } // 获取路径 InputStream inputStream = this.getClass().getResourceAsStream("/static/supervision-detail-record.docx"); ConfigureBuilder builder = Configure.builder(); builder.useSpringEL(true); String finalRatifyUrl = ratifyUrl; XWPFTemplate template = XWPFTemplate.compile(inputStream, builder.build()).render( new HashMap() {{ put("supervision", recordDto); put("supervisoruUrl", UserUtils.getFinalUserSignatureUrl(recordDto.getSupervisor())); put("technicalDirectorUrl", StringUtils.isNotBlank(finalRatifyUrl) ? Pictures.ofLocal(imgUrl + "/" + finalRatifyUrl).create() : null); put("technicalDirectorDateUrl", recordDto.getRatifyTime() != null ? Pictures.ofStream(DateImageUtil.createDateImage(recordDto.getRatifyTime())).create() : null); }}); try { response.setContentType("application/msword"); String fileName = URLEncoder.encode( "导出监督记录表", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".docx"); OutputStream os = response.getOutputStream(); template.write(os); os.flush(); os.close(); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException("导出失败"); } } /************************************************* 不合格工作控制单 ********************************************************/ /** * 新增监督记录不符合控制信息 * @param detailsAccording * @return */ @Override public boolean addSuperviseDetailAccording(QualitySuperviseDetailsAccording detailsAccording) { QualitySuperviseDetailsAccording according = new QualitySuperviseDetailsAccording(); // 当前登录用户信息和部门 User user = userMapper.selectById( SecurityUtils.getUserId().intValue()); String departmentLimsName = userMapper.selectUserDepartmentLimsName(user.getId()); switch (detailsAccording.getFlowType()) { // 不符合工作情况记录 case 0: if (detailsAccording.getSuperviseDetailsId() == null) { throw new ErrorException("缺少质量监督详情Id"); } according.setSuperviseDetailsId(detailsAccording.getSuperviseDetailsId()); according.setOccurrenceDepartment(detailsAccording.getOccurrenceDepartment());//发生部门 according.setHeadDepartment(detailsAccording.getHeadDepartment());//部门负责人 according.setFindWay(detailsAccording.getFindWay());//发现途径 according.setRecordDetail(detailsAccording.getRecordDetail());//不符合记录详细 according.setRecordAccording(detailsAccording.getRecordAccording());//不合格记录依据 according.setFoundDepartment(departmentLimsName);//发现部门 according.setRecordUserId(user.getId());//记录人id according.setRecordUserName(user.getName());//记录人 according.setRecordTime(LocalDate.now());//记录时间 // 处理人信息 User actionsUser = userMapper.selectById(detailsAccording.getActionsUserId()); String actionsDepartmentLims = userMapper.selectUserDepartmentLimsName(actionsUser.getId()); according.setResponsibleDepartment(actionsDepartmentLims);//责任部门 according.setActionsUserId(actionsUser.getId());//处理人id according.setActionsUserName(actionsUser.getName());//处理人 according.setSupervisedUserId(detailsAccording.getSupervisedUserId());//被监督人id // 被监督人 User supervisedUser = userMapper.selectById(detailsAccording.getSupervisedUserId()); according.setSupervisedUserName(supervisedUser.getName());//被监督人 according.setActionsTime(detailsAccording.getSupervisedTime());//被监督时间 qualitySuperviseDetailsAccordingMapper.insert(according); break; // 1处理措施 case 1: according.setSuperviseDetailsAccordingId(detailsAccording.getSuperviseDetailsAccordingId()); according.setEliminateMeasure(detailsAccording.getEliminateMeasure());//清除不符合措施 according.setActionsTime(LocalDate.now());//处理时间 // 纠正负责人信息 User correctsUser = userMapper.selectById(detailsAccording.getCorrectUserId()); according.setCorrectUserId(correctsUser.getId());//纠正负责人id according.setCorrectUserName(correctsUser.getName());//纠正负责人 qualitySuperviseDetailsAccordingMapper.updateById(according); break; // 纠正措施 case 2: according.setSuperviseDetailsAccordingId(detailsAccording.getSuperviseDetailsAccordingId()); according.setCorrectContent(detailsAccording.getCorrectContent());//纠正措施内容 according.setIsCorrect(detailsAccording.getIsCorrect());//是否纠正处理 according.setCorrectTime(LocalDate.now());//纠正填写时间 // 质量负责人 User qualityUser = userMapper.selectById(detailsAccording.getQualityManagerUserId()); according.setQualityManagerUserId(qualityUser.getId());//质量负责人id according.setQualityManagerUserName(qualityUser.getName());//质量负责人 qualitySuperviseDetailsAccordingMapper.updateById(according); break; //是否通知客户可恢复工作 case 3: according.setSuperviseDetailsAccordingId(detailsAccording.getSuperviseDetailsAccordingId()); according.setNotifyCustomer(detailsAccording.getNotifyCustomer());//通知客户 according.setBackToWork(detailsAccording.getBackToWork());//回复工作 according.setQualityManagerTime(LocalDate.now());//日期 according.setIsFinish(1); qualitySuperviseDetailsAccordingMapper.updateById(according); break; } return true; } /** * (装备流程)新增监督记录不符合控制信息 * @param detailsAccording * @return */ @Override public boolean addEquipSuperviseDetailAccording(QualitySuperviseDetailsAccording detailsAccording) { if (detailsAccording.getSuperviseDetailsId() == null) { throw new ErrorException("缺少质量监督详情Id"); } // 当前登录用户信息和部门 Integer userId = SecurityUtils.getUserId().intValue(); User user = userMapper.selectById(userId); String departmentLimsName = userMapper.selectUserDepartmentLimsName(user.getId()); detailsAccording.setFoundDepartment(departmentLimsName);//发现部门 detailsAccording.setRecordUserId(user.getId());//记录人id detailsAccording.setRecordUserName(user.getName());//记录人 // 被监督人 User supervisedUser = userMapper.selectById(detailsAccording.getSupervisedUserId()); detailsAccording.setSupervisedUserName(supervisedUser.getName());//被监督 qualitySuperviseDetailsAccordingMapper.insert(detailsAccording); if (detailsAccording.getApproverUserId() != null) { // 查询详情信息 QualitySuperviseDetails superviseDetails = qualitySuperviseDetailsMapper.selectById(detailsAccording.getSuperviseDetailsId()); // 消息发送 InformationNotification info = new InformationNotification(); // 发送人 info.setCreateUser(user.getName()); info.setMessageType("6"); info.setTheme("CNAS质量监督不合格控制单填写通知"); info.setContent("监督项目为: " + superviseDetails.getSuperviseProject() + " 监督不合格控制单待填写"); info.setSenderId(userId); // 接收人 info.setConsigneeId(detailsAccording.getApproverUserId()); info.setJumpPath(MenuJumpPathConstants.QUALITY_SUPERVISE); informationNotificationService.addInformationNotification(info); // 发送企业微信通知 threadPoolTaskExecutor.execute(() -> { // 查询发送人 User people = userMapper.selectById(detailsAccording.getApproverUserId()); String message = ""; message += "CNAS质量监督记录审批通知"; message += "\n请去过程要求-质量监督计划"; message += "\n" + "监督项目为: " + superviseDetails.getSuperviseProject() + " 监督不合格控制单待填写"; //发送企业微信消息通知 try { WxCpUtils.inform(people.getAccount(), message, null); } catch (Exception e) { throw new RuntimeException(e); } }); } return true; } /** * (装备流程)批准监督记录不符合控制信息 * 批准完成后统一填写三个流程人id和部门 * @param detailsAccording * @return */ @Override public boolean approverEquipSuperviseDetailAccording(QualitySuperviseDetailsAccording detailsAccording) { QualitySuperviseDetailsAccording according = new QualitySuperviseDetailsAccording(); according.setSuperviseDetailsAccordingId(detailsAccording.getSuperviseDetailsAccordingId()); // 当前登录用户信息和部门 User user = userMapper.selectById(SecurityUtils.getUserId().intValue()); String departmentLimsName = userMapper.selectUserDepartmentLimsName(user.getId()); according.setResponsibleDepartment(departmentLimsName);//责任部门 according.setActionsUserId(user.getId());//处理人id according.setActionsUserName(user.getName());//处理人 according.setCorrectUserId(user.getId());//纠正负责人id according.setCorrectUserName(user.getName());//纠正负责人 according.setQualityManagerUserId(user.getId());//质量负责人id according.setQualityManagerUserName(user.getName());//质量负责人 according.setIsFinish(1); qualitySuperviseDetailsAccordingMapper.updateById(according); return true; } /** * 查询监督记录不符合控制信息 * @param superviseDetailsId * @return */ @Override public QualitySuperviseDetailsAccording getSuperviseDetailAccording(Integer superviseDetailsId) { QualitySuperviseDetailsAccording detailsAccording; detailsAccording = qualitySuperviseDetailsAccordingMapper.selectOne(Wrappers.lambdaQuery() .eq(QualitySuperviseDetailsAccording::getSuperviseDetailsId, superviseDetailsId)); if (detailsAccording == null) { detailsAccording = new QualitySuperviseDetailsAccording(); // 查询监督计划详情 QualitySuperviseDetails superviseDetails = qualitySuperviseDetailsMapper.selectById(superviseDetailsId); detailsAccording.setSupervisedUserId(superviseDetails.getSupervisedUserId()); detailsAccording.setSupervisedUserName(superviseDetails.getSupervisee()); } return detailsAccording; } /** * 查询不符合项 * @param page * @param detailsAccording * @return */ @Override public IPage pageSuperviseDetailAccording(Page page, QualitySuperviseDetailsAccording detailsAccording) { return qualitySuperviseDetailsAccordingMapper.pageSuperviseDetailAccording(page, QueryWrappers.queryWrappers(detailsAccording)); } /** * 导出监督记录不符合控制信息 * @param superviseDetailAccordingId * @param response */ @Override public void superviseDetailAccordingExport(Integer superviseDetailAccordingId, HttpServletResponse response) { QualitySuperviseDetailsAccordingDto exportDto = qualitySuperviseDetailsAccordingMapper.selectSuperviseDetailsAccording(superviseDetailAccordingId); // 发现部门 String discovererUrl = null; if (exportDto.getRecordUserId() != null) { discovererUrl = userMapper.selectById(exportDto.getRecordUserId()).getSignatureUrl(); if (StringUtils.isBlank(discovererUrl)) { throw new ErrorException("找不到发现部门人的签名"); } } // 处理措施负责人 String responsibleUrl = null; if (exportDto.getCorrectUserId() != null) { responsibleUrl = userMapper.selectById(exportDto.getCorrectUserId()).getSignatureUrl(); if (StringUtils.isBlank(responsibleUrl)) { throw new ErrorException("找不到处理措施负责人的签名"); } } // 技术负责人 String correctiveUrl = null; if (exportDto.getQualityManagerUserId() != null) { correctiveUrl = userMapper.selectById(exportDto.getQualityManagerUserId()).getSignatureUrl(); if (StringUtils.isBlank(correctiveUrl)) { throw new ErrorException("找不到技术负责人的签名"); } } // 质量负责人 String qualityUrl = null; if (exportDto.getQualityManagerUserId() != null) { qualityUrl = userMapper.selectById(exportDto.getQualityManagerUserId()).getSignatureUrl(); if (StringUtils.isBlank(qualityUrl)) { throw new ErrorException("找不到质量负责人的签名"); } } // 获取路径 InputStream inputStream = this.getClass().getResourceAsStream("/static/supervision-detail-according.docx"); ConfigureBuilder builder = Configure.builder(); String finalDiscovererUrl = discovererUrl; String finalResponsibleUrl = responsibleUrl; String finalCorrectiveUrl = correctiveUrl; String finalQualityUrl = qualityUrl; XWPFTemplate template = XWPFTemplate.compile(inputStream, builder.build()).render( new HashMap() {{ put("control", exportDto); put("discovererUrl", StringUtils.isNotBlank(finalDiscovererUrl) ? Pictures.ofLocal(imgUrl + "/" + finalDiscovererUrl).create() : null); put("responsibleUrl", StringUtils.isNotBlank(finalResponsibleUrl) ? Pictures.ofLocal(imgUrl + "/" + finalResponsibleUrl).create() : null); put("correctiveUrl", StringUtils.isNotBlank(finalCorrectiveUrl) ? Pictures.ofLocal(imgUrl + "/" + finalCorrectiveUrl).create() : null); put("qualityUrl", StringUtils.isNotBlank(finalQualityUrl) ? Pictures.ofLocal(imgUrl + "/" + finalQualityUrl).create() : null); }}); try { response.setContentType("application/msword"); String fileName = URLEncoder.encode( "监督记录不符合控制信息", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".docx"); OutputStream os = response.getOutputStream(); template.write(os); os.flush(); os.close(); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException("导出失败"); } } /************************************************* 纠正措施处理单 ********************************************************/ @Override public boolean addSuperviseDetailCorrect(QualitySuperviseDetailsCorrect detailsCorrect) { QualitySuperviseDetailsCorrect correct = new QualitySuperviseDetailsCorrect(); // 当前登录用户信息和部门 User user = userMapper.selectById(SecurityUtils.getUserId().intValue()); String departmentLimsName = userMapper.selectUserDepartmentLimsName(user.getId()); switch (detailsCorrect.getFlowType()) { // 不合格提出 case 0: if (detailsCorrect.getSuperviseDetailsId() == null) { throw new ErrorException("缺少质量监督详情Id"); } correct.setSuperviseDetailsId(detailsCorrect.getSuperviseDetailsId()); correct.setRaiseResult(detailsCorrect.getRaiseResult());//不合格表述 correct.setVdeRaiseResult(detailsCorrect.getVdeRaiseResult());//vde专家发现 correct.setRaiseDepartment(departmentLimsName);//提出部门 correct.setRaiseUserId(user.getId());//提出人id correct.setRaiseUserName(user.getName());// 提出人 correct.setRaiseTime(LocalDate.now());// 提出时间 // 原因分析人信息 User causeUser = userMapper.selectById(detailsCorrect.getCauseUserId()); String causeDepartmentLims = userMapper.selectUserDepartmentLimsName(causeUser.getId()); correct.setCauseDepartment(causeDepartmentLims);//原因分析责任部门 correct.setCauseUserId(causeUser.getId());//1原因分析人id correct.setCauseUserName(causeUser.getName());// 1原因分析人 qualitySuperviseDetailsCorrectMapper.insert(correct); break; // 原因分析 case 1: correct.setSuperviseDetailsCorrectId(detailsCorrect.getSuperviseDetailsCorrectId()); correct.setCauseResult(detailsCorrect.getCauseResult());//原因分析 correct.setCauseTime(LocalDate.now());// 1原因分析时间 // 纠正人信息 User correctUser = userMapper.selectById(detailsCorrect.getCorrectUserId()); String correctUserDepartmentLims = userMapper.selectUserDepartmentLimsName(correctUser.getId()); correct.setCorrectDepartment(correctUserDepartmentLims);//2纠正责任部门 correct.setCorrectUserId(correctUser.getId());//2纠正人id correct.setCorrectUserName(correctUser.getName());// 2纠正人 qualitySuperviseDetailsCorrectMapper.updateById(correct); break; // 纠正措施 case 2: correct.setSuperviseDetailsCorrectId(detailsCorrect.getSuperviseDetailsCorrectId()); correct.setCorrectResult(detailsCorrect.getCorrectResult());//2纠正措施 correct.setRaiseDepartmentAffirm(detailsCorrect.getRaiseDepartmentAffirm());//2提出部门确认 correct.setCorrectTime(LocalDate.now());// 2纠正时间 // 验证人信息 User validationUser = userMapper.selectById(detailsCorrect.getValidationUserId()); String validationUserDepartmentLims = userMapper.selectUserDepartmentLimsName(validationUser.getId()); correct.setValidationDepartment(validationUserDepartmentLims);//3验证部门 correct.setValidationUserId(validationUser.getId());//3验证人id correct.setValidationUserName(validationUser.getName());// 3验证人 qualitySuperviseDetailsCorrectMapper.updateById(correct); break; // 验证结果 case 3: correct.setSuperviseDetailsCorrectId(detailsCorrect.getSuperviseDetailsCorrectId()); correct.setValidationResult(detailsCorrect.getValidationResult());//3验证结果 correct.setValidationTime(LocalDate.now());// 3验证时间 correct.setIsFinish(1); qualitySuperviseDetailsCorrectMapper.updateById(correct); break; } return true; } /** * (装备流程)新增监督纠正处理信息 * @return */ @Override public boolean addEquipSuperviseDetailCorrect(QualitySuperviseDetailsCorrect detailsCorrect) { if (detailsCorrect.getSuperviseDetailsId() == null) { throw new ErrorException("缺少质量监督详情Id"); } // 当前登录用户信息和部门 Integer userId = SecurityUtils.getUserId().intValue(); User user = userMapper.selectById(userId); String departmentLimsName = userMapper.selectUserDepartmentLimsName(user.getId()); detailsCorrect.setRaiseDepartment(departmentLimsName);//提出部门 detailsCorrect.setRaiseUserId(user.getId());//提出人id detailsCorrect.setRaiseUserName(user.getName());// 提出人 qualitySuperviseDetailsCorrectMapper.insert(detailsCorrect); if (detailsCorrect.getApproverUserId() != null) { // 查询详情信息 QualitySuperviseDetails superviseDetails = qualitySuperviseDetailsMapper.selectById(detailsCorrect.getSuperviseDetailsId()); // 消息发送 InformationNotification info = new InformationNotification(); // 发送人 info.setCreateUser(user.getName()); info.setMessageType("6"); info.setTheme("CNAS质量监督纠正措施填写通知"); info.setContent("监督项目为: " + superviseDetails.getSuperviseProject() + " 监督纠正措施待填写"); info.setSenderId(userId); // 接收人 info.setConsigneeId(detailsCorrect.getApproverUserId()); info.setJumpPath(MenuJumpPathConstants.QUALITY_SUPERVISE); informationNotificationService.addInformationNotification(info); // 发送企业微信通知 threadPoolTaskExecutor.execute(() -> { // 查询发送人 User people = userMapper.selectById(detailsCorrect.getApproverUserId()); String message = ""; message += "CNAS质量监督纠正措施填写通知"; message += "\n请去过程要求-质量监督计划"; message += "\n" + "监督项目为: " + superviseDetails.getSuperviseProject() + " 监督纠正措施待填写"; //发送企业微信消息通知 try { WxCpUtils.inform(people.getAccount(), message, null); } catch (Exception e) { throw new RuntimeException(e); } }); } return true; } /** * (装备流程)批准监督纠正处理信息 * @return */ @Override public boolean approveEquipSuperviseDetailCorrect(QualitySuperviseDetailsCorrect detailsCorrect) { QualitySuperviseDetailsCorrect correct = new QualitySuperviseDetailsCorrect(); // 当前登录用户信息和部门 User user = userMapper.selectById(SecurityUtils.getUserId().intValue()); String departmentLimsName = userMapper.selectUserDepartmentLimsName(user.getId()); correct.setSuperviseDetailsCorrectId(detailsCorrect.getSuperviseDetailsCorrectId()); correct.setCauseDepartment(departmentLimsName);//原因分析责任部门 correct.setCauseUserId(user.getId());//1原因分析人id correct.setCauseUserName(user.getName());// 1原因分析人 correct.setCorrectDepartment(departmentLimsName);//2纠正责任部门 correct.setCorrectUserId(user.getId());//2纠正人id correct.setCorrectUserName(user.getName());// 2纠正人 correct.setValidationDepartment(departmentLimsName);//3验证部门 correct.setValidationUserId(user.getId());//3验证人id correct.setValidationUserName(user.getName());// 3验证人 correct.setIsFinish(1); qualitySuperviseDetailsCorrectMapper.updateById(correct); return true; } /** * 查询监督纠正处理 * @param superviseDetailsId * @return */ @Override public QualitySuperviseDetailsCorrect getSuperviseDetailCorrect(Integer superviseDetailsId) { QualitySuperviseDetailsCorrect detailsCorrect; detailsCorrect = qualitySuperviseDetailsCorrectMapper.selectOne(Wrappers.lambdaQuery() .eq(QualitySuperviseDetailsCorrect::getSuperviseDetailsId, superviseDetailsId)); if (detailsCorrect == null) { detailsCorrect = new QualitySuperviseDetailsCorrect(); } return detailsCorrect; } /** * 查询监督纠正措施列表 * @param page * @param detailsCorrect * @return */ @Override public IPage pageSuperviseDetailCorrect(Page page, QualitySuperviseDetailsCorrect detailsCorrect) { return qualitySuperviseDetailsCorrectMapper.pageSuperviseDetailAccording(page, QueryWrappers.queryWrappers(detailsCorrect)); } /** * 新增监督纠正措施附件 * @param superviseDetailsCorrectId * @param file * @return */ @Override public boolean uploadSuperviseDetailCorrectFile(Integer superviseDetailsCorrectId, MultipartFile file) { if (superviseDetailsCorrectId == null) { throw new ErrorException("缺少纠正措施id"); } String urlString; String pathName; String path; String filename = file.getOriginalFilename(); String contentType = file.getContentType(); QualitySuperviseDetailsCorrectFile superviseDetailsCorrectFile = new QualitySuperviseDetailsCorrectFile(); superviseDetailsCorrectFile.setSuperviseDetailsCorrectId(superviseDetailsCorrectId); superviseDetailsCorrectFile.setFileName(filename); if (contentType != null && contentType.startsWith("image/")) { // 是图片 path = imgUrl; superviseDetailsCorrectFile.setType(1); } else { // 是文件 path = wordUrl; superviseDetailsCorrectFile.setType(2); } try { File realpath = new File(path); if (!realpath.exists()) { realpath.mkdirs(); } pathName = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyMMddHHmmss")) + "_" + file.getOriginalFilename(); urlString = realpath + "/" + pathName; file.transferTo(new File(urlString)); superviseDetailsCorrectFile.setFileUrl(pathName); qualitySuperviseDetailsCorrectFileMapper.insert(superviseDetailsCorrectFile); return true; } catch (Exception e) { e.printStackTrace(); throw new ErrorException(e.getMessage()); } } /** * 查询监督纠正措施附件 * @param superviseDetailsCorrectId * @return */ @Override public List getSuperviseDetailCorrectFileList(Integer superviseDetailsCorrectId) { return qualitySuperviseDetailsCorrectFileMapper.selectList(Wrappers.lambdaQuery() .eq(QualitySuperviseDetailsCorrectFile::getSuperviseDetailsCorrectId, superviseDetailsCorrectId)); } /** * 导出监督纠正措施 * @param superviseDetailsCorrectId * @param response */ @Override public void exportSuperviseDetaillCorrect(Integer superviseDetailsCorrectId, HttpServletResponse response) { QualitySuperviseDetailsCorrect detailsCorrect = qualitySuperviseDetailsCorrectMapper.selectById(superviseDetailsCorrectId); QualitySuperviseDetailsCorrectDto detailsCorrectDto = new QualitySuperviseDetailsCorrectDto(); BeanUtils.copyProperties(detailsCorrect, detailsCorrectDto); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); // 提出时间 detailsCorrectDto.setRaiseTimeString(detailsCorrectDto.getRaiseTime() != null ? detailsCorrectDto.getRaiseTime().format(formatter) : null); // 原因分析时间 detailsCorrectDto.setCauseTimeString(detailsCorrectDto.getCauseTime() != null ? detailsCorrectDto.getCauseTime().format(formatter) : null); // 纠正时间 detailsCorrectDto.setCorrectTimeString(detailsCorrectDto.getCorrectTime() != null ? detailsCorrectDto.getCorrectTime().format(formatter) : null); // 验证时间 detailsCorrectDto.setValidationTimeString(detailsCorrectDto.getValidationTime() != null ? detailsCorrectDto.getValidationTime().format(formatter) : null); // 提出人签名 String raiseUrl = null; if (detailsCorrectDto.getRaiseUserId() != null) { raiseUrl = userMapper.selectById(detailsCorrectDto.getRaiseUserId()).getSignatureUrl(); if (StringUtils.isBlank(raiseUrl)) { throw new ErrorException("找不到提出人的签名"); } } // 原因分析人 String causeUrl = null; if (detailsCorrectDto.getCauseUserId() != null) { causeUrl = userMapper.selectById(detailsCorrectDto.getCauseUserId()).getSignatureUrl(); if (StringUtils.isBlank(causeUrl)) { throw new ErrorException("找不到原因分析人的签名"); } } // 纠正人 String correctUrl = null; if (detailsCorrectDto.getCorrectUserId() != null) { correctUrl = userMapper.selectById(detailsCorrectDto.getCorrectUserId()).getSignatureUrl(); if (StringUtils.isBlank(correctUrl)) { throw new ErrorException("找不到纠正人的签名"); } } // 验证人 String validationUrl = null; if (detailsCorrectDto.getValidationUserId() != null) { validationUrl = userMapper.selectById(detailsCorrectDto.getValidationUserId()).getSignatureUrl(); if (StringUtils.isBlank(validationUrl)) { throw new ErrorException("找不到验证人的签名"); } } // 获取路径 InputStream inputStream = this.getClass().getResourceAsStream("/static/supervise-detail-correct.docx"); ConfigureBuilder builder = Configure.builder(); builder.useSpringEL(true); String finalRaiseUrl = raiseUrl; String finalCauseUrl = causeUrl; String finalCorrectUrl = correctUrl; String finalValidationUrl = validationUrl; XWPFTemplate template = XWPFTemplate.compile(inputStream, builder.build()).render( new HashMap() {{ put("correct", detailsCorrectDto); put("raiseUrl", StringUtils.isNotBlank(finalRaiseUrl) ? Pictures.ofLocal(imgUrl + "/" + finalRaiseUrl).create() : null); put("causeUrl", StringUtils.isNotBlank(finalCauseUrl) ? Pictures.ofLocal(imgUrl + "/" + finalCauseUrl).create() : null); put("correctUrl", StringUtils.isNotBlank(finalCorrectUrl) ? Pictures.ofLocal(imgUrl + "/" + finalCorrectUrl).create() : null); put("validationUrl", StringUtils.isNotBlank(finalValidationUrl) ? Pictures.ofLocal(imgUrl + "/" + finalValidationUrl).create() : null); }}); try { response.setContentType("application/msword"); String fileName = URLEncoder.encode( "监督纠正措施", "UTF-8"); response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".docx"); OutputStream os = response.getOutputStream(); template.write(os); os.flush(); os.close(); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException("导出失败"); } } }