package com.yuanchu.mom.service.impl; import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yuanchu.mom.common.GetLook; import com.yuanchu.mom.mapper.StandardProductListMapper; import com.yuanchu.mom.mapper.StandardTreeMapper; import com.yuanchu.mom.pojo.InsSample; import com.yuanchu.mom.pojo.StandardProductList; import com.yuanchu.mom.pojo.StandardTree; import com.yuanchu.mom.service.StandardProductListService; import lombok.AllArgsConstructor; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.util.ArrayList; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** * @author Administrator * @description 针对表【standard_product_list(标准树下的检验项目)】的数据库操作Service实现 * @createDate 2024-03-05 10:33:29 */ @Service @AllArgsConstructor public class StandardProductListServiceImpl extends ServiceImpl implements StandardProductListService { private StandardProductListMapper standardProductListMapper; private StandardTreeMapper standardTreeMapper; private GetLook getLook; @Override public int upStandardProductList(StandardProductList list) { return standardProductListMapper.updateById(list); } @Override public int delStandardProduct(JSONArray list) { return standardProductListMapper.deleteBatchIds(list); } @Override public List selectStandardProductList(InsSample insSample) { List list = standardProductListMapper.selectList(Wrappers.lambdaQuery().eq(StandardProductList::getStandardMethodListId, insSample.getStandardMethodListId()).eq(StandardProductList::getState, 1).eq(StandardProductList::getModel, insSample.getModel())); list = list.stream().filter(a -> { try { if (a.getSection() != null && !Objects.equals(a.getSection(), "")) { if (a.getSection().contains("~")) { String[] split = a.getSection().split("~"); return new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(split[0])) > -1 && new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(split[1])) < 1; } else if (a.getSection().contains("≥") || a.getSection().contains(">=")) { String param = a.getSection().replace("≥", "").replace(">=", ""); return new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(param)) > -1; } else if (a.getSection().contains("≤") || a.getSection().contains("<=")) { String param = a.getSection().replace("≤", "").replace("<=", ""); return new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(param)) < 1; } else if (a.getSection().contains(">")) { String param = a.getSection().replace(">", ""); return new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(param)) > 0; } else if (a.getSection().contains("<")) { String param = a.getSection().replace("<", ""); return new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(param)) < 0; } else if (a.getSection().contains("=")) { String param = a.getSection().replace("=", ""); return new BigDecimal(insSample.getModel()).compareTo(new BigDecimal(param)) == 0; } } } catch (Exception ignored) { return false; } return true; }).collect(Collectors.toList()); return list; } @Override public List selectStandardProductListByMethodId(Integer id, String tree) { String[] trees = tree.split(" - "); List list = new ArrayList<>(); if (trees.length == 3) { List treeList = standardTreeMapper.selectList(Wrappers.lambdaQuery().eq(StandardTree::getLaboratory, trees[1]).eq(StandardTree::getSampleType, trees[2])); for (StandardTree standardTree : treeList) { String str = tree+" - "+standardTree.getSample()+" - "+standardTree.getModel(); list.addAll(standardTreeMapper.selectStandardProductListByTree("\"" + trees[2] + "\"", standardTree.getSample(), standardTree.getModel(), str)); } } else if (trees.length == 4){ List treeList = standardTreeMapper.selectList(Wrappers.lambdaQuery().eq(StandardTree::getLaboratory, trees[1]).eq(StandardTree::getSampleType, trees[2]).eq(StandardTree::getSample, trees[3])); for (StandardTree standardTree : treeList) { String str = tree+" - "+standardTree.getModel(); list.addAll(standardTreeMapper.selectStandardProductListByTree("\"" + trees[2] + "\"", standardTree.getSample(), standardTree.getModel(), str)); list.addAll(standardTreeMapper.selectStandardProductListByTree2("\"" + trees[2] + "\",\"" + trees[3] + "\"", standardTree.getSample(), standardTree.getModel(), str)); } } else { list.addAll(standardTreeMapper.selectStandardProductListByTree("\"" + trees[2] + "\"", trees[3], trees[4], tree)); list.addAll(standardTreeMapper.selectStandardProductListByTree2("\"" + trees[2] + "\",\"" + trees[3] + "\"", trees[3], trees[4], tree)); } List standardProductLists = standardProductListMapper.selectList(Wrappers.lambdaQuery().eq(StandardProductList::getStandardMethodListId, id).like(StandardProductList::getTree, tree)); for (StandardProductList sp : standardProductLists) { for (StandardProductList pl : list) { if (Objects.equals(sp.getInspectionItem(), pl.getInspectionItem()) && Objects.equals(sp.getInspectionItemSubclass(), pl.getInspectionItemSubclass()) && Objects.equals(sp.getModel(), pl.getModel())) { pl.setId(sp.getId()); pl.setState(sp.getState()); pl.setMethodS(sp.getMethodS()); 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()); } break; } } } Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); // CompletableFuture.supplyAsync(() -> { standardProductListMapper.delete(Wrappers.lambdaUpdate().eq(StandardProductList::getStandardMethodListId, id).like(StandardProductList::getTree, tree)); 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())); /*return null; }).thenAccept(res -> { }).exceptionally(e -> { e.printStackTrace(); return null; });*/ return list; } }