From dd4002e8e234f42ab4f3e2ee5566bc0a1762acb3 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@63.com> Date: 星期一, 05 十二月 2022 16:47:24 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/OutController.java | 59 ++++++++++++++++++++++++++++++++++++++++++----------------- 1 files changed, 42 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java index 1e8569f..14b79e7 100644 --- a/src/main/java/com/zy/asrs/controller/OutController.java +++ b/src/main/java/com/zy/asrs/controller/OutController.java @@ -1,5 +1,7 @@ package com.zy.asrs.controller; +import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.annotations.ManagerAuth; import com.core.common.BaseRes; import com.core.common.Cools; @@ -39,6 +41,8 @@ private WorkService workService; @Autowired private BasDevpService basDevpService; + @Autowired + private MatService matService; @PostMapping("/out/pakout/orderDetlIds/auth") @ManagerAuth @@ -66,7 +70,8 @@ if (issued > 0) { LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(), issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued); - List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103); + int ioType = (issued >= locDetl.getAnfme() && locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("loc_no", locDto.getLocNo())) == 1) ? 101 : 103; + List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ioType); locDto.setStaNos(staNos); locDtos.add(locDto); exist.add(locDetl.getLocNo()); @@ -108,14 +113,29 @@ // 璁㈠崟棰勬牎楠� ===>> 1.璁㈠崟鐘舵�侊紱 2.璁㈠崟甯﹀嚭鏁伴噺 List<OrderDto> orderDtos = new ArrayList<>(); for (LocDto locDto : locDtos) { - if (Cools.isEmpty(locDto.getOrderNo())) { continue; } - OrderDto orderDto = new OrderDto(locDto.getOrderNo(), locDto.getMatnr(), locDto.getAnfme()); - if (OrderDto.has(orderDtos, orderDto)) { - OrderDto dto = OrderDto.find(orderDtos, orderDto); - assert dto != null; - dto.setAnfme(dto.getAnfme() + orderDto.getAnfme()); + if (!isJSON(locDto.getOrderNo())) { + if (Cools.isEmpty(locDto.getOrderNo())) { continue; } + OrderDto orderDto = new OrderDto(locDto.getOrderNo(), locDto.getMatnr(), locDto.getAnfme()); + if (OrderDto.has(orderDtos, orderDto)) { + OrderDto dto = OrderDto.find(orderDtos, orderDto); + assert dto != null; + dto.setAnfme(dto.getAnfme() + orderDto.getAnfme()); + } else { + orderDtos.add(orderDto); + } } else { - orderDtos.add(orderDto); + // 璁㈠崟鍚堝苟鍑哄簱 + List<OrderDto> orderDtoList = JSON.parseArray(locDto.getOrderNo(), OrderDto.class); + for (OrderDto one : orderDtoList) { + OrderDto orderDto = new OrderDto(one.getOrderNo(), locDto.getMatnr(), one.getAnfme()); + if (OrderDto.has(orderDtos, orderDto)) { + OrderDto dto = OrderDto.find(orderDtos, orderDto); + assert dto != null; + dto.setAnfme(dto.getAnfme() + orderDto.getAnfme()); + } else { + orderDtos.add(orderDto); + } + } } } for (OrderDto orderDto : orderDtos) { @@ -148,6 +168,7 @@ taskDtos.add(taskDto); } } + // ----------------------------------------------------------------------------------------------- List<String> excludeLocNos = taskDtos.stream().map(TaskDto::getLocNo).distinct().collect(Collectors.toList()); for (TaskDto taskDto : taskDtos) { @@ -174,20 +195,19 @@ if (Cools.isEmpty(list)) { return R.parse(BaseRes.PARAM); } - List<OrderDetl> orderDetls = orderDetlService.selectBatchIds(ids); + Set<String> exist = new HashSet<>(); List<LocDto> locDtos = new ArrayList<>(); - Set<String> exist = new HashSet<>(); - - for (OrderDetl orderDetl : orderDetls) { - double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D); + for (OrderMergeVo vo : list) { + double issued = Optional.of(vo.getAnfme()).orElse(0.0D); if (issued <= 0.0D) { continue; } - List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), null, exist); + List<LocDetl> locDetls = locDetlService.queryStock(vo.getMatnr(), vo.getBatch(), null, exist); for (LocDetl locDetl : locDetls) { if (issued > 0) { - LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(), + LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), JSON.toJSONString(vo.getOrderDtos()), issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued); - List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103); + int ioType = (issued >= locDetl.getAnfme() && locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("loc_no", locDto.getLocNo())) == 1) ? 101 : 103; + List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ioType); locDto.setStaNos(staNos); locDtos.add(locDto); exist.add(locDetl.getLocNo()); @@ -198,11 +218,16 @@ } } if (issued > 0) { - LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued); + LocDto locDto = new LocDto(null, vo.getMatnr(), vo.getMaktx(), vo.getBatch(), JSON.toJSONString(vo.getOrderDtos()), issued); locDto.setLack(Boolean.TRUE); locDtos.add(locDto); } } + for (LocDto locDto : locDtos) { + Mat mat = matService.selectByMatnr(locDto.getMatnr()); + assert mat != null; + locDto.setSpecs(mat.getSpecs()); + } return R.ok().add(locDtos); } -- Gitblit v1.9.1