package com.yuanchu.mom.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.metadata.IPage; 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.*; import com.deepoove.poi.data.style.BorderStyle; import com.deepoove.poi.data.style.Style; import com.deepoove.poi.data.style.TableStyle; import com.deepoove.poi.util.TableTools; import com.yuanchu.mom.common.GetLook; import com.yuanchu.mom.common.PrintChina; import com.yuanchu.mom.dto.ExcelDto; import com.yuanchu.mom.dto.InsOrderPlanDTO; import com.yuanchu.mom.dto.SampleProductDto; import com.yuanchu.mom.exception.ErrorException; import com.yuanchu.mom.mapper.*; import com.yuanchu.mom.pojo.*; import com.yuanchu.mom.service.InformationNotificationService; import com.yuanchu.mom.service.InsOrderPlanService; import com.yuanchu.mom.service.InsOrderService; import com.yuanchu.mom.service.StandardTemplateService; import com.yuanchu.mom.utils.GiveCode; import com.yuanchu.mom.utils.JackSonUtil; import com.yuanchu.mom.utils.MatrixToImageWriter; import com.yuanchu.mom.utils.QueryWrappers; import com.yuanchu.mom.vo.InsOrderPlanVO; import org.apache.commons.io.IOUtils; import org.apache.poi.xwpf.usermodel.*; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.io.*; import java.nio.file.Files; import java.nio.file.Paths; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; /** * 检验任务-业务实现层 */ @Service //@AllArgsConstructor public class InsOrderPlanServiceImpl extends ServiceImpl implements InsOrderPlanService { @Resource private InsSampleMapper insSampleMapper; @Resource private InsSampleUserMapper insSampleUserMapper; @Resource private GetLook getLook; @Resource private InsOrderMapper insOrderMapper; @Resource private InsOrderService insOrderService; @Resource private StandardTemplateService standardTemplateService; @Resource private InsOrderStateMapper insOrderStateMapper; @Resource private InsProductMapper insProductMapper; @Value("${wordUrl}") private String wordUrl; @Value("${twoCode}") private String twoCode; @Resource private GiveCode giveCode; @Resource private InsReportMapper insReportMapper; @Resource private InsProductResultMapper insProductResultMapper; @Resource private InsProductUserMapper insProductUserMapper; @Resource private InformationNotificationService informationNotificationService; @Override public Map selectInsOrderPlanList(Page page, InsOrderPlanDTO insOrderPlanDTO) { Map map = new HashMap<>(); map.put("head", PrintChina.printChina(InsOrderPlanVO.class)); Map map1 = getLook.selectPowerByMethodAndUserId(null); Integer userId = map1.get("userId"); if (ObjectUtil.isNotEmpty(insOrderPlanDTO.getUserId())) { insOrderPlanDTO.setUserId(userId.longValue()); } IPage insOrderPage = insSampleMapper.findInsSampleAndOrder(page, QueryWrappers.queryWrappers(insOrderPlanDTO), userId); map.put("body", insOrderPage); return map; } @Override public boolean claimInsOrderPlan(InsOrderPlanDTO entity) { if (Objects.isNull(entity)) { return false; } Map map1 = getLook.selectPowerByMethodAndUserId(null); Integer userId = map1.get("userId"); InsSampleUser insSampleUser = new InsSampleUser(entity.getInsSampleId().intValue(), userId, 1); return insSampleUserMapper.insert(insSampleUser) > 0; } @Override public Map doInsOrder(Integer id, String laboratory) { InsOrder insOrder = new InsOrder(); insOrder.setId(id); InsOrder order = insOrderMapper.selectById(id); if (BeanUtil.isEmpty(order.getInsTime())) { insOrder.setInsTime(LocalDateTime.now()); insOrderMapper.updateById(insOrder); insOrderStateMapper.update(null, Wrappers.lambdaUpdate().eq(InsOrderState::getInsOrderId, id).eq(InsOrderState::getLaboratory, laboratory).set(InsOrderState::getInsTime, LocalDateTime.now()).set(InsOrderState::getInsState, 1)); } Map map = insOrderService.getInsOrderAndSample(id, laboratory); Set set = new HashSet<>(); Map map2 = new HashMap<>(); List list = JSON.parseArray(JSON.toJSONString(map.get("sampleProduct")), SampleProductDto.class); for (SampleProductDto samples : list) { if (BeanUtil.isEmpty(samples.getInsProduct())) continue; getTemplateThing(set, map2, samples); } map.put("sampleProduct", list); return map; } @Override public void saveInsContext(Map insContext) { Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); CompletableFuture.supplyAsync(() -> { insContext.forEach((k, v) -> { JSONObject jo = JSON.parseObject(JSON.toJSONString(v)); InsProduct insProduct = new InsProduct(); insProduct.setId(Integer.parseInt(k)); InsProductResult result = insProductResultMapper.selectOne(Wrappers.lambdaQuery().eq(InsProductResult::getInsProductId, insProduct.getId())); if (BeanUtil.isEmpty(result)) { result = new InsProductResult(); } result.setInsProductId(Integer.parseInt(k)); if (jo.get("insValue") != null) { JSONArray jsonArray = JSON.parseArray(JSON.toJSONString(jo.get("insValue"))); List> iv = new ArrayList<>(); for (Object o : jsonArray) { JSONObject insValue = JSON.parseObject(JSON.toJSONString(o)); Map map = new HashMap<>(); map.put("v", JSON.parseObject(JSON.toJSONString(insValue.get("v"))).get("v")); try { if ((insValue.get("u") == null || insValue.get("u").equals("")) && StrUtil.isNotEmpty(JSON.parseObject(JSON.toJSONString(insValue.get("v"))).get("v").toString())) { map.put("u", userId + ""); } else { map.put("u", insValue.get("u")); } iv.add(map); } catch (Exception e) { } } result.setInsValue(JSON.toJSONString(iv)); } if (jo.get("comValue") != null && !Objects.equals(jo.get("comValue"), "")) { JSONArray jsonArray2 = JSON.parseArray(JSON.toJSONString(jo.get("comValue"))); List> cv = new ArrayList<>(); for (Object o : jsonArray2) { JSONObject comValue = JSON.parseObject(JSON.toJSONString(o)); Map map = new HashMap<>(); map.put("v", JSON.parseObject(JSON.toJSONString(comValue.get("v"))).get("v")); cv.add(map); } result.setComValue(JSON.toJSONString(cv)); } try { JSONObject resValue = JSON.parseObject(JSON.toJSONString(jo.get("resValue"))); if (resValue.get("v") != null) { Object o = JSON.parseObject(JSON.toJSONString(resValue.get("v"))).get("v"); insProduct.setLastValue(o.equals("") ? null : (o.toString())); } } catch (Exception e) { } if (jo.get("equipValue") != null) { JSONArray jsonArray2 = JSON.parseArray(JSON.toJSONString(jo.get("equipValue"))); List> ev = new ArrayList<>(); for (Object o : jsonArray2) { JSONObject equipValue = JSON.parseObject(JSON.toJSONString(o)); Map map = new HashMap<>(); map.put("v", JSON.parseObject(JSON.toJSONString(equipValue.get("v"))).get("v")); ev.add(map); } result.setEquipValue(JSON.toJSONString(ev)); } if (jo.get("equipName") != null) { JSONArray jsonArray2 = JSON.parseArray(JSON.toJSONString(jo.get("equipName"))); List> ev = new ArrayList<>(); for (Object o : jsonArray2) { JSONObject equipValue = JSON.parseObject(JSON.toJSONString(o)); Map map = new HashMap<>(); map.put("v", JSON.parseObject(JSON.toJSONString(equipValue.get("v"))).get("v")); ev.add(map); } result.setEquipName(JSON.toJSONString(ev)); } try { JSONObject insResult = JSON.parseObject(JSON.toJSONString(jo.get("insResult"))); String ir = JSON.parseObject(JSON.toJSONString(insResult.get("v"))).get("v") + ""; insProduct.setInsResult(Integer.parseInt(ir)); } catch (Exception e) { } if (BeanUtil.isEmpty(result.getId())) { result.setCreateUser(userId); result.setUpdateUser(userId); insProductResultMapper.insert(result); } else { result.setUpdateUser(userId); result.setUpdateTime(LocalDateTime.now()); insProductResultMapper.updateById(result); } insProduct.setUpdateUser(userId); insProductMapper.updateById(insProduct); insProductUserMapper.insert(new InsProductUser(null, userId, LocalDateTime.now(), insProduct.getId())); InsSample insSample = insSampleMapper.selectById(insProductMapper.selectById(insProduct.getId()).getInsSampleId()); insSample.setInsState(1); Long l = insProductMapper.selectCount(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, insSample.getId())); Long l1 = insProductMapper.selectCount(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, insSample.getId()).isNotNull(InsProduct::getInsResult)); if (l == l1) { insSample.setInsState(2); } insSampleMapper.updateById(insSample); }); return insContext.keySet().stream().findFirst().orElse(null); }).thenAccept(res -> { if (res != null) { int pId = Integer.parseInt(res.replaceAll("\\D+", "")); InsProduct insProduct = insProductMapper.selectById(pId); // 通过pId 获取当前样本id int sampleId = insProductMapper.selectById(pId).getInsSampleId(); // 通过样本id获取订单id int orderId = insSampleMapper.selectById(sampleId).getInsOrderId(); // 通过订单id查找所有样本id List sampleIds = insSampleMapper.selectList(Wrappers.lambdaQuery().eq(InsSample::getInsOrderId, orderId)).stream().map(InsSample::getId).collect(Collectors.toList()); // 通过检查每一个样本id查到属于检验项结论 is null的数量 Long count = insProductMapper.selectCount(Wrappers.lambdaQuery().in(InsProduct::getInsSampleId, sampleIds).isNull(InsProduct::getInsResult).eq(InsProduct::getSonLaboratory, insProduct.getSonLaboratory()).eq(InsProduct::getState, 1)); if (count == 0) { insOrderStateMapper.update(new InsOrderState(), Wrappers.lambdaUpdate() .eq(InsOrderState::getInsOrderId, orderId) .eq(InsOrderState::getLaboratory, insProduct.getSonLaboratory()) .set(InsOrderState::getInsState, 2)); } } }).exceptionally(e -> { e.printStackTrace(); return null; }); } @Override public int upPlanUser(Integer userId, Integer orderId) { InsSampleUser insSampleUser = new InsSampleUser(); insSampleUser.setUserId(userId); insSampleUser.setInsSampleId(orderId); insSampleUser.setState(0); return insSampleUserMapper.insert(insSampleUser); } @Override @Transactional(rollbackFor = Exception.class) public int verifyPlan(Integer orderId, String laboratory, Integer type, String tell) { Integer num = (type == 1 ? 5 : 4); LocalDateTime now = LocalDateTime.now(); insOrderStateMapper.update(null, Wrappers.lambdaUpdate().eq(InsOrderState::getInsOrderId, orderId).eq(InsOrderState::getLaboratory, laboratory).set(InsOrderState::getInsTime, now).set(InsOrderState::getInsState, num).set(InsOrderState::getVerifyTell, tell).set(InsOrderState::getVerifyUser, getLook.selectPowerByMethodAndUserId(null).get("userId"))); List insOrderStates = insOrderStateMapper.selectList(Wrappers.lambdaQuery().eq(InsOrderState::getInsOrderId, orderId)); long count = insOrderStates.stream().filter(a -> a.getInsState() == 5).count(); if (count == insOrderStates.size() && num == 5) { InsOrder insOrder = insOrderMapper.selectById(orderId); Map user = insProductMapper.selectUserById(insOrder.getUserId()); List samples = insSampleMapper.selectSampleProductListByOrderId(orderId); InsReport insReport = new InsReport(); // insReport.setCode(giveCode.giveCode("JCZX/TX-", "ins_report", "-", "yyMMdd")); insReport.setCode(insOrder.getEntrustCode()); insReport.setInsOrderId(orderId); Set set = new HashSet<>(); Map map2 = new HashMap<>(); List> tables = new ArrayList<>(); Set standardMethod = new HashSet<>(); Set deviceSet = new HashSet<>(); Set models = new HashSet<>(); AtomicReference productSize = new AtomicReference<>(0); String[] monthNames = {"January", "February", "March", "April", "May", "June", "July", "August", "September", "October", "November", "December"}; samples.forEach(a -> { models.add(a.getModel()); Set templateSet = new HashSet<>(); getTemplateThing(set, map2, a); for (InsProduct b : a.getInsProduct()) { standardMethod.add(b.getMethodS()); productSize.set(productSize.get() + 1); if (b.getInsProductResult() != null) { List jsonObjects = JSON.parseArray(b.getInsProductResult().getEquipValue(), JSONObject.class); for (JSONObject jsonObject : jsonObjects) { if (!"".equals(jsonObject.get("v") + "")) { deviceSet.add(jsonObject.get("v") + ""); } } } if (b.getTemplate().size() == 0) { continue; } templateSet.add(JSON.toJSONString(b.getTemplate())); } AtomicInteger index = new AtomicInteger(); templateSet.forEach(tem -> { Set set2 = new HashSet<>(); List rows = new ArrayList<>(); List text = new ArrayList<>(); RowRenderData rowRenderData; Set delSet = new HashSet<>(); List excelDtos = JSON.parseArray(tem, ExcelDto.class); List mcList = new ArrayList<>(); excelDtos.forEach(b -> { if (b.getV().getMc() != null && b.getV().getMc().getCs() != null && b.getV().getMc().getRs() != null) { mcList.add(b); } }); int count5 = 0; for (ExcelDto b : mcList) { for (ExcelDto excelDto : excelDtos) { for (int i = 0; i < b.getV().getMc().getCs(); i++) { for (int i2 = 0; i2 < b.getV().getMc().getRs(); i2++) { if (excelDto.getC() == b.getC() + i && excelDto.getR() == b.getR() + i2) { ExcelDto bb = JSON.parseObject(JSON.toJSONString(b), ExcelDto.class); excelDto.getV().setV(bb.getV().getV()); excelDto.getV().setPs(bb.getV().getPs()); excelDto.getV().setFc(bb.getV().getFc()); excelDto.getV().setFs(bb.getV().getFs()); excelDto.getV().setHt(bb.getV().getHt()); excelDto.setMc(count5); break; } } } } count5++; } List temp = JSON.parseArray(JSON.toJSONString(excelDtos), JSONObject.class); Map pMap = new HashMap<>(); Set delRSet = new HashSet<>(); for (JSONObject jo1 : temp) { JSONObject v = JSON.parseObject(JSON.toJSONString(jo1.get("v"))); if (v.get("ps") != null) { int count3 = 0; String str = ""; if ("检验值".equals(JSON.parseObject(JSON.toJSONString(v.get("ps"))).get("value") + "") || "设备名称".equals(JSON.parseObject(JSON.toJSONString(v.get("ps"))).get("value") + "") || "设备编码".equals(JSON.parseObject(JSON.toJSONString(v.get("ps"))).get("value") + "")) { delSet.add(jo1.get("c") + ""); continue; } for (JSONObject jo2 : temp) { JSONObject v2 = JSON.parseObject(JSON.toJSONString(jo2.get("v"))); if (jo1.get("r").equals(jo2.get("r"))) { if (v2.get("ps") != null && JSON.parseObject(JSON.toJSONString(v2.get("ps"))).get("value").equals("检验项")) { if (count3 == 0) { str += v2.get("v"); count3 += 1; } } else if (v2.get("ps") != null && JSON.parseObject(JSON.toJSONString(v2.get("ps"))).get("value").equals("检验子项")) { if (count3 == 1) { str += v2.get("v"); count3 += 1; } } } } if (!str.equals("")) { int count2 = 0; for (InsProduct product : a.getInsProduct()) { if ((product.getInspectionItem() + product.getInspectionItemSubclass()).equals(str)) { pMap.put(jo1.get("r") + "", product); break; } else { count2++; } } if (count2 == a.getInsProduct().size()) { delRSet.add(jo1.get("r") + ""); } } } else { if ("参数".equals(v.get("v"))) delSet.add(jo1.get("c") + ""); } } for (int i = 0; i < temp.size(); i++) { JSONObject jo1 = temp.get(i); TextRenderData textRenderData = new TextRenderData(); if (set2.add(Integer.parseInt(jo1.get("r") + ""))) { if (text.size() > 0) { TextRenderData[] text2 = text.toArray(new TextRenderData[0]); rowRenderData = Rows.of(text2).center().rowAtleastHeight(1).create(); rows.add(rowRenderData); text = new ArrayList<>(); } } if (delRSet.stream().anyMatch(e -> e.equals(jo1.get("r") + ""))) { continue; } if (delSet.stream().anyMatch(e -> e.equals(jo1.get("c") + ""))) { continue; } JSONObject v = JSON.parseObject(JSON.toJSONString(jo1.get("v"))); InsProduct p = pMap.get(jo1.get("r") + ""); if (p != null && v.get("ps") != null) { String value = JSON.parseObject(JSON.toJSONString(v.get("ps"))).get("value") + ""; if (value.equals("要求值")) { textRenderData.setText(p.getAsk()); } else if (value.equals("单位")) { textRenderData.setText(p.getUnit()); } else if (value.equals("结论")) { switch (p.getInsResult()) { case 1: textRenderData.setText("√"); break; case 0: textRenderData.setText("×"); break; default: textRenderData.setText("-"); break; } } else if (value.equals("序号")) { index.getAndIncrement(); textRenderData.setText(index + ""); } else if (value.equals("计算值")) { JSONArray jsonArray = JSON.parseArray(p.getInsProductResult().getComValue()); textRenderData.setText((JSON.parseObject(JSON.toJSONString(jsonArray.get(0))).get("v") + "").equals("") ? "/" : JSON.parseObject(JSON.toJSONString(jsonArray.get(0))).get("v") + ""); } else if (value.equals("最终值")) { textRenderData.setText(p.getLastValue()); } else if (value.equals("样品编号")) { textRenderData.setText(a.getSampleCode()); } else if (value.equals("样品型号")) { textRenderData.setText(a.getModel()); } else if (value.equals("样品名称")) { textRenderData.setText(a.getSample()); } else if (value.equals("试验方法")) { textRenderData.setText(p.getMethodS()); } else { textRenderData.setText(v.get("v") == null ? "" : v.get("v") + ""); } } else if (p == null && v.get("ps") != null) { String value = JSON.parseObject(JSON.toJSONString(v.get("ps"))).get("value") + ""; p = pMap.get(pMap.keySet().iterator().next()); if (value.equals("最终值")) { textRenderData.setText(p.getLastValue()); } else if (value.equals("结论")) { switch (p.getInsResult()) { case 1: textRenderData.setText("✔"); break; case 0: textRenderData.setText("✖"); break; default: textRenderData.setText("-"); break; } } else if (value.equals("样品编号")) { textRenderData.setText(a.getSampleCode()); } else if (value.equals("样品型号")) { textRenderData.setText(a.getModel()); } else if (value.equals("样品名称")) { textRenderData.setText(a.getSample()); } else { textRenderData.setText(v.get("v") == null ? "" : v.get("v") + ""); } } else { textRenderData.setText(v.get("v") == null ? "" : v.get("v") + ""); } if (jo1.get("mc") != null) { textRenderData.setText(textRenderData.getText() + "∑" + jo1.get("mc")); } Style style = new Style(); style.setFontFamily(v.get("ff") == null ? "微软雅黑" : v.get("ff") + ""); // style.setFontSize(v.get("fs")==null?14:Integer.parseInt(v.get("fs")+"")); if (!((v.get("fc") + "").indexOf("rgb") > -1)) { style.setColor(v.get("fc") == null ? "000000" : (v.get("fc") + "").replace("#", "")); } else { style.setColor("000000"); } textRenderData.setStyle(style); text.add(textRenderData); if (i == temp.size() - 1) { TextRenderData[] text2 = text.toArray(new TextRenderData[0]); rowRenderData = Rows.of(text2).rowAtleastHeight(1).center().create(); rows.add(rowRenderData); text = new ArrayList<>(); } } TableRenderData tableRenderData = new TableRenderData(); tableRenderData.setRows(rows); TableStyle tableStyle = new TableStyle(); /*JSONObject styleJo = JSON.parseObject(JSON.toJSONString(b.getStyle().get("columnlen"))); List colLen = new ArrayList<>(); int colSize = rows.get(0).getCells().size(); int colOne = Integer.parseInt(b.getTemplate().get(0).get("r") + ""); for (int i = colOne; i < colSize + colOne; i++) { if (styleJo.get(i + "") == null) { colLen.add(pxToCm(100)); } else { int i1 = Integer.parseInt(styleJo.get(i + "") + ""); colLen.add(pxToCm(i1)); } }*/ // tableStyle.setColWidths(ArrayUtils.toPrimitive(colLen.toArray(new Integer[0]))); tableStyle.setAlign(TableRowAlign.CENTER); tableStyle.setWidth(XWPFTable.DEFAULT_PERCENTAGE_WIDTH); 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 table = new HashMap<>(); table.put("table", tableRenderData); table.put("report", insReport); tables.add(table); }); }); String url; try { InputStream inputStream = this.getClass().getResourceAsStream("/static/report-template.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); } StringBuilder standardMethod2 = new StringBuilder(); for (String s : standardMethod) { standardMethod2.append("、").append(s); } standardMethod2.replace(0, 1, ""); tables.forEach(table -> { table.put("tableSize", tables.size() + 1); }); List> deviceList = null; if (deviceSet.size() != 0) { deviceList = insOrderMapper.selectDeviceList(deviceSet); } Map codeStr = new HashMap<>(); codeStr.put("报告编号", insReport.getCode()); codeStr.put("样品名称", insOrder.getSample()); codeStr.put("规格型号", samples.get(0).getModel()); codeStr.put("发放日期", now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); String codePath; try { codePath = new MatrixToImageWriter().code(JackSonUtil.marshal(codeStr).replaceAll("\\{", "") .replaceAll("}", "").replaceAll(",", "").replaceAll("\"", ""), twoCode); } catch (Exception e) { throw new RuntimeException(e); } String modelStr = ""; for (String model : models) { modelStr += "," + model; } String finalModelStr = modelStr; String sampleEn = insSampleMapper.getSampleEn(insOrder.getSample()); String orderType = insOrderMapper.getEnumLabelByValue(insOrder.getOrderType()); ConfigureBuilder builder = Configure.builder(); builder.useSpringEL(true); List> finalDeviceList = deviceList; XWPFTemplate template = XWPFTemplate.compile(url, builder.build()).render( new HashMap() {{ put("order", insOrder); put("report", insReport); put("user", user); put("sampleSize", samples.size()); put("tables", tables); put("tableSize", tables.size() + 1); put("standardMethod", (standardMethod2.toString().equals("null") ? "" : standardMethod2)); put("deviceList", finalDeviceList); put("twoCode", Pictures.ofLocal(codePath).create()); put("models", finalModelStr.replace(",", "")); put("productSize", productSize); put("createTime", now.format(DateTimeFormatter.ofPattern("yyyy年MM月dd日"))); put("createTimeEn", monthNames[now.getMonthValue() - 1] + " " + now.getDayOfMonth() + ", " + now.getYear()); put("insTime", insOrder.getInsTime().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日"))); put("insTimeEn", monthNames[insOrder.getInsTime().getMonthValue() - 1] + " " + now.getDayOfMonth() + ", " + now.getYear()); put("writeUrl", null); put("insUrl", null); put("examineUrl", null); put("ratifyUrl", null); put("sampleEn", sampleEn); put("orderType", orderType); put("getTime", insOrder.getExamineTime().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日"))); put("getTimeEn", monthNames[insOrder.getExamineTime().getMonthValue() - 1] + " " + insOrder.getExamineTime().getDayOfMonth() + ", " + insOrder.getExamineTime().getYear()); }}); try { String name = insReport.getCode().replace("/", "") + ".docx"; template.writeAndClose(Files.newOutputStream(Paths.get(wordUrl + "/" + name))); insReport.setUrl("/word/" + name); insReportMapper.insert(insReport); // insOrder.setState(4); insOrder.setInsState(5); insOrderMapper.updateById(insOrder); } catch (IOException e) { throw new RuntimeException(e); } String path = wordUrl + "/" + insReport.getCode().replace("/", "") + ".docx"; try { FileInputStream stream = new FileInputStream(path); XWPFDocument document = new XWPFDocument(stream); List xwpfTables = document.getTables(); for (int i = 1; i < xwpfTables.size() - (deviceList == null ? 1 : 2); i++) { Set set1 = new HashSet<>(); Map> maps = new HashMap<>(); for (int j = 0; j < xwpfTables.get(i).getRows().size(); j++) { for (int k = 0; k < xwpfTables.get(i).getRows().get(j).getTableCells().size(); k++) { if (xwpfTables.get(i).getRows().get(j).getTableCells().get(k).getText().indexOf("∑") > -1) { String[] split = xwpfTables.get(i).getRows().get(j).getTableCells().get(k).getText().split("∑"); if (set1.add(split[1])) { Map map = new HashMap<>(); map.put("sr", j); map.put("sc", k); map.put("er", j + 0); map.put("ec", k + 0); maps.put(split[1], map); } else { Map map1 = maps.get(split[1]); if (j == map1.get("sr")) { map1.put("ec", map1.get("ec") + 1); } else if (k == map1.get("sc")) { map1.put("er", map1.get("er") + 1); } } String str = xwpfTables.get(i).getRows().get(j).getTableCells().get(k).getText().split("∑")[0]; xwpfTables.get(i).getRows().get(j).getTableCells().get(k).removeParagraph(0); xwpfTables.get(i).getRows().get(j).getTableCells().get(k).setText(str); xwpfTables.get(i).getRows().get(j).getTableCells().get(k).setVerticalAlignment(XWPFTableCell.XWPFVertAlign.CENTER); xwpfTables.get(i).getRows().get(j).getTableCells().get(k).getParagraphArray(0).setAlignment(ParagraphAlignment.CENTER); } } } maps.forEach((k, v) -> { }); List list = new ArrayList<>(); for (String s : maps.keySet()) { list.add(s); } for (int a = list.size() - 1; a >= 0; a--) { Map v = maps.get(list.get(a)); for (int j = 0; j < v.get("er") - v.get("sr") + 1; j++) { TableTools.mergeCellsHorizonal(xwpfTables.get(i), v.get("sr") + j, v.get("sc"), v.get("ec")); } if (v.get("er") > v.get("sr")) { TableTools.mergeCellsVertically(xwpfTables.get(i), v.get("sc"), v.get("sr"), v.get("er")); } } } FileOutputStream fileOutputStream = new FileOutputStream(path); document.write(fileOutputStream); fileOutputStream.close(); } catch (FileNotFoundException e) { throw new RuntimeException(e); } catch (IOException e) { throw new RuntimeException(e); } } return 1; } private void getTemplateThing(Set set, Map map2, SampleProductDto a) { for (InsProduct product : a.getInsProduct()) { if (product.getTemplateId() == null) { product.setTemplate(new ArrayList<>()); continue; } if (product.getTemplateId() != null && set.add(product.getTemplateId())) { map2.put(product.getTemplateId(), standardTemplateService.getStandTempThingById(product.getTemplateId()) + ""); } String thing = map2.get(product.getTemplateId()); if (StrUtil.isNotEmpty(thing)) { JSONObject sheet = JSON.parseObject(JSON.toJSONString(JSON.parseArray(JSON.toJSONString(JSON.parseObject(thing).get("data"))).get(0))); JSONObject config = JSON.parseObject(JSON.toJSONString(sheet.get("config"))); List cellData = JSON.parseArray(JSON.toJSONString(sheet.get("celldata")), JSONObject.class); Map style = new HashMap<>(); style.put("rowlen", config.get("rowlen")); style.put("columnlen", config.get("columnlen")); product.setTemplate(cellData); product.setStyle(style); product.setTemplateName(standardTemplateService.getStandTempNameById(product.getTemplateId())); } } } @Override public int submitPlan(Integer orderId, String laboratory, Integer verifyUser) { List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery().eq(InsSample::getInsOrderId, orderId).select(InsSample::getId)); List ids = insSamples.stream().map(a -> a.getId()).collect(Collectors.toList()); List insProducts = insProductMapper.selectList(Wrappers.lambdaQuery().in(InsProduct::getInsSampleId, ids).eq(InsProduct::getSonLaboratory, laboratory).eq(InsProduct::getState, 1).isNull(InsProduct::getInsResult)); if (insProducts.size() > 0) { String str = ""; for (InsProduct product : insProducts) { str += product.getInspectionItem() + " " + product.getInspectionItemSubclass() + ";"; } throw new ErrorException("以下是未检验的项目:" + str); } insOrderStateMapper.update(null, Wrappers.lambdaUpdate().eq(InsOrderState::getInsOrderId, orderId).eq(InsOrderState::getLaboratory, laboratory).set(InsOrderState::getInsTime, LocalDateTime.now()).set(InsOrderState::getInsState, 3).set(InsOrderState::getVerifyUser, verifyUser)); Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); InformationNotification info = new InformationNotification(); info.setCreateUser(insProductMapper.selectUserById(userId).get("name")); info.setMessageType("2"); info.setTheme("复核通知"); info.setContent("您有一条检验任务待复核消息"); info.setSenderId(userId); info.setConsigneeId(verifyUser); info.setViewStatus(false); info.setJumpPath("b1-inspect-order-plan"); informationNotificationService.addInformationNotification(info); upPlanUser(userId, orderId); return 1; } public int pxToCm(int px) { return px / 9; } }