From 3536629992d020f689b3726925155a3fd662f442 Mon Sep 17 00:00:00 2001 From: Junjie <540245094@qq.com> Date: 星期二, 15 七月 2025 15:45:53 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/OutController.java | 340 +++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 334 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java index 8f20a4f..e3a92cb 100644 --- a/src/main/java/com/zy/asrs/controller/OutController.java +++ b/src/main/java/com/zy/asrs/controller/OutController.java @@ -1,18 +1,26 @@ package com.zy.asrs.controller; +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.core.annotations.ManagerAuth; import com.core.common.BaseRes; import com.core.common.Cools; import com.core.common.R; -import com.zy.asrs.entity.OrderDetl; -import com.zy.asrs.service.OrderDetlService; -import com.zy.asrs.service.OrderService; +import com.zy.asrs.entity.*; +import com.zy.asrs.service.*; +import com.zy.asrs.utils.MatUtils; +import com.zy.common.model.LocDto; +import com.zy.common.model.TaskDto; import com.zy.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; -import java.util.List; +import javax.annotation.Resource; +import java.math.BigDecimal; +import java.util.*; +import java.util.stream.Collectors; /** * Created by vincent on 2022/3/26 @@ -25,15 +33,335 @@ private OrderService orderService; @Autowired private OrderDetlService orderDetlService; + @Autowired + private OrderDetlPakoutService orderDetlPakoutService; + @Autowired + private LocDetlService locDetlService; + @Autowired + private LocMastService locMastService; + @Autowired + private StaDescService staDescService; + @Autowired + private WorkService workService; + @Autowired + private BasDevpService basDevpService; + + @Resource + private OrderPakoutService orderPakOutService; + + + @PostMapping("/out/pakout/orderDetlIds/auth") + @ManagerAuth + public R pakoutOrderDetlIds(@RequestParam Long orderId) throws InterruptedException { + Thread.sleep(200); + return R.ok().add(orderDetlPakoutService.selectByOrderId(orderId).stream().map(OrderDetlPakout::getId).distinct().collect(Collectors.toList())); + } @PostMapping("/out/pakout/preview/auth") + @ManagerAuth public R pakoutPreview(@RequestBody List<Long> ids) { if (Cools.isEmpty(ids)) { return R.parse(BaseRes.PARAM); } - List<OrderDetl> orderDetls = orderDetlService.selectBatchIds(ids); - return R.ok().add(orderDetls); + List<OrderDetlPakout> orderDetlPakouts = orderDetlPakoutService.selectBatchIds(ids); + if (orderDetlPakouts.size() == 0) { + return R.parse("璁㈠崟鏄庣粏涓虹┖"); + } + + List<LocDto> locDtos = new ArrayList<>(); + + Set<String> exist = new HashSet<>(); + + // 鑾峰彇璁㈠崟涓昏〃 + OrderPakout orderPakOut = orderPakOutService.selectByNo(orderDetlPakouts.get(0).getOrderNo()); + // 鐩樼偣鍗曞嚭搴� + if (orderPakOut.getDocType() == 8) { + for (OrderDetlPakout orderDetl : orderDetlPakouts) { + BigDecimal issuedBigDecimal = Optional.of(BigDecimal.valueOf(orderDetl.getAnfme()).subtract(BigDecimal.valueOf(orderDetl.getWorkQty()))).orElse(new BigDecimal(0)); + double issued = issuedBigDecimal.doubleValue(); + if (issued <= 0.0D) { + continue; + } + List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist,orderDetl.getMatnr(), orderDetl.getBatch(), + orderDetl.getBrand(),orderDetl.getStandby1(),orderDetl.getStandby2(),orderDetl.getStandby3(),orderDetl.getBoxType1(),orderDetl.getBoxType2(),orderDetl.getBoxType3()); + for (LocDetl locDetl : locDetls) { + if (issued > 0) { + LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(), + issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued); + LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetl.getLocNo())); + locDto.setFrozen(locDetl.getFrozen()); + locDto.setFrozenLoc(locMast.getFrozen()); + List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), 107); + locDto.setBrand(orderDetl.getBrand()); + locDto.setStandby1(orderDetl.getStandby1()); + locDto.setStandby2(orderDetl.getStandby2()); + locDto.setStandby3(orderDetl.getStandby3()); + locDto.setBoxType1(orderDetl.getBoxType1()); + locDto.setBoxType2(orderDetl.getBoxType2()); + locDto.setBoxType3(orderDetl.getBoxType3()); + + //璁$畻杈呭崟浣� + Double weight = MatUtils.calcWeight(locDto.getMatnr(), locDto.getAnfme()); + locDto.setWeight(weight); + + locDto.setUnit(orderDetl.getUnit()); + + locDto.setStaNos(staNos); + locDtos.add(locDto); + // 鍓╀綑寰呭嚭鏁伴噺閫掑噺 + issuedBigDecimal = issuedBigDecimal.subtract(BigDecimal.valueOf(locDetl.getAnfme())); + issued = issuedBigDecimal.doubleValue(); + } else { + break; + } + } + if (issued > 0) { + LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued); + locDto.setBrand(orderDetl.getBrand()); + + locDto.setStandby1(orderDetl.getStandby1()); + locDto.setStandby2(orderDetl.getStandby2()); + locDto.setStandby3(orderDetl.getStandby3()); + locDto.setBoxType1(orderDetl.getBoxType1()); + locDto.setBoxType2(orderDetl.getBoxType2()); + locDto.setBoxType3(orderDetl.getBoxType3()); + + //璁$畻杈呭崟浣� + Double weight = MatUtils.calcWeight(locDto.getMatnr(), locDto.getAnfme()); + locDto.setWeight(weight); + + locDto.setUnit(orderDetl.getUnit()); + locDto.setLack(Boolean.TRUE); + locDtos.add(locDto); + } + } + } else { + for (OrderDetlPakout orderDetl : orderDetlPakouts) { + BigDecimal issuedBigDecimal = Optional.of(BigDecimal.valueOf(orderDetl.getAnfme()).subtract(BigDecimal.valueOf(orderDetl.getWorkQty()))).orElse(new BigDecimal(0)); + double issued = issuedBigDecimal.doubleValue(); + if (issued <= 0.0D) { + continue; + } + + //绗竴娆℃悳绱紝涓昏鎼滅储鍙叏鏉垮嚭搴撶殑鎵樼洏 + List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist,orderDetl.getMatnr(), orderDetl.getBatch(), + orderDetl.getBrand(),orderDetl.getStandby1(),orderDetl.getStandby2(),orderDetl.getStandby3(),orderDetl.getBoxType1(),orderDetl.getBoxType2(),orderDetl.getBoxType3()); + //鏍规嵁鎺掑簭缁撴灉鑾峰彇搴撲綅鍙� + List<String> locList = new ArrayList<>(); + for (LocDetl locDetl : locDetls) { + if (locList.contains(locDetl.getLocNo())) { + continue; + } + locList.add(locDetl.getLocNo()); + } + + List<String> containLocList = new ArrayList<>(); + for (String locNo : locList) { + BigDecimal allStockDecimal = new BigDecimal(0); + List<LocDetl> locDetls1 = locDetlService.selectList(new EntityWrapper<LocDetl>() + .eq("loc_no", locNo)); + for (LocDetl locDetl : locDetls1) { + allStockDecimal = allStockDecimal.add(BigDecimal.valueOf(locDetl.getAnfme())); + } + + //姝ゅ簱浣嶆�诲簱瀛� + double allStock = allStockDecimal.doubleValue(); + if (issued <= 0) { + break; + } + + //搴撳瓨杩囧ぇ锛屾棤娉曞叏鏉垮嚭搴擄紝鎼滅储涓嬩竴鏉� + if(allStock > issued) { + continue; + } + + containLocList.add(locNo); + + for (LocDetl locDetl : locDetls1) { + LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(), + issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued); + LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetl.getLocNo())); + locDto.setFrozen(locDetl.getFrozen()); + locDto.setFrozenLoc(locMast.getFrozen()); +// int ioType = (issued >= locDetl.getAnfme() && locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("loc_no", locDto.getLocNo())) == 1) ? 101 : 103; + int ioType = 101; + List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ioType); + locDto.setStaNos(staNos); + locDto.setBrand(orderDetl.getBrand()); + + locDto.setStandby1(orderDetl.getStandby1()); + locDto.setStandby2(orderDetl.getStandby2()); + locDto.setStandby3(orderDetl.getStandby3()); + locDto.setBoxType1(orderDetl.getBoxType1()); + locDto.setBoxType2(orderDetl.getBoxType2()); + locDto.setBoxType3(orderDetl.getBoxType3()); + locDto.setUnit(orderDetl.getUnit()); + + //璁$畻杈呭崟浣� + Double weight = MatUtils.calcWeight(locDto.getMatnr(), locDto.getAnfme()); + locDto.setWeight(weight); + + locDtos.add(locDto); + exist.add(locDetl.getLocNo()); + // 鍓╀綑寰呭嚭鏁伴噺閫掑噺 + issuedBigDecimal = issuedBigDecimal.subtract(BigDecimal.valueOf(locDetl.getAnfme())); + issued = issuedBigDecimal.doubleValue(); + } + } + + //鍏ㄦ澘鎼滅储缁撴潫鍚庯紝杩樻湁鏈嚭鏁伴噺锛屽垯鎼滅储鎷i�夊嚭搴� + if(issued > 0) { + for (LocDetl locDetl : locDetls) { + if (issued <= 0) { + break; + } + + if(containLocList.contains(locDetl.getLocNo())) { + continue; + } + + LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(), + issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued); + LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetl.getLocNo())); + locDto.setFrozen(locDetl.getFrozen()); + locDto.setFrozenLoc(locMast.getFrozen()); +// int ioType = (issued >= locDetl.getAnfme() && locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("loc_no", locDto.getLocNo())) == 1) ? 101 : 103; + int ioType = 103; + List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), ioType); + locDto.setStaNos(staNos); + locDto.setBrand(orderDetl.getBrand()); + + locDto.setStandby1(orderDetl.getStandby1()); + locDto.setStandby2(orderDetl.getStandby2()); + locDto.setStandby3(orderDetl.getStandby3()); + locDto.setBoxType1(orderDetl.getBoxType1()); + locDto.setBoxType2(orderDetl.getBoxType2()); + locDto.setBoxType3(orderDetl.getBoxType3()); + locDto.setUnit(orderDetl.getUnit()); + + //璁$畻杈呭崟浣� + Double weight = MatUtils.calcWeight(locDto.getMatnr(), locDto.getAnfme()); + locDto.setWeight(weight); + + locDtos.add(locDto); + exist.add(locDetl.getLocNo()); + // 鍓╀綑寰呭嚭鏁伴噺閫掑噺 + issuedBigDecimal = issuedBigDecimal.subtract(BigDecimal.valueOf(locDetl.getAnfme())); + issued = issuedBigDecimal.doubleValue(); + } + } + + if (issued > 0) { + LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued); + locDto.setBrand(orderDetl.getBrand()); + locDto.setStandby1(orderDetl.getStandby1()); + locDto.setStandby2(orderDetl.getStandby2()); + locDto.setStandby3(orderDetl.getStandby3()); + locDto.setBoxType1(orderDetl.getBoxType1()); + locDto.setBoxType2(orderDetl.getBoxType2()); + locDto.setBoxType3(orderDetl.getBoxType3()); + + //璁$畻杈呭崟浣� + Double weight = MatUtils.calcWeight(locDto.getMatnr(), locDto.getAnfme()); + locDto.setWeight(weight); + + locDto.setUnit(orderDetl.getUnit()); + locDto.setLack(Boolean.TRUE); + locDtos.add(locDto); + } + } + +// // 閲嶆柊璁$畻鍑哄簱绔欑偣锛屽彲鑳藉瓨鍦ㄤ竴涓墭鐩樺鏉℃槑缁嗭紝澶氭潯鏄庣粏缁熻涓嬫潵鍙叏鏉垮嚭搴擄紝浣嗗疄闄呯粰鍑虹殑绔欑偣鍙兘鎷i�夊嚭搴� +// HashMap<String, Double> locAnfmeMap = new HashMap<>(); +// for (LocDto locDto : locDtos) { +// if(locAnfmeMap.containsKey(locDto.getLocNo())) { +// Double anfme = locAnfmeMap.get(locDto.getLocNo()); +// BigDecimal decimal = BigDecimal.valueOf(locDto.getAnfme()).add(BigDecimal.valueOf(anfme)); +// locAnfmeMap.put(locDto.getLocNo(), decimal.doubleValue()); +// }else { +// locAnfmeMap.put(locDto.getLocNo(), locDto.getAnfme()); +// } +// } +// +// HashMap<String, List<Integer>> locStaNosMap = new HashMap<>(); +// for (Map.Entry<String, Double> entry : locAnfmeMap.entrySet()) { +// String locNo = entry.getKey(); +// Double realAnfme = entry.getValue(); +// +// double stockAnfme = 0D; +// List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locNo)); +// for (LocDetl locDetl : locDetls) { +// BigDecimal decimal = BigDecimal.valueOf(stockAnfme).add(BigDecimal.valueOf(locDetl.getAnfme())); +// stockAnfme = decimal.doubleValue(); +// } +// +// int ioType = 103; +// if(stockAnfme == realAnfme) { +// ioType = 101; +// } +// +// List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locNo, ioType); +// locStaNosMap.put(locNo, staNos); +// } +// +// for (LocDto locDto : locDtos) { +// List<Integer> staNos = locStaNosMap.get(locDto.getLocNo()); +// locDto.setStaNos(staNos); +// } + } + + return R.ok().add(locDtos); + } + + @PostMapping("/out/pakout/auth") + @ManagerAuth(memo = "璁㈠崟鍑哄簱") + public synchronized R pakout(@RequestBody List<LocDto> locDtos) throws InterruptedException { + if (Cools.isEmpty(locDtos)) { + return R.parse(BaseRes.PARAM); + } + List<LocDto> locDtoArrayList = new ArrayList<>(); + for (LocDto locDto : locDtos){ + if (locDto.getFrozen()!=1 && locDto.getFrozenLoc()!=1){ + locDtoArrayList.add(locDto); + } + } + locDtos = locDtoArrayList; + if (Cools.isEmpty(locDtos)) { + return R.parse("搴撳瓨/搴撲綅琚喕缁擄紝璇峰鐞嗗悗鍑哄簱锛侊紒锛�"); + } + boolean lack = true; + for (LocDto locDto : locDtos) { + if (!locDto.isLack()) { + lack = false; + break; + } + } + if (lack) { + return R.error("搴撳瓨涓嶈冻"); + } + + Thread.sleep(1000L); + + List<TaskDto> taskDtos = new ArrayList<>(); + // 鏍规嵁 锛堝簱浣� & 鍑哄簱绔欙級 鍒嗙粍锛� 鐞嗘兂鐘舵�侊細涓�缁勪负涓�娆″嚭搴撲换鍔� + for (LocDto locDto : locDtos) { + if (locDto.isLack()) { continue; } + TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getStaNo(), locDto); + if (TaskDto.has(taskDtos, taskDto)) { + TaskDto dto = TaskDto.find(taskDtos, taskDto); + assert dto != null; + dto.getLocDtos().addAll(taskDto.getLocDtos()); + } else { + taskDtos.add(taskDto); + } + } + // ----------------------------------------------------------------------------------------------- + for (TaskDto taskDto : taskDtos) { + BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo()); + workService.stockOut(staNo, taskDto, getUserId()); + } + return R.ok(); } } -- Gitblit v1.9.1