From 134c06beb2b6b7f7025fb030a9e52bcceebbfc98 Mon Sep 17 00:00:00 2001
From: jinlin <jinlin>
Date: 星期一, 15 七月 2024 14:36:49 +0800
Subject: [PATCH] 修改

---
 modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/ModelLineService.java |  177 +++++++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 165 insertions(+), 12 deletions(-)

diff --git a/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/ModelLineService.java b/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/ModelLineService.java
index 6f17597..660d39d 100644
--- a/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/ModelLineService.java
+++ b/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/ModelLineService.java
@@ -89,6 +89,7 @@
         modelRbdDao.insert(modelRbd);
     }
 
+
     @Transactional(rollbackFor = Exception.class)
     public void update(ModelRbd modelRbd) {
         if (modelRbd==null) return;
@@ -125,23 +126,67 @@
 
         // 1. 瑙f瀽鍑鸿妭鐐逛笌杈�
         getNodeAndLineFromRbd(modelRbd.getId(), rbdJsonArray, modelNodeList, modelLineList, productImgList);
-        // 2. 璁$畻鎵�鏈夎妭鐐圭殑鍏ュ彛绾挎暟鍙婂嚭鍙g嚎鏁�
+        // 2. 瀵逛簬鏈夊鏍瑰叆鍙g嚎鐨勪骇鍝佽妭鐐癸紝灏嗗叾涓婄殑琛ㄥ喅銆佹梺鑱斿叧绯诲墺绂绘垚杩愮畻绗﹁妭鐐癸紝娣诲姞鍒拌鑺傜偣鐨勫墠闈紝骞舵坊鍔犵浉搴旂殑杈�
+        peelOperationFromProductNode(modelRbd.getId(), modelNodeList, modelLineList);
+        // 3. 璁$畻鎵�鏈夎妭鐐圭殑鍏ュ彛绾挎暟鍙婂嚭鍙g嚎鏁�
         calcInOutLineNumAllNode(modelNodeList, modelLineList);
-        // 3. 澶嶅埗浜у搧鑺傜偣(node)鍒發ist
+        // 4. 澶嶅埗浜у搧鑺傜偣(node)鍒發ist
         List<ModelNode> modelNodeAndVnodeList = modelNodeList.stream().filter(item ->
                 "node".equals(item.getNodeType())).collect(Collectors.toList());
-        // 4. 涓嶆柇灏嗗熀鏈ā鍨嬶紙涓茶仈銆佸苟鑱斻�佹梺鑱斻�佽〃鍐炽�佹ˉ鑱旓級鏇挎崲涓鸿櫄鑺傜偣鑰岀畝鍖栧浘褰紝鐩磋嚦鏃犳硶绠�鍖栦负姝€��
+        // 5. 涓嶆柇灏嗗熀鏈ā鍨嬶紙涓茶仈銆佸苟鑱斻�佹梺鑱斻�佽〃鍐炽�佹ˉ鑱旓級鏇挎崲涓鸿櫄鑺傜偣鑰岀畝鍖栧浘褰紝鐩磋嚦鏃犳硶绠�鍖栦负姝€��
         result = getAlgorithmFromRbd(modelRbd, modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList);
 
-        // 5. 杞崲涓虹畻娉曞簱鎺ュ彛XML
+        // 6. 杞崲涓虹畻娉曞簱鎺ュ彛XML
         if (result) {
             result = createIfXmlFromRbd(modelRbd, algorithmList, modelNodeAndVnodeList);
         }
 
-        // 6. 淇濆瓨妯″瀷
+        // 7. 淇濆瓨妯″瀷
         if (saveFlag) saveModel(modelRbd, modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList);
 
         return result;
+    }
+
+    private void peelOperationFromProductNode(Long modelId,
+                                              List<ModelNode> modelNodeList,
+                                              List<ModelLine> modelLineList) {
+        List<ModelNode> nodesToAdd = new ArrayList<>();
+        List<ModelLine> linesToAdd = new ArrayList<>();
+        for (ModelNode node: modelNodeList) {
+            List<ModelLine> inLineList = modelLineList.stream().filter(item ->
+                    item.getEndCell().equals(node.getPicId())).collect(Collectors.toList());
+            if ("node".equals(node.getNodeType()) &&
+                    StringUtils.isNotBlank(node.getNodeTypeExt()) &&
+                    inLineList.size() > 1) {
+                // 鏃佽仈or琛ㄥ喅
+                ModelNode nodeNew =  new ModelNode();
+                Long nodeNewId = UUIDUtil.generateId();
+                nodeNew.setId(nodeNewId);
+                nodeNew.setPicId(nodeNewId.toString());
+                nodeNew.setModelId(modelId);
+                nodeNew.setNodeType(node.getNodeTypeExt());
+                nodeNew.setName(node.getNodeTypeExt());
+                nodeNew.setVoteNum(node.getVoteNum());
+                nodeNew.setPositionX(node.getPositionX());
+                nodeNew.setPositionY(node.getPositionY());
+                nodesToAdd.add(nodeNew);
+
+                ModelLine lineNew = new ModelLine();
+                Long lineNewId = UUIDUtil.generateId();
+                lineNew.setId(lineNewId);
+                lineNew.setPicId(lineNewId.toString());
+                lineNew.setModelId(modelId);
+                lineNew.setBeginCell(nodeNewId.toString());
+                lineNew.setEndCell(node.getPicId());
+                linesToAdd.add(lineNew);
+
+                for(ModelLine line: inLineList){
+                    line.setEndCell(nodeNewId.toString());
+                }
+            }
+        }
+        modelNodeList.addAll(nodesToAdd);
+        modelLineList.addAll(linesToAdd);
     }
 
     private boolean createIfXmlFromRbd(ModelRbd modelRbd,
@@ -210,7 +255,7 @@
             Long dataId = node.getDataId();
             XhProductModel xhProductModel = xhProductModelDao.getById(dataId);
             if (xhProductModel == null) return;
-            if ("1".equals(xhProductModel.getProductType())) {
+            if ("5".equals(xhProductModel.getProductType())) {
                 // 璁惧
                 ParamData paramData = paramDataDao.getParamData(dataId, "expect");
                 if (paramData == null) return;
@@ -295,7 +340,8 @@
         do {
             hasSimplified = false;
             hasSimplified = simplifySeries(modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
-            hasSimplified = simplifyParallel(modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
+//            hasSimplified = simplifyParallel(modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
+            hasSimplified = simplifyOperator("parallel", modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
             hasSimplified = simplifyOperator("switch", modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
             hasSimplified = simplifyOperator("vote", modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
             hasSimplified = simplifyBridge(modelRbd.getId(), modelNodeList, modelLineList, algorithmList, modelNodeAndVnodeList, hasSimplified);
@@ -378,7 +424,7 @@
             if (result.size()<2) continue;
 
             ModelNode endNode = result.get(result.size()-1);
-            if ("start,switch,vote".contains(endNode.getNodeType()) || endNode.getOutLineNum()!=1) {
+            if ("start,parallel,switch,vote,bridge".contains(endNode.getNodeType()) || endNode.getOutLineNum()!=1) {
                 result.remove(endNode);
             }
             List<ModelNode> realSeriesNodes = result.stream().filter(item ->
@@ -642,12 +688,37 @@
                                 List<ModelNode> result) {
         ModelLine inLine = modelLineList.stream().filter(item ->
                 item.getEndCell().equals(startNode.getPicId())).collect(Collectors.toList()).get(0);
-        ModelNode pathNode = modelNodeList.stream().filter(item ->
-                inLine.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (isBridgeUpperLine(inLine, modelLineList) || isBridgeLowerLine(inLine, modelLineList)) return;
+        List<ModelNode> nodes = modelNodeList.stream().filter(item ->
+                inLine.getBeginCell().equals(item.getPicId())).collect(Collectors.toList());
+        if (0==nodes.size()) return;    // 鍒版ˉ鑱斾腑闂磋妭鐐圭殑绾跨殑璧风偣涓嶆槸Node锛岃�屾槸Line锛屾墍浠ヨ幏鍙栫殑璧风偣鏁板彲鑳戒负0
+        ModelNode pathNode = nodes.get(0);
         result.add(pathNode);
         if (pathNode.getOutLineNum()!=1 || pathNode.getInLineNum()!=1) return;
-        if ("switch,vote".contains(pathNode.getNodeType())) return;
+        if ("parallel,switch,vote,bridge".contains(pathNode.getNodeType())) return;
         seekPathSeries(modelNodeList, modelLineList, pathNode, result);
+    }
+
+    private boolean isBridgeUpperLine(ModelLine line, List<ModelLine> modelLineList) {
+        boolean result = false;
+        for (ModelLine ln : modelLineList) {
+            if (ln.getBeginCell().equals(line.getPicId())) {
+                result = true;
+                break;
+            }
+        }
+        return result;
+    }
+
+    private boolean isBridgeLowerLine(ModelLine line, List<ModelLine> modelLineList) {
+        boolean result = false;
+        for (ModelLine ln : modelLineList) {
+            if (ln.getEndCell().equals(line.getPicId())) {
+                result = true;
+                break;
+            }
+        }
+        return result;
     }
 
     private boolean simplifyParallel(Long modelId,
@@ -786,7 +857,7 @@
                                    boolean hasSimplified) {
         boolean hasSimplifiedMe = false;
         List<ModelNode> startNodes = modelNodeList.stream().filter(item ->
-                "node,vnode,connect,end".contains(item.getNodeType())).collect(Collectors.toList());
+                "bridge".equals(item.getNodeType())).collect(Collectors.toList());
         if (startNodes.size()==0) return hasSimplified;
 
         for (ModelNode startNode : startNodes) {
@@ -819,6 +890,9 @@
         ModelNode node3 = null;
         ModelNode node4 = null;
         ModelNode node5 = null;
+        ModelLine line1To2 = null;
+        ModelLine line4To5 = null;
+/*
         ModelNode nodeTmp1 = modelNodeList.stream().filter(item ->
                 linePair.getLine1().getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
         ModelNode nodeTmp2 = modelNodeList.stream().filter(item ->
@@ -883,6 +957,79 @@
                 lineTo4.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
         if (!nodeTmp1.getId().equals(nodeTmp2.getId())) return false;
         ModelNode endNode = nodeTmp1;
+*/
+        ModelNode nodeTmp1 = modelNodeList.stream().filter(item ->
+                linePair.getLine1().getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        ModelNode nodeTmp2 = modelNodeList.stream().filter(item ->
+                linePair.getLine2().getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (nodeTmp1.getInLineNum()!=1 || nodeTmp1.getOutLineNum()!=1) return false;
+        if (nodeTmp2.getInLineNum()!=1 || nodeTmp2.getOutLineNum()!=1) return false;
+        ModelNode finalNode = nodeTmp1;
+        ModelLine lineToNodeTmp1 = modelLineList.stream().filter(item ->
+                item.getEndCell().equals(finalNode.getPicId())).collect(Collectors.toList()).get(0);
+        ModelNode finalNode1 = nodeTmp2;
+        ModelLine lineToNodeTmp2 = modelLineList.stream().filter(item ->
+                item.getEndCell().equals(finalNode1.getPicId())).collect(Collectors.toList()).get(0);
+        ModelNode nodeTmp3 = modelNodeList.stream().filter(item ->
+                lineToNodeTmp1.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        ModelNode nodeTmp4 = modelNodeList.stream().filter(item ->
+                lineToNodeTmp2.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (nodeTmp3.getId().equals(nodeTmp4.getId())) return false;
+        boolean isBridgeUpperLine1 = isBridgeUpperLine(lineToNodeTmp1, modelLineList);
+        boolean isBridgeUpperLine2 = isBridgeUpperLine(lineToNodeTmp2, modelLineList);
+        if (!isBridgeUpperLine1 && !isBridgeUpperLine2) return false;
+        if (isBridgeUpperLine1 && isBridgeUpperLine2) return false;
+        boolean isBridgeLowerLine1 = isBridgeLowerLine(lineToNodeTmp1, modelLineList);
+        boolean isBridgeLowerLine2 = isBridgeLowerLine(lineToNodeTmp2, modelLineList);
+        if (!isBridgeLowerLine1 && !isBridgeLowerLine2) return false;
+        if (isBridgeLowerLine1 && isBridgeLowerLine2) return false;
+        if (isBridgeUpperLine1) {
+            line1To2 = lineToNodeTmp1;
+            line4To5 = lineToNodeTmp2;
+            node2 = nodeTmp1;
+            node5 = nodeTmp2;
+        } else {
+            line1To2 = lineToNodeTmp2;
+            line4To5 = lineToNodeTmp1;
+            node2 = nodeTmp2;
+            node5 = nodeTmp1;
+        }
+        ModelLine finalLine = line1To2;
+        ModelLine lineTo3 = modelLineList.stream().filter(item ->
+                item.getBeginCell().equals(finalLine.getPicId())).collect(Collectors.toList()).get(0);
+        ModelLine finalLine1 = line4To5;
+        ModelLine lineFrom3 = modelLineList.stream().filter(item ->
+                item.getEndCell().equals(finalLine1.getPicId())).collect(Collectors.toList()).get(0);
+        ModelLine finalLine2 = lineTo3;
+        ModelNode node3Candidate1 = modelNodeList.stream().filter(item ->
+                finalLine2.getEndCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        ModelLine finalLine3 = lineFrom3;
+        ModelNode node3Candidate2 = modelNodeList.stream().filter(item ->
+                finalLine3.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (!node3Candidate1.getId().equals(node3Candidate2.getId())) return false;
+        node3 = node3Candidate1;
+        if (node3.getInLineNum()!=1 || node3.getOutLineNum()!=1) return false;
+        ModelLine finalLine4 = line1To2;
+        node1 = modelNodeList.stream().filter(item ->
+                finalLine4.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (node1.getInLineNum()!=1 || node1.getOutLineNum()!=1) return false;
+        ModelLine finalLine5 = line4To5;
+        node4 = modelNodeList.stream().filter(item ->
+                finalLine5.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (node4.getInLineNum()!=1 || node4.getOutLineNum()!=1) return false;
+        ModelNode finalNode3 = node1;
+        ModelLine lineTo1 = modelLineList.stream().filter(item ->
+                item.getEndCell().equals(finalNode3.getPicId())).collect(Collectors.toList()).get(0);
+        ModelNode finalNode4 = node4;
+        ModelLine lineTo4 = modelLineList.stream().filter(item ->
+                item.getEndCell().equals(finalNode4.getPicId())).collect(Collectors.toList()).get(0);
+        nodeTmp1 = modelNodeList.stream().filter(item ->
+                lineTo1.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        nodeTmp2 = modelNodeList.stream().filter(item ->
+                lineTo4.getBeginCell().equals(item.getPicId())).collect(Collectors.toList()).get(0);
+        if (!nodeTmp1.getId().equals(nodeTmp2.getId())) return false;
+        ModelNode endNode = nodeTmp1;
+
         List<ModelNode> branchNodeList = new ArrayList<>();
         branchNodeList.add(node1);
         branchNodeList.add(node2);
@@ -890,6 +1037,11 @@
         branchNodeList.add(node4);
         branchNodeList.add(node5);
 
+        modelNodeAndVnodeList.add(startNode);
+        replaceToVnode("bridge", modelId, modelNodeList, modelLineList,
+                algorithmList, modelNodeAndVnodeList, startNode, endNode, branchNodeList);
+
+/*
         if ("connect".equals(startNode.getNodeType()) && startNode.getInLineNum()==2) {
             // 鏇挎崲鎴愯櫄鑺傜偣
             modelNodeAndVnodeList.add(startNode);
@@ -922,6 +1074,7 @@
                     algorithmList, modelNodeAndVnodeList, vnode, endNode, branchNodeList);
             calcInOutLineNum(startNode, modelLineList);
         }
+*/
 
         return true;
     }

--
Gitblit v1.9.1