| | |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.yuanchu.mom.common.GetLook; |
| | | import com.yuanchu.mom.common.PrintChina; |
| | | import com.yuanchu.mom.dto.InsOrderPlanDTO; |
| | | import com.yuanchu.mom.dto.InsProductResultDto; |
| | | import com.yuanchu.mom.dto.SampleProductDto; |
| | | import com.yuanchu.mom.dto.SubmitPlanDto; |
| | | import com.yuanchu.mom.dto.*; |
| | | import com.yuanchu.mom.exception.ErrorException; |
| | | import com.yuanchu.mom.mapper.*; |
| | | import com.yuanchu.mom.pojo.*; |
| | | import com.yuanchu.mom.service.*; |
| | | import com.yuanchu.mom.utils.*; |
| | | import com.yuanchu.mom.vo.*; |
| | | import org.apache.poi.hwpf.usermodel.*; |
| | | import org.apache.poi.ss.usermodel.CellValue; |
| | | import org.apache.poi.xssf.usermodel.XSSFCell; |
| | | import org.apache.poi.xssf.usermodel.XSSFRow; |
| | |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.imageio.ImageIO; |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import java.io.*; |
| | | import java.nio.file.Files; |
| | |
| | | import java.util.regex.Matcher; |
| | | import java.util.regex.Pattern; |
| | | import java.util.stream.Collectors; |
| | | |
| | | import org.apache.poi.hwpf.HWPFDocument; |
| | | |
| | | /** |
| | | * 检验任务-业务实现层 |
| | |
| | | @Resource |
| | | FuSheUtils fuSheUtils; |
| | | |
| | | @Resource |
| | | DianLuUtils dianLuUtils; |
| | | |
| | | @Override |
| | | public Map<String, Object> selectInsOrderPlanList(Page page, InsOrderPlanDTO insOrderPlanDTO) { |
| | | Map<String, Object> map = new HashMap<>(); |
| | |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, sampleId) |
| | | .eq(InsOrderState::getLaboratory, laboratory)); |
| | | if (ObjectUtils.isEmpty(orderState.getInsTime())){ |
| | | if (ObjectUtils.isEmpty(orderState.getInsTime())) { |
| | | //更新检验任务表的检验时间 |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | |
| | | } |
| | | |
| | | @Override |
| | | public int uploadFile(Integer orderId, MultipartFile file, String sonLaboratory, Integer sampleId) { |
| | | public Object uploadFile(Integer orderId, MultipartFile file, String sonLaboratory, Integer sampleId) { |
| | | InsOrder insOrder = insOrderMapper.selectById(orderId); |
| | | String urlString; |
| | | String pathName; |
| | | String path; |
| | |
| | | file.transferTo(new File(urlString)); |
| | | insOrderFile.setFileUrl(pathName); |
| | | insOrderFileMapper.insert(insOrderFile); |
| | | //如果是辐射试验(近场/远程上传的csv文件) |
| | | String[] split = filename.split("\\."); |
| | | if (ObjectUtils.isNotEmpty(sonLaboratory) && (sonLaboratory.equals("近场") || sonLaboratory.equals("远场")) && |
| | | split[split.length - 1].equals("csv")) { |
| | | //判断是哪种csv文件,是否有—— |
| | | if (sonLaboratory.equals("近场")) { |
| | | fuSheUtils.getFuSheWord1(sonLaboratory, insOrderFile); |
| | | } else { |
| | | fuSheUtils.getFuSheWord2(sonLaboratory, insOrderFile); |
| | | } |
| | | if (ObjectUtils.isNotEmpty(sonLaboratory) && sonLaboratory.equals("近场") && split[split.length - 1].equals("csv")) { |
| | | fuSheUtils.getFuSheWord1(sonLaboratory, insOrderFile); |
| | | } else if (ObjectUtils.isNotEmpty(sonLaboratory) && sonLaboratory.equals("远场") && split[split.length - 1].equals("xlsx")) { |
| | | fuSheUtils.getFuSheWord2(sonLaboratory, insOrderFile); |
| | | } else if (ObjectUtils.isNotEmpty(sonLaboratory) && sonLaboratory.equals("电路试验") && split[split.length - 1].equals("xlsx") && filename.contains("交调")) { |
| | | dianLuUtils.readDianLuFile1(sampleId, insOrderFile); |
| | | } else if (ObjectUtils.isNotEmpty(sonLaboratory) && sonLaboratory.equals("电路试验") && split[split.length - 1].equals("csv") && filename.contains("驻波")) { |
| | | dianLuUtils.readDianLuFile2(sampleId, insOrderFile); |
| | | } else if (ObjectUtils.isNotEmpty(sonLaboratory) && sonLaboratory.equals("电路试验") && split[split.length - 1].equals("csv") && insOrder.getSampleType().equals("无源器件")) { |
| | | dianLuUtils.readDianLuFile3(sampleId, insOrderFile); |
| | | } |
| | | // 电路实验返回文件名 |
| | | if(ObjectUtils.isNotEmpty(sonLaboratory) && sonLaboratory.equals("电路试验")){ |
| | | return pathName; |
| | | } |
| | | // 震动doc文件解析 |
| | | if(filename.contains(".doc") && sonLaboratory.equals("振动")){ |
| | | return docAnalysis(urlString,orderId,sampleId,file.getOriginalFilename()); |
| | | } |
| | | } catch (Exception e) { |
| | | System.err.println("附件上传错误"); |
| | | throw new ErrorException(e.getMessage()); |
| | | } |
| | | return 0; |
| | | } |
| | |
| | | |
| | | //扫码报检 |
| | | @Override |
| | | public int scanInsOrderState(String sonLaboratory, String sampleCode, String trees) { |
| | | public int scanInsOrderState(String sonLaboratory, String sampleCode, String trees, String entrustCode) { |
| | | /*样品入库*/ |
| | | warehouseService.inWarehouse(trees, sampleCode); |
| | | warehouseService.inWarehouse(trees, sampleCode, entrustCode); |
| | | /*新增检验任务*/ |
| | | //先判断该样品是否有这个站点的项目 |
| | | InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getSampleCode, sampleCode)); |
| | | List<InsOrder> insOrders = insOrderMapper.selectList(Wrappers.<InsOrder>lambdaQuery().eq(InsOrder::getEntrustCode, entrustCode)); |
| | | InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery() |
| | | .eq(InsSample::getSampleCode, sampleCode) |
| | | .eq(InsSample::getInsOrderId, insOrders.get(0).getId())); |
| | | List<String> collect = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery() |
| | | .eq(InsProduct::getState, 1) |
| | | .eq(InsProduct::getInsSampleId, insSample.getId())).stream().map(InsProduct::getSonLaboratory).collect(Collectors.toList()); |
| | |
| | | |
| | | //扫码出库 |
| | | @Override |
| | | public int outInsOrderState(String sonLaboratory, String sampleCode) { |
| | | public int outInsOrderState(String sonLaboratory, String sampleCode, String entrustCode) { |
| | | //判断该样品的检验任务是否已经结束(继续试验或者是结束试验) |
| | | //先判断该样品是否有这个站点的项目 |
| | | InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getSampleCode, sampleCode)); |
| | | List<InsOrder> insOrders = insOrderMapper.selectList(Wrappers.<InsOrder>lambdaQuery().eq(InsOrder::getEntrustCode, entrustCode)); |
| | | InsSample insSample = insSampleMapper.selectOne(Wrappers.<InsSample>lambdaQuery() |
| | | .eq(InsSample::getSampleCode, sampleCode) |
| | | .eq(InsSample::getInsOrderId, insOrders.get(0).getId())); |
| | | List<String> collect = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery() |
| | | .eq(InsProduct::getState, 1) |
| | | .eq(InsProduct::getInsSampleId, insSample.getId())).stream().map(InsProduct::getSonLaboratory).collect(Collectors.toList()); |
| | |
| | | } |
| | | } |
| | | boolean a = true; |
| | | warehouseService.outWarehouse(sampleCode, a); |
| | | warehouseService.outWarehouse(sampleCode, a, entrustCode); |
| | | return 0; |
| | | } |
| | | |
| | |
| | | } catch (Exception e) { |
| | | result.setAfterCheck("");//'' |
| | | } |
| | | //实验结果 |
| | | try { |
| | | JSONObject resValue = JSON.parseObject(JSON.toJSONString(jo.get("testResult"))); |
| | | if (resValue.get("v") != null) { |
| | | Object o = JSON.parseObject(JSON.toJSONString(resValue.get("v"))).get("v"); |
| | | result.setTestResult(o.equals("") ? null : (o.toString())); |
| | | } |
| | | } catch (Exception e) { |
| | | result.setTestResult("");//'' |
| | | } |
| | | //设备编号 |
| | | if (jo.get("equipValue") != null) { |
| | | JSONArray jsonArray2 = JSON.parseArray(JSON.toJSONString(jo.get("equipValue"))); |
| | |
| | | .in(InsProductResult2::getInsProductId, insProductResultDtos.getInsProductResult2s().stream().map(InsProductResult2::getInsProductId).distinct().collect(Collectors.toList())) |
| | | .eq(InsProductResult2::getNum, orderState.getNum()) |
| | | .eq(InsProductResult2::getFrequency, insProductResultDtos.getFrequency())); |
| | | List<InsProductResult2> result2s = new ArrayList<>(); |
| | | List<InsProductUser> insProductUsers = new ArrayList<>(); |
| | | for (InsProductResult2 insProductResult2 : insProductResultDtos.getInsProductResult2s()) { |
| | | InsProduct insProduct = new InsProduct(); |
| | | insProduct.setId(insProductResult2.getInsProductId());//项目id |
| | |
| | | } |
| | | result2.setCreateUser(userId); |
| | | result2.setUpdateUser(userId); |
| | | insProductResult2Mapper.insert(result2); |
| | | insProduct.setUpdateUser(userId); |
| | | insProductMapper.updateById(insProduct); |
| | | insProductUserMapper.insert(new InsProductUser(null, userId, LocalDateTime.now(), insProduct.getId())); |
| | | result2s.add(result2); |
| | | //insProductResult2Mapper.insert(result2); |
| | | //insProduct.setUpdateUser(userId); |
| | | //insProducts.add(insProduct); |
| | | //insProductMapper.updateById(insProduct); |
| | | insProductUsers.add(new InsProductUser(null, userId, LocalDateTime.now(), insProduct.getId())); |
| | | //insProductUserMapper.insert(new InsProductUser(null, userId, LocalDateTime.now(), insProduct.getId())); |
| | | /*更新样品的检验状态*/ |
| | | insSample.setInsState(1); |
| | | Long l = insProductMapper.selectCount(Wrappers.<InsProduct>lambdaQuery() |
| | |
| | | //如果所有项目都有结论,那么该样品状态已检 |
| | | insSample.setInsState(2); |
| | | } |
| | | insSampleMapper.updateById(insSample); |
| | | } |
| | | insProductResult2Mapper.saveBatch(result2s); |
| | | insProductUserMapper.saveBatch(insProductUsers); |
| | | insSampleMapper.updateById(insSample); |
| | | /*判断该站点的检验项目是否全部已检*/ |
| | | int count = insProductMapper.selectInsProductCountByOrderId(insSample.getInsOrderId()); |
| | | if (count == 0) { |
| | |
| | | .set(InsOrderState::getInsState, 2)); |
| | | } |
| | | return list; |
| | | } |
| | | |
| | | //电路试验的保存检验内容(返回/提交) |
| | | @Override |
| | | public int saveInsContext2s(InsProductResultDtos insProductResultDtos) { |
| | | for (InsProductResultDto insProductResultDto : insProductResultDtos.getInsProductResultDtos()) { |
| | | saveInsContext2(insProductResultDto); |
| | | } |
| | | return 1; |
| | | } |
| | | |
| | | /** |
| | | * 震动doc文件解析 |
| | | * @param urlString |
| | | * @param orderId |
| | | * @param sampleId |
| | | * @param originFileName |
| | | * @return |
| | | */ |
| | | private Map<String, String> docAnalysis(String urlString,Integer orderId,Integer sampleId,String originFileName) { |
| | | Map<String, String> analysisMap = new HashMap<>(); |
| | | try { |
| | | File file = new File(urlString); |
| | | HWPFDocument document = new HWPFDocument(new FileInputStream(file)); |
| | | Range range = document.getRange(); |
| | | TableIterator tableIterator = new TableIterator(range); |
| | | List<Table> tableList = new ArrayList<>(); |
| | | while (tableIterator.hasNext()) { |
| | | tableList.add(tableIterator.next()); |
| | | } |
| | | for (int tableIndex = 0; tableIndex < tableList.size(); tableIndex++) { |
| | | // 取第一个表单限制参数的 振动台型号、运动部件等效质量、试件质量数值 |
| | | if(tableIndex == 0){ |
| | | Table table = tableList.get(0); |
| | | for (int i = 0; i < table.numRows(); i++) { |
| | | String columnText = ObjectUtils.isEmpty(table.getRow(i).getCell(0))? "" : table.getRow(i).getCell(0).text(); |
| | | String columnValue = ObjectUtils.isEmpty(table.getRow(i).getCell(1))? "" : table.getRow(i).getCell(1).text(); |
| | | if(columnValue.contains("\u0007")){ |
| | | columnValue = columnValue.replace("\u0007",""); |
| | | } |
| | | if(columnText.contains("\u0007")){ |
| | | columnText = columnText.replace("\u0007",""); |
| | | } |
| | | if(columnText.equals("振动台型号")){ |
| | | analysisMap.put("11",columnValue); |
| | | } |
| | | if(columnText.equals("运动部件等效质量")){ |
| | | analysisMap.put("12",columnValue); |
| | | } |
| | | if(columnText.equals("试件质量")){ |
| | | analysisMap.put("1",columnValue); |
| | | } |
| | | } |
| | | } |
| | | //取第一个表单输入通道参数第一条数据 |
| | | if(tableIndex == 1){ |
| | | Table table = tableList.get(1); |
| | | if(ObjectUtils.isNotEmpty(table)&& table.numRows() > 0){ |
| | | String columnValue = ObjectUtils.isEmpty(table.getRow(1).getCell(2))? "" : table.getRow(1).getCell(2).text(); |
| | | if(columnValue.contains("\u0007")){ |
| | | columnValue = columnValue.replace("\u0007",""); |
| | | } |
| | | analysisMap.put("9",columnValue); |
| | | } |
| | | } |
| | | // 取最后一个表单第三第四行信息 |
| | | if(tableIndex == tableList.size() - 1){ |
| | | Table table = tableList.get(tableIndex); |
| | | for (int i = 0; i < table.numRows(); i++) { |
| | | String columnText = ObjectUtils.isEmpty(table.getRow(i).getCell(0))? "" : table.getRow(i).getCell(0).text(); |
| | | String columnValue = ObjectUtils.isEmpty(table.getRow(i).getCell(1))? "" : table.getRow(i).getCell(1).text(); |
| | | if(columnValue.contains("\u0007")){ |
| | | columnValue = columnValue.replace("\u0007",""); |
| | | } |
| | | if(columnText.contains("\u0007")){ |
| | | columnText = columnText.replace("\u0007",""); |
| | | } |
| | | if(columnText.contains("总运行时间")){ |
| | | analysisMap.put("13",columnValue); |
| | | } |
| | | if(columnText.contains("试验扫频数")){ |
| | | analysisMap.put("10",columnValue); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | // 图片绑定 |
| | | List<Picture> pictureList = document.getPicturesTable().getAllPictures(); |
| | | String[] split = originFileName.split("\\."); |
| | | String docName = ""; |
| | | if(null != split && split.length > 0){ |
| | | docName = split[0]; |
| | | } |
| | | for (Picture picture : pictureList) { |
| | | byte[] pictureData = picture.getContent(); |
| | | File imgDir = new File(imgUrl); |
| | | if (!imgDir.exists()) { |
| | | imgDir.mkdirs(); |
| | | } |
| | | String filename = docName + "_" + UUID.randomUUID()+".png"; |
| | | File pictureFile = new File(imgUrl + File.separatorChar + filename); |
| | | // 创建输出流以将图片数据写入到指定路径 |
| | | try (OutputStream outputStream = new FileOutputStream(pictureFile)) { |
| | | // 写入数据 |
| | | outputStream.write(pictureData); |
| | | } |
| | | InsOrderFile insOrderFile = new InsOrderFile(); |
| | | insOrderFile.setInsOrderId(orderId); |
| | | insOrderFile.setInsSampleId(sampleId); |
| | | insOrderFile.setSonLaboratory("振动"); |
| | | insOrderFile.setType(1); |
| | | insOrderFile.setFileName(filename); |
| | | insOrderFile.setFileUrl(filename); |
| | | insOrderFileMapper.insert(insOrderFile); |
| | | } |
| | | }catch (Exception e){ |
| | | log.error(e.getMessage()); |
| | | } |
| | | return analysisMap; |
| | | } |
| | | |
| | | //温湿度试验+功率试验的保存检验内容 |
| | |
| | | } |
| | | } |
| | | // 处理其他比较条件 |
| | | if (ask.startsWith(">")) { |
| | | if (ask.startsWith(">") || ask.startsWith(">")) { |
| | | double threshold = Double.parseDouble(ask.substring(1)); |
| | | return s > threshold; |
| | | } else if (ask.startsWith("≥")) { |
| | | double threshold = Double.parseDouble(ask.substring(1)); |
| | | return s >= threshold; |
| | | } else if (ask.startsWith("<")) { |
| | | } else if (ask.startsWith("<")|| ask.startsWith("<")) { |
| | | double threshold = Double.parseDouble(ask.substring(1)); |
| | | return s < threshold; |
| | | } else if (ask.startsWith("≤")) { |
| | | double threshold = Double.parseDouble(ask.substring(1)); |
| | | return s <= threshold; |
| | | } else if (ask.equals("=")) { |
| | | } else if (ask.equals("=")|| ask.startsWith("=")) { |
| | | double exactValue = Double.parseDouble(ask.substring(1)); |
| | | return s == exactValue; |
| | | } |
| | |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public int verifyPlan(Integer sampleId, String laboratory, Integer type, String tell) throws IOException { |
| | | public int verifyPlan(Integer sampleId, String laboratory, Integer type, String tell) { |
| | | LocalDateTime now = LocalDateTime.now(); |
| | | Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); |
| | | List<InsUnPass> insUnPasses = new ArrayList<>(); |
| | |
| | | .set(InsOrderState::getVerifyTell, tell) |
| | | .set(InsOrderState::getVerifyUser, userId)); |
| | | //如果订单类型是原理样机,则该订单直接闭环 |
| | | if (insOrder.getFormType().equals("原理样机")) { |
| | | //出库 |
| | | try { |
| | | outInsOrderState(laboratory, insSample.getSampleCode()); |
| | | } catch (Exception e) { |
| | | List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, insSample.getInsOrderId())); |
| | | for (InsSample sample : insSamples) { |
| | | try{ |
| | | outInsOrderState(laboratory, sample.getSampleCode(), insOrder.getEntrustCode()); |
| | | }catch (Exception e){ |
| | | |
| | | } |
| | | } |
| | | /*生成对应的检验报告*/ |
| | | List<InsReportDto1> insReportDto1s=insOrderUserMapper.selectInsReportDto1(insOrder.getId()); |
| | | createReport(insOrder.getId(),insReportDto1s); |
| | | //该订单闭环 |
| | | insOrder.setState(4); |
| | | insOrderMapper.updateById(insOrder); |
| | | break; |
| | |
| | | return 1; |
| | | } |
| | | |
| | | private void getTemplateThing(Set<Integer> set, Map<Integer, String> map2, List<InsProduct> insProducts) { |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public int verifyPlan2(Integer sampleId, String laboratory, Integer type, String tell) { |
| | | Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); |
| | | InsSample insSample = insSampleMapper.selectById(sampleId); |
| | | InsOrder insOrder = insOrderMapper.selectById(insSample.getInsOrderId()); |
| | | /*type=0 再次试验; type=1 继续试验 ; type=2 结束试验*/ |
| | | // 查询根据 id 倒序排列的第一条记录 |
| | | InsOrderState record = insOrderStateMapper.selectOne(Wrappers.<InsOrderState>lambdaQuery() |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, sampleId) |
| | | .eq(InsOrderState::getLaboratory, laboratory) |
| | | .orderByDesc(InsOrderState::getId) |
| | | .last("LIMIT 1")); // 确保只取一条记录 |
| | | if (record != null) { |
| | | switch (type) { |
| | | case 0: |
| | | //再次试验:该单子退回到检验状态(排序改成当前的最后),次数递增(保留以前的数据); |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getId, record.getId()) |
| | | .set(InsOrderState::getInsTime, LocalDateTime.now()) |
| | | .set(InsOrderState::getInsState, 4) |
| | | .set(InsOrderState::getVerifyTell, tell) |
| | | .set(InsOrderState::getVerifyUser, userId) |
| | | .set(InsOrderState::getNum, record.getNum() + 1)//次数加1 |
| | | .set(InsOrderState::getCreateTime, LocalDateTime.now())); |
| | | break; |
| | | case 1: |
| | | //继续试验:该样品该站点任务结束(可以再次扫码检验); |
| | | //先判断上一个复核是什么结论 |
| | | if (record.getInsState()==4){ |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, sampleId) |
| | | .eq(InsOrderState::getLaboratory, laboratory) |
| | | .set(InsOrderState::getInsState, 6) |
| | | .set(InsOrderState::getVerifyTell, tell) |
| | | .set(InsOrderState::getNum, record.getNum() - 1)//次数-1 |
| | | .set(InsOrderState::getVerifyUser, userId)); |
| | | }else { |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, sampleId) |
| | | .eq(InsOrderState::getLaboratory, laboratory) |
| | | .set(InsOrderState::getInsState, 6) |
| | | .set(InsOrderState::getVerifyTell, tell) |
| | | .set(InsOrderState::getVerifyUser, userId)); |
| | | } |
| | | break; |
| | | case 2: |
| | | //结束试验:此委托单停止试验(无法再次检验)。 |
| | | //先判断上一个复核是什么结论 |
| | | if (record.getInsState()==4){ |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, sampleId) |
| | | .eq(InsOrderState::getLaboratory, laboratory) |
| | | .set(InsOrderState::getInsState, 5) |
| | | .set(InsOrderState::getNum, record.getNum() - 1)//次数-1 |
| | | .set(InsOrderState::getVerifyTell, tell) |
| | | .set(InsOrderState::getVerifyUser, userId)); |
| | | }else { |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, sampleId) |
| | | .eq(InsOrderState::getLaboratory, laboratory) |
| | | .set(InsOrderState::getInsState, 5) |
| | | .set(InsOrderState::getVerifyTell, tell) |
| | | .set(InsOrderState::getVerifyUser, userId)); |
| | | } |
| | | //出库 |
| | | List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, insSample.getInsOrderId())); |
| | | for (InsSample sample : insSamples) { |
| | | try{ |
| | | outInsOrderState(laboratory, sample.getSampleCode(), insOrder.getEntrustCode()); |
| | | }catch (Exception e){ |
| | | } |
| | | } |
| | | /*生成对应的检验报告*/ |
| | | List<InsReportDto1> insReportDto1s=insOrderUserMapper.selectInsReportDto1(insOrder.getId()); |
| | | createReport(insOrder.getId(),insReportDto1s); |
| | | //订单闭环 |
| | | insOrder.setState(4); |
| | | insOrderMapper.updateById(insOrder); |
| | | break; |
| | | } |
| | | } |
| | | return 1; |
| | | } |
| | | |
| | | |
| | | /*生成对应的检验报告*/ |
| | | private void createReport(Integer orderId,List<InsReportDto1> insReportDto1s){ |
| | | for (InsReportDto1 insReportDto1 : insReportDto1s) { |
| | | if (ObjectUtils.isNotEmpty(insReportDto1.getInsReportDto2s())){ |
| | | wordUtils.generateReport(orderId, insReportDto1); |
| | | // try{ |
| | | // wordUtils.generateReport(orderId, insReportDto1); |
| | | // }catch (Exception e){ |
| | | // throw new ErrorException("报告格式生成有误,请联系管理员!"); |
| | | // } |
| | | } |
| | | } |
| | | } |
| | | |
| | | private void getTemplateThing |
| | | (Set<Integer> set, Map<Integer, String> map2, List<InsProduct> insProducts) { |
| | | for (InsProduct product : insProducts) { |
| | | if (product.getTemplateId() == null) { |
| | | product.setTemplate(new ArrayList<>()); |
| | |
| | | InsOrderUser insOrderUser = new InsOrderUser(); |
| | | insOrderUser.setInsOrderStateId(orderState.getId()); |
| | | insOrderUser.setSubmitUser(getLook.selectPowerByMethodAndUserId(null).get("userId")); |
| | | insOrderUser.setInsTime(orderState.getInsTime()); |
| | | insOrderUser.setSubmitTime(LocalDateTime.now()); |
| | | insOrderUser.setNum(orderState.getNum()); |
| | | insOrderUser.setNote(ObjectUtils.isNotEmpty(submitPlanDto.getNote()) ? submitPlanDto.getNote() : null); |
| | |
| | | String str = ""; |
| | | int count = 0; |
| | | for (InsProduct product : insProducts) { |
| | | //辐射试验,温湿度试验,功率试验的检验项目,不需要去手动填写检验值,只需要上传表格文件就可以了,后台提交的时候校验跳过这个检验项目 |
| | | if (product.getInspectionItem().equals("辐射试验") || product.getInspectionItem().equals("温湿度试验") || product.getInspectionItem().equals("功率试验")) { |
| | | //温湿度试验,功率试验的检验项目,不需要去手动填写检验值,只需要上传表格文件就可以了,后台提交的时候校验跳过这个检验项目 |
| | | if ( product.getInspectionItem().equals("温湿度试验") || product.getInspectionItem().equals("功率试验")) { |
| | | product.setInsResult(3);//不判定 |
| | | insProductMapper.updateById(product); |
| | | continue; |
| | |
| | | info.setViewStatus(false); |
| | | info.setJumpPath("b1-inspect-order-plan"); |
| | | informationNotificationService.addInformationNotification(info); |
| | | // todo 企业微信消息推送@zss |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | String account = userMapper.selectById(submitPlanDto.getVerifyUser()).getAccount(); |
| | | map.put("touser", account);//接收消息成员的账号'ZT-031292'这种类型(如果有多个用'|'分隔) |
| | | map.put("toparty", "");//接收部门id |
| | | map.put("totag", "");//消息标签id |
| | | map.put("msgtype", "text");//消息类型 text:文本 |
| | | map.put("agentid", 1000517);//应用id |
| | | HashMap<String, Object> hashMap = new HashMap<>(); |
| | | hashMap.put("content", "您有一条检验任务待复核消息,订单号是:" + insOrder.getEntrustCode() + ",样品名称为:" + insSample.getSample() + |
| | | ",请前往LIMS系统查看。请点击<a href=\"https://ztwxlims.ztt.cn:7443/enter\">中天通信LIMS系统 </a>"); |
| | | map.put("text", hashMap);//消息内容 |
| | | map.put("safe", 0);//是否保密消息.0否 |
| | | map.put("enable_id_trans", 0);//是否开启id转译.0否 |
| | | map.put("enable_duplicate_check", 0);//是否开启重复消息检查.0否 |
| | | qywxApi.send(map); |
| | | //复核人--检验单相关负责人 |
| | | InsSampleUser insSampleUser = new InsSampleUser(); |
| | | insSampleUser.setUserId(submitPlanDto.getVerifyUser()); |
| | |
| | | insSampleUserMapper.insert(insSampleUser); |
| | | /*生成电路试验的站点报告并上传到附件中*/ |
| | | if (submitPlanDto.getLaboratory().equals("电路试验")) { |
| | | //wordUtils.generateWord(submitPlanDto.getTerm(), orderState); |
| | | //todo 电路站点报告 正式库部署放开 |
| | | try { |
| | | if (!insOrder.getSampleType().equals("无源器件")) { |
| | | wordUtils.generateWord(submitPlanDto.getTerm(), orderState); |
| | | } catch (Exception e) { |
| | | throw new ErrorException("电路试验的站点报告生成有误,请联系开发人员调整!"); |
| | | } else { |
| | | wordUtils.generateWord2(submitPlanDto.getTerm(), orderState); |
| | | } |
| | | //todo 电路站点报告 正式库部署放开 |
| | | // try { |
| | | // if (!insOrder.getSampleType().equals("无源器件")) { |
| | | // wordUtils.generateWord(submitPlanDto.getTerm(), orderState); |
| | | // }else { |
| | | // wordUtils.generateWord2(submitPlanDto.getTerm(), orderState); |
| | | // } |
| | | // } catch (Exception e) { |
| | | // throw new ErrorException("电路试验的站点报告生成有误,请联系开发人员调整!"); |
| | | // } |
| | | } |
| | | |
| | | /*生成产量工时*/ |
| | | //校验如果这个人这个检测项目已经添加过了则不需要再新增 |
| | | //首先判断当前人的当前时间是否是排班时间内,如果不是就是加班 |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | // todo 企业微信消息推送@zss |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | String account = userMapper.selectById(submitPlanDto.getVerifyUser()).getAccount(); |
| | | map.put("touser", account);//接收消息成员的账号'ZT-031292'这种类型(如果有多个用'|'分隔) |
| | | map.put("toparty", "");//接收部门id |
| | | map.put("totag", "");//消息标签id |
| | | map.put("msgtype", "text");//消息类型 text:文本 |
| | | map.put("agentid", 1000517);//应用id |
| | | HashMap<String, Object> hashMap = new HashMap<>(); |
| | | hashMap.put("content", "您有一条检验任务待复核消息,订单号是:" + insOrder.getEntrustCode() + ",样品名称为:" + insSample.getSample() + |
| | | ",请前往LIMS系统查看。请点击<a href=\"https://ztwxlims.ztt.cn:7443/enter\">中天通信LIMS系统 </a>"); |
| | | map.put("text", hashMap);//消息内容 |
| | | map.put("safe", 0);//是否保密消息.0否 |
| | | map.put("enable_id_trans", 0);//是否开启id转译.0否 |
| | | map.put("enable_duplicate_check", 0);//是否开启重复消息检查.0否 |
| | | qywxApi.send(map); |
| | | return 1; |
| | | } |
| | | |
| | | @Override |
| | | public int cancelSubmitPlan(Integer orderStateId) { |
| | | InsOrderState orderState = insOrderStateMapper.selectById(orderStateId); |
| | | InsOrder insOrder = insOrderMapper.selectById(orderState.getInsOrderId()); |
| | | InsSample insSample = insSampleMapper.selectById(orderState.getInsSampleId()); |
| | | /*删除记录检验任务每次的备注信息*/ |
| | | insOrderUserMapper.delete(Wrappers.<InsOrderUser>lambdaQuery() |
| | | .eq(InsOrderUser::getInsOrderStateId, orderState.getId()) |
| | | .eq(InsOrderUser::getNum, orderState.getNum())); |
| | | //撤销提交 |
| | | insOrderStateMapper.update(null, Wrappers.<InsOrderState>lambdaUpdate() |
| | | .eq(InsOrderState::getInsOrderId, orderState.getInsOrderId()) |
| | | .eq(InsOrderState::getInsSampleId, orderState.getInsSampleId()) |
| | | .eq(InsOrderState::getLaboratory, orderState.getLaboratory()) |
| | | .set(InsOrderState::getInsState, 2)); |
| | | Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); |
| | | //LIMS系统消息推送 |
| | | InformationNotification info = new InformationNotification(); |
| | | info.setCreateUser(insProductMapper.selectUserById(userId).get("name")); |
| | | info.setMessageType("2"); |
| | | info.setTheme("复核撤销通知"); |
| | | info.setContent("您有一条检验任务待复核已撤销的消息,订单号是:" + insOrder.getEntrustCode() + ",样品名称为:" + insSample.getSample()); |
| | | info.setSenderId(userId); |
| | | info.setConsigneeId(orderState.getVerifyUser()); |
| | | info.setViewStatus(false); |
| | | info.setJumpPath("b1-inspect-order-plan"); |
| | | informationNotificationService.addInformationNotification(info); |
| | | //删除复核人--检验单相关负责人 |
| | | insSampleUserMapper.delete(Wrappers.<InsSampleUser>lambdaQuery() |
| | | .eq(InsSampleUser::getState, 1) |
| | | .eq(InsSampleUser::getSonLaboratory, orderState.getLaboratory()) |
| | | .eq(InsSampleUser::getUserId, orderState.getVerifyUser()) |
| | | .eq(InsSampleUser::getInsSampleId, orderState.getInsSampleId())); |
| | | //删除生成的报告 |
| | | if (orderState.getLaboratory().equals("电路试验")) { |
| | | List<InsOrderFile> insOrderFiles = insOrderFileMapper.selectList(Wrappers.<InsOrderFile>lambdaQuery() |
| | | .eq(InsOrderFile::getType, 2) |
| | | .like(InsOrderFile::getFileName, "电路参数.docx") |
| | | .eq(InsOrderFile::getInsOrderId, insOrder.getId()) |
| | | .eq(InsOrderFile::getInsSampleId, orderState.getInsSampleId()) |
| | | .eq(InsOrderFile::getSonLaboratory, orderState.getLaboratory())); |
| | | for (InsOrderFile insOrderFile : insOrderFiles) { |
| | | File file = new File(wordUrl + "/" + insOrderFile.getFileUrl()); |
| | | file.delete(); |
| | | insOrderFileMapper.deleteById(insOrderFile.getId()); |
| | | } |
| | | } |
| | | |
| | | /*删除生成产量工时*/ |
| | | List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery().eq(InsProduct::getInsSampleId, insSample.getId())); |
| | | List<Integer> productIds = insProducts.stream().map(InsProduct::getId).distinct().collect(Collectors.toList()); |
| | | auxiliaryOutputWorkingHoursMapper.delete(Wrappers.<AuxiliaryOutputWorkingHours>lambdaQuery() |
| | | .eq(AuxiliaryOutputWorkingHours::getSample, insSample.getSampleCode()) |
| | | .in(AuxiliaryOutputWorkingHours::getInsProductId, productIds) |
| | | .eq(AuxiliaryOutputWorkingHours::getNum, orderState.getNum())); |
| | | |
| | | // todo 企业微信消息推送@zss |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | String account = userMapper.selectById(orderState.getVerifyUser()).getAccount(); |
| | | map.put("touser", account);//接收消息成员的账号'ZT-031292'这种类型(如果有多个用'|'分隔) |
| | | map.put("toparty", "");//接收部门id |
| | | map.put("totag", "");//消息标签id |
| | | map.put("msgtype", "text");//消息类型 text:文本 |
| | | map.put("agentid", 1000517);//应用id |
| | | HashMap<String, Object> hashMap = new HashMap<>(); |
| | | hashMap.put("content", "您有一条复核的消息已撤销,订单号是:" + insOrder.getEntrustCode() + ",样品名称为:" + insSample.getSample() + |
| | | ",请前往LIMS系统查看。请点击<a href=\"https://ztwxlims.ztt.cn:7443/enter\">中天通信LIMS系统 </a>"); |
| | | map.put("text", hashMap);//消息内容 |
| | | map.put("safe", 0);//是否保密消息.0否 |
| | | map.put("enable_id_trans", 0);//是否开启id转译.0否 |
| | | map.put("enable_duplicate_check", 0);//是否开启重复消息检查.0否 |
| | | qywxApi.send(map); |
| | | return 0; |
| | | } |
| | | |
| | | public static String getWeek(String dayStr) { |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | try { |