From 17c00b467d3b495ef37ef9c83a7422fc400b8f6d Mon Sep 17 00:00:00 2001
From: xyc <jc_xiong@hotmail.com>
Date: 星期五, 16 八月 2024 16:02:26 +0800
Subject: [PATCH] 解析模型时,将二项分布参数保持到数据库(表model_node_algorithm)。

---
 modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java |  364 +++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 321 insertions(+), 43 deletions(-)

diff --git a/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java b/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java
index 10595e9..f014eb1 100644
--- a/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java
+++ b/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java
@@ -2,24 +2,30 @@
 
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONArray;
+import cn.hutool.json.XML;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.spire.pdf.tables.table.convert.Convert;
 import com.zt.common.exception.RenException;
 import com.zt.common.service.BaseService;
 import com.zt.common.servlet.Result;
+import com.zt.common.utils.TreeUtils;
 import com.zt.common.utils.UUIDUtil;
 import com.zt.life.modules.mainPart.basicInfo.dao.ParamDataDao;
 import com.zt.life.modules.mainPart.basicInfo.dao.XhProductModelDao;
 import com.zt.life.modules.mainPart.basicInfo.model.ParamData;
 import com.zt.life.modules.mainPart.basicInfo.model.XhProductModel;
+import com.zt.life.modules.mainPart.basicInfo.service.XhProductModelService;
 import com.zt.life.modules.mainPart.taskReliability.dao.*;
 import com.zt.common.utils.JsonUtils2;
 import com.zt.life.modules.mainPart.taskReliability.dao.SimulatAssessDao;
 import com.zt.life.modules.mainPart.taskReliability.dao.TimeDiagramDao;
+import com.zt.life.modules.mainPart.taskReliability.dto.*;
 import com.zt.life.modules.mainPart.taskReliability.dto.ProductStatusDto;
-import com.zt.life.modules.mainPart.taskReliability.dto.TaskModelCheckResult;
+import com.zt.life.modules.mainPart.taskReliability.dto.TaskModelCheckResultDto;
+import com.zt.life.modules.mainPart.taskReliability.dto.TaskPhaseConstraintDto;
 import com.zt.life.modules.mainPart.taskReliability.model.*;
 import com.zt.life.modules.mainPart.utils.GetStringSpace;
+import org.apache.commons.io.IOUtils;
 import org.dom4j.Document;
 import org.dom4j.DocumentHelper;
 import org.dom4j.Element;
@@ -27,7 +33,6 @@
 import org.dom4j.io.XMLWriter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import com.zt.life.modules.mainPart.taskReliability.dto.StatusDto;
 import com.zt.life.modules.mainPart.taskReliability.model.ModelRbd;
 import com.zt.life.modules.mainPart.taskReliability.model.SimulatAssess;
 import com.zt.life.modules.mainPart.taskReliability.model.SimulatAssessTaskPhaseModel;
@@ -38,13 +43,8 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.io.BufferedReader;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.io.StringWriter;
+import java.io.*;
 import java.util.*;
-import java.io.File;
-import java.io.IOException;
 import java.util.stream.Collectors;
 
 
@@ -76,7 +76,7 @@
     @Autowired
     private TaskService taskService;
     @Autowired
-    private TaskPhaseService taskPhaseService;
+    private XhProductModelService xhProductModelService;
     @Autowired
     private SimulatAssessTaskPhaseModelService simulatAssessTaskPhaseModelService;
     @Autowired
@@ -111,6 +111,8 @@
     Map<String, JSONObject> templetsMap = new HashMap<>();
     Map<String, String> templetsStrMap = new HashMap<>();
 
