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