From c61be765fe40fce1a57471a8fc8b93932c0a970c Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@63.com> Date: 星期六, 02 四月 2022 15:37:50 +0800 Subject: [PATCH] Merge branch 'jkasrs' of http://47.97.1.152:5880/r/zy-asrs into jkasrs --- src/main/java/com/zy/asrs/controller/OutController.java | 59 +++++++++++++++++++---------------------------------------- 1 files changed, 19 insertions(+), 40 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/OutController.java b/src/main/java/com/zy/asrs/controller/OutController.java index 1f44421..8cbcbed 100644 --- a/src/main/java/com/zy/asrs/controller/OutController.java +++ b/src/main/java/com/zy/asrs/controller/OutController.java @@ -1,6 +1,5 @@ package com.zy.asrs.controller; -import com.alibaba.fastjson.JSON; import com.core.annotations.ManagerAuth; import com.core.common.BaseRes; import com.core.common.Cools; @@ -8,9 +7,7 @@ import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.LocDetl; import com.zy.asrs.entity.OrderDetl; -import com.zy.asrs.entity.result.StoPreTab; import com.zy.asrs.service.*; -import com.zy.common.model.DetlDto; import com.zy.common.model.LocDto; import com.zy.common.model.TaskDto; import com.zy.common.web.BaseController; @@ -19,7 +16,9 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RestController; -import java.util.*; +import java.util.ArrayList; +import java.util.List; +import java.util.Optional; /** * Created by vincent on 2022/3/26 @@ -43,40 +42,6 @@ @Autowired private BasDevpService basDevpService; - -// @PostMapping("/out/pakout/preview/auth") -// public R pakoutPreview(@RequestBody List<Long> ids) { -// if (Cools.isEmpty(ids)) { -// return R.parse(BaseRes.PARAM); -// } -// List<OrderDetl> orderDetls = orderDetlService.selectBatchIds(ids); -// Set<DetlDto> detlDtos = new HashSet<>(); -// for (OrderDetl orderDetl : orderDetls) { -// if (DetlDto.hasList(detlDtos, orderDetl)) { -// DetlDto detlDto = DetlDto.find(detlDtos, orderDetl.getMatnr(), orderDetl.getBatch()); -// assert detlDto != null; -// detlDto.setAnfme(detlDto.getAnfme() + orderDetl.getAnfme()); -// } else { -// detlDtos.add(new DetlDto(orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getAnfme())); -// } -// } -// List<LocDto> locDtos = new ArrayList<>(); -// for (DetlDto detlDto : detlDtos) { -// double issued = Optional.ofNullable(detlDto.getAnfme()).orElse(0.0D) ; -// List<LocDetl> locDetls = locDetlService.queryStock(detlDto.getMatnr(), detlDto.getBatch(), null); -// for (LocDetl locDetl : locDetls) { -// if (issued > 0) { -// locDtos.add(new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), issued>=locDetl.getAnfme()?locDetl.getAnfme():issued)); -// // 鍓╀綑寰呭嚭鏁伴噺閫掑噺 -// issued = issued - locDetl.getAnfme(); -// } else { -// break; -// } -// } -// } -// return R.ok().add(locDtos); -// } - @PostMapping("/out/pakout/preview/auth") @ManagerAuth public R pakoutPreview(@RequestBody List<Long> ids) { @@ -86,7 +51,8 @@ List<OrderDetl> orderDetls = orderDetlService.selectBatchIds(ids); List<LocDto> locDtos = new ArrayList<>(); for (OrderDetl orderDetl : orderDetls) { - double issued = Optional.ofNullable(orderDetl.getAnfme()).orElse(0.0D); + double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D); + if (issued <= 0.0D) { continue; } List<LocDetl> locDetls = locDetlService.queryStock(orderDetl.getMatnr(), orderDetl.getBatch(), null); for (LocDetl locDetl : locDetls) { if (issued > 0) { @@ -112,10 +78,23 @@ @PostMapping("/out/pakout/auth") @ManagerAuth(memo = "璁㈠崟鍑哄簱") - public synchronized R pakout(@RequestBody List<LocDto> locDtos) { + public synchronized R pakout(@RequestBody List<LocDto> locDtos) throws InterruptedException { if (Cools.isEmpty(locDtos)) { return R.parse(BaseRes.PARAM); } + 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) { -- Gitblit v1.9.1