+    private JSONObject xmlJSONObj;
+
 
     /**
      * 鍒嗛〉鏌ヨ
@@ -135,8 +137,12 @@
         return baseDao.getNumById(productId, taskModelId);
     }
 
-    public List<SimulatAssess> getList(Long productId, Long taskModelId) {
-        return baseDao.getList(productId, taskModelId);
+    public List<SimulatAssess> getList(Long taskModelId) {
+        return baseDao.getList(taskModelId);
+    }
+
+    public SimulatAssess getByTaskId(Long taskModelId) {
+        return baseDao.getByTaskId(taskModelId);
     }
 
     public SimulatAssess getParams(Long id, Long taskModelId) {
@@ -206,9 +212,9 @@
                 x2 = x1 + status.getTimes() * pointNumPerHour + 5;
                 JSONObject lineJson = new JSONObject(templetsStrMap.get(status.getStatus()));
                 setlineXy(lineJson, x1, y, x2, y, "");
-                JsonUtils2.setJsonValueByPath(lineJson,"data/status".split("/"),status.getStatus());
-                JsonUtils2.setJsonValueByPath(lineJson,"data/startTimes".split("/"),String.format("%.4f", x1));
-                JsonUtils2.setJsonValueByPath(lineJson,"data/endTimes".split("/"),String.format("%.4f", x1 + status.getTimes()));
+                JsonUtils2.setJsonValueByPath(lineJson, "data/status".split("/"), status.getStatus());
+                JsonUtils2.setJsonValueByPath(lineJson, "data/startTimes".split("/"), String.format("%.4f", x1));
+                JsonUtils2.setJsonValueByPath(lineJson, "data/endTimes".split("/"), String.format("%.4f", x1 + status.getTimes()));
                 JsonUtils2.setJsonValueByPath(lineJson, "id".split("/"), UUIDUtil.generateId().toString());
                 x1 = x2 - 5;
                 jsonArray.add(lineJson);
@@ -675,7 +681,7 @@
     public Result simulate(SimulatAssess simulatAssess) {
         Result result = null;
         // 1. 妫�鏌ユā鍨嬪畬鏁存��
-        List<TaskModelCheckResult> chkResult = taskService.checkTaskModel(simulatAssess.getProductId(),
+        List<TaskModelCheckResultDto> chkResult = taskService.checkTaskModel(simulatAssess.getProductId(),
                 simulatAssess.getTaskModelId());
         if (chkResult.size() > 0) {
             result = Result.error("妯″瀷涓嶅畬鏁达紝璇锋鏌ユā鍨嬪畾涔夊強鍙傛暟閰嶇疆銆�");
@@ -782,7 +788,6 @@
         Long taskId = simulatAssess.getTaskModelId();
         Task task = taskService.get(taskId);
         List<TaskBinoParam> binoParams = taskBinoParamDao.getBinoParams(taskId);
-        List<TaskRepairParam> taskRepairParams = taskRepairParamDao.getTaskRepairParams(taskId);
 
         // 1. 璁$畻鍚勪换鍔¢樁娈电殑杩愯鏃堕暱
         List<TaskPhase> taskPhases = calcTaskPhaseDuration(task);
@@ -801,12 +806,12 @@
             Element root = document.addElement("des");
             root.addAttribute("name", "General system");
             addTasksTag(taskPhaseModelAll, root);
-            addModelsTag(productId,
+            addModelsTag(taskId,
+                    productId,
                     productList,
                     paramDataList,
                     taskPhaseModelAll,
                     binoParams,
-                    taskRepairParams,
                     root,
                     failureModels, repairModels);
             addFailureModelsTag(failureModels, root);
@@ -854,7 +859,8 @@
             satpm.setPhaseName(phase.getPhaseName());
             satpm.setPhaseDurationRate(phase.getPhaseDurationRate());
             satpm.setPhaseDuration(phase.getPhaseDuration());
-            satpm.setPhaseConstraint(null); // TODO
+            satpm.setPhaseConstraint(tpm.getPhaseConstraints().stream().map(item ->
+                    item.getProductId().toString()).collect(Collectors.joining(",")));
             satpm.setGkId(tpm.getOperatConditId());
             satpm.setGkName(tpm.getOperatConditName());
             satpm.setGkDurationRate(tpm.getOperatConditDurationRate());
@@ -871,6 +877,11 @@
             Element taskTag = tasksTag.addElement("task");
             taskTag.addAttribute("duration", String.valueOf(taskPhaseModel.getOperatConditDuration()));
             taskTag.addAttribute("model", taskPhaseModel.getOperatConditId().toString());
+            if (null != taskPhaseModel.getPhaseConstraints() && taskPhaseModel.getPhaseConstraints().size() > 0) {
+                taskTag.addAttribute("NAM",
+                        taskPhaseModel.getPhaseConstraints().stream().map(item ->
+                                item.getProductId().toString()).collect(Collectors.joining(",")));
+            }
         }
     }
 
@@ -902,7 +913,7 @@
                     ele.addAttribute("value", String.valueOf(failureModel.getParam3()));
                     break;
                 case FailureModel.TYPE_FIX:
-                    ele = failureModelTag.addElement("unreliability");
+                    ele = failureModelTag.addElement("reliability");
                     ele.addAttribute("value", String.valueOf(failureModel.getParam1()));
                     break;
                 default:
@@ -945,6 +956,10 @@
             double duration = taskPhase.getPhaseDuration() * taskPhaseModel.getOperatConditDurationRate() / totalRate;
             taskPhaseModel.setOperatConditDuration(duration);
             sum += duration;
+
+            List<TaskPhaseConstraintDto> taskRepairConstraints = taskRepairParamDao.getTaskRepairConstraints(taskPhase.getTaskId(),
+                    taskPhaseModel.getPhaseId(), taskPhaseModel.getOperatConditId());
+            taskPhaseModel.setPhaseConstraints(taskRepairConstraints);
             taskPhaseModelAll.add(taskPhaseModel);
         }
         // 鎶婇浂澶磋ˉ鍒版渶鍚庝竴涓伐鍐垫ā鍨�
@@ -968,12 +983,12 @@
         return taskPhases;
     }
 
-    private void addModelsTag(Long productId,
+    private void addModelsTag(Long taskId,
+                              Long productId,
                               List<XhProductModel> productList,
                               List<ParamData> paramDataList,
                               List<TaskPhaseModel> taskPhaseModelAll,
                               List<TaskBinoParam> binoParams,
-                              List<TaskRepairParam> taskRepairParams,
                               Element root,
                               List<FailureModel> failureModels,
                               List<RepairModel> repairModels) {
@@ -992,28 +1007,32 @@
                     "end".equals(item.getAlgorithmType())).collect(Collectors.toList()).get(0);
             ModelNode computerNode = modelNodeAndVnodeList.stream().filter(item ->
                     endAlgo.getComputerList().equals(item.getId().toString())).collect(Collectors.toList()).get(0);
-            node2DOM(productId,
+            node2DOM(taskId,
+                    taskPhaseModel,
+                    gkModelTop.getModelId(),
+                    productId,
                     productList,
                     paramDataList,
                     gkModelsAssembled,
                     algorithmList,
                     modelNodeAndVnodeList,
                     binoParams,
-                    taskRepairParams,
                     computerNode, modelTag,
                     failureModels, repairModels);
         }
     }
 
     // 閫掑綊鍑芥暟
-    private void node2DOM(Long productId,
+    private void node2DOM(Long taskId,
+                          TaskPhaseModel taskPhaseModel,
+                          Long modelId,
+                          Long productId,
                           List<XhProductModel> productList,
                           List<ParamData> paramDataList,
                           List<OperatConditModel> gkModelsAssembled,
                           List<Algorithm> algorithmList,
                           List<ModelNode> modelNodeAndVnodeList,
                           List<TaskBinoParam> binoParams,
-                          List<TaskRepairParam> taskRepairParams,
                           ModelNode node,
                           Element parent,
                           List<FailureModel> failureModels,
@@ -1032,37 +1051,53 @@
                         "end".equals(item.getAlgorithmType())).collect(Collectors.toList()).get(0);
                 ModelNode computerNode = modelNodeAndVnodeListSub.stream().filter(item ->
                         endAlgo.getComputerList().equals(item.getId().toString())).collect(Collectors.toList()).get(0);
-                node2DOM(product.getId(),
+                node2DOM(taskId,
+                        taskPhaseModel,
+                        gkModel.getModelId(),
+                        product.getId(),
                         productList,
                         paramDataList,
                         gkModelsAssembled,
                         algorithmListSub,
                         modelNodeAndVnodeListSub,
                         binoParams,
-                        taskRepairParams,
                         computerNode, parent,
                         failureModels, repairModels);
             } else if ("5".equals(product.getProductType())) {
                 // 璁惧
-                ParamData paramData = paramDataList.stream().filter(item ->
-                        dataId.equals(item.getProductId())).collect(Collectors.toList()).get(0);
                 Element nodeTag = parent.addElement("node");
                 nodeTag.addAttribute("name", dataId.toString());
                 nodeTag.addAttribute("type", "node");
 
-                FailureModel failureModel = new FailureModel();
-                failureModel.setId(UUIDUtil.generateId());
-                failureModel.setType(FailureModel.TYPE_EXP);
-                failureModel.setParam1(1.0 / paramData.getTaskMtbcfRegulate());
+                ParamData paramData = paramDataList.stream().filter(item ->
+                        dataId.equals(item.getProductId())).collect(Collectors.toList()).get(0);
+                Double ratio = paramData.getTaskMtbcfOperatingRatio();
+                if (null != ratio && ratio > 0) {
+                    // 闂存柇鍨嬭澶囩殑澶勭悊
+                    double cycon = taskPhaseModel.getOperatConditDuration() * ratio;
+                    double cycdown = taskPhaseModel.getOperatConditDuration() - cycon;
+                    nodeTag.addAttribute("cycon", String.valueOf(cycon));
+                    nodeTag.addAttribute("cycdown", String.valueOf(cycdown));
+                }
+                TaskBinoParam taskBinoParam = null;
+                if (3 == paramData.getReliabDistribType()) {
+                    // 浜岄」鍒嗗竷澶勭悊
+                    taskBinoParam = binoParams.stream()
+                            .filter(item -> taskId.equals(item.getTaskId()))
+                            .filter(item -> taskPhaseModel.getPhaseId().equals(item.getPhaseId()))
+                            .filter(item -> taskPhaseModel.getOperatConditId().equals(item.getOperatConditId()))
+                            .filter(item -> modelId.equals(item.getModelId()))
+                            .filter(item -> dataId.equals(item.getProductId()))
+                            .collect(Collectors.toList()).get(0);
+                }
+                FailureModel failureModel = createFailureModel(paramData, taskBinoParam);
                 failureModels.add(failureModel);
-
                 Element failureTag = nodeTag.addElement("failure_model");
                 failureTag.addAttribute("name", failureModel.getId().toString());
+
                 if (1 == paramData.getRepairable()) {
-                    RepairModel repairModel = new RepairModel();
-                    repairModel.setId(UUIDUtil.generateId());
-                    repairModel.setType(RepairModel.TYPE_EXP);
-                    repairModel.setParam1(1.0 / paramData.getRepairMttcr());
+                    // 鍙淮淇�
+                    RepairModel repairModel = createRepairModel(paramData);
                     repairModels.add(repairModel);
                     Element repairTag = nodeTag.addElement("repair_model");
                     repairTag.addAttribute("name", repairModel.getId().toString());
@@ -1094,35 +1129,50 @@
             for (String nodeStr : computerNodeListStr) {
                 ModelNode mn = modelNodeAndVnodeList.stream().filter(item ->
                         nodeStr.equals(item.getId().toString())).collect(Collectors.toList()).get(0);
-                node2DOM(null,
+                node2DOM(taskId,
+                        taskPhaseModel,
+                        modelId,
+                        null,
                         productList,
                         paramDataList,
                         gkModelsAssembled,
                         algorithmList,
                         modelNodeAndVnodeList,
                         binoParams,
-                        taskRepairParams,
                         mn, element,
                         failureModels, repairModels);
             }
         }
     }
 
-    private FailureModel createFailureModel(ParamData paramData) {
+    private FailureModel createFailureModel(ParamData paramData, TaskBinoParam taskBinoParam) {
         FailureModel failureModel = new FailureModel();
         failureModel.setId(UUIDUtil.generateId());
         switch (paramData.getReliabDistribType()) {
             case 1:
+                // 鎸囨暟鍒嗗竷
                 failureModel.setType(FailureModel.TYPE_EXP);
                 failureModel.setParam1(1.0 / paramData.getTaskMtbcfRegulate());
                 break;
             case 2:
+                // 濞佸竷灏斿垎甯�
                 failureModel.setType(FailureModel.TYPE_WBL);
                 failureModel.setParam2(paramData.getTaskMtbcfOtherParams2());
                 failureModel.setParam3(paramData.getTaskMtbcfOtherParams3());
                 break;
             case 3:
-                failureModel.setType(FailureModel.TYPE_BIN);
+                // 浜岄」鍒嗗竷
+                if (taskBinoParam.getSimulatTimes().intValue() == taskBinoParam.getSuccessTimes().intValue()) {
+                    // 鐩哥瓑鍒欎负鎴愯触鍨�
+                    failureModel.setType(FailureModel.TYPE_FIX);
+                    failureModel.setParam1(taskBinoParam.getSuccessRate());
+                } else {
+                    // 浜岄」鍒嗗竷
+                    failureModel.setType(FailureModel.TYPE_BIN);
+                    failureModel.setParam1(taskBinoParam.getSuccessRate());
+                    failureModel.setParam2(taskBinoParam.getSimulatTimes());
+                    failureModel.setParam3(taskBinoParam.getSuccessTimes());
+                }
                 break;
             default:
                 break;
@@ -1130,4 +1180,232 @@
 
         return failureModel;
     }
+
+    private RepairModel createRepairModel(ParamData paramData) {
+        RepairModel repairModel = new RepairModel();
+        repairModel.setId(UUIDUtil.generateId());
+        switch (paramData.getRepairDistribType()) {
+            case 1:
+                // 鎸囨暟鍒嗗竷
+                repairModel.setType(FailureModel.TYPE_EXP);
+                repairModel.setParam1(1.0 / paramData.getRepairMttcr());
+                break;
+            case 2:
+                // 濞佸竷灏斿垎甯�
+                repairModel.setType(FailureModel.TYPE_WBL);
+                repairModel.setParam2(paramData.getRepairMttcrOtherParams2());
+                repairModel.setParam3(paramData.getRepairMttcrOtherParams3());
+                break;
+            case 3:
+                // 浜岄」鍒嗗竷锛堢淮淇病鏈夛級
+                break;
+            default:
+                break;
+        }
+
+        return repairModel;
+    }
+
+    public List<WeakDto> getReliabilityWeakness(Long fzId, Long taskId, Long productId) {
+        String filePath = path + "/" + fzId + "/" + "result.xml";
+        List<WeakDto> list = new ArrayList<>();
+        Map<Long, WeakDto> map = new HashMap<>();
+        String xml = null;
+        InputStream in = null;
+        try {
+            in = new FileInputStream(filePath);
+            xml = IOUtils.toString(in);
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                in.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        List<WeakDto> productList = baseDao.getProductList(taskId, productId);
+        for (WeakDto dto : productList) {
+            map.put(dto.getId(), dto);
+        }
+        JSONObject xmlJSONObj = XML.toJSONObject(xml);
+        JSONArray jsonArray = xmlJSONObj.getJSONObject("ResultNodes").getJSONArray("ResultNode");
+        for (int i = 0; i < jsonArray.size(); i++) {
+            WeakDto data = new WeakDto();
+            Long productId1 = null;
+            Object nameValue = jsonArray.getJSONObject(i).get("name");
+            if (nameValue instanceof Long) {
+                productId1 = (Long) nameValue;
+                WeakDto weakDto = map.get(productId1);
+                Double mtbfTime = null;
+
+                Double mtbf = (Double) jsonArray.getJSONObject(i).get("mttf");
+                Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
+                Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
+
+                data.setMtbf(mtbf);
+                data.setMttr(mttr);
+                data.setMsr(msr);
+
+                if (weakDto != null) {
+                    data.setId(weakDto.getId());
+                    data.setSort(weakDto.getSort());
+                    data.setPid(weakDto.getPid());
+                    data.setName(weakDto.getName());
+                    data.setProductType(weakDto.getProductType());
+                    data.setTimeRate(weakDto.getTimeRate());
+                    mtbfTime = mtbf / weakDto.getTimeRate();
+                }
+
+                data.setMtbfTime(mtbfTime);
+                data.setIsWeak(0);
+
+                list.add(data);
+            }
+        }
+        List<WeakDto> treeList = TreeUtils.build(list);
+        this.getIsweak(treeList.get(0).getChildren());
+        return treeList;
+    }
+
+    private void getIsweak(List<WeakDto> treeList) {
+        WeakDto minDto = null;
+        for (WeakDto dto : treeList) {
+            if (dto.getProductType() == 10)
+                continue;
+            if (minDto == null) {
+                minDto = dto;
+            }
+            if (dto.getMtbfTime() < minDto.getMtbfTime()) {
+                minDto = dto;
+            }
+        }
+        minDto.setIsWeak(1);
+        if (minDto.getChildren().size() > 0) {
+            this.getIsweak(minDto.getChildren());
+        }
+    }
+
+    public SchemeComparDto SchemeCompar(String[] taskList, Long showProductId) {
+        SchemeComparDto dto = new SchemeComparDto();
+        List<SimulaDataDto> dataDtoList = new ArrayList<>();
+        List<SchemeComparCurve> curveList = new ArrayList<>();
+        List<Double> xData = new ArrayList<>();
+        SimulatAssess simulatAssess;
+        SimulaDataDto data;
+
+        Task task;
+        for (String taskId : taskList) {
+            Long taskModelId = Long.parseLong(taskId);
+            task = taskService.get(taskModelId);
+            simulatAssess = this.getByTaskId(taskModelId);
+            SimulaDataDto resultData;
+            if (showProductId!=null){
+                simulatAssess.setShowProductId(showProductId);
+                resultData =this.getResultData(simulatAssess);
+            }else{
+                resultData = this.getResultXML(simulatAssess);
+            }
+
+            data = resultData;
+            data.setName(task.getTaskName());
+            dataDtoList.add(data);
+            xData = resultData.getCurveParam().getXData();
+
+            SchemeComparCurve curve = new SchemeComparCurve();
+            curve.setName(task.getTaskName());
+            curve.setSmooth(true);
+            curve.setType("line");
+            curve.setData(resultData.getCurveParam().getYData());
+            curveList.add(curve);
+        }
+        dto.setXDataList(xData);
+        dto.setDataList(dataDtoList);
+        dto.setCurveList(curveList);
+        return dto;
+    }
+
+    public SimulaDataDto getResultXML(SimulatAssess simulatAssess) {
+        if (simulatAssess.getDataType() != null && simulatAssess.getDataType().equals("fz")) {
+            Integer num = this.getNumById(simulatAssess.getProductId(), simulatAssess.getTaskModelId());
+            simulatAssess.setName("浠跨湡璁板綍" + (num + 1));
+            this.insert(simulatAssess);
+        }
+        String filePath = path + "/" + simulatAssess.getId() + "/" + "result.xml";
+        String xml = null;
+        InputStream in = null;
+
+        try {
+            in = new FileInputStream(filePath);
+            xml = IOUtils.toString(in);
+        } catch (IOException e) {
+            e.printStackTrace();
+            throw new RenException("鏂囦欢涓嶅瓨鍦ㄦ垨鑰呮枃浠舵墦涓嶅紑");
+        } finally {
+            try {
+                in.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        xmlJSONObj = XML.toJSONObject(xml);
+        simulatAssess.setShowProductId(simulatAssess.getProductId());
+        SimulaDataDto data = this.getResultData(simulatAssess);
+        return data;
+    }
+
+    public SimulaDataDto getResultData(SimulatAssess simulatAssess) {
+        SimulaDataDto data = new SimulaDataDto();
+        CurveParam param = new CurveParam();
+        Double samplPeriod = Double.valueOf(simulatAssess.getSamplPeriod());
+        samplPeriod = samplPeriod / 60;
+        JSONArray jsonArray = xmlJSONObj.getJSONObject("ResultNodes").getJSONArray("ResultNode");
+        for (int i = 0; i < jsonArray.size(); i++) {
+            Long productId = null;
+            Object nameValue = jsonArray.getJSONObject(i).get("name");
+            if (nameValue instanceof Long) {
+                productId = (Long) nameValue;
+                if (productId.equals(simulatAssess.getShowProductId())) {
+                    Object object = jsonArray.getJSONObject(i).get("phase");
+                    List<Double> doubleArray = new ArrayList<>();
+                    List<Double> xList = new ArrayList<>();
+                    String availability = null;
+                    if (object instanceof JSONArray) {
+                        JSONArray jsonArray2 = jsonArray.getJSONObject(i).getJSONArray("phase");
+                        for (int j = 0; j < jsonArray2.size(); j++) {
+                            if (availability != null) {
+                                availability = availability + " " + jsonArray2.getJSONObject(j).get("availability");
+                            } else {
+                                availability = (String) jsonArray2.getJSONObject(j).get("availability");
+                            }
+                        }
+                    } else {
+                        JSONObject jsonObject2 = jsonArray.getJSONObject(i).getJSONObject("phase");
+                        availability = (String) jsonObject2.get("availability");
+                    }
+
+                    String[] arr = availability.split(" ");
+                    // 閬嶅巻瀛愬瓧绗︿覆鏁扮粍锛屽皢姣忎釜鍏冪礌杞崲涓篸ouble骞跺瓨鍌ㄥ埌double鏁扮粍涓�
+                    Double j = 0.0;
+                    for (int a = 0; a < arr.length; a++) {
+                        j = samplPeriod + j;
+                        doubleArray.add(Double.parseDouble(arr[a]));
+                        xList.add(j);
+                    }
+
+                    param.setXData(xList);
+                    param.setYData(doubleArray);
+                    Double mtbf = (Double) jsonArray.getJSONObject(i).get("mttf");
+                    Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
+                    Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
+                    data.setMtbf(mtbf);
+                    data.setMttr(mttr);
+                    data.setMsr(msr);
+                }
+                data.setCurveParam(param);
+            }
+        }
+        return data;
+    }
 }

--
Gitblit v1.9.1