From 1fe60de0b826d028c5798de86ec055be45684220 Mon Sep 17 00:00:00 2001 From: zss <zss@example.com> Date: 星期五, 28 六月 2024 09:48:03 +0800 Subject: [PATCH] 委托编号格式变更+下单查询检验项目+报告的设备日期+检验下单的样品数量不准确+检验的检验进度计算 --- inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java | 118 +++++++++++++++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 102 insertions(+), 16 deletions(-) diff --git a/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java b/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java index a3de060..6e42544 100644 --- a/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java +++ b/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java @@ -2,6 +2,7 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; +import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; @@ -18,14 +19,15 @@ import com.yuanchu.mom.utils.QueryWrappers; import com.yuanchu.mom.vo.SampleDefectsFatherVo; import lombok.AllArgsConstructor; +import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDate; import java.time.LocalDateTime; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.time.format.DateTimeFormatter; +import java.util.*; +import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Collectors; /** @@ -78,9 +80,13 @@ if (map1.get("look") == 1) { //涓汉 sampleOrderDto.setCreateUser(map1.get("userId")); - }else { + } else { //缁勭粐 - sampleOrderDto.setCompany(customMapper.selectById(user.getCompany()).getCompany()); + try { + sampleOrderDto.setCompany(customMapper.selectById(user.getCompany()).getCompany()); + } catch (NullPointerException e) { + throw new ErrorException("鎵句笉鍒版墍灞炲崟浣�"); + } } } Map<String, Object> map = new HashMap<>(); @@ -99,7 +105,7 @@ insOrderMapper.updateById(insOrder); List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, orderId).select(InsSample::getId)); List<Integer> ids = insSamples.stream().map(a -> a.getId()).collect(Collectors.toList()); - List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery().in(InsProduct::getInsSampleId, ids).eq(InsProduct::getState, 1).select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory)); + List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery().in(InsProduct::getInsSampleId, ids).eq(InsProduct::getState, 1).isNull(InsProduct::getInsFibersId).isNull(InsProduct::getInsFiberId).select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory)); for (InsProduct insProduct : insProducts) { InsOrderState insOrderState = new InsOrderState(); insOrderState.setInsOrderId(orderId); @@ -123,34 +129,70 @@ @Override @Transactional(rollbackFor = Exception.class) - public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder) { + public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder, List<List<Integer>> pairing) { insOrder.setState(0); - String code = insOrderMapper.getLaboratoryCode(insOrder.getLaboratory()); - insOrder.setEntrustCode(giveCode.giveCode("JCZX-" + code + "-", "ins_order", "-", "yyyyMMdd")); + String code = customMapper.selectById(insOrder.getCompanyId()).getCode2(); + //insOrder.setEntrustCode(giveCode.giveCode("JCZX-" + code + "-", "ins_order", "", "yyMMdd")); + String giveCode = this.giveCode.giveCode("JCZX-" + code + "-", "ins_order", "", "yyMMdd"); insOrderMapper.insert(insOrder); + AtomicInteger count = new AtomicInteger(); list.forEach(a -> { + count.getAndIncrement(); a.setId(null); a.setInsOrderId(insOrder.getId()); if (StrUtil.isEmpty(a.getSampleCode())) { - a.setSampleCode(giveCode.giveCode("", "ins_sample", "", "yyMMdd")); + a.setSampleCode(giveCode.split("-")[2] + "-" + count.get()); } insSampleMapper.insert(a); if (ObjectUtil.isNotEmpty(a.getInsProduct())) { addInsProductMethod(a.getId(), a.getInsProduct(), null, 0); } + if (ObjectUtil.isNotEmpty(a.getInsulating())) { + List<InsProduct> ip2 = new ArrayList<>(); + for (Integer i = 0; i < a.getInsulating().getNum(); i++) { + ip2.addAll(a.getInsulating().getInsProduct()); + } + for (InsProduct product : ip2) { + product.setStandardMethodListId(a.getInsulating().getStandardMethodListId()); + } + addInsProductMethod(a.getId(), ip2, null, 0); + } + if (ObjectUtil.isNotEmpty(a.getSheath())) { + for (InsProduct product : a.getSheath().getInsProduct()) { + product.setStandardMethodListId(a.getSheath().getStandardMethodListId()); + } + addInsProductMethod(a.getId(), a.getSheath().getInsProduct(), null, 0); + } + if (ObjectUtil.isNotEmpty(a.getChildSampleList())) { + for (SampleProductDto b : a.getChildSampleList()) { + for (int i = 0; i < b.getNum(); i++) { + b.setId(null); + b.setInsOrderId(insOrder.getId()); + b.setParentId(a.getId()); + if (StrUtil.isEmpty(b.getSampleCode())) { + b.setSampleCode(this.giveCode.giveCode("", "ins_sample", "", "yyMMdd")); + } + insSampleMapper.insert(b); + if (ObjectUtil.isNotEmpty(b.getInsProduct())) { + addInsProductMethod(b.getId(), b.getInsProduct(), null, 0); + } + } + } + } if (ObjectUtil.isNotEmpty(a.getBushing())) { for (BushingDto bushingDto : a.getBushing()) { - bushingDto.setInsSampleId(a.getInsOrderId()); + bushingDto.setInsSampleId(a.getId()); insBushingMapper.insert(bushingDto); - if(bushingDto.getFiber().size()!=0){ + if (bushingDto.getFiber().size() != 0) { for (FiberDto fiberDto : bushingDto.getFiber()) { fiberDto.setInsBushingId(bushingDto.getId()); insFiberMapper.insert(fiberDto); addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2); } - }else{ + } else { for (FibersDto fibersDto : bushingDto.getFibers()) { fibersDto.setInsBushingId(bushingDto.getId()); + fibersDto.setCode(this.giveCode.giveCode("", "ins_fibers", "", "yyMMdd")); insFibersMapper.insert(fibersDto); for (FiberDto fiberDto : fibersDto.getFiber()) { fiberDto.setInsFibersId(fibersDto.getId()); @@ -163,13 +205,30 @@ } } }); + for (List<Integer> i : pairing) { + SampleProductDto sample = JSON.parseObject(JSON.toJSONString(list.get(i.get(0) - 1)), SampleProductDto.class); + sample.setSampleCode(list.get(i.get(0) - 1).getSampleCode() + "/" + list.get(i.get(1) - 1).getSampleCode()); + sample.setId(null); + insSampleMapper.insert(sample); + try { + InsProduct insProduct = sample.getInsProduct().stream().filter(a -> Objects.equals(a.getInspectionItem(), "鐔旀帴鎹熻��")).findFirst().get(); + insProduct.setId(null); + insProduct.setInsSampleId(sample.getId()); + insProductMapper.insert(insProduct); + } catch (Exception e) { + } + } return insOrder.getId(); } private void addInsProductMethod(Integer sampleId, List<InsProduct> productList, Integer id, Integer type) { for (InsProduct product : productList) { - if(product.getState()==1){ - switch (type){ + /*if(product.getState()==1 && (product.getAsk().indexOf("D")>-1||product.getAsk().indexOf("W")>-1||product.getAsk().indexOf("X")>-1 + ||product.getAsk().indexOf("RTS")>-1||product.getAsk().indexOf("H")>-1||product.getAsk().indexOf("L")>-1)){ + throw new ErrorException("鎻愪氦澶辫触锛屽瓨鍦ㄦ湭濉啓鐨勫彉閲忥細"+product.getInspectionItem()+" "+product.getInspectionItemSubclass()); + }*/ + if (product.getState() == 1 && !product.getInspectionItem().equals("鐔旀帴鎹熻��")) { + switch (type) { case 1: product.setInsFibersId(id); break; @@ -195,7 +254,7 @@ public Map<String, Object> getInsOrder(Integer id) { Map<String, Object> map = new HashMap<>(); InsOrder insOrder = insOrderMapper.selectById(id); - List<SampleProductDto> list = insSampleMapper.selectSampleProductListByOrderId(id); + List<SampleProductDto> list = insSampleMapper.selectSampleProductListByOrderId2(id); map.put("insOrder", insOrder); map.put("sampleProduct", list); return map; @@ -204,6 +263,12 @@ @Override public int upInsOrderOfState(InsOrder insOrder) { insOrder.setExamineTime(LocalDateTime.now()); + String code = baseMapper.selLaboratoryCode(insOrder.getLaboratory()); + if (StringUtils.isEmpty(code)) { + code = ""; + } + String code2 = customMapper.selectById(insOrder.getCompanyId()).getCode2(); + insOrder.setEntrustCode(giveCode.giveCode("JC/ZX" + code + "-" + code2 + "-", "ins_order", "", "yyMM")); return insOrderMapper.updateById(insOrder); } @@ -252,6 +317,27 @@ public int updateStatus(Integer id) { return insOrderMapper.updateStatus(id); } + + //鏍囩鎵撳嵃 + @Override + public List<SampleProductDto3> labelPrinting(String ids) { + List<Integer> list = Arrays.stream(ids.split(",")).map(Integer::parseInt).collect(Collectors.toList()); + List<SampleProductDto3> sampleProductDtos = insSampleMapper.selectSampleProductListByOrderId3(list); + Set<String> processedCodes = new HashSet<>(); + //濡傛灉鏄厜绾ゆ垨鑰呮槸鍏夌氦甯﹂粯璁ゅ彧鎵撳嵃绗竴涓� + List<SampleProductDto3> sampleProductDto3s = sampleProductDtos.stream().filter(sampleProductDto3 -> { + if (!"鍏夌氦".equals(sampleProductDto3.getIoSampleType()) && !"鍏夌氦甯�".equals(sampleProductDto3.getIoSampleType())) { + return true; + } + if (processedCodes.contains(sampleProductDto3.getCode())) { + return false; + } else { + processedCodes.add(sampleProductDto3.getCode()); + return true; + } + }).collect(Collectors.toList()); + return sampleProductDto3s; + } } -- Gitblit v1.9.3