| | |
| | | package com.ruoyi.basic.service.impl; |
| | | |
| | | import cn.hutool.core.util.NumberUtil; |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.core.toolkit.*; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ruoyi.basic.dto.ProductDto; |
| | | import com.ruoyi.basic.mapper.StandardProductListMapper; |
| | | import com.ruoyi.basic.mapper.StandardTreeMapper; |
| | | import com.ruoyi.basic.pojo.InsSample1; |
| | | import com.ruoyi.basic.pojo.StandardProductList; |
| | | import com.ruoyi.basic.pojo.StandardTree; |
| | | import com.ruoyi.common.exception.base.BaseException; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | | import com.ruoyi.basic.dto.CopyStandardProductListDto; |
| | | import com.ruoyi.basic.dto.InsSampleReceiveDto; |
| | | import com.ruoyi.basic.dto.ProductDto; |
| | | import com.ruoyi.basic.dto.ResetTreeDragDTO; |
| | | import com.ruoyi.basic.mapper.StandardProductListMapper; |
| | | import com.ruoyi.basic.mapper.StandardProductListSupplierAskMapper; |
| | | import com.ruoyi.basic.mapper.StandardTreeMapper; |
| | | import com.ruoyi.basic.pojo.StandardProductList; |
| | | import com.ruoyi.basic.pojo.StandardProductListSupplierAsk; |
| | | import com.ruoyi.basic.pojo.StandardTree; |
| | | import com.ruoyi.basic.service.StandardProductListService; |
| | | import com.ruoyi.basic.service.StandardProductListService2; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import lombok.AllArgsConstructor; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | |
| | | private StandardTreeMapper standardTreeMapper; |
| | | |
| | | private StandardProductListService2 standardProductListService2; |
| | | |
| | | private StandardProductListSupplierAskMapper standardProductListSupplierAskMapper; |
| | | |
| | | |
| | | @Override |
| | | public int upStandardProductList(StandardProductList list) { |
| | |
| | | } |
| | | |
| | | @Override |
| | | public List<StandardProductList> selectStandardProductList(InsSampleReceiveDto insSample) { |
| | | // 是否没有产品 |
| | | boolean isNoSample = false; |
| | | // String[] models = insSample.getModel().split("-(?=[^-]*$)");//拆分最后一个【-】 |
| | | String model = insSample.getModel(); |
| | | String modelNum = insSample.getModelNum(); |
| | | List<StandardProductList> list = standardProductListMapper.selectDetail(insSample.getStandardMethodListId(), 1, model, insSample.getIsCableTag()); |
| | | if (list.size() == 0) { |
| | | public List<StandardProductList> selectStandardProductList(InsSample1 insSample) { |
| | | String[] models = insSample.getModel().split("-(?=[^-]*$)");//拆分最后一个【-】 |
| | | String[] splits = StringUtils.isNotEmpty(insSample.getFactory())?insSample.getFactory().split(" - "):new String[0]; |
| | | List<StandardProductList> list = new ArrayList<>(); |
| | | if(splits.length<4){ |
| | | list = standardProductListMapper.selectDetail(insSample.getStandardMethodListId(), 1, models[0],"",""); |
| | | }else { |
| | | list = standardProductListMapper.selectDetail(insSample.getStandardMethodListId(), 1, models[0],splits[2],splits[3]); |
| | | } |
| | | if (list.isEmpty()) { |
| | | if (Objects.equals(insSample.getFactory(), "") || insSample.getFactory() == null) { |
| | | return null; |
| | | } |
| | | String[] split = insSample.getFactory().split(" - "); |
| | | split[3] = split[3].replace("- ", ""); |
| | | String tree = split[0] + " - " + split[1] + " - " + split[2] + " - " + split[3] + " - null"; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree, insSample.getIsCableTag()); |
| | | if (list.size() == 0) { |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree); |
| | | if (list.isEmpty()) { |
| | | String tree1 = split[0] + " - " + split[1] + " - " + split[2] + " - null - " + split[3]; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree1, insSample.getIsCableTag()); |
| | | |
| | | // 只有对象的一层 |
| | | if (list.size() == 0) { |
| | | String tree2 = split[0] + " - " + split[1] + " - " + split[2] + " - null - null"; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree2, insSample.getIsCableTag()); |
| | | // 样品直接赋值样品分类 |
| | | list.forEach(standardProductList -> standardProductList.setSample(standardProductList.getSampleType())); |
| | | isNoSample = true; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree1); |
| | | if(list.isEmpty()) { |
| | | String tree2 = split[0] + " - " + split[1] + " - " + split[2] + " - " + split[3] + " - "; |
| | | list = standardProductListMapper.selectDetail2(insSample.getStandardMethodListId(), 1, tree2); |
| | | } |
| | | } |
| | | } |
| | | String[] split1 = insSample.getFactory().split(" - "); |
| | | if (!isNoSample) { |
| | | //判断长度 |
| | | 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()); |
| | | } |
| | | //判断长度 |
| | | if (splits.length > 4) { |
| | | if (ObjectUtils.isNotEmpty(splits[3])) { |
| | | list = list.stream().filter(list1 -> Objects.nonNull(list1.getSample())&&Objects.equals(list1.getSample(),splits[3])).collect(Collectors.toList()); |
| | | }else if (splits[3].isEmpty()) { |
| | | list = list.stream().filter(list1 -> Objects.nonNull(list1.getSampleType())&&Objects.equals(list1.getSampleType(),splits[2])).collect(Collectors.toList()); |
| | | } |
| | | } |
| | | list = list.stream().filter(a -> { |
| | | try { |
| | | if (a.getSection() != null && !Objects.equals(a.getSection(), "")) { |
| | | List<String> sections = JSON.parseArray(a.getSection(), String.class);// 区间 |
| | | List<String> cores = JSON.parseArray(a.getCores(), String.class); // 芯数 |
| | | List<String> conductorMaterials = JSON.parseArray(a.getConductorMaterial(), String.class); // 导体材质 |
| | | List<String> conductorTypes = JSON.parseArray(a.getConductorType(), String.class); // 导体类型 |
| | | List<String> asks = JSON.parseArray(a.getAsk(), String.class); |
| | | List<String> tells = JSON.parseArray(a.getTell(), String.class); |
| | | boolean isIf; |
| | | for (int i = 0; i < sections.size(); i++) { |
| | | if (Objects.equals(a.getBsm(), "1")) { |
| | | return true; |
| | | } else { |
| | | if (sections.get(i).contains("&")) { |
| | | String[] split = sections.get(i).split("&"); |
| | | isIf = getIsIf(split[0], modelNum, cores.get(i), conductorMaterials.get(i), conductorTypes.get(i), insSample) |
| | | && getIsIf(split[1], modelNum, cores.get(i), conductorMaterials.get(i), conductorTypes.get(i), insSample); |
| | | } else { |
| | | isIf = getIsIf(sections.get(i), modelNum, cores.get(i), conductorMaterials.get(i), conductorTypes.get(i), insSample); |
| | | } |
| | | if (isIf) { |
| | | a.setSection(sections.get(i)); |
| | | a.setAsk(asks.get(i)); |
| | | a.setTell(tells.get(i)); |
| | | return true; |
| | | } |
| | | } |
| | | try { |
| | | if (a.getSection() != null && !Objects.equals(a.getSection(), "")) { |
| | | List<String> sections = JSON.parseArray(a.getSection(), String.class); |
| | | List<String> asks = JSON.parseArray(a.getAsk(), String.class); |
| | | List<String> tells = JSON.parseArray(a.getTell(), String.class); |
| | | List<String> manHours = JSON.parseArray(a.getManHour(), String.class); |
| | | List<String> prices = JSON.parseArray(a.getPrice(), String.class); |
| | | boolean isIf; |
| | | for (int i = 0; i < sections.size(); i++) { |
| | | if (Objects.equals(a.getBsm(), "1")) { |
| | | return true; |
| | | } else { |
| | | if (sections.get(i).contains("&")) { |
| | | String[] split = sections.get(i).split("&"); |
| | | isIf = getIsIf(split[0], models[1]) && getIsIf(split[1], models[1]); |
| | | } else { |
| | | isIf = getIsIf(sections.get(i), models[1]); |
| | | } |
| | | return false; |
| | | } |
| | | } catch (Exception ignored) { |
| | | return false; |
| | | } |
| | | return true; |
| | | }).peek(standardProductList -> { |
| | | // todo: 判断是否是原材下单, 需要啊把颜色绑定到试样颜色的要求值上 |
| | | if (StringUtils.isNotBlank(insSample.getPartNo())) { |
| | | // 判断是否有这个字段且是文本类型 |
| | | if (StringUtils.isNotBlank(standardProductList.getInspectionItem()) |
| | | && standardProductList.getInspectionItem().contains("试样颜色")) { |
| | | Map<String, String> partColor = baseMapper.selectPartColor(insSample.getPartNo()); |
| | | if (CollectionUtils.isNotEmpty(partColor)) { |
| | | if (StringUtils.isNotBlank(partColor.get("color"))) { |
| | | // 判断检验值是否为空和不等于 - 和 / |
| | | if (StringUtils.isBlank(standardProductList.getAsk()) || partColor.get("color").contains("本")) { // 没有ask直接复制 |
| | | // 查询对象绑定表和产品绑定表 |
| | | standardProductList.setAsk("=" + partColor.get("color") |
| | | + (StringUtils.isBlank(partColor.get("color_code")) ? "" : "(" + partColor.get("color_code") + ")")); |
| | | standardProductList.setTell(partColor.get("color") |
| | | + (StringUtils.isBlank(partColor.get("color_code")) ? "" : "(" + partColor.get("color_code") + ")")); |
| | | standardProductList.setInspectionValueType("2"); |
| | | } else { // 拼接到要求描述前面 |
| | | standardProductList.setTell(partColor.get("color") |
| | | + (StringUtils.isBlank(partColor.get("color_code")) ? "" : "(" + partColor.get("color_code") + ")") + "@" + standardProductList.getTell()); |
| | | } |
| | | } |
| | | if (isIf) { |
| | | a.setSection(sections.get(i)); |
| | | a.setAsk(asks.get(i)); |
| | | a.setTell(tells.get(i)); |
| | | a.setPrice(prices.get(i)); |
| | | a.setManHour(manHours.get(i)); |
| | | return true; |
| | | } |
| | | } |
| | | } |
| | | }) |
| | | .collect(Collectors.toList()); |
| | | |
| | | |
| | | |
| | | return false; |
| | | } |
| | | } catch (Exception ignored) { |
| | | return false; |
| | | } |
| | | return true; |
| | | }).collect(Collectors.toList()); |
| | | return list; |
| | | } |
| | | |
| | | /** |
| | | * |
| | | * @param str 判定公式 |
| | | * @param model 型号 |
| | | * @param standardCores 芯数 |
| | | * @param conductorMaterial 导体材质 |
| | | * @param conductorType 导体类型 |
| | | * @param insSample |
| | | * @return |
| | | */ |
| | | private boolean getIsIf(String str, String model, String standardCores, String conductorMaterial, String conductorType,InsSampleReceiveDto insSample) { |
| | | private boolean getIsIf(String str, String model) { |
| | | Matcher matcher = Pattern.compile("\\d+(\\.\\d+)?").matcher(model); |
| | | BigDecimal modelNumber = BigDecimal.ZERO; |
| | | String model2 = ""; |
| | | while (matcher.find()) { |
| | | model2 += matcher.group(); |
| | | modelNumber = BigDecimal.valueOf(Double.parseDouble(model2)); |
| | | break; |
| | | } |
| | | boolean flag = false; |
| | | Double param = matchNumber(str); |
| | | if (str.contains("≥") || str.contains(">=")) { |
| | | String param = str.replace("≥", "").replace(">=", ""); |
| | | flag = new BigDecimal(model2).compareTo(new BigDecimal(param)) > -1; |
| | | // String param = str.replace("≥", "").replace(">=", ""); |
| | | return modelNumber.compareTo(new BigDecimal(param)) > -1; |
| | | } else if (str.contains("≤") || str.contains("<=")) { |
| | | String param = str.replace("≤", "").replace("<=", ""); |
| | | flag = new BigDecimal(model2).compareTo(new BigDecimal(param)) < 1; |
| | | // String param = str.replace("≤", "").replace("<=", ""); |
| | | return modelNumber.compareTo(new BigDecimal(param)) < 1; |
| | | } else if (str.contains(">") || str.contains(">")) { |
| | | String param = str.replace(">", "").replace(">", ""); |
| | | flag = new BigDecimal(model2).compareTo(new BigDecimal(param)) > 0; |
| | | // String param = str.replace(">", "").replace(">", ""); |
| | | return modelNumber.compareTo(new BigDecimal(param)) > 0; |
| | | } else if (str.contains("<") || str.contains("<")) { |
| | | String param = str.replace("<", "").replace("<", ""); |
| | | flag = new BigDecimal(model2).compareTo(new BigDecimal(param)) < 0; |
| | | // String param = str.replace("<", "").replace("<", ""); |
| | | return modelNumber.compareTo(new BigDecimal(param)) < 0; |
| | | } else if (str.contains("=")) { |
| | | String param = str.replace("=", ""); |
| | | flag = new BigDecimal(model2).compareTo(new BigDecimal(param)) == 0; |
| | | // String param = str.replace("=", ""); |
| | | return modelNumber.compareTo(new BigDecimal(param)) == 0; |
| | | } |
| | | if (flag) { |
| | | boolean coresMatch = true; |
| | | boolean conductorMaterialMatch = true; |
| | | boolean conductorTypeMatch = true; |
| | | |
| | | // 判断是否有线芯数量 |
| | | if (StringUtils.isNotBlank(standardCores)) { |
| | | if (StringUtils.isBlank(insSample.getCores()) || !standardCores.equals(insSample.getCores())) { |
| | | coresMatch = false; |
| | | } |
| | | return false; |
| | | } |
| | | public Double matchNumber(String str) { |
| | | String regex = "[><≥≤=]?[>=<]?\\s*(-?\\d+(\\.\\d+)?)"; |
| | | // 编译正则表达式 |
| | | Matcher matcher = Pattern.compile(regex).matcher(str); |
| | | List<Double> numbers = new ArrayList<>(); |
| | | while(matcher.find()) { |
| | | if(matcher.group(1) != null) { |
| | | numbers.add(Double.parseDouble(matcher.group(1))); |
| | | } |
| | | |
| | | // 判断是否有导体材质 |
| | | if (StringUtils.isNotBlank(conductorMaterial)) { |
| | | if (StringUtils.isBlank(insSample.getConductorMaterial()) || !conductorMaterial.equals(insSample.getConductorMaterial())) { |
| | | conductorMaterialMatch = false; |
| | | } |
| | | } |
| | | |
| | | // 判断是否有导体类型 |
| | | if (StringUtils.isNotBlank(conductorType)) { |
| | | if (StringUtils.isBlank(insSample.getConductorType()) || !conductorType.equals(insSample.getConductorType())) { |
| | | conductorTypeMatch = false; |
| | | } |
| | | } |
| | | // 最终判断 |
| | | flag = coresMatch && conductorMaterialMatch && conductorTypeMatch; |
| | | } |
| | | |
| | | return flag; |
| | | if(numbers.size() > 0) { |
| | | return numbers.get(0); |
| | | } |
| | | return 0.00; |
| | | } |
| | | |
| | | @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 BaseException("操作太快,系统传参错误!!!!"); |
| | | } |
| | | boolean isDrag = false; |
| | | // try { |
| | | // String tree1 = trees[2]; |
| | | // } catch (Exception e) { |
| | | // throw new ErrorException("操作太快,系统传参错误!!!!"); |
| | | // } |
| | | //list为根据条件查询的能力范围数据 |
| | | List<StandardProductList> list = new ArrayList<>(); |
| | | if (trees.length == 3) { |
| | | List<StandardTree> treeList = new ArrayList<>(); |
| | |
| | | standardTree.setLaboratory(trees[1]); |
| | | standardTree.setSampleType(trees[2]); |
| | | List<ProductDto> pList = standardTreeMapper.selectPList(trees[2]); |
| | | if (pList.size() == 0 || pList.get(0) == null) { |
| | | if (pList.isEmpty() || pList.get(0) == null) { |
| | | List<StandardTree> treeList1 = standardTreeMapper.selectList(Wrappers.<StandardTree>lambdaQuery().eq(StandardTree::getLaboratory, trees[1]).eq(StandardTree::getSampleType, trees[2])); |
| | | if (treeList1.size() == 0) { |
| | | if (treeList1.isEmpty()) { |
| | | treeList.add(standardTree); |
| | | } else { |
| | | treeList.addAll(treeList1); |
| | |
| | | for (ProductDto p : pList) { |
| | | standardTree.setSample(p.getName()); |
| | | List<StandardTree> treeList1 = standardTreeMapper.selectList(Wrappers.<StandardTree>lambdaQuery().eq(StandardTree::getLaboratory, trees[1]).eq(StandardTree::getSampleType, trees[2]).eq(StandardTree::getSample, p.getName())); |
| | | if (treeList1.size() == 0) { |
| | | if (treeList1.isEmpty()) { |
| | | treeList.add(JSON.parseObject(JSON.toJSONString(standardTree), StandardTree.class)); |
| | | } else { |
| | | treeList.addAll(treeList1); |
| | |
| | | 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) { |
| | | // 判断第四层是否有型号 |
| | | Long count = standardProductListMapper.selectCount(Wrappers.<StandardProductList>lambdaQuery() |
| | | .eq(StandardProductList::getStandardMethodListId, id) |
| | | .isNull(StandardProductList::getModel) |
| | | .like(StandardProductList::getTree, tree)); |
| | | if (count == 0) { |
| | | isDrag = true; |
| | | } |
| | | |
| | | isDrag = true; |
| | | } |
| | | 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) { |
| | | if (treeList.isEmpty()) { |
| | | StandardTree standardTree = new StandardTree(); |
| | | standardTree.setFactory(trees[0]); |
| | | standardTree.setLaboratory(trees[1]); |
| | |
| | | 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 { |
| | | isDrag = true; |
| | | } |
| | | 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])); |
| | | } |
| | | for (StandardProductList productList : list) { |
| | | productList.setId(IdWorker.getId()); |
| | | } |
| | | List<StandardProductList> standardProductLists; |
| | | |
| | | if (isDrag) { |
| | | standardProductLists = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery() |
| | | .eq(StandardProductList::getStandardMethodListId, id) |
| | | .like(StandardProductList::getTree, tree) |
| | | .orderByAsc(StandardProductList::getSort)); |
| | | // 判断是否有没有序号的, 没有序号重置 |
| | | boolean b = standardProductLists.stream().anyMatch(standardProductList -> standardProductList.getSort() == null); |
| | | } else { |
| | | standardProductLists = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery() |
| | | .eq(StandardProductList::getStandardMethodListId, id) |
| | | .like(StandardProductList::getTree, tree)); |
| | | } |
| | | |
| | | //标准库对应检验项数据 |
| | | List<StandardProductList> standardProductLists = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery() |
| | | .eq(StandardProductList::getStandardMethodListId, id)//标准方法id |
| | | .eq(StandardProductList::getSampleType,trees[2])//样品大类 |
| | | .eq(trees.length>3,StandardProductList::getSample,trees.length>3?trees[3]:"")//样品 |
| | | .eq(trees.length>4,StandardProductList::getModel,trees.length>4?trees[4]:"")//型号 |
| | | ); |
| | | //处理数据 |
| | | //不能编辑的数据以能力范围为主,可编辑的数据以标准库为主 |
| | | for (StandardProductList sp : standardProductLists) { |
| | | for (StandardProductList pl : list) { |
| | | // 判断条件是否只有一个, 有一个的话默认第一个 |
| | | String radiusList = pl.getRadiusList(); |
| | | if (StringUtils.isNotBlank(radiusList) && !radiusList.equals("null") && !radiusList.equals("\"\"")) { |
| | | JSONArray jsonArray = JSON.parseArray(radiusList); |
| | | List<String> radius = jsonArray.toJavaList(String.class); |
| | | if (CollectionUtils.isNotEmpty(radius) && radius.size() == 1) { |
| | | pl.setRadius(radius.get(0)); |
| | | } |
| | | } |
| | | if (Objects.equals(sp.getInspectionItem(), pl.getInspectionItem()) |
| | | && Objects.equals((sp.getInspectionItemSubclass() == null) ? "" : sp.getInspectionItemSubclass(), pl.getInspectionItemSubclass() == null ? "" : pl.getInspectionItemSubclass()) |
| | | // && Objects.equals(sp.getSample(), pl.getSample()) |
| | | && Objects.equals(sp.getModel(), pl.getModel()) |
| | | && sp.getTree().indexOf(pl.getSample() == null ? "null" : pl.getSample()) > -1 |
| | | && Objects.equals(sp.getStructureItemParameterId(), pl.getStructureItemParameterId())) { |
| | | pl.setId(sp.getId()); |
| | | // 添加排序字段 |
| | | pl.setSort(sp.getSort()); |
| | | if (sp.getState() != null && !sp.getState().equals("")) { |
| | | pl.setState(sp.getState()); |
| | | } else { |
| | | pl.setState(id == 0 ? 1 : 0); |
| | | } |
| | | if (sp.getMethodS() != null && !sp.getMethodS().equals("")) { |
| | | pl.setMethod(sp.getMethodS()); |
| | | } |
| | | if (sp.getRadius() != null && !sp.getRadius().equals("")) { |
| | | pl.setRadius(sp.getRadius()); |
| | | } |
| | | if (sp.getRates() != null && !sp.getRates().equals("")) { |
| | | pl.setRates(sp.getRates()); |
| | | } |
| | | if (sp.getAsk() != null && !sp.getAsk().equals("")) { |
| | | pl.setAsk(sp.getAsk()); |
| | | } |
| | | if (sp.getTell() != null && !sp.getTell().equals("")) { |
| | | pl.setTell(sp.getTell()); |
| | | } |
| | | if (sp.getPrice() != null && !sp.getPrice().equals("")) { |
| | | pl.setPrice(sp.getPrice()); |
| | | } |
| | | if (sp.getManHour() != null && !sp.getManHour().equals("")) { |
| | | pl.setManHour(sp.getManHour()); |
| | | } |
| | | if (sp.getSection() != null && !sp.getSection().equals("")) { |
| | | pl.setSection(sp.getSection()); |
| | | } |
| | | if (sp.getCores() != null && !sp.getCores().equals("")) { |
| | | pl.setCores(sp.getCores()); |
| | | } |
| | | if (sp.getConductorMaterial() != null && !sp.getConductorMaterial().equals("")) { |
| | | pl.setConductorMaterial(sp.getConductorMaterial()); |
| | | } |
| | | if (sp.getConductorType() != null && !sp.getConductorType().equals("")) { |
| | | pl.setConductorType(sp.getConductorType()); |
| | | } |
| | | if (sp.getTemplateId() != null && !sp.getTemplateId().equals("")) { |
| | | pl.setTemplateId(sp.getTemplateId()); |
| | | } |
| | | //因为还有个产品叫耐张线夹 接续金具 ,这两个项目的数据完全一样,特殊处理 |
| | | if (sp.getTree() != null && !sp.getTree().equals("") && !pl.getTree().equals("中天科技检测中心 - 电力产品实验室 - 金具 - 耐张线夹 - null")) { |
| | | pl.setTree(sp.getTree()); |
| | | } |
| | | if(Objects.isNull(sp.getStructureItemParameterId())){ |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (page == 1) { |
| | | Integer userId = SecurityUtils.getUserId().intValue(); |
| | | // 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)); |
| | | } |
| | | |
| | | boolean success = false; |
| | | int retryCount = 0; |
| | | while (!success && retryCount < 100) { |
| | | try { |
| | | standardProductListService2.saveBatch(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) { |
| | | // 处理重复 ID 的记录,重新生成 ID 并继续尝试插入 |
| | | for (StandardProductList productList : list) { |
| | | productList.setId(IdWorker.getId()); |
| | | } |
| | | pl.setFactory(sp.getFactory()); |
| | | pl.setSampleType(sp.getSampleType()); |
| | | pl.setStandardMethodListId(id);//标准方法id |
| | | if(NumberUtil.equals(sp.getStructureItemParameterId(),pl.getStructureItemParameterId()) && (trees.length <= 4 || Objects.equals(sp.getModel(), pl.getModel()))){ |
| | | pl.setId(sp.getId()); |
| | | pl.setAsk(sp.getAsk());//要求值 |
| | | pl.setTell(sp.getTell());//要求描述 |
| | | pl.setManHour(sp.getManHour());//工时系数 |
| | | pl.setManHourGroup(sp.getManHourGroup());//工时分组 |
| | | pl.setPrice(sp.getPrice());//单价 |
| | | pl.setTemplateId(sp.getTemplateId());//模板id |
| | | pl.setSection(sp.getSection());//区间 |
| | | pl.setState(sp.getState());//勾选状态 |
| | | pl.setMethodS(sp.getMethodS());//试验方法 |
| | | pl.setMethodS(sp.getMethodS());//方法 |
| | | pl.setTree(sp.getTree());//树形结构字符 |
| | | } |
| | | } |
| | | if (!success) { |
| | | throw new RuntimeException("插入失败"); |
| | | } |
| | | |
| | | } |
| | | //查询标准库对应的数据为空,证明是新加的标准,以能力范围为主 |
| | | if(standardProductLists.isEmpty()){ |
| | | list.forEach(l->{ |
| | | l.setStandardMethodListId(id); |
| | | l.setFactory(org.apache.commons.lang3.StringUtils.isNotBlank(trees[0])?trees[0]:""); |
| | | l.setSampleType(org.apache.commons.lang3.StringUtils.isNotBlank(trees[2])?trees[2]:""); |
| | | }); |
| | | } |
| | | //添加新加的项目 |
| | | list.stream().filter(l->Objects.isNull(l.getId())).forEach(this::save); |
| | | Map<String, Object> map = new HashMap<>(); |
| | | Collections.sort(list, (o1, o2) -> { |
| | | list.sort((o1, o2) -> { |
| | | String field1 = o1.getManHourGroup(); |
| | | String field2 = o2.getManHourGroup(); |
| | | |
| | |
| | | return Integer.compare(num1, num2); |
| | | } |
| | | }); |
| | | // 按照索引排序 |
| | | if (isDrag) { |
| | | list.sort((o1, o2) -> (o1.getSort() == null ? 0 : o1.getSort()) |
| | | - (o2.getSort() == null ? 0 : o2.getSort())); |
| | | } |
| | | try { |
| | | map.put("productList", list.subList((page - 1) * 300, page * 300)); |
| | | map.put("productList", list.subList((page - 1) * 50, page * 50)); |
| | | } catch (IndexOutOfBoundsException e) { |
| | | map.put("productList", list.subList((page - 1) * 300, list.size())); |
| | | map.put("productList", list.subList((page - 1) * 50, list.size())); |
| | | } |
| | | map.put("total", list.size()); |
| | | return map; |
| | |
| | | .groupBy(StandardProductList::getInspectionItemSubclass))); |
| | | } |
| | | return map; |
| | | } |
| | | |
| | | /** |
| | | * 修改标准库区间 |
| | | * @param list |
| | | * @return |
| | | */ |
| | | @Override |
| | | public boolean updateSection(StandardProductList list) { |
| | | standardProductListMapper.updateSection(list); |
| | | return true; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 标准库拖拽 |
| | | * @param resetTreeDragDTO |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void resetTreeDrag(ResetTreeDragDTO resetTreeDragDTO) { |
| | | Integer beginIndex = Integer.parseInt(resetTreeDragDTO.getBeginIndex()); |
| | | Integer endIndex = Integer.parseInt(resetTreeDragDTO.getEndIndex()); |
| | | Integer methodId = Integer.parseInt(resetTreeDragDTO.getMethodId()); |
| | | Long productionId = Long.parseLong(resetTreeDragDTO.getProductionId()); |
| | | // 判断是从上往下拖拽还是从下往上放拖拽 |
| | | // 从上往下 |
| | | if (beginIndex < endIndex) { |
| | | standardProductListMapper.updateSortUp(beginIndex, |
| | | endIndex, |
| | | methodId, |
| | | resetTreeDragDTO.getTree()); |
| | | |
| | | // 从下往上 |
| | | } else if (beginIndex > endIndex){ |
| | | standardProductListMapper.updateSortDown(beginIndex, |
| | | endIndex, |
| | | methodId, |
| | | resetTreeDragDTO.getTree()); |
| | | } else { |
| | | return; |
| | | } |
| | | // 修改标准库项顺序 |
| | | standardProductListMapper.update(null, Wrappers.<StandardProductList>lambdaUpdate() |
| | | .eq(StandardProductList::getId, productionId) |
| | | .set(StandardProductList::getSort, endIndex)); |
| | | } |
| | | |
| | | @Override |
| | | public void resetTreeDragBatch(List<StandardProductList> standardProductLists) { |
| | | standardProductListService2.updateBatchById(standardProductLists); |
| | | } |
| | | |
| | | /** |
| | | * 检验项要求值对比 |
| | | * @param copyDto |
| | | * @return |
| | | */ |
| | | @Override |
| | | public List<StandardProductList> copyStandardProductList(CopyStandardProductListDto copyDto) { |
| | | List<StandardProductList> productLists = new ArrayList<>(); |
| | | |
| | | // 对比检验项一样的填充要求值要求描述 |
| | | for (StandardProductList oldProductList : copyDto.getOldStandardProductList()) { |
| | | String oldItemName = oldProductList.getInspectionItemClassEn() |
| | | + oldProductList.getInspectionItem() |
| | | + oldProductList.getInspectionItemSubclass(); |
| | | for (StandardProductList newProductList : copyDto.getNewStandardProductList()) { |
| | | String newItemName = newProductList.getInspectionItemClassEn() |
| | | + newProductList.getInspectionItem() |
| | | + newProductList.getInspectionItemSubclass(); |
| | | // 判断名称是否一样 |
| | | if (oldItemName.equals(newItemName)) { |
| | | // 区间 |
| | | oldProductList.setSection(newProductList.getSection()); |
| | | // 芯数 |
| | | oldProductList.setCores(newProductList.getCores()); |
| | | // 要求值 |
| | | oldProductList.setAsk(newProductList.getAsk()); |
| | | // 要求描述 |
| | | oldProductList.setTell(newProductList.getTell()); |
| | | // 单价 |
| | | oldProductList.setPrice(newProductList.getPrice()); |
| | | // 工时分组 |
| | | oldProductList.setManHour(newProductList.getManHour()); |
| | | // 导体材质 |
| | | oldProductList.setConductorMaterial(newProductList.getConductorMaterial()); |
| | | // 导体类型 |
| | | oldProductList.setConductorType(newProductList.getConductorType()); |
| | | productLists.add(oldProductList); |
| | | } |
| | | } |
| | | } |
| | | return productLists; |
| | | } |
| | | |
| | | /** |
| | | * 检验项复制对比一个 |
| | | * @param dto |
| | | * @return |
| | | */ |
| | | @Override |
| | | public List<StandardProductList> copyStandardProductOne(CopyStandardProductListDto dto) { |
| | | if (CollectionUtils.isEmpty(dto.getNewStandardProductList()) && dto.getNewStandardProductList().size() == 1 && |
| | | CollectionUtils.isEmpty(dto.getOldStandardProductList()) && dto.getOldStandardProductList().size() == 1) { |
| | | throw new BaseException("需要对比的检验项请选择一个"); |
| | | } |
| | | StandardProductList newProductList = dto.getNewStandardProductList().get(0); |
| | | StandardProductList oldProductList = dto.getOldStandardProductList().get(0); |
| | | // 区间 |
| | | oldProductList.setSection(newProductList.getSection()); |
| | | // 芯数 |
| | | oldProductList.setCores(newProductList.getCores()); |
| | | // 要求值 |
| | | oldProductList.setAsk(newProductList.getAsk()); |
| | | // 要求描述 |
| | | oldProductList.setTell(newProductList.getTell()); |
| | | // 单价 |
| | | oldProductList.setPrice(newProductList.getPrice()); |
| | | // 工时分组 |
| | | oldProductList.setManHour(newProductList.getManHour()); |
| | | // 导体材质 |
| | | oldProductList.setConductorMaterial(newProductList.getConductorMaterial()); |
| | | // 导体类型 |
| | | oldProductList.setConductorType(newProductList.getConductorType()); |
| | | List<StandardProductList> productLists = new ArrayList<>(); |
| | | productLists.add(oldProductList); |
| | | return productLists; |
| | | } |
| | | |
| | | /** |
| | | * 检验项复制排序 |
| | | * @param copyDto |
| | | * @return |
| | | */ |
| | | @Override |
| | | public boolean copyStandardProductSort(CopyStandardProductListDto copyDto) { |
| | | List<StandardProductList> productLists = new ArrayList<>(); |
| | | |
| | | // 对比检验项一样的填充要求值要求描述 |
| | | for (StandardProductList oldProductList : copyDto.getOldStandardProductList()) { |
| | | String oldItemName = oldProductList.getInspectionItemClassEn() |
| | | + oldProductList.getInspectionItem() |
| | | + oldProductList.getInspectionItemSubclass(); |
| | | for (StandardProductList newProductList : copyDto.getNewStandardProductList()) { |
| | | String newItemName = newProductList.getInspectionItemClassEn() |
| | | + newProductList.getInspectionItem() |
| | | + newProductList.getInspectionItemSubclass(); |
| | | // 判断名称是否一样 |
| | | if (oldItemName.equals(newItemName)) { |
| | | StandardProductList standardProductList = new StandardProductList(); |
| | | standardProductList.setId(oldProductList.getId()); |
| | | // 复制排序 |
| | | standardProductList.setSort(newProductList.getSort()); |
| | | productLists.add(standardProductList); |
| | | } |
| | | } |
| | | } |
| | | this.updateBatchById(productLists); |
| | | return false; |
| | | } |
| | | } |
| | | |