| | |
| | | import com.yuanchu.mom.common.GetLook; |
| | | import com.yuanchu.mom.dto.ProductDto; |
| | | import com.yuanchu.mom.exception.ErrorException; |
| | | import com.yuanchu.mom.mapper.StandardMethodListMapper; |
| | | import com.yuanchu.mom.mapper.StandardProductListMapper; |
| | | import com.yuanchu.mom.mapper.StandardTreeMapper; |
| | | import com.yuanchu.mom.pojo.InsSample; |
| | | import com.yuanchu.mom.pojo.StandardMethodList; |
| | | import com.yuanchu.mom.pojo.StandardProductList; |
| | | import com.yuanchu.mom.pojo.StandardTree; |
| | | import com.yuanchu.mom.service.StandardProductListService; |
| | |
| | | @Override |
| | | public List<StandardProductList> selectStandardProductList(InsSample insSample) { |
| | | String[] models = insSample.getModel().split("-(?=[^-]*$)");//拆分最后一个【-】 |
| | | List<StandardProductList> list = standardProductListMapper.selectDetail(insSample.getStandardMethodListId(), 1, models[0]); |
| | | String[] models1 = insSample.getModel().split(";(?=[^;]*$)");//拆分最后一个【-】 |
| | | List<Integer> ids = Arrays.stream(insSample.getStandardMethodListId().split(",")) |
| | | .map(String::trim).map(Integer::parseInt).collect(Collectors.toList()); |
| | | List<StandardProductList> list = standardProductListMapper.selectDetail(ids, 1, models[0]); |
| | | if (list.size() == 0) { |
| | | if (Objects.equals(insSample.getFactory(), "") || insSample.getFactory() == null) { |
| | | return null; |
| | | } |
| | | String[] split = insSample.getFactory().split(" - "); |
| | | String tree = split[0] + " - " + split[1] + " - " + split[2] + " - " + split[3] + " - null"; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree); |
| | | list = standardProductListMapper.selectDetail2(ids, 1, tree); |
| | | if (list.size() == 0) { |
| | | String tree1 = split[0] + " - " + split[1] + " - " + split[2] + " - null - " + split[3]; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree1); |
| | | list = standardProductListMapper.selectDetail2(ids, 1, tree1); |
| | | } |
| | | } |
| | | String[] split1 = insSample.getFactory().split(" - "); |
| | | //判断长度 |
| | | if (split1.length > 4) { |
| | | if (ObjectUtils.isNotEmpty(split1[3])) { |
| | | list = list.stream().filter(list1 -> list1.getSample().equals(split1[3])).collect(Collectors.toList()); |
| | | }else if (split1[3].equals("")) { |
| | | list = list.stream().filter(list1 -> list1.getSampleType().equals(split1[2])).collect(Collectors.toList()); |
| | | |
| | | list = list.stream().filter(list1 -> Objects.nonNull(list1.getSample()) && Objects.equals(list1.getSample(), split1[3])).collect(Collectors.toList()); |
| | | } else if (split1[3].equals("")) { |
| | | list = list.stream().filter(list1 -> Objects.nonNull(list1.getSampleType()) && Objects.equals(list1.getSampleType(), split1[2])).collect(Collectors.toList()); |
| | | } |
| | | } |
| | | list = list.stream().filter(a -> { |
| | |
| | | } else { |
| | | if (sections.get(i).contains("&")) { |
| | | String[] split = sections.get(i).split("&"); |
| | | isIf = getIsIf(split[0], models[1]) && getIsIf(split[1], models[1]); |
| | | isIf = getIsIf(split[0], models1[1]); |
| | | } else { |
| | | isIf = getIsIf(sections.get(i), models[1]); |
| | | isIf = getIsIf(sections.get(i), models1[1]); |
| | | } |
| | | if (isIf) { |
| | | a.setSection(sections.get(i)); |
| | |
| | | return false; |
| | | } |
| | | return true; |
| | | }).map(standardProductList -> { |
| | | String code = baseMapper.selectStandardMethodById(standardProductList.getStandardMethodListId()); |
| | | standardProductList.setMethodS(code); |
| | | return standardProductList; |
| | | }).collect(Collectors.toList()); |
| | | //按照电路试验--辐射试验--温湿度试验--环境试验进行排序 |
| | | // 定义自定义排序器 |
| | | Comparator<StandardProductList> testTypeComparator = (o1, o2) -> { |
| | | String[] order = {"电路试验", "辐射试验", "温湿度试验", "环境试验", "功率试验"}; |
| | | int index1 = -1; |
| | | int index2 = -1; |
| | | // 找出两个对象 在自定义顺序数组中的位置 |
| | | for (int i = 0; i < order.length; i++) { |
| | | if (o1.getInspectionItem().equals(order[i])) { |
| | | index1 = i; |
| | | } |
| | | if (o2.getInspectionItem().equals(order[i])) { |
| | | index2 = i; |
| | | } |
| | | if (index1 != -1 && index2 != -1) { |
| | | break; // 两个位置都找到了,可以退出循环 |
| | | } |
| | | } |
| | | // 比较位置 |
| | | int compareResult = Integer.compare(index1, index2); |
| | | // 如果是环境试验,且两个对象在主检验项目上排序相同,则用次级检验项目排序 |
| | | if (compareResult == 0 && order[index1].equals("环境试验")) { |
| | | String[] subOrder = {"冲水试验", "振动试验"}; |
| | | int subIndex1 = -1; |
| | | int subIndex2 = -1; |
| | | for (int i = 0; i < subOrder.length; i++) { |
| | | if (o1.getInspectionItemSubclass().contains(subOrder[i])) { |
| | | subIndex1 = i; |
| | | } |
| | | if (o2.getInspectionItemSubclass().contains(subOrder[i])) { |
| | | subIndex2 = i; |
| | | } |
| | | if (subIndex1 != -1 && subIndex2 != -1) { |
| | | break; // 两个次级位置都找到了,可以退出循环 |
| | | } |
| | | } |
| | | compareResult = Integer.compare(subIndex1, subIndex2); |
| | | } |
| | | // 比较位置 |
| | | return compareResult; |
| | | }; |
| | | // 对列表进行排序 |
| | | Collections.sort(list, testTypeComparator); |
| | | return list; |
| | | } |
| | | |
| | | private boolean getIsIf(String str, String model) { |
| | | Matcher matcher = Pattern.compile("\\d+(\\.\\d+)?").matcher(model); |
| | | String model2 = ""; |
| | | while (matcher.find()) { |
| | | if (matcher.find()) { |
| | | model2 += matcher.group(); |
| | | break; |
| | | } else { |
| | | model2 = model; |
| | | } |
| | | if (str.contains("≥") || str.contains(">=")) { |
| | | String param = str.replace("≥", "").replace(">=", ""); |
| | |
| | | return new BigDecimal(model2).compareTo(new BigDecimal(param)) < 0; |
| | | } else if (str.contains("=")) { |
| | | String param = str.replace("=", ""); |
| | | return new BigDecimal(model2).compareTo(new BigDecimal(param)) == 0; |
| | | if (matcher.find()) { |
| | | return new BigDecimal(model2).compareTo(new BigDecimal(param)) == 0; |
| | | } else { |
| | | return model2.equals(param); |
| | | } |
| | | } |
| | | return false; |
| | | } |
| | |
| | | list.addAll(standardTreeMapper.selectStandardProductListByTree("\"" + trees[2] + "\"", standardTree2.getSample(), standardTree2.getModel(), tree2, trees[1])); |
| | | list.addAll(standardTreeMapper.selectStandardProductListByTree2("\"" + trees[2] + "\",\"" + standardTree2.getSample() + "\"", standardTree2.getSample(), standardTree2.getModel(), tree2, trees[1])); |
| | | } |
| | | } |
| | | else if (trees.length == 4) { |
| | | } else if (trees.length == 4) { |
| | | List<StandardTree> treeList = standardTreeMapper.selectList(Wrappers.<StandardTree>lambdaQuery().eq(StandardTree::getLaboratory, trees[1]).eq(StandardTree::getSampleType, trees[2]).eq(StandardTree::getSample, trees[3])); |
| | | if (treeList.size() == 0) { |
| | | StandardTree standardTree = new StandardTree(); |
| | |
| | | list.addAll(standardTreeMapper.selectStandardProductListByTree("\"" + trees[2] + "\"", standardTree.getSample(), standardTree.getModel(), str, trees[1])); |
| | | list.addAll(standardTreeMapper.selectStandardProductListByTree2("\"" + trees[2] + "\",\"" + trees[3] + "\"", standardTree.getSample(), standardTree.getModel(), str, trees[1])); |
| | | } |
| | | } |
| | | else { |
| | | } else { |
| | | list.addAll(standardTreeMapper.selectStandardProductListByTree("\"" + trees[2] + "\"", trees[3].equals("null") ? null : trees[3], trees[4], tree, trees[1])); |
| | | list.addAll(standardTreeMapper.selectStandardProductListByTree2("\"" + trees[2] + "\",\"" + trees[3] + "\"", trees[3].equals("null") ? null : trees[3], trees[4], tree, trees[1])); |
| | | } |
| | |
| | | int retryCount = 0; |
| | | while (!success && retryCount < 100) { |
| | | try { |
| | | standardProductListService2.saveBatch(list.stream().map(a -> { |
| | | standardProductListService2.saveOrUpdateBatch(list.stream().map(a -> { |
| | | a.setFactory(trees[0]); |
| | | a.setLaboratory(trees[1]); |
| | | a.setSampleType(trees[2]); |
| | |
| | | a.setStandardMethodListId(id); |
| | | return a; |
| | | }).collect(Collectors.toList())); |
| | | ; |
| | | success = true; |
| | | } catch (Exception e) { |
| | | retryCount++; |