//package com.ruoyi.inspect.service.impl; // //import cn.hutool.core.util.StrUtil; //import cn.hutool.json.JSONUtil; //import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; //import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; //import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; //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.data.Pictures; //import com.ruoyi.common.properties.WechatProperty; //import com.ruoyi.common.utils.QueryWrappers; //import com.ruoyi.inspect.dto.ReportPageDto; //import com.ruoyi.inspect.mapper.InsOrderStateMapper; //import com.ruoyi.inspect.mapper.InsProductMapper; //import com.ruoyi.inspect.mapper.InsReportMapper; //import com.ruoyi.inspect.mapper.InsUnqualifiedRetestProductMapper; //import com.ruoyi.inspect.pojo.InsReport; //import com.ruoyi.inspect.service.InsOrderService; //import com.ruoyi.inspect.service.InsReportService; //import com.ruoyi.system.mapper.UserMapper; //import org.apache.poi.xwpf.usermodel.*; //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.imageio.ImageIO; //import java.awt.image.BufferedImage; //import java.io.*; //import java.nio.file.Files; //import java.nio.file.Path; //import java.nio.file.Paths; //import java.nio.file.StandardCopyOption; //import java.time.LocalDateTime; //import java.time.format.DateTimeFormatter; //import java.util.*; //import java.util.stream.Collectors; //import java.util.zip.ZipEntry; //import java.util.zip.ZipFile; //import java.util.zip.ZipOutputStream; // ///** // * @author Administrator // * @description 针对表【ins_report(检验报告)】的数据库操作Service实现 // * @createDate 2024-03-17 22:10:02 // */ //@Service //public class InsReportServiceImpl extends ServiceImpl // implements InsReportService { // // @Resource // private GetLook getLook; // @Resource // private UserMapper userMapper; // @Resource // private InsReportMapper insReportMapper; // @Resource // private InsOrderStateMapper insOrderStateMapper; // @Resource // private InsProductMapper insProductMapper; // @Resource // private InformationNotificationService informationNotificationService; // @Value("${wordUrl}") // private String wordUrl; // @Value("${file.path}") // private String imgUrl; // @Value("${file.licenseUrl}") // private String licenseUrl; // @Resource // private InsOrderMapper insOrderMapper; // @Resource // private IfsInventoryQuantityMapper ifsInventoryQuantityMapper; // @Resource // private InsUnqualifiedHandlerMapper insUnqualifiedHandlerMapper; // @Resource // private InsSampleMapper insSampleMapper; // @Resource // private ThreadPoolTaskExecutor threadPoolTaskExecutor; // @Resource // private InsOrderService insOrderService; // @Resource // private WechatProperty wechatProperty; // @Resource // private InsUnqualifiedRetestProductMapper insUnqualifiedRetestProductMapper; // @Resource // private IfsApiUtils ifsApiUtils; // @Resource // private InsSampleUserMapper insSampleUserMapper; // // // @Override // public Map pageInsReport(Page page, ReportPageDto reportPageDto) { // Map map = new HashMap<>(); // map.put("head", PrintChina.printChina(ReportPageDto.class)); // Map map1 = getLook.selectPowerByMethodAndUserId("pageInsReport"); // User user = userMapper.selectById(map1.get("userId"));//当前登录的人 // //获取当前人所属实验室id // String departLimsId = user.getDepartLimsId(); // String laboratory = null; //// if (ObjectUtils.isNotEmpty(departLimsId) && !departLimsId.equals("")) { //// String[] split = departLimsId.split(","); //// //查询对应架构名称(通信实验室,电力实验室,检测办) //// String departLims = insOrderMapper.seldepLimsId(Integer.parseInt(split[split.length - 1])); //// if (departLims.contains("实验室")) { //// laboratory = departLims; //// } //// } // // Integer createOrderUser = null; // if (map1.get("look") == 1) { // //个人 // createOrderUser = map1.get("userId"); // } // String queryStatus = reportPageDto.getQueryStatus(); // reportPageDto.setQueryStatus(null); // // map.put("body", insReportMapper.pageInsReport(page, // QueryWrappers.queryWrappers(reportPageDto), // laboratory, // map1.get("userId"), // queryStatus, // createOrderUser)); // return map; // } // // @Override // public int inReport(String url, Integer id) { // InsReport insReport = new InsReport(); // insReport.setId(id); // insReport.setUrlS(url); // // 还原pdf // String tempUrlPdf = wordToPdfTemp(insReport.getUrlS().replace("/word", wordUrl)); // insReport.setTempUrlPdf("/word/" + tempUrlPdf); // return insReportMapper.updateById(insReport); // } // // @Override // public int upReportUrl(Integer id) { // InsReport report = insReportMapper.selectById(id); // // 还原pdf // String tempUrlPdf = wordToPdfTemp(report.getUrl().replace("/word", wordUrl)); // // return insReportMapper.update(null, Wrappers.lambdaUpdate() // .eq(InsReport::getId, id) // .set(InsReport::getUrlS, null) // .set(InsReport::getTempUrlPdf, "/word/" + tempUrlPdf)); // } // // //提交 // @Override // @Transactional(rollbackFor = Exception.class) // public int writeReport(Integer id, Integer userId, Integer submitUserId) { // submitUserId = submitUserId == null ? getLook.selectPowerByMethodAndUserId(null).get("userId") : submitUserId; // InsReport insReport = insReportMapper.selectById(id); // insReport.setId(id); // insReport.setState(1); // insReport.setWriteUserId(submitUserId);//提交人 // if (userId == null) { // throw new ErrorException("缺少审核人"); // } // insReport.setExamineUserId(userId);//审核人 // insReport.setWriteTime(LocalDateTime.now());//提交时间 // //获取提交人的签名地址 // String signatureUrl; // try { // signatureUrl = userMapper.selectById(insReport.getWriteUserId()).getSignatureUrl(); // } catch (Exception e) { // throw new ErrorException("找不到编制人的签名"); // } // if (ObjectUtils.isEmpty(signatureUrl) || signatureUrl.equals("")) { // throw new ErrorException("找不到检验人的签名"); // } // // Integer insOrderId = insReportMapper.selectById(id).getInsOrderId(); // InsOrder order = insOrderMapper.selectById(insOrderId); // boolean isRawMater = order.getTypeSource() != null && order.getTypeSource().equals(1); // // //发送消息 // InformationNotification info = new InformationNotification(); // info.setCreateUser(insProductMapper.selectUserById(userId).get("name")); // info.setMessageType("3"); // info.setTheme("审核通知"); // info.setContent("您有一条报告编制待审核消息, 编号:" + insReport.getCode()); // info.setSenderId(submitUserId); //发送人 // info.setConsigneeId(userId); //收件人 // info.setViewStatus(false); // info.setJumpPath("b1-report-preparation"); // informationNotificationService.addInformationNotification(info); // //系统生成报告地址 // String url = insReport.getUrl(); // //手动上传报告地址 // String urlS = insReport.getUrlS(); // // // 判断是否是原材料 需要替换****成供应商 // IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper() // .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId())); // if (one != null) { // if (isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) { // changeText(new HashMap() {{ // put("**********", one.getSupplierName()); // }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl)); // } // } // // wordInsertUrl(new HashMap() {{ // put("writeUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create()); // put("writeDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create()); // put("insUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create()); // }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl)); // // // 修改临时pdf // String tempUrlPdf = wordToPdfTemp((StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl)); // insReport.setTempUrlPdf("/word/" + tempUrlPdf); // // insReportMapper.updateById(insReport); // // // 清空审核时间, 审核状态 // insReportMapper.update(null, Wrappers.lambdaUpdate() // .eq(InsReport::getId, insReport.getId()) // .set(InsReport::getRatifyTime, null) // .set(InsReport::getIsRatify, null) // .set(InsReport::getExamineTime, null) // .set(InsReport::getIsExamine, null)); // // return 1; // } // // //审核 // @Override // @Transactional(rollbackFor = Exception.class) // public int examineReport(Integer id, Integer isExamine, String examineTell, Integer userId) { // InsReport insReport = insReportMapper.selectById(id); // insReport.setIsExamine(isExamine); // if (ObjectUtils.isNotEmpty(examineTell)) { // insReport.setExamineTell(examineTell); // } // // // 检验人 // String userName = insProductMapper.selectUserById(insReport.getWriteUserId()).get("name"); // String userAccount = insProductMapper.selectUserById(insReport.getWriteUserId()).get("account"); // // // 审核人 // Integer checkUserId = getLook.selectPowerByMethodAndUserId(null).get("userId"); // String checkUserName = insProductMapper.selectUserById(checkUserId).get("name"); // // insReport.setExamineTime(LocalDateTime.now());//审核时间 // if (isExamine == 0) { // // 发送企业微信通知(审核退回) // threadPoolTaskExecutor.execute(() -> { // // 查询订单 // InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId()); // InsSample insSample = insSampleMapper.selectOne(Wrappers.lambdaQuery() // .eq(InsSample::getInsOrderId, insReport.getInsOrderId()) // .last("limit 1")); // // 查询原材料 // IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId()); // // String message = ""; // message += "报告编制审核退回通知"; // message += "\n审核人: " + checkUserName; // message += "\n委托编号: " + order.getEntrustCode(); // message += "\n样品名称: " + insSample.getModel(); // message += "\n规格型号: " + order.getPartDetail(); // if (ifsInventoryQuantity != null) { // message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo(); // } // message += "\n退回原因: " + examineTell; // //发送企业微信消息通知 提交复核 // try { // WxCpUtils.inform(userAccount, message, null); // } catch (Exception e) { // throw new RuntimeException(e); // } // }); // // //如果审核不通过 // insReport.setState(0);//提交状态改为待提交 // return insReportMapper.updateById(insReport); // } else { // if (userId == null) { // throw new ErrorException("缺少批准人"); // } // } // insReport.setRatifyUserId(userId);//批准人 // //获取审核人的签名地址 // String signatureUrl; // try { // signatureUrl = userMapper.selectById(insReport.getExamineUserId()).getSignatureUrl(); // } catch (Exception e) { // throw new ErrorException("找不到审核人的签名"); // } // if (StringUtils.isBlank(signatureUrl)) { // throw new ErrorException("找不到审核人的签名"); // } // // // 批准人 // String sendUserAccount = insProductMapper.selectUserById(userId).get("account"); // // //发送消息 // //当前用户 // Integer currentUser = getLook.selectPowerByMethodAndUserId(null).get("userId"); // InformationNotification info = new InformationNotification(); // info.setCreateUser(insProductMapper.selectUserById(userId).get("name")); // info.setMessageType("3"); // info.setTheme("批准通知"); // info.setContent("您有一条报告编制待批准消息, 编号:" + insReport.getCode()); // info.setSenderId(currentUser); //发送人 // info.setConsigneeId(userId); //收件人 // info.setViewStatus(false); // info.setJumpPath("b1-report-preparation"); // informationNotificationService.addInformationNotification(info); // //系统生成报告地址 // String url = insReport.getUrl(); // //手动上传报告地址 // String urlS = insReport.getUrlS(); // wordInsertUrl(new HashMap() {{ // put("examineUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create()); // put("examineDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create()); // }}, (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl)); // // // 修改临时pdf // String tempUrlPdf = wordToPdfTemp((StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl)); // insReport.setTempUrlPdf("/word/" + tempUrlPdf); // // // 发送企业微信通知(通知批准人审批) // threadPoolTaskExecutor.execute(() -> { // // 查询订单 // InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId()); // InsSample insSample = insSampleMapper.selectOne(Wrappers.lambdaQuery() // .eq(InsSample::getInsOrderId, insReport.getInsOrderId()) // .last("limit 1")); // // 查询原材料 // IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId()); // // String message = ""; // message += "报告编制批准通知"; // message += "\n检验人: " + userName; // message += "\n复核人: " + checkUserName; // message += "\n委托编号: " + order.getEntrustCode(); // message += "\n样品名称: " + insSample.getModel(); // message += "\n规格型号: " + order.getPartDetail(); // if (ifsInventoryQuantity != null) { // message += "\n生产厂家: " + ifsInventoryQuantity.getSupplierName(); // message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo(); // } // //发送企业微信消息通知 提交复核 // try { // WxCpUtils.inform(sendUserAccount, message, null); // } catch (Exception e) { // throw new RuntimeException(e); // } // }); // insReportMapper.updateById(insReport); // // // 清空批准备注, 批准时间, 批准状态 // insReportMapper.update(null, Wrappers.lambdaUpdate() // .eq(InsReport::getId, insReport.getId()) // .set(InsReport::getExamineTell, null) // .set(InsReport::getRatifyTime, null) // .set(InsReport::getIsRatify, null)); // return 1; // } // // //批准 // @Override // @Transactional(rollbackFor = Exception.class) // public int ratifyReport(Integer id, Integer isRatify, String ratifyTell) { // InsReport insReport = insReportMapper.selectById(id); // insReport.setIsRatify(isRatify); // if (ObjectUtils.isNotEmpty(ratifyTell)) { // insReport.setRatifyTell(ratifyTell); // } // insReport.setRatifyTime(LocalDateTime.now());//批准时间 // if (isRatify == 0) { // // // 批准人 // Integer ratifyUserId = getLook.selectPowerByMethodAndUserId(null).get("userId"); // String ratifyUserName = insProductMapper.selectUserById(ratifyUserId).get("name"); // // // 发送人(审核人)(检验人) // // 检验人 // String userAccount = insProductMapper.selectUserById(insReport.getWriteUserId()).get("account"); // // 审核人 // String checkUserAccount = insProductMapper.selectUserById(insReport.getExamineUserId()).get("account"); // // // // 发送企业微信通知(批准退回) // threadPoolTaskExecutor.execute(() -> { // // 查询订单 // InsOrder order = insOrderMapper.selectById(insReport.getInsOrderId()); // InsSample insSample = insSampleMapper.selectOne(Wrappers.lambdaQuery() // .eq(InsSample::getInsOrderId, insReport.getInsOrderId()) // .last("limit 1")); // // 查询原材料 // IfsInventoryQuantity ifsInventoryQuantity = ifsInventoryQuantityMapper.selectById(order.getIfsInventoryId()); // // String message = ""; // message += "报告编制批准退回通知"; // message += "\n批准人: " + ratifyUserName; // message += "\n委托编号: " + order.getEntrustCode(); // message += "\n样品名称: " + insSample.getModel(); // message += "\n规格型号: " + order.getPartDetail(); // if (ifsInventoryQuantity != null) { // message += "\n批次号: " + ifsInventoryQuantity.getUpdateBatchNo(); // } // message += "\n退回原因: " + ratifyTell; // //发送企业微信消息通知 提交复核 // try { // // 审批人 // WxCpUtils.inform(checkUserAccount, message, null); // // // 检验人 // WxCpUtils.inform(userAccount, message, null); // } catch (Exception e) { // throw new RuntimeException(e); // } // }); // // //如果批准不通过 直接退回到提交人那边去 // insReport.setState(0); // insReport.setIsExamine(0); // return insReportMapper.updateById(insReport); // } // //获取批准人的签名地址 // String signatureUrl; // try { // signatureUrl = userMapper.selectById(insReport.getRatifyUserId()).getSignatureUrl(); // } catch (Exception e) { // throw new ErrorException("找不到批准人的签名"); // } // if (StringUtils.isBlank(signatureUrl)) { // throw new ErrorException("找不到批准人的签名"); // } // Integer insOrderId = insReportMapper.selectById(id).getInsOrderId(); // InsOrder order = insOrderMapper.selectById(insOrderId); // boolean isRawMater = order.getTypeSource() != null && order.getTypeSource().equals(1); // // //获取场所的报告专用章 // String sealUrl; // String laboratory = insOrderMapper.selectById(insReport.getInsOrderId()).getLaboratory(); // try { // String type = ""; // if (isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)) { // type = "进厂报告"; // } else { // type = "委托报告"; // } // sealUrl = insReportMapper.getLaboratoryByName(laboratory, type); // } catch (Exception e) { // throw new ErrorException(laboratory + "找不到报告专用章"); // } // if (StringUtils.isBlank(sealUrl)) { // throw new ErrorException(laboratory + "找不到报告专用章"); // } // //系统生成报告地址 // String url = insReport.getUrl(); // //手动上传报告地址 // String urlS = insReport.getUrlS(); // String finalUrl = (StrUtil.isBlank(urlS) ? url : urlS).replace("/word", wordUrl); // // wordInsertUrl(new HashMap() {{ // put("ratifyUrl", Pictures.ofLocal(imgUrl + "/" + signatureUrl).create()); // put("ratifyDateUrl", Pictures.ofStream(DateImageUtil.createDateImage(null)).create()); // put("seal1", Pictures.ofLocal(imgUrl + "/" + sealUrl).create()); // put("seal2", Pictures.ofLocal(imgUrl + "/" + sealUrl).create()); // }}, finalUrl); // // // 修改临时pdf // insReport.setTempUrlPdf((StrUtil.isBlank(urlS) ? url : urlS).replace(".docx", ".pdf")); // // InsOrder insOrder = new InsOrder(); // insOrder.setId(insOrderId); // insOrder.setState(4); // insOrderMapper.updateById(insOrder); // // wordToPdf(finalUrl, sealUrl, isRawMater && order.getOrderType().equals(InsOrderTypeConstants.ENTER_THE_FACTORY)); // // // 判断是否为原材料 // if (isRawMater) { // // 修改ifs库存状态 // ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() // .set(IfsInventoryQuantity::getState, 2) // .eq(IfsInventoryQuantity::getId, order.getIfsInventoryId())); // } // insReport.setRatifyTell(""); // // // 发送文件到委托人 // if (StringUtils.isNotBlank(order.getPrepareCode())) { // threadPoolTaskExecutor.execute(() -> { // String message = ""; // message += "委托编号: " + order.getEntrustCode(); // message += "委托样品: " + order.getSampleView(); // message += "已检测结束, 请接收"; // try { // WxCpUtils.inform(order.getPrepareCode(), message, new File(finalUrl.replace(".docx", ".pdf"))); // } catch (Exception e) { // throw new RuntimeException(e); // } // }); // } // // return insReportMapper.updateById(insReport); // } // // @Override // public int wordInsertUrl(Map map, String url) { // XWPFTemplate template = XWPFTemplate.compile(url).render(map); // try { // template.writeAndClose(Files.newOutputStream(Paths.get(url))); // } catch (IOException e) { // throw new RuntimeException(e); // } // return 1; // } // // // //报告批量下载 // @Override // @Transactional(rollbackFor = Exception.class) // public String downAll(String ids) { // List list = Arrays.stream(ids.split(",")).map(Long::parseLong).collect(Collectors.toList()); // List insReports = insReportMapper.selectBatchIds(list); // String zipFilePath = null; // // 临时文件夹路径 // try { // String tempFolderPath = wordUrl + "/tempFolder"; // File tempFolder = new File(tempFolderPath); // if (tempFolder.exists()) { // deleteDirectory(tempFolder); // 删除旧的临时文件夹 // } // tempFolder.mkdirs(); // 创建新的临时文件夹 // for (InsReport insReport : insReports) { // File sourceFile = new File((ObjectUtils.isNotEmpty(insReport.getUrlS()) ? insReport.getUrlS() : insReport.getUrl()).replace("/word", wordUrl)); // File destinationFile = new File(tempFolder, sourceFile.getName()); // Files.copy(sourceFile.toPath(), destinationFile.toPath(), StandardCopyOption.REPLACE_EXISTING); // } // // 压缩临时文件夹 // zipFilePath = wordUrl + "/zip/output.zip"; // zipDirectory(tempFolderPath, zipFilePath); // // // 清理临时文件夹 // deleteDirectory(tempFolder); // // System.out.println("ZIP文件创建完成！"); // } catch (IOException e) { // e.printStackTrace(); // } // return "/word/zip/output.zip"; // } // // //批量上传 // @Override // @Transactional(rollbackFor = Exception.class) // public int upAll(MultipartFile file) throws IOException { // File tempFile = null; // File unzipDir = null; // try { // tempFile = File.createTempFile(wordUrl, ".zip"); // file.transferTo(tempFile); // // unzipDir = new File("uploaded_files"); // if (!unzipDir.exists()) { // unzipDir.mkdir(); // } // unzip(tempFile, unzipDir); // // 处理解压后的文件 // File[] files = unzipDir.listFiles(); // if (files != null) { // for (File f : files) { // // 根据文件名查询id // String name = f.getName(); // InsReport insReport = insReportMapper.selectOne(Wrappers.lambdaQuery().like(InsReport::getCode, f.getName().replace(".docx", "").replace("JCZX", "JCZX/"))); // if (ObjectUtils.isEmpty(insReport)) { // throw new ErrorException("没有找到 " + f.getName() + " 这个文件对应的报告数据"); // } // String urlString; // String pathName; // try { // String path = wordUrl; // File realpath = new File(path); // if (!realpath.exists()) { // realpath.mkdirs(); // } // pathName = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyMMddHHmmss")) + "_" + f.getName(); // urlString = realpath + "/" + pathName; // // 复制文件到指定路径 // Files.copy(f.toPath(), new File(urlString).toPath(), StandardCopyOption.REPLACE_EXISTING); // inReport("/word/" + pathName, insReport.getId()); // } catch (IOException e) { // throw new ErrorException("文件上传失败"); // } // } // } // } catch (IOException e) { // throw new ErrorException("文件处理失败"); // } finally { // if (tempFile != null && tempFile.exists()) { // tempFile.delete(); // } // // 递归删除解压目录及其中的文件 // if (unzipDir.exists()) { // deleteDirectory(unzipDir); // 删除旧的临时文件夹 // } // } // return 0; // } // // // //解压文件夹 // private void unzip(File zipFile, File destDir) throws IOException { // try (ZipFile zip = new ZipFile(zipFile)) { // Enumeration entries = zip.entries(); // while (entries.hasMoreElements()) { // ZipEntry entry = entries.nextElement(); // File file = new File(destDir, entry.getName()); // if (entry.isDirectory()) { // file.mkdirs(); // } else { // file.getParentFile().mkdirs(); // try (InputStream in = zip.getInputStream(entry); // OutputStream out = new FileOutputStream(file)) { // byte[] buffer = new byte[1024]; // int len; // while ((len = in.read(buffer)) > 0) { // out.write(buffer, 0, len); // } // } // } // } // } // } // // // 压缩文件夹 // public static void zipDirectory(String sourceDirPath, String zipFilePath) throws IOException { // try (ZipOutputStream zipOut = new ZipOutputStream(new FileOutputStream(zipFilePath))) { // Path sourceDir = Paths.get(sourceDirPath); // Files.walk(sourceDir) // .filter(path -> !Files.isDirectory(path)) // .forEach(path -> { // ZipEntry zipEntry = new ZipEntry(sourceDir.relativize(path).toString()); // try { // zipOut.putNextEntry(zipEntry); // Files.copy(path, zipOut); // zipOut.closeEntry(); // } catch (IOException e) { // e.printStackTrace(); // } // }); // } // } // // // 删除文件夹及其内容 // public static void deleteDirectory(File directory) throws IOException { // if (directory.isDirectory()) { // File[] files = directory.listFiles(); // if (files != null) { // for (File file : files) { // deleteDirectory(file); // } // } // } // Files.delete(directory.toPath()); // } // // @Override // public void wordToPdf(String path, String sealUrl, boolean isRawMater) { // try { // wordToPdf(path, path.replace(".docx", ".pdf"), sealUrl, isRawMater); // } catch (Exception e) { // throw new ErrorException("转换失败"); // } // } // // // public String wordToPdf(String wordPath, String pdfPath, String sealUrl, boolean isRawMater) { // FileOutputStream os = null; // try { // //凭证 不然切换后有水印 //// InputStream is = this.getClass().getResourceAsStream("/lib/license.xml"); //// InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("license.xml"); // InputStream is = Files.newInputStream(new File(licenseUrl).toPath()); // License license = new License(); // license.setLicense(is); // if (!license.getIsLicensed()) { // System.out.println("License验证不通过..."); // return null; // } // //生成一个空的PDF文件 // File file; // //判断是否是进厂报告 // if (!isRawMater) { // file = new File(pdfPath.replace(".pdf", "-1.pdf")); // } else { // file = new File(pdfPath.replace(".pdf", ".pdf")); // } // os = new FileOutputStream(file); // //要转换的word文件 // com.aspose.words.Document doc = new com.aspose.words.Document(wordPath); // doc.save(os, SaveFormat.PDF); // // //添加骑缝章 // if (!isRawMater) { // stamperCheckMarkPDF(pdfPath.replace(".pdf", "-1.pdf"), pdfPath, imgUrl + "/" + sealUrl); // } // // // } catch (Exception e) { // e.printStackTrace(); // } finally { // if (os != null) { // try { // os.close(); // } catch (IOException e) { // e.printStackTrace(); // } // } // } // return null; // } // // /** // * 切割图片 // * // * @param Path 图片路径 // * @param n 切割份数 // */ // public static com.itextpdf.text.Image[] slicingImages(String Path, int n) throws IOException, BadElementException { // com.itextpdf.text.Image[] nImage = new com.itextpdf.text.Image[n]; // BufferedImage img = ImageIO.read(new File(Path)); // // int h = img.getHeight(); // int w = img.getWidth(); // // int sw = w / n; // for (int i = 0; i < n; i++) { // BufferedImage subImg; // if (i == n - 1) {//最后剩余部分 // subImg = img.getSubimage(i * sw, 0, w - i * sw, h); // } else {//前n-1块均匀切 // subImg = img.getSubimage(i * sw, 0, sw, h); // } // ByteArrayOutputStream out = new ByteArrayOutputStream(); // ImageIO.write(subImg, Path.substring(Path.lastIndexOf('.') + 1), out); // nImage[i] = com.itextpdf.text.Image.getInstance(out.toByteArray()); // // } // return nImage; // } // // /** // * 盖骑缝章 // * // * @param infilePath 原PDF路径 // * @param outFilePath 输出PDF路径 // */ // public static void stamperCheckMarkPDF(String infilePath, String outFilePath, String picPath) throws IOException, DocumentException { // PdfReader reader = new PdfReader(infilePath);//选择需要印章的pdf // PdfStamper stamp = new PdfStamper(reader, new FileOutputStream(outFilePath));//加完印章后的pdf // // // com.itextpdf.text.Rectangle pageSize = reader.getPageSize(1);//获得第一页 // float height = pageSize.getHeight(); // float width = pageSize.getWidth(); // // int nums = reader.getNumberOfPages(); // com.itextpdf.text.Image[] nImage = slicingImages(picPath, nums);//生成骑缝章切割图片 // // for (int n = 1; n <= nums; n++) { // PdfContentByte over = stamp.getOverContent(n);//设置在第几页打印印章 // com.itextpdf.text.Image img = nImage[n - 1];//选择图片 // float newHeight = 100f; // float newWidth = img.getWidth() / (img.getHeight() / 100); // img.scaleAbsolute(newWidth, newHeight);//控制图片大小 // img.setAbsolutePosition(width - newWidth, height / 2 - newHeight / 2);//控制图片位置 // over.addImage(img); // } // stamp.close(); // } // // @Transactional(rollbackFor = Exception.class) // public void isRawMaterial(InsOrder insOrder) { // IfsInventoryQuantity one = ifsInventoryQuantityMapper.selectOne(new LambdaQueryWrapper() // .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())); // if (Objects.isNull(one)) { // throw new ErrorException("找不到原材料信息"); // } // // 判断是否有不合格信息 // Long count = insUnqualifiedHandlerMapper.selectCount(Wrappers.lambdaQuery() // .eq(InsUnqualifiedHandler::getInventoryQuantityId, one.getId())); // String toLocation = null; // // // 判断是否有不合格 // Long unqualifiedCount = getUnqualifiedCount(insOrder); // // if (count.equals(0L) && unqualifiedCount.equals(0L) && one.getIsFinish().equals(0) && one.getIsSource().equals(1)) { // // 原材料移库 // toLocation = this.moveRawMaterial(one); // } // // // 判断结束状态修改合格状态 // int inspectStatus = (count == 0 && unqualifiedCount == 0) ? 1 : 2; // insOrderMapper.update(null, Wrappers.lambdaUpdate() // .eq(InsOrder::getId, insOrder.getId()) // .set(InsOrder::getInsResult, inspectStatus)); // // if (one.getIsFinish().equals(0)) { // ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() // .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId()) // .set(IfsInventoryQuantity::getInspectStatus, inspectStatus)); // // // 修改ifs库存状态 // if (StringUtils.isBlank(toLocation)) { // ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() // .set(IfsInventoryQuantity::getIsFinish, 1) // .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())); // } else { // ifsInventoryQuantityMapper.update(null, new LambdaUpdateWrapper() // .set(IfsInventoryQuantity::getIsFinish, 1) // .set(IfsInventoryQuantity::getToLocation, toLocation) // .eq(IfsInventoryQuantity::getId, insOrder.getIfsInventoryId())); // } // // threadPoolTaskExecutor.execute(() -> { // // 企业微信通知 // String message = ""; // message += "检测结果提交通知"; // message += "\n批次号: " + one.getUpdateBatchNo(); // message += "\n零件号: " + one.getPartNo(); // message += "\n零件描述: " + one.getPartDesc(); // message += "\n供应商名称: " + one.getSupplierName(); // message += "\n抵达数量: " + one.getQtyArrived().stripTrailingZeros().toPlainString() + one.getBuyUnitMeas(); // // 发送企业inspectStatus信通知 // if (inspectStatus == 1) { // message += "\n检测结果: 合格"; // } else { // message += "\n检测结果: 不合格"; // } // WxCpUtils.informWebHook(wechatProperty.getExaminingUrl(), message); // }); // // } // // // } // // /** // * 判断是否有不合格 // * @param insOrder // * @return // */ // @Override // public Long getUnqualifiedCount(InsOrder insOrder) { // Long unqualifiedCount = 0L; // List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery() // .eq(InsSample::getInsOrderId, insOrder.getId())); // if (CollectionUtils.isNotEmpty(insSamples)) { // unqualifiedCount = insProductMapper.selectCount(Wrappers.lambdaQuery() // .in(InsProduct::getInsSampleId, insSamples.stream().map(InsSample::getId).collect(Collectors.toList())) // .eq(InsProduct::getInsResult, 0)); // // // 判断如果有不合格的检验项, 判断有没有检验项复测, 复核合格也算合格通过 // if (!unqualifiedCount.equals(0L)) { // List insProducts = insProductMapper.selectList(Wrappers.lambdaQuery() // .in(InsProduct::getInsSampleId, insSamples.stream().map(InsSample::getId).collect(Collectors.toList())) // .eq(InsProduct::getInsResult, 0)); // // boolean flag = true; // for (InsProduct insProduct : insProducts) { // Long unqualifiedProductCount = insUnqualifiedRetestProductMapper.selectCount(Wrappers.lambdaQuery() // .eq(InsUnqualifiedRetestProduct::getInsProductId, insProduct.getId()) // .ne(InsUnqualifiedRetestProduct::getInsResult, 0)); // if (unqualifiedProductCount != 2) { // flag = false; // } // } // if (flag) { // unqualifiedCount = 0L; // } // } // } // return unqualifiedCount; // } // // /** // * ifs移库操作 // * @param one // * @return // */ // @Override // public String moveRawMaterial(IfsInventoryQuantity one) { // String toLocation; // // 登记采购检验结果STD // if (one.getIsRegister().equals(0)) { // Map resultMap = new HashMap<>(); // List> resultList = new ArrayList<>(); // Map map = new HashMap<>(); // map.put("ORDER_NO", one.getOrderNo()); // 采购订单号 // map.put("LINE_NO", one.getLineNo()); // 行号 // map.put("RELEASE_NO", one.getReleaseNo()); // 下达号 // map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号 // map.put("PURCH_QTY", one.getQtyToInspect()); // 要检验的采购数量 // resultList.add(map); // resultMap.put("RECORD_ID", UUID.randomUUID().toString()); // resultMap.put("SYSCODE", "LIMS"); // resultMap.put("SYSMODEL", "登记采购检验结果"); // resultMap.put("BATCH_INFO", resultList); // Result result = ifsApiUtils.getProcurementResults(JSONUtil.toJsonStr(resultMap)); // if (result.getCode() != 200) { // throw new ErrorException("IFS登记采购检验结果失败: " + result.getMessage()); // } // } // insOrderService.updateIfsInventoryQuantity(one.getId()); // /** // * TODO 后续需要调用IFS的接口 移入的库位号 toLocation // */ // // 检验后移库 // toLocation = "1301"; // Map moveResultMap = new HashMap<>(); // List> moveResultList = new ArrayList<>(); // Map moveMap = new HashMap<>(); // moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号 // moveMap.put("LINE_NO", one.getLineNo()); // moveMap.put("RELEASE_NO", one.getReleaseNo()); // moveMap.put("RECEIPT_NO", one.getReceiptNo()); // moveMap.put("PART_NO", one.getPartNo()); // moveMap.put("QTY", one.getQtyArrived()); // moveMap.put("LOCATION_NO", one.getLocationNo()); // moveMap.put("TO_LOCATION_NO", toLocation); // moveMap.put("LOT_BATCH_NO", one.getLotBatchNo()); // moveMap.put("SERIAL_NO", one.getSerialNo()); // moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); // moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel()); // moveMap.put("ACTIVITY_SEQ", one.getActivitySeq()); // moveResultList.add(moveMap); // moveResultMap.put("RECORD_ID", UUID.randomUUID().toString()); // moveResultMap.put("SYSCODE", "LIMS"); // moveResultMap.put("SYSMODEL", "检验后移库"); // moveResultMap.put("BATCH_INFO", moveResultList); // // Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap)); // // 如果有必须为零件指定批号报错需要重新提交移库信息去指定批号 // if (result1.getCode() != 200) { // String message = result1.getMessage(); // if (message.contains("必须为零件") && message.contains("指定批号")) { // updaeBatch(one, toLocation); // } else { // throw new ErrorException("IFS检验后移库失败: " + result1.getMessage()); // } // } // return toLocation; // } // // /** // * 退回到检验任务 // * @param id // * @return // */ // @Override // @Transactional(rollbackFor = Exception.class) // public boolean sendBackTask(Integer id) { // InsReport report = insReportMapper.selectById(id); // // 根据订单查询试验室 // String laboratory = insOrderMapper.selectLaboratoryByOrderId(report.getInsOrderId()); // // // 修改订单状态 // insOrderStateMapper.update(null, Wrappers.lambdaUpdate() // .eq(InsOrderState::getInsOrderId, report.getInsOrderId()) // .eq(InsOrderState::getLaboratory, laboratory) // .set(InsOrderState::getInsState, 4)); // // Integer insSampleId = insSampleUserMapper.selectOne(Wrappers.lambdaQuery() // .eq(InsSampleUser::getInsSampleId, report.getInsOrderId()) // .orderByDesc(InsSampleUser::getId) // .last("limit 1")).getId(); // insSampleUserMapper.deleteById(insSampleId); // // // 修改报告行为未显示 // insReportMapper.update(null, Wrappers.lambdaUpdate() // .eq(InsReport::getId, id) // .set(InsReport::getIsPass, 0)); // // return false; // } // // // /** // * 先修改采购订单批次号, 后进行移库操作 // * @param one // * @param toLocation // */ // private void updaeBatch(IfsInventoryQuantity one, String toLocation) { // if (one.getIsUpdateBatch().equals(0)) { // // 先修改批次号后进行移库 // Map resultMap = new HashMap<>(); // List> resultList = new ArrayList<>(); // Map map = new HashMap<>(); // map.put("ORDER_NO", one.getOrderNo()); // 采购订单号 // map.put("LINE_NO", one.getLineNo()); // 行号 // map.put("RELEASE_NO", one.getReleaseNo()); // 下达号 // map.put("RECEIPT_NO", one.getReceiptNo()); // 接收号 // map.put("PART_NO", one.getPartNo()); //零件号 // map.put("CONFIGURATION_ID", one.getConfigurationId()); // 配置标识 // map.put("LOCATION_NO", one.getLocationNo()); // 库位号 // map.put("LOT_BATCH_NO", one.getLotBatchNo());// 批次号 // map.put("NEW_LOT_BATCH_NO", one.getUpdateBatchNo()); // 目标批次号 // map.put("SERIAL_NO", one.getSerialNo()); // 序列号 // map.put("ENG_CHG_LEVEL", one.getEngChgLevel()); // 版本号 // map.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); // wdr号 // map.put("ACTIVITY_SEQ", one.getActivitySeq()); // 活动序号 // map.put("QTY_TO_CHANGE", one.getQtyArrived()); // 变更数量 // resultList.add(map); // resultMap.put("RECORD_ID", UUID.randomUUID().toString()); // resultMap.put("SYSCODE", "LIMS"); // resultMap.put("SYSMODEL", "修改采购订单批次号"); // resultMap.put("BATCH_INFO", resultList); // // Result result = ifsApiUtils.updateMoveReceiptLot(JSONUtil.toJsonStr(resultMap)); // // if (result.getCode() != 200) { // throw new ErrorException("IFS修改批次号失败: " + result.getMessage()); // } // ifsInventoryQuantityMapper.update(null, Wrappers.lambdaUpdate() // .set(IfsInventoryQuantity::getIsUpdateBatch, 1) // .eq(IfsInventoryQuantity::getId, one.getId())); // } // // Map moveResultMap = new HashMap<>(); // List> moveResultList = new ArrayList<>(); // Map moveMap = new HashMap<>(); // moveMap.put("ORDER_NO", one.getOrderNo()); // 采购订单号 // moveMap.put("LINE_NO", one.getLineNo()); // moveMap.put("RELEASE_NO", one.getReleaseNo()); // moveMap.put("RECEIPT_NO", one.getReceiptNo()); // moveMap.put("PART_NO", one.getPartNo()); // moveMap.put("QTY", one.getQtyArrived()); // moveMap.put("LOCATION_NO", one.getLocationNo()); // moveMap.put("TO_LOCATION_NO", toLocation); // moveMap.put("LOT_BATCH_NO", one.getUpdateBatchNo()); // moveMap.put("SERIAL_NO", one.getSerialNo()); // moveMap.put("WAIV_DEV_REJ_NO", one.getWaivDevRejNo()); // moveMap.put("ENG_CHG_LEVEL", one.getEngChgLevel()); // moveMap.put("ACTIVITY_SEQ", one.getActivitySeq()); // moveResultList.add(moveMap); // moveResultMap.put("RECORD_ID", UUID.randomUUID().toString()); // moveResultMap.put("SYSCODE", "LIMS"); // moveResultMap.put("SYSMODEL", "检验后移库"); // moveResultMap.put("BATCH_INFO", moveResultList); // // Result result1 = ifsApiUtils.moveReceipt(JSONUtil.toJsonStr(moveResultMap)); // if (result1.getCode() != 200) { // throw new ErrorException("IFS检验后移库失败: " + result1.getMessage()); // } // // } // // /** // * 替换段落文本 // * @param filePath docx解析对象 // * @param textMap 需要替换的信息集合 // */ // public static void changeText(Map textMap, String filePath) { // try { // FileInputStream stream = new FileInputStream(filePath); // XWPFDocument document = new XWPFDocument(stream); // List tables = document.getTables(); // for (XWPFTable table : tables) { // for (XWPFTableRow row : table.getRows()) { // for (XWPFTableCell cell : row.getTableCells()) { // // textMap.forEach((s, s2) -> { // if (cell.getText().equals(s)) { // XWPFParagraph paragraph = cell.getParagraphs().get(0); // XWPFRun oldRun = paragraph.getRuns().get(0); // // 保存原样式 // String fontFamily = oldRun.getFontFamily(); // int fontSize = oldRun.getFontSize(); // String color = oldRun.getColor(); // ParagraphAlignment alignment = paragraph.getAlignment(); // // 替换内容 // paragraph.removeRun(0); // 移除原有的 run // XWPFRun newRun = paragraph.createRun(); // newRun.setText(s2); // // 应用原样式 // newRun.setFontFamily(fontFamily); // newRun.setFontSize(fontSize); // newRun.setColor(color); // paragraph.setAlignment(alignment); // } // }); // } // } // } // FileOutputStream fileOutputStream = new FileOutputStream(filePath); // document.write(fileOutputStream); // fileOutputStream.close(); // // } catch (Exception e) { // e.printStackTrace(); // throw new ErrorException(e.getMessage()); // } // } // // /** // * word转换pdf // * @param path // * @return // */ // private String wordToPdfTemp(String path) { // try { // return wordToPdf(path, path.replace(".docx", "-临时.pdf")); // } catch (Exception e) { // throw new ErrorException("转换失败"); // } // } // // private String wordToPdf(String wordPath, String pdfPath) { // FileOutputStream os = null; // try { // //凭证 不然切换后有水印 // InputStream is = Files.newInputStream(new File(licenseUrl).toPath()); // License license = new License(); // license.setLicense(is); // if (!license.getIsLicensed()) { // System.out.println("License验证不通过..."); // return null; // } // //生成一个空的PDF文件 // File file; // //判断是否是进厂报告 // file = new File(pdfPath); // os = new FileOutputStream(file); // //要转换的word文件 // com.aspose.words.Document doc = new com.aspose.words.Document(wordPath); // doc.save(os, SaveFormat.PDF); // String name = file.getName(); // return file.getName(); // } catch (Exception e) { // e.printStackTrace(); // } finally { // if (os != null) { // try { // os.close(); // } catch (IOException e) { // e.printStackTrace(); // } // } // } // return null; // } //} // // // // // //