From 745b115acbb46829eb52f904f0c276012decf938 Mon Sep 17 00:00:00 2001 From: Fancy <Fancy.fx@outlook.com> Date: 星期二, 20 八月 2024 10:53:35 +0800 Subject: [PATCH] order manage --- pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/process/ProcessSv.java | 16 ++++++++++++++-- 1 files changed, 14 insertions(+), 2 deletions(-) diff --git a/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/process/ProcessSv.java b/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/process/ProcessSv.java index d51b920..4f2a3b7 100644 --- a/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/process/ProcessSv.java +++ b/pms-parent/pms-web-product/src/main/java/com/dy/pmsProduct/process/ProcessSv.java @@ -29,6 +29,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Map; +import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Collectors; @Slf4j @@ -106,11 +107,11 @@ if (CollectionUtils.isNotEmpty(planList)) { if (planList.stream().anyMatch(plan -> plan.getInputNumber() > 0)) { //瀛樺湪浠诲姟宸茬粡鎶曞叆鐢熶骇 if (!originProductionProcess.getProId().equals(process.getProId())) { - throw new RuntimeException("瀛樺湪宸茬粡鎶曞叆鐢熶骇缁戝畾鐨勪换鍔�,浜у搧涓嶈兘淇敼"); + throw new RuntimeException("瀛樺湪宸茬粡鎶曞叆鐢熶骇鐨勭粦瀹氫换鍔�,浜у搧涓嶈兘淇敼"); } //鑺傜偣id涓嶈兘鍒犻櫎 if (!originProductionProcess.getNodes().stream().allMatch(node -> process.getNodes().stream().anyMatch(newNode -> node.getId().equals(newNode.getId())))) { - throw new RuntimeException("瀛樺湪宸茬粡鎶曞叆鐢熶骇缁戝畾鐨勪换鍔�,鑺傜偣涓嶈兘鍒犻櫎"); + throw new RuntimeException("宸叉湁缁戝畾鐨勪换鍔℃姇鍏ョ敓浜�,鑺傜偣涓嶈兘鍒犻櫎"); } } else if (CollectionUtils.isNotEmpty(onlinePlanList)) { //鍏堝皢缁勮浠诲姟缃负鏆傚仠鐘舵�� @@ -150,10 +151,21 @@ if (loginUser != null) { process.creator = loginUser.id; } + AtomicInteger startCount = new AtomicInteger(); + AtomicInteger endCount = new AtomicInteger(); process.nodes.forEach(node -> { node.processId = process.id; node.deleted = false; + if(node.isStart){ + startCount.getAndIncrement(); + } + if(node.isEnd){ + endCount.getAndIncrement(); + } }); + if (startCount.get() != 1 || endCount.get() != 1) { + throw new RuntimeException("鑺傜偣寮�濮嬪拰缁撴潫鑺傜偣鏈変笖鍙兘鏈変竴涓�"); + } } // 灏嗚妭鐐瑰拰宸ヤ綔鎸囩ず鐨勪繚瀛橀�昏緫灏佽鍒颁竴涓柟娉曚腑 -- Gitblit v1.8.0