package com.yuanchu.mom.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.lang.UUID; 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.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; 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.yuanchu.mom.common.GetLook; import com.yuanchu.mom.common.PrintChina; 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.ss.usermodel.CellValue; import org.apache.poi.xssf.usermodel.XSSFCell; import org.apache.poi.xssf.usermodel.XSSFRow; import org.apache.poi.xssf.usermodel.XSSFSheet; import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.io.*; import java.nio.file.Files; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; /** * 检验任务-业务实现层 */ @Service @Transactional(rollbackFor = Exception.class) 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; @Resource private InsOrderUserMapper insOrderUserMapper; @Resource private ShiftTimeMapper shiftTimeMapper; @Resource private PerformanceShiftMapper performanceShiftMapper; @Resource private WarehouseHistoryMapper warehouseHistoryMapper; @Resource private WarehouseService warehouseService; @Value("${wordUrl}") private String wordUrl; @Resource WordUtils wordUtils; @Resource private InsReportMapper insReportMapper; @Resource private InsProductResultMapper insProductResultMapper; @Resource private InsProductResult2Mapper insProductResult2Mapper; @Resource private InsProductUserMapper insProductUserMapper; @Resource private InsUnPassService insUnPassService; @Resource AuxiliaryOutputWorkingHoursMapper auxiliaryOutputWorkingHoursMapper; @Resource QYWXApi qywxApi; @Resource private InformationNotificationService informationNotificationService; @Resource private UserMapper userMapper; @Value("${file.path}") private String imgUrl; @Resource private InsOrderFileMapper insOrderFileMapper; @Resource FuSheUtils fuSheUtils; @Resource DianLuUtils dianLuUtils; @Override public Map selectInsOrderPlanList(Page page, InsOrderPlanDTO insOrderPlanDTO) { Map map = new HashMap<>(); map.put("head", PrintChina.printChina(InsOrderPlanVO.class)); Map map1 = getLook.selectPowerByMethodAndUserId(null); String laboratory = null; String userName = null; if (ObjectUtil.isNotEmpty(insOrderPlanDTO.getUserId())) { userName = userMapper.selectById(map1.get("userId")).getName(); insOrderPlanDTO.setUserId(null); } String sonLaboratory = insOrderPlanDTO.getSonLaboratory();//试验室 insOrderPlanDTO.setSonLaboratory(null); IPage insOrderPage = insSampleMapper.findInsSampleAndOrder(page, QueryWrappers.queryWrappers(insOrderPlanDTO), userName, sonLaboratory, laboratory); map.put("body", insOrderPage); return map; } @Override public Map inspectionOrderDetailsTaskSwitching(Page page, InsOrderPlanDTO insOrderPlanDTO) { Map map = new HashMap<>(); map.put("head", PrintChina.printChina(InsOrderPlanTaskSwitchVo.class)); Map map1 = getLook.selectPowerByMethodAndUserId(null); Integer userId = map1.get("userId"); User user = userMapper.selectById(map1.get("userId"));//当前登录的人 String laboratory = null; if (ObjectUtil.isNotEmpty(insOrderPlanDTO.getUserId())) { insOrderPlanDTO.setUserId(userId.longValue()); } String sonLaboratory = insOrderPlanDTO.getSonLaboratory();//试验室 IPage insOrderPage = insSampleMapper.inspectionOrderDetailsTaskSwitching(page, QueryWrappers.queryWrappers(insOrderPlanDTO), userId, sonLaboratory, laboratory); 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, 0, entity.getSonLaboratory()); return insSampleUserMapper.insert(insSampleUser) > 0; } @Override public Map doInsOrder(Integer sampleId, String laboratory) { InsSample insSample = insSampleMapper.selectById(sampleId); InsOrder insOrder = new InsOrder(); insOrder.setId(insSample.getInsOrderId()); InsOrder order = insOrderMapper.selectById(insSample.getInsOrderId()); if (BeanUtil.isEmpty(order.getInsTime())) { insOrder.setInsTime(LocalDateTime.now());//订单的检验时间 insOrderMapper.updateById(insOrder); } InsOrderState orderState = insOrderStateMapper.selectOne(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, sampleId) .eq(InsOrderState::getLaboratory, laboratory)); if (ObjectUtils.isEmpty(orderState.getInsTime())) { //更新检验任务表的检验时间 insOrderStateMapper.update(null, Wrappers.lambdaUpdate() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, sampleId) .eq(InsOrderState::getLaboratory, laboratory) .set(InsOrderState::getInsTime, LocalDateTime.now()) .set(InsOrderState::getInsState, 1)); } Map map = insOrderService.getInsOrderAndSample(sampleId, laboratory); List list = JSON.parseArray(JSON.toJSONString(map.get("sampleProduct")), SampleProductDto.class); map.put("sampleProduct", list); return map; } @Override public List getInsProduct(Integer id, Integer type, String laboratory, HttpServletRequest request) { List insProducts = new ArrayList<>(); switch (type) { case 0: //样品 insProducts = insSampleMapper.getInsProduct1(id, laboratory); if (insProducts.size() == 0) { insProducts = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, id) .eq(InsProduct::getState, 1) .eq(InsProduct::getSonLaboratory, laboratory)); for (InsProduct insProduct : insProducts) { List insProductResult2List = insProductResult2Mapper.selectList(Wrappers.lambdaQuery() .eq(InsProductResult2::getInsProductId, insProduct.getId()).isNull(InsProductResult2::getNum)); insProduct.setInsProductResult2(insProductResult2List); InsProductResult insProductResult = insProductResultMapper.selectOne(Wrappers.lambdaQuery() .eq(InsProductResult::getInsProductId, insProduct.getId()).isNull(InsProductResult::getNum)); insProduct.setInsProductResult(insProductResult); } } break; case 1: //光纤带 break; case 2: //光纤 break; case 3: //套管 break; } Set set = new HashSet<>(); Map map2 = new HashMap<>(); if (BeanUtil.isEmpty(insProducts)) return null; getTemplateThing(set, map2, insProducts); return insProducts; } @Override public List getInsProduct2(Integer id, Integer type, String laboratory, HttpServletRequest request, Integer num) { List insProducts = new ArrayList<>(); switch (type) { case 0: //样品 insProducts = insSampleMapper.get2InsProduct1(id, laboratory, num); if (insProducts.size() == 0) { throw new ErrorException("当前检验数据还没有保存,保存之后有数据历史"); } break; case 1: //光纤带 break; case 2: //光纤 break; case 3: //套管 break; } Set set = new HashSet<>(); Map map2 = new HashMap<>(); if (BeanUtil.isEmpty(insProducts)) return null; getTemplateThing(set, map2, insProducts); return insProducts; } @Override public List checkSubmitPlan(Integer sampleId, String laboratory) { List collect = new ArrayList<>(); List insProducts = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, sampleId) .eq(InsProduct::getSonLaboratory, laboratory) .eq(InsProduct::getState, 1) .eq(InsProduct::getInsResult, 0)); if (insProducts.size() > 0) { collect = insProducts.stream().map(insProduct -> { return insProduct.getInspectionItem() + "-" + insProduct.getInspectionItemSubclass(); }).collect(Collectors.toList()); } return collect; } @Override public Map getFileList(Page page, InsOrderFile insOrderFile) { Map map = new HashMap<>(); map.put("head", PrintChina.printChina(InsOrderFile.class)); Integer insOrderId = insOrderFile.getInsOrderId(); insOrderFile.setInsOrderId(null); String sonLaboratory = null; Integer sampleId = null; if (ObjectUtils.isNotEmpty(insOrderFile.getSonLaboratory())) { sonLaboratory = insOrderFile.getSonLaboratory(); insOrderFile.setSonLaboratory(null); } if (ObjectUtils.isNotEmpty(insOrderFile.getInsSampleId())) { sampleId = insOrderFile.getInsSampleId(); insOrderFile.setInsSampleId(null); } IPage insOrderFileIPage = insOrderFileMapper.getFileList(page, QueryWrappers.queryWrappers(insOrderFile), insOrderId, sonLaboratory, sampleId); map.put("body", insOrderFileIPage); return map; } @Override public Object uploadFile(Integer orderId, MultipartFile file, String sonLaboratory, Integer sampleId) { InsOrder insOrder = insOrderMapper.selectById(orderId); String urlString; String pathName; String path; String filename = file.getOriginalFilename(); String contentType = file.getContentType(); InsOrderFile insOrderFile = new InsOrderFile(); insOrderFile.setInsOrderId(orderId); if (ObjectUtils.isNotEmpty(sampleId)) { insOrderFile.setInsSampleId(sampleId); } if (ObjectUtils.isNotEmpty(sonLaboratory)) { insOrderFile.setSonLaboratory(sonLaboratory); } insOrderFile.setFileName(filename); if (contentType != null && contentType.startsWith("image/")) { // 是图片 path = imgUrl; insOrderFile.setType(1); } else { // 是文件 path = wordUrl; insOrderFile.setType(2); } try { File realpath = new File(path); if (!realpath.exists()) { realpath.mkdirs(); } pathName = UUID.randomUUID() + "_" + file.getOriginalFilename().replace("#", "&"); urlString = realpath + "/" + pathName; file.transferTo(new File(urlString)); insOrderFile.setFileUrl(pathName); insOrderFileMapper.insert(insOrderFile); String[] split = filename.split("\\."); 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); } } catch (Exception e) { throw new ErrorException(e.getMessage()); } return 0; } @Override public List upPlanUser2(Integer sampleId) { List sonLaboratory = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getState, 1) .eq(InsProduct::getInsSampleId, sampleId)) .stream().map(InsProduct::getSonLaboratory).distinct().collect(Collectors.toList()); return sonLaboratory; } @Override public int deleteInsContext(InsProductResultVo insProductResultVo) { return insProductResult2Mapper.delete(Wrappers.lambdaQuery() .eq(InsProductResult2::getFrequency, insProductResultVo.getFrequency()) .eq(InsProductResult2::getNum, insProductResultVo.getNum()) .in(InsProductResult2::getInsProductId, insProductResultVo.getProductIds())); } //扫码报检 @Override public int scanInsOrderState(String sonLaboratory, String sampleCode, String trees, String entrustCode) { /*样品入库*/ warehouseService.inWarehouse(trees, sampleCode, entrustCode); /*新增检验任务*/ //先判断该样品是否有这个站点的项目 List insOrders = insOrderMapper.selectList(Wrappers.lambdaQuery().eq(InsOrder::getEntrustCode, entrustCode)); InsSample insSample = insSampleMapper.selectOne(Wrappers.lambdaQuery() .eq(InsSample::getSampleCode, sampleCode) .eq(InsSample::getInsOrderId, insOrders.get(0).getId())); List collect = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getState, 1) .eq(InsProduct::getInsSampleId, insSample.getId())).stream().map(InsProduct::getSonLaboratory).collect(Collectors.toList()); if (!collect.contains(sonLaboratory)) { throw new ErrorException("该样品没有" + sonLaboratory + "站点的相关项目,请查看下单详情!"); } //判断该订单是否站点任务有结束试验(只要任一任务结束试验都不能再次试验) List orderStates = insOrderStateMapper.selectList(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsState, 5)); if (CollectionUtils.isNotEmpty(orderStates)) { throw new ErrorException("该订单站点的任务已经结束试验,无法再次进行试验!"); } InsOrderState orderState = insOrderStateMapper.selectOne(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, insSample.getId()) .eq(InsOrderState::getLaboratory, sonLaboratory)); if (ObjectUtils.isNotEmpty(orderState)) { //继续试验 if (orderState.getInsState() == 6) { orderState.setInsState(0); orderState.setNum(orderState.getNum() + 1);//递增 insOrderStateMapper.updateById(orderState); } } else { InsOrderState insOrderState = new InsOrderState(); insOrderState.setInsOrderId(insSample.getInsOrderId()); insOrderState.setInsSampleId(insSample.getId()); insOrderState.setLaboratory(sonLaboratory); insOrderState.setInsState(0); insOrderState.setNum(1);//初始是第一次 insOrderStateMapper.insert(insOrderState); } return 1; } //扫码出库 @Override public int outInsOrderState(String sonLaboratory, String sampleCode, String entrustCode) { //判断该样品的检验任务是否已经结束(继续试验或者是结束试验) //先判断该样品是否有这个站点的项目 List insOrders = insOrderMapper.selectList(Wrappers.lambdaQuery().eq(InsOrder::getEntrustCode, entrustCode)); InsSample insSample = insSampleMapper.selectOne(Wrappers.lambdaQuery() .eq(InsSample::getSampleCode, sampleCode) .eq(InsSample::getInsOrderId, insOrders.get(0).getId())); List collect = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getState, 1) .eq(InsProduct::getInsSampleId, insSample.getId())).stream().map(InsProduct::getSonLaboratory).collect(Collectors.toList()); if (!collect.contains(sonLaboratory)) { throw new ErrorException("该样品没有" + sonLaboratory + "站点的相关项目,请查看下单详情!"); } //判断该订单是否站点任务有(继续试验或者是结束试验) List orderStates = insOrderStateMapper.selectList(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsState, 5));//结束试验 if (CollectionUtils.isEmpty(orderStates)) { List orderStates1 = insOrderStateMapper.selectList(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, insSample.getId()) .eq(InsOrderState::getLaboratory, sonLaboratory) .eq(InsOrderState::getInsState, 6));//继续试验 if (CollectionUtils.isEmpty(orderStates1)) { throw new ErrorException("该样品的检验任务还没有结束试验或继续试验,暂时无法出库!"); } } boolean a = true; warehouseService.outWarehouse(sampleCode, a, entrustCode); return 0; } @Override public List getInsOrderUserList(Integer insOrderStateId) { return insOrderUserMapper.getInsOrderUserList(insOrderStateId); } private static final String splitIdentifier = "@-@"; // 自定义唯一标识分割符 //预览文件 @Override public Object preview(Integer id) throws Exception { InsOrderFile insOrderFile = insOrderFileMapper.selectById(id); File file = new File(wordUrl + "/" + insOrderFile.getFileUrl()); StringBuilder stringBuilder = new StringBuilder(); // 创建 reader try (BufferedReader br = Files.newBufferedReader(file.toPath())) { // CSV文件的分隔符 String DELIMITER = ","; // 按行读取 String line; while ((line = br.readLine()) != null) { // 分割 String[] columns = line.split(DELIMITER); // 打印行 stringBuilder.append(String.join(splitIdentifier, columns)).append("\n"); } } catch (Exception ex) { List list = new ArrayList<>(); //创建工作簿对象 XSSFWorkbook xssfWorkbook = new XSSFWorkbook(new FileInputStream(file)); //获取工作簿下sheet的个数 只读取第一个sheet int sheetNum = xssfWorkbook.getNumberOfSheets(); //遍历工作簿中的所有数据 for (int i = 0; i < sheetNum; i++) { Map map = new HashMap<>(); StringBuilder result = new StringBuilder(); XSSFSheet sheet = xssfWorkbook.getSheetAt(i); //获取最后一行的num，即总行数。此处从0开始 int maxRow = sheet.getLastRowNum(); for (int row = 0; row <= maxRow; row++) { XSSFRow xssfRow = sheet.getRow(row); //获取最后单元格num，即总单元格数 ***注意：此处从1开始计数*** int maxRol = sheet.getRow(row).getLastCellNum(); StringBuilder aLine = new StringBuilder(); /*for (int rol = 0; rol < maxRol; rol++) { aLine.append(sheet.getRow(row).getCell(rol)).append(","); }*/ for (int rol = 0; rol < maxRol; rol++) { XSSFCell cell = xssfRow.getCell(rol); if (cell == null) { aLine.append(","); } else { switch (cell.getCellType()) { case FORMULA: // 计算公式并获取结果 CellValue cellValue = xssfWorkbook.getCreationHelper().createFormulaEvaluator().evaluate(cell); switch (cellValue.getCellType()) { case NUMERIC: String formattedValue = String.format("%.4f", cellValue.getNumberValue()); aLine.append(formattedValue); break; case STRING: aLine.append(cellValue.getStringValue()); break; case BOOLEAN: aLine.append(cellValue.getBooleanValue()); break; case ERROR: aLine.append("#ERR!"); break; default: aLine.append(""); break; } break; case NUMERIC: String formattedValue = String.format("%.4f", cell.getNumericCellValue()); aLine.append(formattedValue); break; case STRING: aLine.append(cell.getStringCellValue()); break; case BOOLEAN: aLine.append(cell.getBooleanCellValue()); break; case ERROR: aLine.append("#ERR!"); break; default: aLine.append(""); break; } aLine.append(","); } } String substring = aLine.substring(0, aLine.length() - 1); result.append(substring).append("\n"); } map.put("sheetName", sheet.getSheetName()); map.put("content", result.toString()); list.add(map); } return list; } return stringBuilder.toString(); } //模版保存检验内容 @Override public void saveInsContext(Map insContext, Integer num) { 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)); List results = insProductResultMapper.selectList(Wrappers.lambdaQuery() .eq(InsProductResult::getNum, num) .eq(InsProductResult::getInsProductId, insProduct.getId())); InsProductResult result; if (CollectionUtils.isEmpty(results)) { result = new InsProductResult(); } else { result = results.get(0); } result.setInsProductId(Integer.parseInt(k)); result.setNum(num); //检验值 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")); map.put("r", JSON.toJSONString(insValue.get("r"))); map.put("c", JSON.toJSONString(insValue.get("c"))); map.put("w", insValue.get("w")); 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) { insProduct.setLastValue("");//'' } //试验前样品检查 try { JSONObject resValue = JSON.parseObject(JSON.toJSONString(jo.get("beforeCheck"))); if (resValue.get("v") != null) { Object o = JSON.parseObject(JSON.toJSONString(resValue.get("v"))).get("v"); result.setBeforeCheck(o.equals("") ? null : (o.toString())); } } catch (Exception e) { result.setBeforeCheck("");//'' } //试验后样品检查 try { JSONObject resValue = JSON.parseObject(JSON.toJSONString(jo.get("afterCheck"))); if (resValue.get("v") != null) { Object o = JSON.parseObject(JSON.toJSONString(resValue.get("v"))).get("v"); result.setAfterCheck(o.equals("") ? null : (o.toString())); } } catch (Exception e) { result.setAfterCheck("");//'' } //设备编号 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) { insProduct.setInsResult(2);//待定 } 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())); insProduct = insProductMapper.selectById(insProduct); 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()) .and(wrapper -> wrapper .isNotNull(InsProduct::getInsResult) .or() .ne(InsProduct::getInsResult, 2) )); if (l == l1) { //如果所有项目都有结论,那么该样品状态已检 insSample.setInsState(2); } insSampleMapper.updateById(insSample); /*校验一下result表*/ List insProductResults = insProductResultMapper.selectList(Wrappers.lambdaQuery() .eq(InsProductResult::getNum, num) .eq(InsProductResult::getInsProductId, insProduct.getId())); if (insProductResults.size() > 1) { for (int i = 1; i < insProductResults.size(); i++) { insProductResultMapper.deleteById(insProductResults.get(i)); } } }); return insContext.keySet().stream().findFirst().orElse(null); }).thenAccept(res -> { if (res != null) { int pId = Integer.parseInt(res.replaceAll("\\D+", "")); InsProduct insProduct = insProductMapper.selectById(pId); // 通过样本id获取订单id InsSample insSample = insSampleMapper.selectById(insProduct.getInsSampleId()); int orderId = insSample.getInsOrderId(); int count = insProductMapper.selectInsProductCountByOrderId(insSample.getId()); if (count == 0) { insOrderStateMapper.update(new InsOrderState(), Wrappers.lambdaUpdate() .eq(InsOrderState::getInsOrderId, orderId) .eq(InsOrderState::getInsSampleId, insSample.getId()) .eq(InsOrderState::getLaboratory, insProduct.getSonLaboratory()) .set(InsOrderState::getInsState, 2)); } } }).exceptionally(e -> { e.printStackTrace(); return null; }); } //电路试验的保存检验内容 @Override public List saveInsContext2(InsProductResultDto insProductResultDtos) { if (ObjectUtils.isEmpty(insProductResultDtos.getFrequency())) { throw new ErrorException("频率不能为空"); } Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); //查询样品信息 InsSample insSample = insSampleMapper.selectById(insProductResultDtos.getSampleId()); //查询检验单信息 InsOrderState orderState = insOrderStateMapper.selectOne(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, insProductResultDtos.getSampleId()) .eq(InsOrderState::getLaboratory, insProductResultDtos.getSonLaboratory()) .orderByDesc(InsOrderState::getId) .last("LIMIT 1"));// 确保只取一条记录 List list = new ArrayList<>(); /*新增检验项目检验值记录表(采取先删后增)*/ insProductResult2Mapper.delete(Wrappers.lambdaQuery() .in(InsProductResult2::getInsProductId, insProductResultDtos.getInsProductResult2s().stream().map(InsProductResult2::getInsProductId).distinct().collect(Collectors.toList())) .eq(InsProductResult2::getNum, orderState.getNum()) .eq(InsProductResult2::getFrequency, insProductResultDtos.getFrequency())); List result2s = new ArrayList<>(); List insProductUsers = new ArrayList<>(); for (InsProductResult2 insProductResult2 : insProductResultDtos.getInsProductResult2s()) { InsProduct insProduct = new InsProduct(); insProduct.setId(insProductResult2.getInsProductId());//项目id InsProductResult2 result2 = new InsProductResult2(); result2.setNum(orderState.getNum()); result2.setInsProductId(insProductResult2.getInsProductId()); //频率 result2.setFrequency(insProductResultDtos.getFrequency()); //频点 if (insProductResult2.getOften() != null) { result2.setOften(insProductResult2.getOften()); } //端口 if (insProductResult2.getPort() != null) { result2.setPort(insProductResult2.getPort()); } //角度 if (insProductResult2.getAngle() != null) { result2.setAngle(insProductResult2.getAngle()); } //设备编号 if (insProductResult2.getEquipValue() != null) { result2.setEquipValue(insProductResult2.getEquipValue()); } //设备名称 if (insProductResult2.getEquipName() != null) { result2.setEquipName(insProductResult2.getEquipName()); } insProduct = insProductMapper.selectById(insProduct.getId()); //值 if (insProductResult2.getValue() != null) { result2.setValue(insProductResult2.getValue()); //结论 int ressult = 1; String valueStr = insProductResult2.getValue(); String regex = "[\u4e00-\u9fa5]"; if (!insProduct.getAsk().contains(",")) { if (insProduct.getAsk().equals("/") || Pattern.compile(regex).matcher(insProduct.getAsk()).find()) { ressult = 3; //不判定 } else if (!isValueValid(valueStr, new String[]{insProduct.getAsk()})) { ressult = 0; //不合格 } } else { // 如果要求值是(2°≥20,7°≥25,12°≥25)这种情况 String[] askParts = insProduct.getAsk().split(","); String[] angles = insProductResult2.getAngle().split(","); for (String s : askParts) { String[] askSplit = s.split("°"); String angleKey = askSplit[0]; String angleValue = askSplit[1]; for (int i = 0; i < angles.length; i++) { if (angles[i].split("°")[0].equals(angleKey)) { try { String s1 = valueStr.substring(1, valueStr.length() - 1).split("\\],\\[")[i]; if (!s1.startsWith("[")) { s1 = "[" + s1; } if (!s1.endsWith("]")) { s1 = s1 + "]"; } if (!isValueValid("[" + s1 + "]", new String[]{angleValue})) { ressult = 0; // 不合格 break; } } catch (Exception e) { } finally { continue; } } } } } result2.setResult(ressult); list.add(ressult); } result2.setCreateUser(userId); result2.setUpdateUser(userId); 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.lambdaQuery() .eq(InsProduct::getInsSampleId, insSample.getId())); Long l1 = insProductMapper.selectCount(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, insSample.getId()) .and(wrapper -> wrapper .isNotNull(InsProduct::getInsResult) .or() .ne(InsProduct::getInsResult, 2) )); if (l == l1) { //如果所有项目都有结论,那么该样品状态已检 insSample.setInsState(2); } } insProductResult2Mapper.saveBatch(result2s); insProductUserMapper.saveBatch(insProductUsers); insSampleMapper.updateById(insSample); /*判断该站点的检验项目是否全部已检*/ int count = insProductMapper.selectInsProductCountByOrderId(insSample.getInsOrderId()); if (count == 0) { insOrderStateMapper.update(new InsOrderState(), Wrappers.lambdaUpdate() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, insProductResultDtos.getSampleId()) .eq(InsOrderState::getLaboratory, insProductResultDtos.getSonLaboratory()) .set(InsOrderState::getInsState, 2)); } return list; } //电路试验的保存检验内容(返回/提交) @Override public int saveInsContext2s(InsProductResultDtos insProductResultDtos) { for (InsProductResultDto insProductResultDto : insProductResultDtos.getInsProductResultDtos()) { saveInsContext2(insProductResultDto); } return 1; } //温湿度试验+功率试验的保存检验内容 @Override public int saveInsContext3(InsProductResult insProductResult) { //先删后加 insProductResultMapper.delete(Wrappers.lambdaQuery() .eq(InsProductResult::getInsProductId, insProductResult.getInsProductId()) .eq(InsProductResult::getNum, insProductResult.getNum())); insProductResult.setEquipValue("[{\"v\":\"" + insProductResult.getEquipValue() + "\"}]"); insProductResult.setEquipName("[{\"v\":\"" + insProductResult.getEquipName() + "\"}]"); insProductResultMapper.insert(insProductResult); return 0; } //解析要求值的格式 private boolean getResult(double s, String ask) { // 处理±范围的条件 if (ask.contains("±")) { Pattern pattern = Pattern.compile("(\\d+)±(\\d+)"); Matcher matcher = pattern.matcher(ask); if (matcher.matches()) { double center = Double.parseDouble(matcher.group(1)); double tolerance = Double.parseDouble(matcher.group(2)); return Math.abs(s - center) <= tolerance; } } // 处理其他比较条件 if (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("<")) { 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("=")) { double exactValue = Double.parseDouble(ask.substring(1)); return s == exactValue; } // 处理不支持的条件 throw new IllegalArgumentException("未知格式要求值请检查" + ask); } //将前端传过来的值转换成数组的形式 private String[] parseValues(String valueStr) { String trimmedStr = valueStr.substring(1, valueStr.length() - 1); return Arrays.stream(trimmedStr.split("\\],\\[")) .map(s -> s.substring(1, s.length() - 1).split(",")) .flatMap(Arrays::stream) .map(s -> s.replace("\"", "")) .toArray(String[]::new); } //判读合格与不合格 private boolean isValueValid(String valueStr, String[] valuesToCheck) { for (String s : parseValues(valueStr)) { if (ObjectUtils.isEmpty(s)) { continue; } double numericValue = Math.abs(Double.parseDouble(s)); boolean valid = Arrays.stream(valuesToCheck) .allMatch(v -> getResult(numericValue, v)); if (!valid) { return false; } } return true; } //交接 @Override public int upPlanUser(Integer userId, Integer sampleId, String sonLaboratory) { InsSampleUser insSampleUser = new InsSampleUser(); insSampleUser.setUserId(userId); insSampleUser.setInsSampleId(sampleId); insSampleUser.setState(0); insSampleUser.setSonLaboratory(sonLaboratory); return insSampleUserMapper.insert(insSampleUser); } @Override @Transactional(rollbackFor = Exception.class) public int verifyPlan(Integer sampleId, String laboratory, Integer type, String tell) throws IOException { LocalDateTime now = LocalDateTime.now(); Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); List insUnPasses = new ArrayList<>(); /*样品下的项目只要有一个项目不合格则检验结果为0,否则为1*/ InsSample insSample = insSampleMapper.selectById(sampleId); List insProducts = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, insSample.getId()) .eq(InsProduct::getSonLaboratory, laboratory) .eq(InsProduct::getState, 1)); List results = insProducts.stream().map(InsProduct::getInsResult).filter(str -> str != null).collect(Collectors.toList()); if (results.contains(0)) { insSample.setInsResult(0); } else { insSample.setInsResult(1); } insSampleMapper.updateById(insSample); /*复核后，将不合格的项目信息添加到ins_un_pass表中*/ InsOrder insOrder = insOrderMapper.selectById(insSample.getInsOrderId()); for (InsProduct insProduct : insProducts) { if (insProduct.getInsResult() == 0) { InsUnPass insUnPass = new InsUnPass(); insUnPass.setId(null); insUnPass.setModel(insSample.getModel()); insUnPass.setSample(insSample.getSample()); insUnPass.setInspectionItem(insProduct.getInspectionItem()); insUnPass.setInspectionItemSubclass(insProduct.getInspectionItemSubclass()); insUnPass.setLastValue(insProduct.getLastValue()); insUnPass.setEntrustCode(insOrder.getEntrustCode()); List userIds = insProductUserMapper.selectList(Wrappers.lambdaQuery().eq(InsProductUser::getInsProductId, insProduct.getId())).stream().map(InsProductUser::getCreateUser).distinct().collect(Collectors.toList()); String name = userMapper.selectBatchIds(userIds).stream().map(User::getName).collect(Collectors.joining(",")); insUnPass.setName(name); insUnPasses.add(insUnPass); } } insUnPassService.saveBatch(insUnPasses); /*type=0 再次试验; type=1 继续试验 ; type=2 结束试验*/ // 查询根据 id 倒序排列的第一条记录 InsOrderState record = insOrderStateMapper.selectOne(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, sampleId) .eq(InsOrderState::getLaboratory, laboratory) .orderByDesc(InsOrderState::getId) .last("LIMIT 1")); // 确保只取一条记录 if (record != null) { //更新记录 insOrderUserMapper.update(null, Wrappers.lambdaUpdate() .eq(InsOrderUser::getInsOrderStateId, record.getId()) .eq(InsOrderUser::getNum, record.getNum()) .set(InsOrderUser::getTell, tell)); switch (type) { case 0: //再次试验:该单子退回到检验状态(排序改成当前的最后),次数递增(保留以前的数据)； insOrderStateMapper.update(null, Wrappers.lambdaUpdate() .eq(InsOrderState::getId, record.getId()) .set(InsOrderState::getInsTime, 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: //继续试验:该样品该站点任务结束(可以再次扫码检验)； insOrderStateMapper.update(null, Wrappers.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: //结束试验:此委托单停止试验(无法再次检验)。 insOrderStateMapper.update(null, Wrappers.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)); //如果订单类型是原理样机,则该订单直接闭环 if (insOrder.getFormType().equals("原理样机")) { //出库 try { List insSamples = insSampleMapper.selectList(Wrappers.lambdaQuery().eq(InsSample::getInsOrderId, insSample.getInsOrderId())); for (InsSample sample : insSamples) { outInsOrderState(laboratory, sample.getSampleCode(), insOrder.getEntrustCode()); } } catch (Exception e) { } } insOrder.setState(4); insOrderMapper.updateById(insOrder); break; } } return 1; } private void getTemplateThing(Set set, Map map2, List insProducts) { for (InsProduct product : insProducts) { if (product.getTemplateId() == null) { product.setTemplate(new ArrayList<>()); continue; } String thing = null; if (product.getTemplateId() != null && set.add(product.getTemplateId())) { map2.put(product.getTemplateId(), standardTemplateService.getStandTempThingById(product.getTemplateId()) + ""); 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(SubmitPlanDto submitPlanDto) { InsSample insSample = insSampleMapper.selectById(submitPlanDto.getSampleId()); InsOrderState orderState = insOrderStateMapper.selectOne(Wrappers.lambdaQuery() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, submitPlanDto.getSampleId()) .eq(InsOrderState::getLaboratory, submitPlanDto.getLaboratory()) .orderByDesc(InsOrderState::getId) .last("LIMIT 1"));// 确保只取一条记录 /*记录检验任务每次的备注信息*/ 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); insOrderUser.setTerm(ObjectUtils.isNotEmpty(submitPlanDto.getTerm()) ? submitPlanDto.getTerm() : null); insOrderUserMapper.insert(insOrderUser); List insProducts = insProductMapper.selectList(Wrappers.lambdaQuery() .eq(InsProduct::getInsSampleId, insSample.getId()) .eq(InsProduct::getSonLaboratory, submitPlanDto.getLaboratory()) .and(wrapper -> wrapper .isNull(InsProduct::getInsResult) .or() .eq(InsProduct::getInsResult, 2) ) .eq(InsProduct::getState, 1)); if (insProducts.size() > 0) { String str = ""; int count = 0; for (InsProduct product : insProducts) { //辐射试验,温湿度试验,功率试验的检验项目,不需要去手动填写检验值,只需要上传表格文件就可以了,后台提交的时候校验跳过这个检验项目 if (product.getInspectionItem().equals("辐射试验") || product.getInspectionItem().equals("温湿度试验") || product.getInspectionItem().equals("功率试验")) { product.setInsResult(3);//不判定 insProductMapper.updateById(product); continue; } //电路试验的检验项目,需要在提交的时候再去赋值合格与不合格 if (product.getInspectionItem().equals("电路试验")) { List collect = insProductResult2Mapper.selectList(Wrappers.lambdaQuery() .eq(InsProductResult2::getNum, orderState.getNum()) .eq(InsProductResult2::getInsProductId, product.getId())).stream().map(InsProductResult2::getResult).distinct().collect(Collectors.toList()); if (collect.contains(0)) { product.setInsResult(0);//不合格 } else { product.setInsResult(1);//合格 } insProductMapper.updateById(product); continue; } count++; str += "
" + count + "：" + product.getInspectionItem() + " " + product.getInspectionItemSubclass() + "
"; } if (ObjectUtils.isNotEmpty(str)) { throw new ErrorException("存在待检验的项目：
" + str); } } insOrderStateMapper.update(null, Wrappers.lambdaUpdate() .eq(InsOrderState::getInsOrderId, insSample.getInsOrderId()) .eq(InsOrderState::getInsSampleId, submitPlanDto.getSampleId()) .eq(InsOrderState::getLaboratory, submitPlanDto.getLaboratory()) .set(InsOrderState::getInsState, 3) .set(InsOrderState::getVerifyUser, submitPlanDto.getVerifyUser())); InsOrder insOrder = insOrderMapper.selectById(insSample.getInsOrderId()); 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(submitPlanDto.getVerifyUser()); info.setViewStatus(false); info.setJumpPath("b1-inspect-order-plan"); informationNotificationService.addInformationNotification(info); //复核人--检验单相关负责人 InsSampleUser insSampleUser = new InsSampleUser(); insSampleUser.setUserId(submitPlanDto.getVerifyUser()); insSampleUser.setInsSampleId(submitPlanDto.getSampleId()); insSampleUser.setState(1); insSampleUser.setSonLaboratory(submitPlanDto.getLaboratory()); insSampleUserMapper.insert(insSampleUser); /*生成电路试验的站点报告并上传到附件中*/ if (submitPlanDto.getLaboratory().equals("电路试验")) { // wordUtils.generateWord(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("电路试验的站点报告生成有误,请联系开发人员调整!"); } } /*生成产量工时*/ //校验如果这个人这个检测项目已经添加过了则不需要再新增 //首先判断当前人的当前时间是否是排班时间内,如果不是就是加班 LocalDateTime today = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT); PerformanceShift performanceShift = performanceShiftMapper.selectOne(Wrappers.lambdaQuery() .eq(PerformanceShift::getUserId, userId) .eq(PerformanceShift::getWorkTime, today)); if (ObjectUtils.isNotEmpty(performanceShift)) { ShiftTime shiftTime = shiftTimeMapper.selectOne(Wrappers.lambdaQuery().eq(ShiftTime::getShift, performanceShift.getShift())); if (ObjectUtils.isNotEmpty(shiftTime)) { DateTimeFormatter forma = DateTimeFormatter.ofPattern("HH:mm"); LocalTime now = LocalTime.now(); LocalTime startTime = LocalTime.parse(shiftTime.getStartTime(), forma); LocalTime endTime = LocalTime.parse(shiftTime.getEndTime(), forma); // 检查当前时间是否在范围内（包括边界） boolean isWithinRange; if (endTime.isAfter(startTime)) { // 不跨天的情况 isWithinRange = !now.isBefore(startTime) && !now.isAfter(endTime); } else { // 跨天的情况 isWithinRange = !now.isBefore(startTime) || !now.isAfter(endTime); } for (AuxiliaryOutputWorkingHours auxiliaryOutputWorkingHours : submitPlanDto.getAuxiliaryOutputWorkingHoursList()) { InsProduct insProduct = insProductMapper.selectById(auxiliaryOutputWorkingHours.getInsProductId()); if (isWithinRange) { //在时间内就是正常上班 auxiliaryOutputWorkingHours.setOrderNo(insOrder.getEntrustCode());//非加班委托单号 auxiliaryOutputWorkingHours.setWorkTime(auxiliaryOutputWorkingHours.getOutputWorkTime());//非加班工时 auxiliaryOutputWorkingHours.setAmount(1);//非加班数量 } else { //加班 auxiliaryOutputWorkingHours.setOvertimeOrderNo(insOrder.getEntrustCode());//加班委托单号 auxiliaryOutputWorkingHours.setOvertimeWorkTime(auxiliaryOutputWorkingHours.getOutputWorkTime());//加班工时 auxiliaryOutputWorkingHours.setOvertimeAmount(1);//加班数量 } auxiliaryOutputWorkingHours.setManHourGroup(insProduct.getManHourGroup());//工时分组 DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); DateTimeFormatter formatters = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); auxiliaryOutputWorkingHours.setDateTime(LocalDateTime.now().toLocalDate().atStartOfDay().format(formatters));//日期 LocalDateTime localDateTime = LocalDateTime.now(); DateTime parse = DateUtil.parse(localDateTime.format(formatter)); auxiliaryOutputWorkingHours.setWeekDay(getWeek(localDateTime.format(formatters)));//星期 auxiliaryOutputWorkingHours.setWeek(String.valueOf(DateUtil.weekOfYear(DateUtil.offsetDay(parse, 1))));//周次 auxiliaryOutputWorkingHoursMapper.insert(auxiliaryOutputWorkingHours); } } } // todo 企业微信消息推送@zss HashMap 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 hashMap = new HashMap<>(); hashMap.put("content", "您有一条检验任务待复核消息,订单号是：" + insOrder.getEntrustCode() + ",样品名称为：" + insSample.getSample() + ",请前往LIMS系统查看。请点击中天通信LIMS系统 "); 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.lambdaQuery() .eq(InsOrderUser::getInsOrderStateId,orderState.getId()) .eq(InsOrderUser::getNum,orderState.getNum())); //撤销提交 insOrderStateMapper.update(null, Wrappers.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.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 insOrderFiles = insOrderFileMapper.selectList(Wrappers.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 insProducts = insProductMapper.selectList(Wrappers.lambdaQuery().eq(InsProduct::getInsSampleId, insSample.getId())); List productIds = insProducts.stream().map(InsProduct::getId).distinct().collect(Collectors.toList()); auxiliaryOutputWorkingHoursMapper.delete(Wrappers.lambdaQuery() .eq(AuxiliaryOutputWorkingHours::getSample,insSample.getSampleCode()) .in(AuxiliaryOutputWorkingHours::getInsProductId,productIds) .eq(AuxiliaryOutputWorkingHours::getNum,orderState.getNum())); // todo 企业微信消息推送@zss HashMap 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 hashMap = new HashMap<>(); hashMap.put("content", "您有一条复核的消息已撤销,订单号是：" + insOrder.getEntrustCode() + ",样品名称为：" + insSample.getSample() + ",请前往LIMS系统查看。请点击中天通信LIMS系统 "); 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 { Date date = sdf.parse(dayStr); Calendar calendar = Calendar.getInstance(); calendar.setTime(date); int dayOfWeek = calendar.get(Calendar.DAY_OF_WEEK); int day = calendar.get(Calendar.DAY_OF_MONTH); return getWeekDay(dayOfWeek); } catch (Exception e) { e.printStackTrace(); } return null; } public static String getWeekDay(int dayOfWeek) { switch (dayOfWeek) { case Calendar.MONDAY: return "周一"; case Calendar.TUESDAY: return "周二"; case Calendar.WEDNESDAY: return "周三"; case Calendar.THURSDAY: return "周四"; case Calendar.FRIDAY: return "周五"; case Calendar.SATURDAY: return "周六"; case Calendar.SUNDAY: return "周日"; default: return "未知"; } } }