From 97bb7a8832281eafe0ef947ea095258d355e52f5 Mon Sep 17 00:00:00 2001 From: zss <zss@example.com> Date: 星期一, 30 十二月 2024 15:57:51 +0800 Subject: [PATCH] 无源器件的数采+电路模版查询 --- inspect-server/src/main/java/com/yuanchu/mom/service/impl/StandardProductListServiceImpl.java | 163 +++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 135 insertions(+), 28 deletions(-) diff --git a/inspect-server/src/main/java/com/yuanchu/mom/service/impl/StandardProductListServiceImpl.java b/inspect-server/src/main/java/com/yuanchu/mom/service/impl/StandardProductListServiceImpl.java index c38f1a6..8b37802 100644 --- a/inspect-server/src/main/java/com/yuanchu/mom/service/impl/StandardProductListServiceImpl.java +++ b/inspect-server/src/main/java/com/yuanchu/mom/service/impl/StandardProductListServiceImpl.java @@ -1,6 +1,6 @@ package com.yuanchu.mom.service.impl; -import cn.hutool.core.lang.Console; +import com.alibaba.excel.annotation.ExcelProperty; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.metadata.IPage; @@ -11,15 +11,19 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; 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; import com.yuanchu.mom.service.StandardProductListService2; import lombok.AllArgsConstructor; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.util.*; @@ -59,21 +63,30 @@ @Override public List<StandardProductList> selectStandardProductList(InsSample insSample) { String[] models = insSample.getModel().split("-(?=[^-]*$)");//鎷嗗垎鏈�鍚庝竴涓��-銆� -// String[] factorys = insSample.getFactory().split(" - "); - //List<StandardProductList> list = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery().eq(StandardProductList::getStandardMethodListId, insSample.getStandardMethodListId()).eq(StandardProductList::getState, 1).eq(StandardProductList::getModel, models[0]).eq(StandardProductList::getSampleType, factorys[2])); - 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]; - list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree); - /* list = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery() - .eq(StandardProductList::getStandardMethodListId, insSample.getStandardMethodListId()) - .eq(StandardProductList::getState, 1) - .like(StandardProductList::getTree, split[0] + " - " + split[1] + " - " + split[2] + " - " + split[3]));*/ - + String tree = split[0] + " - " + split[1] + " - " + split[2] + " - " + split[3] + " - null"; + list = standardProductListMapper.selectDetail2(ids, 1, tree); + if (list.size() == 0) { + String tree1 = split[0] + " - " + split[1] + " - " + split[2] + " - null - " + split[3]; + 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 -> 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 -> { try { @@ -90,9 +103,9 @@ } 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)); @@ -110,15 +123,64 @@ 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(); + } else { + model2 = model; } if (str.contains("鈮�") || str.contains(">=")) { String param = str.replace("鈮�", "").replace(">=", ""); @@ -134,14 +196,24 @@ 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; } @Override + @Transactional(rollbackFor = Exception.class) public Map<String, Object> selectStandardProductListByMethodId(Integer id, String tree, Integer page) { String[] trees = tree.split(" - "); + try { + String tree1 = trees[2]; + } catch (Exception e) { + throw new ErrorException("鎿嶄綔澶揩,绯荤粺浼犲弬閿欒!!!!"); + } List<StandardProductList> list = new ArrayList<>(); if (trees.length == 3) { List<StandardTree> treeList = new ArrayList<>(); @@ -238,13 +310,48 @@ } if (page == 1) { Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); - CompletableFuture.supplyAsync(() -> { - if (trees.length == 5) { - standardProductListMapper.delete(Wrappers.<StandardProductList>lambdaUpdate().eq(StandardProductList::getStandardMethodListId, id).eq(StandardProductList::getTree, tree)); - } else { - standardProductListMapper.delete(Wrappers.<StandardProductList>lambdaUpdate().eq(StandardProductList::getStandardMethodListId, id).like(StandardProductList::getTree, tree)); +// CompletableFuture.supplyAsync(() -> { + System.out.println("寮�濮嬪紑濮嬪紑濮嬪紑濮�!!!!!!!!!!"); + if (trees.length == 5) { + standardProductListMapper.delete(Wrappers.<StandardProductList>lambdaUpdate() + .eq(StandardProductList::getStandardMethodListId, id) + .eq(StandardProductList::getTree, tree)); + } else { + standardProductListMapper.delete(Wrappers.<StandardProductList>lambdaUpdate() + .eq(StandardProductList::getStandardMethodListId, id) + .like(StandardProductList::getTree, tree)); + } + + boolean success = false; + int retryCount = 0; + while (!success && retryCount < 100) { + try { + standardProductListService2.saveOrUpdateBatch(list.stream().map(a -> { + a.setFactory(trees[0]); + a.setLaboratory(trees[1]); + a.setSampleType(trees[2]); + a.setCreateUser(userId); + a.setUpdateUser(userId); + a.setStandardMethodListId(id); + return a; + }).collect(Collectors.toList())); + success = true; + } catch (Exception e) { + retryCount++; + System.out.println("閲嶅" + retryCount + "娆�"); + // 澶勭悊閲嶅 ID 鐨勮褰曪紝閲嶆柊鐢熸垚 ID 骞剁户缁皾璇曟彃鍏� + for (StandardProductList productList : list) { + productList.setId(IdWorker.getId()); + } } - standardProductListService2.saveBatch(list.stream().map(a -> { + } + if (!success) { + throw new RuntimeException("鎻掑叆澶辫触"); + } else { + System.out.println("缁撴潫缁撴潫缁撴潫缁撴潫@@@@@@@@@@@@"); + } + + /* standardProductListService2.saveBatch(list.stream().map(a -> { a.setFactory(trees[0]); a.setLaboratory(trees[1]); a.setSampleType(trees[2]); @@ -252,13 +359,13 @@ a.setUpdateUser(userId); a.setStandardMethodListId(id); return a; - }).collect(Collectors.toList())); - return null; - }).thenAccept(res -> { - }).exceptionally(e -> { - e.printStackTrace(); - return null; - }); + }).collect(Collectors.toList()));*/ +// return null; +// }).thenAccept(res -> { +// }).exceptionally(e -> { +// e.printStackTrace(); +// return null; +// }); } Map<String, Object> map = new HashMap<>(); Collections.sort(list, (o1, o2) -> { -- Gitblit v1.9.3