lims-ruoyi-after.git

			@@ -3,6 +3,7 @@
			import cn.hutool.core.lang.UUID;
			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.extension.plugins.pagination.Page;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.deepoove.poi.XWPFTemplate;
			@@ -13,7 +14,15 @@
			import com.ruoyi.common.core.domain.entity.User;
			import com.ruoyi.common.utils.QueryWrappers;
			import com.ruoyi.common.utils.SecurityUtils;
			import com.ruoyi.common.utils.SignatureImageUtil;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.ruoyi.framework.exception.ErrorException;
			import com.ruoyi.inspect.mapper.InsOrderMapper;
			import com.ruoyi.inspect.mapper.InsReportMapper;
			import com.ruoyi.inspect.pojo.InsOrder;
			import com.ruoyi.inspect.pojo.InsReport;
			import com.ruoyi.inspect.util.HackLoopTableRenderPolicy;
			import com.ruoyi.process.dto.ProcessReportDto;
			import com.ruoyi.process.mapper.ProcessReportMapper;
			import com.ruoyi.process.pojo.ProcessReport;
			import com.ruoyi.process.service.ProcessReportService;
			@@ -25,13 +34,18 @@
			import org.springframework.transaction.annotation.Transactional;

			import javax.annotation.Resource;
			import javax.servlet.http.HttpServletResponse;
			import java.io.*;
			import java.net.URLEncoder;
			import java.nio.file.Files;
			import java.nio.file.Path;
			import java.nio.file.Paths;
			import java.util.ArrayList;
			import java.util.HashMap;
			import java.util.HashSet;
			import java.util.List;
			import java.util.Map;
			import java.util.Set;
			import java.util.stream.Collectors;

			/**
			@@ -39,7 +53,7 @@
			* 检验报告发放登记表服务实现类
			* </p>
			*
			* @author 芯导软件（江苏）有限公司
			* @author
			* @since 2024-11-05 08:58:39
			*/
			@Service
			@@ -48,376 +62,201 @@

			@Resource
			private ProcessReportMapper processReportMapper;


			@Value("${file.path}")
			private String imgUrl;
			@Value("${wordUrl}")
			private String wordUrl;

			@Resource
			private UserMapper userMapper;

			@Resource
			private InsReportMapper insReportMapper;

			@Resource
			private InsOrderMapper insOrderMapper;

			@Override
			public IPage<ProcessReport> pageProcessReport(Page page, ProcessReport processReport) {
			//todo 仅看我
			IPage<ProcessReport> processReportIPage = processReportMapper.pageProcessReport(page, QueryWrappers.queryWrappers(processReport));
			// for (ProcessReport record : processReportIPage.getRecords()) {
			// List<String> name = new ArrayList<>();
			// for (String s : record.getSignatory().split(",")) {
			// User user = userMapper.selectById(Integer.parseInt(s));
			// name.add(user.getName());
			// }
			// String signatoryName = name.stream().collect(Collectors.joining(","));
			// record.setSignatoryName(signatoryName);
			// }
			public IPage<ProcessReportDto> pageProcessReport(Page page, ProcessReportDto processReport) {
			// #21 打开列表时，自动带出已通过审批（批准状态=批准）但尚未登记的检验单
			autoBringOutApproved();
			IPage<ProcessReportDto> processReportIPage = processReportMapper.pageProcessReport(page, QueryWrappers.queryWrappers(processReport));

			return processReportIPage;
			}

			@Override
			public String exportProcessReport(List<Integer> ids) {
			List<ProcessReport> processReports = processReportMapper.getIds(ids);
			for (ProcessReport processReport : processReports) {
			List<String> name = new ArrayList<>();
			for (String s : processReport.getSignatory().split(",")) {
			User user = userMapper.selectById(Integer.parseInt(s));
			name.add(user.getName());
			/**
			* 扫描已批准但尚未进入报告结果登记表的检验报告，自动生成待登记记录（以报告编号去重，幂等）。
			*/
			private void autoBringOutApproved() {
			List<InsReport> approved = insReportMapper.selectList(Wrappers.<InsReport>lambdaQuery()
			.eq(InsReport::getIsRatify, 1)
			.eq(InsReport::getIsPass, 1));
			if (approved.isEmpty()) {
			return;
			}
			Set<String> existing = this.list(Wrappers.<ProcessReport>lambdaQuery()
			.select(ProcessReport::getInsReportCode)).stream()
			.map(ProcessReport::getInsReportCode)
			.filter(StringUtils::isNotBlank)
			.collect(Collectors.toCollection(HashSet::new));
			for (InsReport report : approved) {
			String code = report.getCode();
			if (StringUtils.isBlank(code) \|\| existing.contains(code)) {
			continue;
			}
			String signatoryName = name.stream().collect(Collectors.joining(","));
			processReport.setSignatoryName(signatoryName);
			ProcessReport pr = new ProcessReport();
			pr.setInsReportCode(code);
			pr.setInspectionOrderId(report.getInsOrderId());
			if (report.getRatifyTime() != null) {
			pr.setSendTime(report.getRatifyTime().toLocalDate());
			}
			if (report.getInsOrderId() != null) {
			InsOrder order = insOrderMapper.selectById(report.getInsOrderId());
			if (order != null) {
			pr.setSend(order.getCompany());
			pr.setMethod(getReportDeliveryName(order));
			}
			}
			this.save(pr);
			existing.add(code);
			}
			//生成检验报告发放登记表
			String url;
			try {
			InputStream inputStream = this.getClass().getResourceAsStream("/static/report-deal.docx");
			File file = File.createTempFile("temp", ".tmp");
			OutputStream outputStream = new FileOutputStream(file);
			IOUtils.copy(inputStream, outputStream);
			url = file.getAbsolutePath();
			} catch (FileNotFoundException e) {
			throw new ErrorException("找不到模板文件");
			} catch (IOException e) {
			throw new RuntimeException(e);
			}
			ConfigureBuilder builder = Configure.builder();
			builder.useSpringEL(true);
			}

			List<Map<String, Object>> reportList = new ArrayList<>();
			Integer index = 1;
			Integer index1 = 1;
			for (int c = 0; c < processReports.size(); c++) {
			//超过15行换页
			if (c % 15 == 0) {
			List<RowRenderData> rows = new ArrayList<>();
			//表格的行数
			for (int i = 0; i < 16; i++) {
			RowRenderData rowRenderData = new RowRenderData();
			RowStyle rowStyle = new RowStyle();
			rowStyle.setHeight(40);
			rowRenderData.setRowStyle(rowStyle);
			List<CellRenderData> cells = new ArrayList<>();
			//表格的列数
			for (int j = 0; j < 10; j++) {
			CellRenderData cellRenderData = new CellRenderData();
			CellStyle cellStyle = new CellStyle();
			cellStyle.setVertAlign(XWPFTableCell.XWPFVertAlign.CENTER);
			cellRenderData.setCellStyle(cellStyle);
			List<ParagraphRenderData> paragraphRenderDataList = new ArrayList<>();
			ParagraphRenderData paragraphRenderData = new ParagraphRenderData();
			ParagraphStyle paragraphStyle = new ParagraphStyle();
			paragraphStyle.setAlign(ParagraphAlignment.CENTER);
			paragraphRenderData.setParagraphStyle(paragraphStyle);
			List<RenderData> renderData = new ArrayList<>();
			TextRenderData textRenderData = new TextRenderData();
			Style style = new Style();
			style.setFontFamily("宋体");
			style.setColor("000000");
			textRenderData.setStyle(style);
			if (i == 0) {
			//第一行
			if (j == 0) {
			//第一列序号
			textRenderData.setText("序号@No.");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 1) {
			//第二列
			textRenderData.setText("检验报告编号@Inspection report number");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 2) {
			//第三列
			textRenderData.setText("页数@Pages");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 3) {
			//第四列
			textRenderData.setText("发送份数@Number of copies sent");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 4) {
			//第五列
			textRenderData.setText("发往何处@Where to send to");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 5) {
			//第六列
			textRenderData.setText("发送方式@Send method");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 6) {
			//第七列
			textRenderData.setText("发送日期@Date sent");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}else if (j == 7) {
			//第八列
			textRenderData.setText("发送人@Sender");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}else if (j == 8) {
			//第九列
			textRenderData.setText("签收人@Signatory");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}else{
			//第十列
			textRenderData.setText("备注@Remark");
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			}
			else {
			//其他行
			if (j == 0) {
			//第一列
			try{
			String insReportCode = processReports.get((i-1) + (index1 - 1) * 20).getInsReportCode();
			textRenderData.setText(index + "");
			} catch (Exception e) {
			textRenderData.setText("");
			}
			index++;
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			} else if (j == 1) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getInsReportCode());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 2) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getPages());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 3) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getNumber());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 4) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getSend());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 5) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getMethod());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 6) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getSendTime()+"");
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 7) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getSendUserName());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else if (j == 8) {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getSignatoryName());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			else {
			try{
			textRenderData.setText(processReports.get((i-1) + (index1 - 1) * 20).getRemark());
			} catch (Exception e) {
			textRenderData.setText("");
			}
			renderData.add(textRenderData);
			paragraphRenderData.setContents(renderData);
			paragraphRenderDataList.add(paragraphRenderData);
			cellRenderData.setParagraphs(paragraphRenderDataList);
			cells.add(cellRenderData);
			}
			}
			}
			rowRenderData.setCells(cells);
			if (rowRenderData.getCells().size() != 0) {
			rows.add(rowRenderData);
			}
			}
			TableRenderData tableRenderData = new TableRenderData();
			tableRenderData.setRows(rows);
			int countSize = tableRenderData.getRows().get(0).getCells().size();
			for (RowRenderData row : tableRenderData.getRows()) {
			if (row.getCells().size() != countSize) {
			throw new ErrorException("每行单元格不相等");
			}
			}
			TableStyle tableStyle = new TableStyle();
			tableStyle.setWidth(XWPFTable.DEFAULT_PERCENTAGE_WIDTH);
			tableStyle.setAlign(TableRowAlign.CENTER);
			BorderStyle borderStyle = new BorderStyle();
			borderStyle.setColor("000000");
			borderStyle.setType(XWPFTable.XWPFBorderType.THICK);
			borderStyle.setSize(14);
			tableStyle.setLeftBorder(borderStyle);
			tableStyle.setTopBorder(borderStyle);
			tableStyle.setRightBorder(borderStyle);
			tableStyle.setBottomBorder(borderStyle);
			tableRenderData.setTableStyle(tableStyle);
			Map<String, Object> table = new HashMap<>();
			table.put("report", tableRenderData);
			table.put("index1", index1);
			reportList.add(table);
			index1++;
			private String getReportDeliveryName(InsOrder order) {
			if (order.getReportDelivery() != null) {
			switch (order.getReportDelivery()) {
			case 1:
			return "自取";
			case 2:
			return "快递";
			case 3:
			return "电子传送";
			default:
			break;
			}
			}
			Integer finalIndex = index1;
			XWPFTemplate template = XWPFTemplate.compile(url, builder.build()).render(
			// 兼容尚未维护 report_delivery 的历史委托单。
			return order.getSend() != null && order.getSend() == 1 ? "自取" : "其他";
			}

			@Override
			public void downloadStampedReport(Integer id, String format, HttpServletResponse response) {
			if (id == null) {
			throw new ErrorException("报告结果不能为空");
			}
			ProcessReport processReport = getById(id);
			if (processReport == null) {
			throw new ErrorException("报告结果不存在");
			}
			if (StringUtils.isBlank(processReport.getInsReportCode())
			&& processReport.getInspectionOrderId() == null) {
			throw new ErrorException("该记录未关联检验报告，无法下载");
			}

			String downloadFormat = StringUtils.isBlank(format) ? "pdf" : format.trim().toLowerCase();
			if (!"pdf".equals(downloadFormat) && !"word".equals(downloadFormat)) {
			throw new ErrorException("下载格式不正确");
			}

			com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<InsReport> query =
			Wrappers.<InsReport>lambdaQuery()
			.eq(InsReport::getIsRatify, 1)
			.eq(StringUtils.isNotBlank(processReport.getInsReportCode()),
			InsReport::getCode, processReport.getInsReportCode())
			.eq(processReport.getInspectionOrderId() != null,
			InsReport::getInsOrderId, processReport.getInspectionOrderId())
			.orderByDesc(InsReport::getId)
			.last("limit 1");
			InsReport report = insReportMapper.selectOne(query);
			if (report == null) {
			throw new ErrorException("未找到已批准的报告，无法下载有章报告");
			}

			String fileUrl;
			String extension;
			String contentType;
			if ("word".equals(downloadFormat)) {
			fileUrl = StringUtils.isNotBlank(report.getUrlS()) ? report.getUrlS() : report.getUrl();
			extension = ".docx";
			contentType = "application/vnd.openxmlformats-officedocument.wordprocessingml.document";
			} else {
			fileUrl = report.getTempUrlPdf();
			extension = ".pdf";
			contentType = "application/pdf";
			}
			if ("pdf".equals(downloadFormat) && StringUtils.isBlank(fileUrl)) {
			String reportUrl = StringUtils.isNotBlank(report.getUrlS()) ? report.getUrlS() : report.getUrl();
			if (StringUtils.isNotBlank(reportUrl) && reportUrl.toLowerCase().endsWith(".docx")) {
			fileUrl = reportUrl.substring(0, reportUrl.length() - 5) + ".pdf";
			}
			}
			if (StringUtils.isBlank(fileUrl) \|\| !fileUrl.replace('\\', '/').startsWith("/word/")) {
			throw new ErrorException("有章报告尚未生成，请先完成报告批准");
			}

			Path root = Paths.get(wordUrl).toAbsolutePath().normalize();
			Path file = root.resolve(fileUrl.replace('\\', '/').substring("/word/".length())).normalize();
			if (!file.startsWith(root) \|\| !Files.isRegularFile(file)) {
			throw new ErrorException("有章报告文件不存在，请重新批准生成");
			}

			try {
			String filename = StringUtils.isNotBlank(processReport.getInsReportCode())
			? processReport.getInsReportCode() + extension : file.getFileName().toString();
			String encodedName = URLEncoder.encode(filename, "UTF-8").replace("+", "%20");
			response.setContentType(contentType);
			response.setHeader("Content-Disposition", "attachment; filename*=UTF-8''" + encodedName);
			response.setHeader("Access-Control-Expose-Headers", "Content-Disposition,download-filename");
			response.setHeader("download-filename", encodedName);
			response.setContentLengthLong(Files.size(file));
			try (InputStream inputStream = Files.newInputStream(file);
			OutputStream outputStream = response.getOutputStream()) {
			IOUtils.copy(inputStream, outputStream);
			outputStream.flush();
			}
			} catch (IOException e) {
			throw new ErrorException("有章报告下载失败");
			}
			}

			@Override
			public void exportProcessReport(ProcessReportDto dto, HttpServletResponse response) {
			List<ProcessReportDto> processReports = processReportMapper.exportProcessReport();
			for (ProcessReportDto processReport : processReports) {
			// 发送人生成签名图片
			processReport.setSendUserRender(StringUtils.isNotBlank(processReport.getSendUserUrl())
			? Pictures.ofLocal(imgUrl + "/" + processReport.getSendUserUrl()).create() : null);

			// 签收人生成图片
			processReport.setSignatoryRender(StringUtils.isNotBlank(processReport.getSignatory())
			? Pictures.ofStream(SignatureImageUtil.saveImageToFile(processReport.getSignatory())).create() : null);
			}

			// 获取路径
			InputStream inputStream = this.getClass().getResourceAsStream("/static/report-deal.docx");
			Configure configure = Configure.builder()
			.bind("reportList", new HackLoopTableRenderPolicy())
			.build();
			XWPFTemplate template = XWPFTemplate.compile(inputStream, configure).render(
			new HashMap<String, Object>() {{
			put("reportList", reportList);
			put("reportList", processReports);
			}});
			String name = UUID.randomUUID() + "_检验报告发放登记表" + ".docx";
			try {
			template.writeAndClose(Files.newOutputStream(Paths.get(wordUrl + "/" + name)));
			} catch (IOException e) {
			throw new RuntimeException(e);
			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();
			inputStream.close();
			inputStream.close();
			} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException("导出失败");
			}
			//处理中英文换行的问题
			String path = wordUrl + "/" + name;
			try {
			FileInputStream stream1 = new FileInputStream(path);
			XWPFDocument document1 = new XWPFDocument(stream1);
			List<XWPFTable> xwpfTables1 = document1.getTables();
			for (int i = 0; i < xwpfTables1.size(); i++) {
			for (int j = 0; j < xwpfTables1.get(i).getRows().size(); j++) {
			for (int k = 0; k < xwpfTables1.get(i).getRows().get(j).getTableCells().size(); k++) {
			if (xwpfTables1.get(i).getRows().get(j).getTableCells().get(k).getText().contains("@")) {
			String text = xwpfTables1.get(i).getRows().get(j).getTableCells().get(k).getText();
			String[] split = text.split("@");
			xwpfTables1.get(i).getRows().get(j).getTableCells().get(k).removeParagraph(0);
			XWPFParagraph xwpfParagraph = xwpfTables1.get(i).getRows().get(j).getTableCells().get(k).addParagraph();
			XWPFRun run = xwpfParagraph.createRun();
			run.setText(split[0]);
			if (ObjectUtils.isNotNull(split[1])) {
			run.addBreak();
			run.setText(split[1]);
			}
			xwpfParagraph.setAlignment(ParagraphAlignment.CENTER);
			}
			}
			}
			}
			FileOutputStream fileOutputStream1 = new FileOutputStream(path);
			document1.write(fileOutputStream1);
			fileOutputStream1.close();
			} catch (FileNotFoundException e) {
			throw new RuntimeException(e);
			} catch (IOException e) {
			throw new RuntimeException(e);
			}
			return name;
			}
			}