From ebe2da6e4eefd59b366ebab3a651b32763b580ed Mon Sep 17 00:00:00 2001 From: skyouc Date: 星期日, 22 六月 2025 14:23:56 +0800 Subject: [PATCH] Merge branch 'ycds-wms-dev' of http://47.97.1.152:5880/r/zy-asrs-master into ycds-wms-dev --- zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/CacheSiteServiceImpl.java | 9 +++++++-- 1 files changed, 7 insertions(+), 2 deletions(-) diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/CacheSiteServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/CacheSiteServiceImpl.java index d1b99b5..4943af9 100644 --- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/CacheSiteServiceImpl.java +++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/CacheSiteServiceImpl.java @@ -13,6 +13,7 @@ import org.springframework.stereotype.Service; import java.util.*; +import java.util.stream.Collectors; @Service("cacheSiteService") public class CacheSiteServiceImpl extends ServiceImpl<CacheSiteMapper, CacheSite> implements CacheSiteService { @@ -68,6 +69,9 @@ HashMap<Long, Double> stockMap = new HashMap<>(); List<WaveSeed> waveSeeds = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getOrderId, orderId)); + //fixme 鏍¢獙褰撳墠璁㈠崟鏄惁瀹屾垚鎾锛岄渶瑕佽幏鍙栧綋鍓嶆尝娆℃墍鏈変换鍔′腑A鐗╂枡鐨勬墽琛屾暟閲忔槸鍚︾瓑浜庤鍗曠殑鎬婚噺-宸插畬鎴愭暟閲�(anfme - qty) 鎴栬�� 浠诲姟涓凡鎵ц鏁伴噺鏄惁绛夎鍗曚腑鐨勬墽琛屾暟閲� workQty = workQty + List<OrderDetl> orderDetls = orderDetlService.getOrderDetlByOrderId(orderId); + for (WaveSeed waveSeed : waveSeeds) { Double anfme = stockMap.get(waveSeed.getOrderDetlId()); if (anfme == null) { @@ -77,7 +81,6 @@ stockMap.put(waveSeed.getOrderDetlId(), anfme); } - List<OrderDetl> orderDetls = orderDetlService.getOrderDetlByOrderId(orderId); boolean check = true; for (OrderDetl orderDetl : orderDetls) { Double anfme = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D); @@ -123,6 +126,7 @@ Long waveId = order.getWaveId(); boolean check = this.seedCompletePreview(param); + if (!check) {//璁㈠崟鏈鐞嗗畬鎴� List<Long> taskIds = new ArrayList<>(); List<TaskDetl> taskDetls = taskDetlService.list(new LambdaQueryWrapper<TaskDetl>().eq(TaskDetl::getWaveId, waveId)); @@ -133,7 +137,8 @@ } if (!taskIds.isEmpty()) { - List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, taskIds).notIn(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id, TaskStsType.UPDATED_OUT.id)); + List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, taskIds) + .notIn(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id, TaskStsType.UPDATED_OUT.id)); if (!tasks.isEmpty()) { throw new CoolException("瀛樺湪鏈畬鎴愪换鍔�"); } -- Gitblit v1.9.1