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.Style; import com.deepoove.poi.data.style.TableStyle; import com.yuanchu.mom.common.GetLook; import com.yuanchu.mom.common.PrintChina; import com.yuanchu.mom.dto.InsOrderPlanDTO; import com.yuanchu.mom.dto.SampleProductDto; import com.yuanchu.mom.mapper.*; import com.yuanchu.mom.pojo.*; import com.yuanchu.mom.exception.ErrorException; 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.poi.xwpf.usermodel.TableRowAlign; import org.apache.poi.xwpf.usermodel.XWPFTable; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ResourceUtils; import javax.annotation.Resource; import java.io.FileNotFoundException; import java.io.IOException; 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.atomic.AtomicReference; import java.util.stream.Collectors; import java.util.concurrent.CompletableFuture; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Stream; /** * 检验任务-业务实现层 */ @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; @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.setInsState(1); 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 @Transactional(rollbackFor = Exception.class) 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) { 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)); } JSONObject resValue = JSON.parseObject(JSON.toJSONString(jo.get("resValue"))); if (resValue.get("v") != null) { insProduct.setLastValue(JSON.parseObject(JSON.toJSONString(resValue.get("v"))).get("v") + ""); } 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)); } 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 null; }).thenAccept(res -> { }).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); insOrderStateMapper.update(null, Wrappers.lambdaUpdate().eq(InsOrderState::getInsOrderId, orderId).eq(InsOrderState::getLaboratory, laboratory).set(InsOrderState::getInsTime, LocalDateTime.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.setInsOrderId(orderId); Set set = new HashSet<>(); Map map2 = new HashMap<>(); List> tables = new ArrayList<>(); Set standardMethod = new HashSet<>(); Set deviceSet = new HashSet<>(); samples.forEach(a -> { Set templateSet = new HashSet<>(); getTemplateThing(set, map2, a); a.getInsProduct().forEach(b -> { String[] split = b.getMethod().replaceAll("]", "").replaceAll("\\[", "").replaceAll("\"", "").split(","); standardMethod.addAll(Arrays.asList(split)); if (b.getInsProductResult() != null) { if (b.getInsProductResult().getEquipValue() != null && !Objects.equals(b.getInsProductResult().getEquipValue(), "")) { deviceSet.add(b.getInsProductResult().getEquipValue()); } } if (b.getTemplate().size() == 0) { return; } 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 temp = JSON.parseArray(tem, 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) { if ("检验值".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") + ""); } if ("检验子项".equals(JSON.parseObject(JSON.toJSONString(v.get("ps"))).get("value") + "")) { int count2 = 0; for (InsProduct p : a.getInsProduct()) { if (v.get("v").equals(p.getInspectionItemSubclass())) { pMap.put(jo1.get("r") + "", p); break; } else { count2++; } } if (count2 == a.getInsProduct().size()) { delRSet.add(jo1.get("r") + ""); } } } } for (int i = 0; i < temp.size(); i++) { JSONObject jo1 = temp.get(i); if (delRSet.stream().anyMatch(e -> e.equals(jo1.get("r") + ""))) { continue; } if (delSet.stream().anyMatch(e -> e.equals(jo1.get("c") + ""))) { continue; } 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<>(); } } 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 { 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") + ""); } 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")+"")); style.setColor(v.get("fc") == null ? "000000" : (v.get("fc") + "").replace("#", "")); 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); tableRenderData.setTableStyle(tableStyle); Map table = new HashMap<>(); table.put("table", tableRenderData); table.put("report", insReport); tables.add(table); }); }); String url; try { url = ResourceUtils.getURL("classpath:static/report-template.docx").getPath(); } catch (FileNotFoundException e) { throw new ErrorException("找不到模板文件"); } 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 = insOrderMapper.selectDeviceList(deviceSet); Map codeStr = new HashMap<>(); codeStr.put("报告编号", insReport.getCode()); codeStr.put("样品名称", insOrder.getSample()); codeStr.put("规格型号", samples.get(0).getModel()); codeStr.put("发放日期", LocalDateTime.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); } ConfigureBuilder builder = Configure.builder(); builder.useSpringEL(true); XWPFTemplate template = XWPFTemplate.compile(url, builder.build()).render( new HashMap() {{ put("order", insOrder); put("report", insReport); put("user", user); // put("samples", samples); put("sampleSize", samples.size() + samples.get(0).getUnit()); put("tables", tables); put("tableSize", tables.size() + 1); put("standardMethod", standardMethod2); put("deviceList", deviceList); put("twoCode", Pictures.ofLocal(codePath).create()); }}); try { String name = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yy_MM_dd&HH_mm_ss")) + ".docx"; template.writeAndClose(Files.newOutputStream(Paths.get(wordUrl + "/" + name))); insReport.setUrl("/word/" + name); insReportMapper.insert(insReport); insOrder.setState(4); insOrderMapper.updateById(insOrder); } 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 (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); } } } @Override public int submitPlan(Integer orderId, String laboratory) { 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)); return 1; } public int pxToCm(int px) { return px / 9; } }