From 664db98c9e8595ce4dd636a27f480e3a08b81ff5 Mon Sep 17 00:00:00 2001
From: xyc <jc_xiong@hotmail.com>
Date: 星期五, 21 二月 2025 11:13:51 +0800
Subject: [PATCH] 新增可忽略的维修时间
---
modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java | 1337 +++++++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 1,127 insertions(+), 210 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 0f94aaa..af14543 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
@@ -5,11 +5,13 @@
import cn.hutool.json.XML;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.spire.pdf.tables.table.convert.Convert;
+import com.zt.common.db.query.QueryFilter;
import com.zt.common.exception.RenException;
import com.zt.common.service.BaseService;
-import com.zt.common.servlet.Result;
+import com.zt.common.utils.CommonUtils;
import com.zt.common.utils.TreeUtils;
import com.zt.common.utils.UUIDUtil;
+import com.zt.life.export.service.DownloadService;
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;
@@ -24,7 +26,10 @@
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 com.zt.life.modules.mainPart.utils.OSUtils.ProcessUtils;
+import org.apache.commons.beanutils.PropertyUtils;
import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.StringUtils;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
@@ -42,6 +47,9 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.util.*;
import java.util.stream.Collectors;
@@ -110,17 +118,7 @@
Map<Integer, String> templetsStrMap2 = new HashMap<>();
private JSONObject xmlJSONObj;
-
-
- /**
- * 鍒嗛〉鏌ヨ
- *
- * @param queryFilter
- * @return
- */
- /* public List<SimulatAssess> page(QueryFilter queryFilter) {
- return baseDao.getList(queryFilter.getQueryParams());
- }*/
+
/**
* 鍒犻櫎
@@ -196,9 +194,9 @@
double pointNumPerHour = 60.0 / simulatAssess.getSamplPeriod();
//鏃跺簭鍥剧嚎
- List<List<TimeDiagramStatusDto>> lineArray = new ArrayList();
+ List<TimeDiagramStatusDto> statusDtoList = new ArrayList<>();
+ List<TimeDiagramStatusDto> statusDtoListOld = new ArrayList<>();
for (int i = 0; i < list.size(); i++) {
- List<TimeDiagramStatusDto> statusDtoList = new ArrayList<>();
x1 = 0;
groupY = groupHeight * i;
ProductStatusDto dto = list.get(i);
@@ -228,7 +226,11 @@
break;
}
x2 = x1 + status.getTimes() * pointNumPerHour + 5;
- statusDtoList.add(new TimeDiagramStatusDto(x1, x2, status2));
+ if (i == 0) {
+ statusDtoList.add(new TimeDiagramStatusDto(x1, x2, status2));
+ } else {
+ statusDtoListOld.add(new TimeDiagramStatusDto(x1, x2, status2));
+ }
JSONObject lineJson = new JSONObject(templetsStrMap.get(status.getStatus()));
setlineXy(lineJson, x1, y, x2, y, "");
JsonUtils2.setJsonValueByPath(lineJson, "data/status".split("/"), status.getStatus());
@@ -239,13 +241,11 @@
x1 = x2 - 5;
jsonArray.add(lineJson);
}
- lineArray.add(statusDtoList);
-
JSONObject textJson = new JSONObject(templetsStrMap.get("text"));
JsonUtils2.setJsonValueByPath(textJson, "id".split("/"), UUIDUtil.generateId().toString());
JsonUtils2.setJsonValueByPath(textJson, "attrs/label/textWrap/text".split("/"), dto.getName());
JsonUtils2.setJsonValueByPath(textJson, "position/x".split("/"), 20);
- JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y - 15);
+ JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y + 10);
jsonArray3.add(textJson);
}
@@ -324,67 +324,76 @@
curPointHour += periodHour;
}
+ List<TimeDiagramStatusDto> statusDtoListNew = new ArrayList<>();
+ while (statusDtoListOld.size() > 0) {
+ //statusDtoListOld.stream().sorted(Comparator.comparing(TimeDiagramStatusDto::getX1)).collect(Collectors.toList());
+ statusDtoListOld.sort(Comparator.comparing(TimeDiagramStatusDto::getX1, Comparator.naturalOrder()));
+ TimeDiagramStatusDto nextStatusDto = statusDtoListOld.get(0);
+ if (statusDtoListNew.size() == 0) {
+ statusDtoListNew.add(nextStatusDto);
+ } else {
+ TimeDiagramStatusDto currentStatusDto = statusDtoListNew.get(statusDtoListNew.size() - 1);
+ if (nextStatusDto.getStatus() < currentStatusDto.getStatus()) {
+ if (nextStatusDto.getX1() == currentStatusDto.getX1() && nextStatusDto.getX2() == currentStatusDto.getX2()) {
+ currentStatusDto.setStatus(nextStatusDto.getStatus());
+ } else if (nextStatusDto.getX1() == currentStatusDto.getX1() && nextStatusDto.getX2() < currentStatusDto.getX2()) {
+ statusDtoListOld.add(new TimeDiagramStatusDto(nextStatusDto.getX2(), currentStatusDto.getX2(), currentStatusDto.getStatus()));
+ currentStatusDto.setStatus(nextStatusDto.getStatus());
+ currentStatusDto.setX2(nextStatusDto.getX2());
+ } else if (nextStatusDto.getX1() == currentStatusDto.getX1() && nextStatusDto.getX2() > currentStatusDto.getX2()) {
+ currentStatusDto.setStatus(nextStatusDto.getStatus());
+ currentStatusDto.setX2(nextStatusDto.getX2());
+ } else if (nextStatusDto.getX1() > currentStatusDto.getX1() && nextStatusDto.getX2() >= currentStatusDto.getX2()) {
+ currentStatusDto.setX2(nextStatusDto.getX1());
+ statusDtoListNew.add(new TimeDiagramStatusDto(nextStatusDto.getX1(), nextStatusDto.getX2(), nextStatusDto.getStatus()));
+ } else if (nextStatusDto.getX1() > currentStatusDto.getX1() && nextStatusDto.getX2() < currentStatusDto.getX2()) {
+ statusDtoListNew.add(new TimeDiagramStatusDto(nextStatusDto.getX1(), nextStatusDto.getX2(), nextStatusDto.getStatus()));
+ statusDtoListOld.add(new TimeDiagramStatusDto(nextStatusDto.getX2(), currentStatusDto.getX2(), currentStatusDto.getStatus()));
+ currentStatusDto.setX2(nextStatusDto.getX1());
+ }
+ } else {
+ if (nextStatusDto.getX1() >= currentStatusDto.getX2()) {
+ statusDtoListNew.add(new TimeDiagramStatusDto(nextStatusDto.getX1(), nextStatusDto.getX2(), nextStatusDto.getStatus()));
+ } else if (nextStatusDto.getX2() > currentStatusDto.getX2()) {
+ statusDtoListOld.add(new TimeDiagramStatusDto(currentStatusDto.getX2(), nextStatusDto.getX2(), nextStatusDto.getStatus()));
+ }
+ }
+ }
+ statusDtoListOld.remove(0);
+ }
timeDiagramDto.setTotalWidth(x2);
double pointRate = timeDiagramDto.getTotalWidth() / timeDiagramDto.getSmallWidth();
- List<TimeDiagramStatusDto> subStatusDtoList = new ArrayList<>();
- int lastStatus = 5;
- boolean isFirst = true;
- x1 = 0;
- for (double i = 0; i < timeDiagramDto.getSmallWidth(); i = i + timeDiagramDto.getMinPointNum()) {
- int netStatus = 5;
- for (int j = 1; j < list.size(); j++) {
- if (i >= 448) {
- System.out.println(111);
- }
- int tmpStatus = getPointStatus(lineArray.get(j), i * pointRate, (i + timeDiagramDto.getMinPointNum()) * pointRate - 1);
- if (tmpStatus < netStatus) {
- netStatus = tmpStatus;
- }
- }
- if (!isFirst) {
- if (lastStatus != netStatus) {
- subStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
- lastStatus = netStatus;
- x1 = i;
- }
- } else {
- lastStatus = netStatus;
- isFirst = false;
- }
- x2 = i + timeDiagramDto.getMinPointNum() - 1;
- }
- subStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
+ List<List<TimeDiagramStatusDto>> lineArray = new ArrayList();
+ lineArray.add(statusDtoList);
+ lineArray.add(statusDtoListNew);
- List<TimeDiagramStatusDto> parentStatusDtoList = new ArrayList<>();
- lastStatus = 5;
- isFirst = true;
- x1 = 0;
- for (double i = 0; i < timeDiagramDto.getSmallWidth(); i = i + timeDiagramDto.getMinPointNum()) {
- if (i >= 448) {
- System.out.println(111);
- }
- int netStatus = getPointStatus(lineArray.get(0), i * pointRate, (i + timeDiagramDto.getMinPointNum()) * pointRate - 1);
- if (!isFirst) {
- if (lastStatus != netStatus) {
- parentStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
+ List<List<TimeDiagramStatusDto>> smallStatusDtoList = new ArrayList<>();
+ for (int j = 0; j < lineArray.size(); j++) {
+ List<TimeDiagramStatusDto> tmpStatusDtoList = new ArrayList<>();
+ int lastStatus = 5;
+ Boolean isFirst = true;
+ x1 = 0;
+ for (double i = 0; i < timeDiagramDto.getSmallWidth(); i = i + timeDiagramDto.getMinPointNum()) {
+ int netStatus = getPointStatus(lineArray.get(j), i * pointRate, (i + timeDiagramDto.getMinPointNum()) * pointRate - 1);
+ if (!isFirst) {
+ if (lastStatus != netStatus) {
+ tmpStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
+ lastStatus = netStatus;
+ x1 = i;
+ }
+ } else {
lastStatus = netStatus;
- x1 = i;
+ isFirst = false;
}
- } else {
- lastStatus = netStatus;
- isFirst = false;
+ x2 = i + timeDiagramDto.getMinPointNum() - 1;
}
- x2 = i + timeDiagramDto.getMinPointNum() - 1;
+ tmpStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
+ smallStatusDtoList.add(tmpStatusDtoList);
}
- parentStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
JSONObject jsonObject2 = new JSONObject(modelStr2);
JSONArray jsonArray2 = jsonObject2.getJSONArray("cells");
- List<List<TimeDiagramStatusDto>> smallStatusDtoList = new ArrayList<>();
- smallStatusDtoList.add(parentStatusDtoList);
- smallStatusDtoList.add(subStatusDtoList);
-
y = 10;
for (int i = 0; i < smallStatusDtoList.size(); i++) {
for (TimeDiagramStatusDto status : smallStatusDtoList.get(i)) {
@@ -536,13 +545,42 @@
}
public List<ProductStatusDto> getStatusData(Long productId, Long taskId) {
- List<ProductStatusDto> childList = this.getProduct(productId, taskId);
+
+ List<ProductStatusDto> dbList = this.getProduct(productId, taskId);
+ List<ProductStatusDto> childList = new ArrayList<>();
+ for (ProductStatusDto item : dbList) {
+ int sameNum = item.getSameSbNum() == null ? 1 : item.getSameSbNum();
+ for (int i = 1; i <= sameNum; i++) {
+ try {
+ ProductStatusDto newRow = null;
+ if (sameNum > 1) {
+ newRow = item.clone();
+ } else
+ newRow = item;
+ if ("5".equals(newRow.getProductType())) {
+ newRow.setDeviceNo(i);
+ newRow.setDataId(item.getId().toString() + "-" + i);
+ if (i > 1) {
+ newRow.setName(item.getName() + "-" + i);
+ }
+ } else {
+ newRow.setDeviceNo(0);
+ newRow.setDataId(item.getId().toString());
+ }
+ childList.add(newRow);
+ } catch (CloneNotSupportedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ childList.sort(Comparator.comparing(ProductStatusDto::getDeviceNo, Comparator.naturalOrder()));
for (ProductStatusDto item : childList) {
- JSONArray jsonArray = dialgramJson.getJSONArray(String.valueOf(item.getId()));
+ JSONArray jsonArray = dialgramJson.getJSONArray(item.getDataId());
if (jsonArray != null) {
this.processJSONArray(jsonArray, item, taskId);
}
}
+ childList.removeIf(item -> item.getStatusList().size() == 0);
return childList;
}
@@ -557,7 +595,7 @@
if (jsonArray3.size() == 0) {
StatusDto statusDto = new StatusDto();
statusDto.setTimes(phaseModelList.get(j).getGkDuration());
- statusDto.setStatus("");
+ statusDto.setStatus("M");
productStatusDto.getStatusList().add(statusDto);
} else {
for (int a = 0; a < jsonArray3.size(); a++) {
@@ -571,6 +609,9 @@
}
}
if (status != null || times != null) {
+ if (StringUtils.isBlank(status)) {
+ status = "M";
+ }
StatusDto statusDto = new StatusDto();
statusDto.setTimes(times);
statusDto.setStatus(status);
@@ -606,16 +647,19 @@
}
@Transactional(rollbackFor = Exception.class)
- public Result simulate(SimulatAssess simulatAssess) {
- Result result = null;
+ public List<TaskModelCheckResultDto> simulateChecK(SimulatAssess simulatAssess) {
+ List<TaskModelCheckResultDto> result = null;
// 1. 妫�鏌ユā鍨嬪畬鏁存��
List<TaskModelCheckResultDto> chkResult = taskService.checkTaskModel(simulatAssess.getProductId(),
simulatAssess.getTaskModelId());
if (chkResult.size() > 0) {
- result = Result.ok(chkResult);
- return result;
+ return chkResult;
}
+ return result;
+ }
+ public Boolean simulate(SimulatAssess simulatAssess) {
+ Boolean result = false;
// 2. 缁勮渚涚畻娉曞簱浠跨湡鐨勬ā鍨媥ml
assembleModelXml(simulatAssess);
@@ -625,8 +669,13 @@
return result;
}
- private Result callReliaSimLib(SimulatAssess simulatAssess) {
- Result result = null;
+ public List<SimulatAssess> process(QueryFilter queryFilter) {
+ List<SimulatAssess> page = baseDao.getProcessList(queryFilter.getParams());
+ return queryFilter.getPageList(page);
+ }
+
+ private Boolean callReliaSimLib(SimulatAssess simulatAssess) {
+ Boolean result = false;
InputStream is = null;
BufferedReader br = null;
try {
@@ -648,6 +697,8 @@
} else {
throw new RenException("鏆備笉鏀寔璇ユ搷浣滅郴缁燂紝杩涜鍚姩绠楁硶搴撹绠楋紒");
}
+ long pid = ProcessUtils.getProcessId(process);
+ logger.info("绠楁硶搴揚ID锛�" + pid);
is = process.getInputStream();
// 浠ュ懡浠よ鏂瑰紡璋冪敤绠楁硶搴撴椂锛屾帴鍙ｇ害瀹氳繑鍥炵殑缁撴灉鏄痷tf-8缂栫爜
br = new BufferedReader(new InputStreamReader(is, "utf-8"));
@@ -658,7 +709,9 @@
ReliaSimLibResult rtn = com.alibaba.fastjson.JSONObject.parseObject(line, ReliaSimLibResult.class);
if ("0".equals(rtn.getCode())) {
logger.info("鍚姩鍙潬鎬т豢鐪熻瘎浼扮畻娉曞簱鎴愬姛銆�");
- result = Result.ok();
+ newProcess(simulatAssess, pid, command);
+ update(simulatAssess);
+ result = true;
} else {
String errorMsg = rtn.getErrorMsg();
throw new RenException("鍚姩鍙潬鎬т豢鐪熻瘎浼扮畻娉曞簱澶辫触: errorMsg=" + errorMsg);
@@ -686,6 +739,14 @@
}
return result;
+ }
+
+ public void newProcess(SimulatAssess simulatAssess, long pid, String command) {
+ simulatAssess.setPid(pid);
+ simulatAssess.setCommandLine(command);
+ simulatAssess.setProcessIsAlive(true);
+ simulatAssess.setProcessStartTime(new Date());
+ simulatAssess.setProgress(0);
}
private void setParamToRedis(SimulatAssess simulatAssess) {
@@ -720,6 +781,9 @@
List<ParamData> paramDataList = paramDataDao.getDeviceParams(productId);
Long taskId = simulatAssess.getTaskModelId();
Task task = taskService.get(taskId);
+ if (simulatAssess.getTaskDuration() != null) {
+ task.setTaskDuration(simulatAssess.getTaskDuration());
+ }
List<TaskBinoParam> binoParams = taskBinoParamDao.getBinoParams(taskId);
// 1. 璁＄畻鍚勪换鍔￠樁娈电殑杩愯鏃堕暱
@@ -739,7 +803,8 @@
Element root = document.addElement("des");
root.addAttribute("name", "General system");
addTasksTag(taskPhaseModelAll, root);
- addModelsTag(taskId,
+ addModelsTag(simulatAssess,
+ taskId,
productId,
product.getName(),
product.getNamePath(),
@@ -811,7 +876,8 @@
for (TaskPhaseModel taskPhaseModel : taskPhaseModelAll) {
Element taskTag = tasksTag.addElement("task");
taskTag.addAttribute("duration", String.valueOf(taskPhaseModel.getOperatConditDuration()));
- taskTag.addAttribute("model", taskPhaseModel.getOperatConditId().toString());
+// taskTag.addAttribute("model", taskPhaseModel.getOperatConditId().toString());
+ taskTag.addAttribute("model", taskPhaseModel.getId().toString());
if (null != taskPhaseModel.getPhaseConstraints() && taskPhaseModel.getPhaseConstraints().size() > 0) {
taskTag.addAttribute("NAM",
taskPhaseModel.getPhaseConstraints().stream().map(item ->
@@ -834,11 +900,11 @@
ele.addAttribute("value", String.valueOf(failureModel.getParam1()));
break;
case FailureModel.TYPE_BIN:
- ele = failureModelTag.addElement("reliability");
+ ele = failureModelTag.addElement("p");
ele.addAttribute("value", String.valueOf(failureModel.getParam1()));
ele = failureModelTag.addElement("n");
ele.addAttribute("value", String.valueOf(failureModel.getParam2()));
- ele = failureModelTag.addElement("k");
+ ele = failureModelTag.addElement("m");
ele.addAttribute("value", String.valueOf(failureModel.getParam3()));
break;
case FailureModel.TYPE_WBL:
@@ -875,6 +941,10 @@
ele.addAttribute("value", String.valueOf(repairModel.getParam2()));
ele = repairModelTag.addElement("shape");
ele.addAttribute("value", String.valueOf(repairModel.getParam3()));
+ break;
+ case RepairModel.TYPE_DIRAC:
+ ele = repairModelTag.addElement("repair-time");
+ ele.addAttribute("value", String.valueOf(repairModel.getParam1()));
break;
default:
break;
@@ -918,7 +988,8 @@
return taskPhases;
}
- private void addModelsTag(Long taskId,
+ private void addModelsTag(SimulatAssess simulatAssess,
+ Long taskId,
Long productId,
String productName,
String productNamePath,
@@ -932,7 +1003,8 @@
Element modelsTag = root.addElement("models");
for (TaskPhaseModel taskPhaseModel : taskPhaseModelAll) {
Element modelTag = modelsTag.addElement("model");
- modelTag.addAttribute("name", taskPhaseModel.getOperatConditId().toString());
+// modelTag.addAttribute("name", taskPhaseModel.getOperatConditId().toString());
+ modelTag.addAttribute("name", taskPhaseModel.getId().toString());
List<OperatConditModel> gkModelsAssembled = operatConditModelDao.getGKModelAssembled(
taskPhaseModel.getOperatConditId());
OperatConditModel gkModelTop = gkModelsAssembled.stream().filter(item ->
@@ -944,7 +1016,8 @@
"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(taskId,
+ node2DOM(simulatAssess,
+ taskId,
taskPhaseModel,
gkModelTop.getModelId(),
productId,
@@ -962,7 +1035,8 @@
}
// 閫掑綊鍑芥暟
- private void node2DOM(Long taskId,
+ private void node2DOM(SimulatAssess simulatAssess,
+ Long taskId,
TaskPhaseModel taskPhaseModel,
Long modelId,
Long productId,
@@ -992,7 +1066,8 @@
"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(taskId,
+ node2DOM(simulatAssess,
+ taskId,
taskPhaseModel,
gkModel.getModelId(),
product.getId(),
@@ -1010,15 +1085,16 @@
// 璁惧
Integer deviceNo = node.getDeviceNo();
Element nodeTag = parent.addElement("node");
- nodeTag.addAttribute("name", deviceNo == 0 ? dataId.toString() : dataId.toString()+"-"+deviceNo);
- nodeTag.addAttribute("real_name", deviceNo == 0 ? product.getName() : product.getName()+"-"+deviceNo);
+ nodeTag.addAttribute("name", dataId.toString() + "-" + deviceNo);
+ nodeTag.addAttribute("real_name", product.getName() + "-" + deviceNo);
nodeTag.addAttribute("name_path", product.getNamePath());
nodeTag.addAttribute("type", "node");
ParamData paramData = paramDataList.stream().filter(item ->
dataId.equals(item.getProductId())).collect(Collectors.toList()).get(0);
Double ratio = paramData.getTaskMtbcfOperatingRatio();
- if (null != ratio && ratio > 0) {
+// if (null != ratio && ratio > 0) {
+ if (null != ratio && ratio != 1.0) {
// 闂存柇鍨嬭澶囩殑澶勭悊
double cycon = taskPhaseModel.getOperatConditDuration() * ratio;
double cycdown = taskPhaseModel.getOperatConditDuration() - cycon;
@@ -1032,18 +1108,33 @@
.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 -> modelId.equals(item.getModelId()))
.filter(item -> dataId.equals(item.getProductId()))
.collect(Collectors.toList()).get(0);
}
- FailureModel failureModel = createFailureModel(paramData, taskBinoParam);
+ FailureModel failureModel = null;
+ if (1 == paramData.getRepairable() &&
+ isRepairDirac(simulatAssess.getRepairDiracFlag(), taskPhaseModel, product.getId())) {
+ failureModel = createFailureModelDirac();
+ } else {
+ failureModel = createFailureModel(paramData, taskBinoParam);
+ }
failureModels.add(failureModel);
Element failureTag = nodeTag.addElement("failure_model");
failureTag.addAttribute("name", failureModel.getId().toString());
if (1 == paramData.getRepairable()) {
+ // 鍙拷鐣ョ殑缁翠慨鏃堕棿
+ if (paramData.getNegligibleRepairTime() != null && paramData.getNegligibleRepairTime().doubleValue() > 0) {
+ nodeTag.addAttribute("negligible_repair_time", String.valueOf(paramData.getNegligibleRepairTime()));
+ }
// 鍙淮淇�
- RepairModel repairModel = createRepairModel(paramData);
+ RepairModel repairModel = null;
+ if (isRepairDirac(simulatAssess.getRepairDiracFlag(), taskPhaseModel, product.getId())) {
+ repairModel = createRepairModelDirac(0);
+ } else {
+ repairModel = createRepairModel(paramData);
+ }
repairModels.add(repairModel);
Element repairTag = nodeTag.addElement("repair_model");
repairTag.addAttribute("name", repairModel.getId().toString());
@@ -1078,7 +1169,8 @@
for (String nodeStr : computerNodeListStr) {
ModelNode mn = modelNodeAndVnodeList.stream().filter(item ->
nodeStr.equals(item.getId().toString())).collect(Collectors.toList()).get(0);
- node2DOM(taskId,
+ node2DOM(simulatAssess,
+ taskId,
taskPhaseModel,
modelId,
null,
@@ -1133,23 +1225,55 @@
return failureModel;
}
+ private FailureModel createFailureModelDirac() {
+ FailureModel failureModel = new FailureModel();
+ failureModel.setId(UUIDUtil.generateId());
+ failureModel.setType(FailureModel.TYPE_FIX);
+ failureModel.setParam1(1);
+
+ return failureModel;
+ }
+
+ private boolean isRepairDirac(Boolean repairDiracFlag, TaskPhaseModel taskPhaseModel, Long productId) {
+ boolean result = false;
+
+ if (repairDiracFlag != null && repairDiracFlag) {
+ if (taskPhaseModel.getPhaseConstraints() == null) {
+ result = true;
+ } else {
+ List<TaskPhaseConstraintDto> list = taskPhaseModel.getPhaseConstraints().stream().filter(item ->
+ productId.equals(item.getProductId())).collect(Collectors.toList());
+ if (list.size() == 0) {
+ result = true;
+ }
+ }
+ }
+
+ return result;
+ }
+
+ private RepairModel createRepairModelDirac(double time) {
+ RepairModel repairModel = new RepairModel();
+ repairModel.setId(UUIDUtil.generateId());
+ repairModel.setType(RepairModel.TYPE_DIRAC);
+ repairModel.setParam1(0);
+ return repairModel;
+ }
+
private RepairModel createRepairModel(ParamData paramData) {
RepairModel repairModel = new RepairModel();
repairModel.setId(UUIDUtil.generateId());
switch (paramData.getRepairDistribType()) {
case 1:
// 鎸囨暟鍒嗗竷
- repairModel.setType(FailureModel.TYPE_EXP);
+ repairModel.setType(RepairModel.TYPE_EXP);
repairModel.setParam1(1.0 / paramData.getRepairMttcr());
break;
case 2:
// 濞佸竷灏斿垎甯�
- repairModel.setType(FailureModel.TYPE_WBL);
+ repairModel.setType(RepairModel.TYPE_WBL);
repairModel.setParam2(paramData.getRepairMttcrOtherParams2());
repairModel.setParam3(paramData.getRepairMttcrOtherParams3());
- break;
- case 3:
- // 浜岄」鍒嗗竷锛堢淮淇病鏈夛級
break;
default:
break;
@@ -1160,8 +1284,7 @@
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;
InputStream in = null;
try {
@@ -1181,50 +1304,63 @@
}
- List<WeakDto> productList = baseDao.getProductList(taskId, productId);
- for (WeakDto dto : productList) {
- map.put(dto.getId(), dto);
- }
+ Map<Long, WeakDto> map = new HashMap<>();
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;
- Object nameValue = jsonArray.getJSONObject(i).get("name");
- if (nameValue instanceof Long) {
- productId1 = (Long) nameValue;
- if (map.get(productId1) != null) {
- WeakDto weakDto = map.get(productId1);
- Double mtbfTime = null;
+ String nameValue = jsonArray.getJSONObject(i).get("name").toString();
+ if (StringUtils.isNotBlank(nameValue)) {
+ productId1 = Convert.toLong(nameValue.split("-")[0]);
- Double mtbf = (Double) jsonArray.getJSONObject(i).get("mttf");
- Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
- Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
+ Double mtbf = null;
+ Double mttr = null;
+ Double msr = null;
+ if (!jsonArray.getJSONObject(i).get("mttf").equals("inf")){
+ mtbf = (Double)jsonArray.getJSONObject(i).get("mttf");
+ }else{
+ mtbf = 0.0;
+ }
+ if (!jsonArray.getJSONObject(i).get("mttr").equals("inf")){
+ mttr = (Double)jsonArray.getJSONObject(i).get("mttr");
+ }else{
+ mttr = 0.0;
+ }
+ if (!jsonArray.getJSONObject(i).get("msr").equals("inf")){
+ msr = (Double)jsonArray.getJSONObject(i).get("msr");
+ }else{
+ msr = 0.0;
+ }
- 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();
+ WeakDto weakDto = new WeakDto();
+ weakDto.setId(productId1);
+ weakDto.setMtbf(mtbf);
+ weakDto.setMttr(mttr);
+ weakDto.setMsr(msr);
+ if (map.get(productId1) == null) {
+ map.put(productId1, weakDto);
+ } else {
+ if (weakDto.getMsr() < map.get(productId1).getMsr()) {
+ map.put(productId1, weakDto);
}
-
- data.setMtbfTime(mtbfTime);
- data.setIsWeak(0);
-
- list.add(data);
}
}
}
+ List<WeakDto> productList = baseDao.getProductList(taskId, productId);
+ for (WeakDto item : productList) {
+ if (map.get(item.getId()) != null) {
+ WeakDto dto = map.get(item.getId());
+ item.setMtbf(dto.getMtbf());
+ item.setMttr(dto.getMttr());
+ item.setMsr(dto.getMsr());
+ item.setMtbfTime(dto.getMtbf() / item.getTimeRate());
+ item.setIsWeak(0);
+ }
+ }
+
List<WeakDto> treeList = new ArrayList<>();
- if (list.size() > 0) {
- treeList = TreeUtils.build(list);
+ if (productList.size() > 0) {
+ treeList = TreeUtils.build(productList);
this.getIsweak(treeList.get(0).getChildren());
}
@@ -1234,13 +1370,15 @@
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;
+ if (dto.getMtbfTime() != null) {
+ if (dto.getProductType() == 10)
+ continue;
+ if (minDto == null) {
+ minDto = dto;
+ }
+ if (dto.getMtbfTime() < minDto.getMtbfTime()) {
+ minDto = dto;
+ }
}
}
minDto.setIsWeak(1);
@@ -1249,49 +1387,60 @@
}
}
- public SchemeComparDto SchemeCompar(String[] taskList, Long showProductId) {
- SchemeComparDto dto = new SchemeComparDto();
+ public SimulatResult SchemeCompar(String[] taskList, Long showProductId, Integer samplPeriod, Integer simulatFrequency) {
+ SimulatResult simulatResult = new SimulatResult();
+ List<Long> idList = new ArrayList<>();
+ List<TaskModelCheckResultDto> result = null;
+/* SchemeComparDto dto = new SchemeComparDto();
List<SimulaDataDto> dataDtoList = new ArrayList<>();
List<SchemeComparCurve> curveList = new ArrayList<>();
List<Double> xData = new ArrayList<>();
- SimulatAssess simulatAssess;
- SimulaDataDto data;
+
+ SimulaDataDto data;*/
+
+ List<SimulatAssess> simulatAssessList = new ArrayList<>();
Task task;
+ double maxTaskDuration = 0.0;
for (String taskId : taskList) {
- Long taskModelId = Long.parseLong(taskId);
- task = taskService.get(taskModelId);
- simulatAssess = this.getByTaskId(taskModelId);
- SimulaDataDto resultData;
- if (showProductId != null) {
- simulatAssess.setProductId(showProductId);
- resultData = this.getResultXML(simulatAssess);
- } else {
- resultData = this.getResultXML(simulatAssess);
+ task = taskService.get(Long.parseLong(taskId));
+ if (task.getTaskDuration() > maxTaskDuration) {
+ maxTaskDuration = task.getTaskDuration();
}
- data = resultData;
- data.setName(task.getTaskName());
- dataDtoList.add(data);
- xData = resultData.getCurveParam().getXData();
+ SimulatAssess simulatAssess = new SimulatAssess();
+ Long id = UUIDUtil.generateId();
+ simulatAssess.setId(id);
+ simulatAssess.setName("");
+ simulatAssess.setProductId(showProductId);
+ simulatAssess.setSamplPeriod(samplPeriod);
+ simulatAssess.setSimulatFrequency(simulatFrequency);
+ simulatAssess.setTaskDuration(maxTaskDuration);
+ simulatAssess.setTaskModelId(Long.parseLong(taskId));
- SchemeComparCurve curve = new SchemeComparCurve();
- curve.setName(task.getTaskName());
- curve.setSmooth(true);
- curve.setType("line");
- curve.setData(resultData.getCurveParam().getYData());
- curveList.add(curve);
+ simulatAssessList.add(simulatAssess);
+ result = simulateChecK(simulatAssess);
+ if (result != null) {
+ simulatResult.setType("errorList");
+ simulatResult.setErrList(result);
+ return simulatResult;
+ }
+ idList.add(id);
}
- dto.setXDataList(xData);
- dto.setDataList(dataDtoList);
- dto.setCurveList(curveList);
- return dto;
+
+ for (SimulatAssess simulatAssess : simulatAssessList) {
+ simulatAssess.setTaskDuration(maxTaskDuration);
+ this.simulate(simulatAssess);
+ }
+
+ simulatResult.setType("idList");
+ simulatResult.setIdList(idList);
+ return simulatResult;
}
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));
+ simulatAssess.setName(simulatAssess.getName());
this.update(simulatAssess);
}
String filePath = path + "/" + simulatAssess.getId() + "/" + "result.xml";
@@ -1314,7 +1463,7 @@
}
}
xmlJSONObj = XML.toJSONObject(xml);
- simulatAssess.setShowProductId(simulatAssess.getProductId());
+ simulatAssess.setShowProductId(simulatAssess.getProductId().toString());
SimulaDataDto data = this.getResultData(simulatAssess);
return data;
}
@@ -1326,50 +1475,818 @@
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");
- }
+ String nameValue = jsonArray.getJSONObject(i).get("name").toString();
+ if (nameValue.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);
+ } else {
+ JSONObject jsonObject2 = jsonArray.getJSONObject(i).getJSONObject("phase");
+ availability = (String) jsonObject2.get("availability");
}
- data.setCurveParam(param);
+
+ String[] arr = availability.split(" ");
+ // 閬嶅巻瀛愬瓧绗︿覆鏁扮粍锛屽皢姣忎釜鍏冪礌杞崲涓篸ouble骞跺瓨鍌ㄥ埌double鏁扮粍涓�
+ Double j = 0.0;
+ for (int a = 0; a < arr.length - 1; a++) {
+ j = samplPeriod + j;
+ if (!StringUtils.isEmpty(arr[a])) {
+ doubleArray.add(Double.parseDouble(arr[a]));
+ }
+ xList.add(j);
+ }
+
+ param.setXData(xList);
+ param.setYData(doubleArray);
+
+ Double mttfMle = null;
+ Double mttrMle = null;
+ Double mtbf = null;
+ Double mttr = null;
+ Double msr = null;
+ if (!jsonArray.getJSONObject(i).get("mttf").equals("inf")){
+ mtbf = (Double)jsonArray.getJSONObject(i).get("mttf");
+ }else{
+ mtbf = 0.0;
+ }
+ if (!jsonArray.getJSONObject(i).get("mttr").equals("inf")){
+ mttr = (Double)jsonArray.getJSONObject(i).get("mttr");
+ }else{
+ mttr = 0.0;
+ }
+ if (!jsonArray.getJSONObject(i).get("msr").equals("inf")){
+ msr = (Double)jsonArray.getJSONObject(i).get("msr");
+ }else{
+ msr = 0.0;
+ }
+
+ if (!jsonArray.getJSONObject(i).get("mttr_MLE").equals("inf")){
+ mttrMle = (Double)jsonArray.getJSONObject(i).get("mttr_MLE");
+ }else{
+ mttrMle = 0.0;
+ }
+ if(!jsonArray.getJSONObject(i).get("mttf_MLE").equals("inf")){
+ mttfMle = (Double) jsonArray.getJSONObject(i).get("mttf_MLE");
+ }else{
+ mttfMle = 0.0;
+ }
+ data.setMtbf(mtbf);
+ data.setMttr(mttr);
+ data.setMsr(msr);
+ data.setMttfMle(mttfMle);
+ data.setMttrMle(mttrMle);
}
+ data.setCurveParam(param);
}
+
return data;
}
+
+ public String verify(Long taskId) {
+ StringBuilder result = new StringBuilder();
+ Task task = taskService.get(taskId);
+ double taskTime = task.getTaskDuration();
+ List<OperatConditModel> list = baseDao.getModel(taskId);
+ List<Double> reliabiyList = new ArrayList<>();
+ String modelStr2 = "";
+ for (OperatConditModel model : list) {
+ if (model.getProductId().equals(task.getProductId())) {
+ modelStr2 = model.getContent();
+ continue;
+ }
+ List<verifyDto> listNodes = baseDao.getNode(model.getModelId());
+ for (verifyDto node : listNodes) {
+ //lmd,reliabiy,failRate
+ double lmd = 1 / node.getMtbf();
+ double reliabiy = Math.exp(-1 * lmd * taskTime);
+ double failRate = 1 - reliabiy;
+ node.setLmd(lmd);
+ node.setReliabiy(reliabiy);
+ node.setFailRate(failRate);
+ }
+ int total = listNodes.size();
+ String modelStr = model.getContent();
+ //鎵惧埌琛ㄥ喅鏁伴噺
+
+ if (modelStr.contains("switch")) {
+ double a = 0;
+ double lmd = listNodes.get(0).getLmd();
+ result.append("\n").append(total).append("涓浉鍚岃澶囨梺鑱�,3閫�1,MTTBCF鏄�").append(listNodes.get(0).getMtbf()).append("\n");
+ for (int i = 0; i <= total - 1; i++) {
+ double ijc = getjc(i);
+ double b = Math.pow(taskTime * lmd, i) * Math.exp(-1 * lmd * taskTime) / ijc;
+ a = a + b;
+ result.append("鏈�").append(i + 1).append("涓澶囧ソ鐨勭殑姒傜巼涓�").append(b).append("\n");
+ }
+ result.append("鏁翠釜鏃佽仈绯荤粺鐨勫彲闈犲害涓�").append(new Formatter().format("%.4f", a)).append("\n");
+ reliabiyList.add(a);
+ } else if (modelStr.contains("parallel")) {
+ double a = 1;
+ result.append("\n骞惰仈璁惧鏈�").append(total).append("涓猏n");
+ for (int i = 0; i < listNodes.size(); i++) {
+ a = a * listNodes.get(i).getFailRate();
+ result.append("绗�").append(i + 1).append("涓澶囩殑MTBCF涓�").append(listNodes.get(i).getMtbf()).append(",").append(i + 1).append("涓澶囧苟鑱旂殑澶辨晥鐜囦负").append(a).append("\n");
+ }
+ double reliabiy = 1 - a;
+ result.append("鏁翠釜骞惰仈绯荤粺鐨勫け鏁堢巼涓�").append(a).append("鏁翠釜骞惰仈绯荤粺鐨勫彲闈犲害涓�").append(new Formatter().format("%.4f", reliabiy)).append("\n");
+ reliabiyList.add(reliabiy);
+ } else if (modelStr.contains("vote")) {
+ Integer voteNum = baseDao.getVoteNum(model.getModelId());
+ if (voteNum != null) {
+ result.append("\n").append(total).append("涓浉鍚岃澶囪〃鍐�,MTBCF涓�").append(listNodes.get(0).getMtbf()).append("琛ㄥ喅鏁伴噺涓�").append(voteNum).append("涓猏n");
+ double a = 0;
+ double zjc = getjc(total);
+ double reliabiy = listNodes.get(0).getReliabiy();
+ for (int i = voteNum; i <= total; i++) {
+ double ijc = getjc(i);
+ double nijc = getjc(total - i);
+ double b = (zjc / (ijc * nijc)) * Math.pow(reliabiy, i) * Math.pow(1 - reliabiy, total - i);
+ a = a + b;
+ result.append("鏈�").append(i).append("涓澶囨槸濂界殑姒傜巼涓�").append(b).append("\n");
+ }
+ result.append("鏁翠釜琛ㄥ喅绯荤粺鐨勫彲闈犲害涓�").append(new Formatter().format("%.4f", a)).append("\n");
+ reliabiyList.add(a);
+ }
+
+ }
+ }
+ double totalReliabiy = 1;
+ if (modelStr2.contains("parallel")) {
+ for (Double reliabiy : reliabiyList) {
+ totalReliabiy = totalReliabiy * (1 - reliabiy);
+ }
+ totalReliabiy = 1 - totalReliabiy;
+ } else {
+ for (Double reliabiy : reliabiyList) {
+ totalReliabiy = totalReliabiy * reliabiy;
+ }
+ }
+ result.append("\n鏁翠釜鎬讳綋绯荤粺鐨勫彲闈犲害涓�").append(totalReliabiy).append("\n");
+ return String.valueOf(result);
+ }
+
+ Double getjc(int a) {
+ double result = 1.0;
+ for (int i = a; i > 0; i--)
+ result = result * i;
+ return result;
+ }
+
+ public SchemeComparDto getEcharts(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);
+ simulatAssess.setDataType("fz");
+ SimulaDataDto resultData;
+ if (showProductId != null) {
+ simulatAssess.setProductId(showProductId);
+ resultData = this.getResultXML(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.setSymbol("none");
+ 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 void downloadXml(HttpServletRequest request, HttpServletResponse response, String type, Long id, Integer xml) {
+ if (type.equals("fz")) {
+ if (xml == 1) {
+ SimulatAssess simulatAssess = this.get(id);
+ String xml1 = simulatAssess.getXml();
+ writeToTxt(request, response, xml1, "浠跨湡杈撳叆");
+ } else {
+ String filePath = path + "/" + id + "/" + "result.xml";
+ String xml1;
+ InputStream in = null;
+
+ try {
+ in = new FileInputStream(filePath);
+ xml1 = IOUtils.toString(in);
+ } catch (IOException e) {
+ e.printStackTrace();
+ throw new RenException("鏂囦欢涓嶅瓨鍦ㄦ垨鑰呮枃浠舵墦涓嶅紑");
+ } finally {
+ try {
+ if (in != null) {
+ in.close();
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ writeToTxt(request, response, xml1, "浠跨湡杈撳嚭");
+ }
+ } else if (type.equals("sxt")) {
+ if (xml == 1) {
+ String filePath = path + "/" + id + "/" + "status.json";
+ ObjectMapper mapper = new ObjectMapper();
+ String jsonStr = null;
+ try {
+ Object obj = mapper.readValue(new File(filePath), Object.class);
+ jsonStr = mapper.writeValueAsString(obj);
+ } catch (IOException e) {
+ // 澶勭悊寮傚父
+ e.printStackTrace();
+ throw new RenException("鏂囦欢涓嶅瓨鍦ㄦ垨鑰呮枃浠舵墦涓嶅紑");
+ }
+ writeToTxt(request, response, jsonStr, "鏃跺簭鍥捐緭鍏�");
+ } else {
+ SimulatAssess simulatAssess = this.get(id);
+ TimeDiagramDto timeDiagram = getTimeDiagram(simulatAssess.getProductId(), simulatAssess.getTaskModelId(), simulatAssess.getId(), 1200, 5);
+ String xml2 = timeDiagram.getDiagramJson();
+ writeToTxt(request, response, xml2, "鏃跺簭鍥捐緭鍑�");
+ }
+ }
+ }
+
+ public void writeToTxt(HttpServletRequest request, HttpServletResponse response, String jsonString, String name) {//璁剧疆鍝嶅簲鐨勫瓧绗﹂泦
+ //璁剧疆鍝嶅簲鍐呭鐨勭被鍨�
+ BufferedOutputStream buff = null;
+ ServletOutputStream outStr = null;
+ try {
+ response.setContentType("text/plain;charset=UTF-8");
+ String encodedFilename = DownloadService.getNameEncoder(request, name + "xml.txt");
+ response.addHeader("Content-Disposition", "attachment;filename=" + encodedFilename);
+ outStr = response.getOutputStream();
+ buff = new BufferedOutputStream(outStr);
+ buff.write(jsonString.getBytes("UTF-8"));
+ buff.flush();
+ buff.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ buff.close();
+ outStr.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+/*
+ public Boolean mySimulate(SimulatAssess simulatAssess) {
+ logger.info("浠跨湡璇勪及寮�濮�");
+ // 1. 浠跨湡鍒濆鍖�
+ SimulateStaticDataDto simulateStaticDataDto = new SimulateStaticDataDto();
+ SimulateDynamicDataDto simulateDynamicDataDto = new SimulateDynamicDataDto();
+ initSimulate(simulatAssess, simulateStaticDataDto, simulateDynamicDataDto);
+ logger.info("浠跨湡璇勪及鍒濆鍖栧畬鎴�");
+
+ // 2. 浠跨湡澶勭悊
+ for (int i = 0; i < simulatAssess.getSimulatFrequency(); i++) {
+ doSimulate(i, simulatAssess, simulateStaticDataDto, simulateDynamicDataDto);
+ }
+ logger.info("浠跨湡璇勪及浠跨湡澶勭悊瀹屾垚");
+
+ return true;
+ }
+
+ private void initSimulate(SimulatAssess simulatAssess,
+ SimulateStaticDataDto simulateStaticDataDto,
+ SimulateDynamicDataDto simulateDynamicDataDto) {
+ Date beginDate = new Date();
+ XhProductModel product = xhProductModelDao.getById(simulatAssess.getProductId());
+ List<XhProductModel> productList = xhProductModelDao.getByShipId(product.getId());
+ List<ParamData> paramDataList = paramDataDao.getDeviceParams(product.getId());
+ Task task = taskService.get(simulatAssess.getTaskModelId());
+ if (simulatAssess.getTaskDuration() != null) {
+ task.setTaskDuration(simulatAssess.getTaskDuration());
+ }
+ List<TaskBinoParam> binoParams = taskBinoParamDao.getBinoParams(task.getId());
+
+ // 1. 璁＄畻鍚勪换鍔￠樁娈电殑杩愯鏃堕暱
+ List<TaskPhase> taskPhases = calcTaskPhaseDuration(task);
+ // 2. 璁＄畻鍚勫伐鍐垫ā鍨嬬殑杩愯鏃堕暱
+ List<TaskPhaseModel> taskPhaseModelAll = new ArrayList<>();
+ for (TaskPhase taskPhase : taskPhases) {
+ calcTaskPhaseModelDuration(taskPhase, taskPhaseModelAll);
+ }
+ Date date1 = new Date();
+ logger.info("鏁版嵁鍑嗗鏃堕棿锛�" + CommonUtils.getDatePoor(date1, beginDate));
+ // 3. 灏嗗悇宸ュ喌妯″瀷閫掑綊鎷嗚В涓哄畬鏁寸殑鍙緵浠跨湡璁＄畻鐨勯樁娈靛伐鍐垫ā鍨嬫暟鎹�
+ createAllModelData(simulatAssess.getRepairDiracFlag(),
+ task.getId(),
+ product.getId(),
+ product.getName(),
+ product.getNamePath(),
+ productList,
+ paramDataList,
+ taskPhaseModelAll,
+ binoParams,
+ simulateStaticDataDto);
+ Date date2 = new Date();
+ logger.info("鐢熸垚闃舵宸ュ喌妯″瀷鏁版嵁鏃堕棿锛�" + CommonUtils.getDatePoor(date2, date1));
+ // 4. 鐢熸垚闈欐�佷簨浠跺垪琛�
+ createStaticEventList(simulateStaticDataDto, task.getTaskDuration());
+ Date date3 = new Date();
+ logger.info("鐢熸垚闈欐�佷簨浠跺垪琛ㄦ椂闂达細" + CommonUtils.getDatePoor(date3, date2));
+ // 5. 鐢熸垚鍔ㄦ�佷豢鐪熸暟鎹�
+ createDynamicSimulateData(simulatAssess, simulateStaticDataDto, simulateDynamicDataDto);
+ Date date4 = new Date();
+ logger.info("鐢熸垚鍔ㄦ�佷豢鐪熸暟鎹椂闂达細" + CommonUtils.getDatePoor(date4, date3));
+ // 6. 瀛樼洏
+ saveSimulatAssessTaskPhaseModel(simulatAssess,
+ task,
+ taskPhases,
+ taskPhaseModelAll);
+ }
+
+ private void createDynamicSimulateData(SimulatAssess simulatAssess,
+ SimulateStaticDataDto simulateStaticDataDto,
+ SimulateDynamicDataDto simulateDynamicDataDto) {
+ List<SimulateNode> nodeList = simulateDynamicDataDto.getNodeList();
+ Map<Long, SimulateModelData> modelDataMap = simulateStaticDataDto.getModelDataMap();
+ for (Long key : modelDataMap.keySet()) {
+ for (SimulateNode node : modelDataMap.get(key).getActualNodeList()) {
+ List<SimulateNode> nodes = nodeList.stream().filter(item ->
+ node.getId().equals(item.getId())).collect(Collectors.toList());
+ if (nodes.size() == 0) {
+ nodeList.add(node.clone());
+ }
+ }
+ }
+ simulateDynamicDataDto.setStaticNodeNum(nodeList.size());
+
+ for (SimulateNode node : nodeList) {
+ List<List<SimulateStatus>> statusData = new ArrayList<>();
+ node.setStatusData(statusData);
+ for (int i = 0; i < simulatAssess.getSimulatFrequency(); i++) {
+ List<SimulateStatus> statusList = new ArrayList<>();
+ statusData.add(statusList);
+ }
+ }
+ }
+
+ private void createStaticEventList(SimulateStaticDataDto simulateStaticDataDto, double taskDuration) {
+ Map<Long, SimulateModelData> modelDataMap = simulateStaticDataDto.getModelDataMap();
+ Map<Long, SimulatePhaseModel> modelStartTimeMap = simulateStaticDataDto.getModelStartTimeMap();
+ for (Long key : modelStartTimeMap.keySet()) {
+ // 1. 闃舵宸ュ喌妯″瀷鍒囨崲浜嬩欢
+ double startTime = modelStartTimeMap.get(key).getStartTime();
+ SimulateEvent event = new SimulateEvent();
+ event.setId(UUIDUtil.generateId());
+ event.setType(SimulateEvent.TYPE_MODEL_CHG);
+ event.setTime(startTime);
+ event.setNodeId(key.toString());
+ simulateStaticDataDto.getStaticEventList().add(event);
+
+ // 2. 鏈夎繍琛屾瘮鐨勮澶囪妭鐐圭殑cycon/cycoff浜嬩欢
+ List<SimulateNode> nodes = modelDataMap.get(key).getActualNodeList().stream().filter(item ->
+ item.getIsLeafNode() && item.getCycOffDuration() != null).collect(Collectors.toList());
+ if (nodes.size() > 0) {
+ List<SimulateEvent> cycEventList = new ArrayList<>();
+ simulateStaticDataDto.getCycEventMap().put(key, cycEventList);
+ for (SimulateNode node : nodes) {
+// event = new SimulateEvent();
+// event.setId(UUIDUtil.generateId());
+// event.setType(SimulateEvent.TYPE_CYCON);
+// event.setTime(startTime);
+// event.setNodeId(node.getId());
+// cycEventList.add(event);
+ event = new SimulateEvent();
+ event.setId(UUIDUtil.generateId());
+ event.setType(SimulateEvent.TYPE_CYCOFF);
+ event.setTime(startTime + node.getCycOnDuration());
+ event.setNodeId(node.getId());
+ cycEventList.add(event);
+ }
+ }
+ }
+
+ // 3. 浠跨湡缁撴潫浜嬩欢
+ SimulateEvent event = new SimulateEvent();
+ event.setId(UUIDUtil.generateId());
+ event.setType(SimulateEvent.TYPE_END);
+ event.setTime(taskDuration);
+ simulateStaticDataDto.getStaticEventList().add(event);
+ }
+
+ private void createAllModelData(boolean repairDiracFlag,
+ Long taskId,
+ Long productId,
+ String productName,
+ String productNamePath,
+ List<XhProductModel> productList,
+ List<ParamData> paramDataList,
+ List<TaskPhaseModel> taskPhaseModelAll,
+ List<TaskBinoParam> binoParams,
+ SimulateStaticDataDto simulateStaticDataDto) {
+ double startTime = 0;
+ for (TaskPhaseModel taskPhaseModel : taskPhaseModelAll) {
+ List<OperatConditModel> gkModelsAssembled = operatConditModelDao.getGKModelAssembled(
+ taskPhaseModel.getOperatConditId());
+ OperatConditModel gkModelTop = gkModelsAssembled.stream().filter(item ->
+ productId.equals(item.getProductId())).collect(Collectors.toList()).get(0);
+ List<ModelNode> modelNodeAndVnodeList = modelNodeAlgorithmDao.getListByModelId(gkModelTop.getModelId());
+ List<Algorithm> algorithmList = algorithmDao.getListByModelId(gkModelTop.getModelId());
+ // 灏嗘ā鍨嬭浆鎹负Tree
+ SimulateNode root = new SimulateNode();
+ Algorithm endAlgo = algorithmList.stream().filter(item ->
+ "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);
+ Date beginDate = new Date();
+ node2Tree(repairDiracFlag,
+ taskId,
+ taskPhaseModel,
+ productId,
+ productName,
+ productNamePath,
+ productList,
+ paramDataList,
+ gkModelsAssembled,
+ algorithmList,
+ modelNodeAndVnodeList,
+ binoParams,
+ computerNode, root);
+ Date date1 = new Date();
+ logger.info("node2Tree鏃堕棿锛�" + CommonUtils.getDatePoor(date1, beginDate));
+ SimulateModelData simulateModelData = new SimulateModelData();
+ SimulateNode.treeToModelData(root, simulateModelData);
+ Date date2 = new Date();
+ logger.info("treeToModelData鏃堕棿锛�" + CommonUtils.getDatePoor(date2, date1));
+ simulateStaticDataDto.getModelDataMap().put(taskPhaseModel.getId(), simulateModelData);
+ SimulatePhaseModel simulatePhaseModel = new SimulatePhaseModel();
+ simulatePhaseModel.setId(taskPhaseModel.getId());
+ simulatePhaseModel.setStartTime(startTime);
+ simulateStaticDataDto.getModelStartTimeMap().put(taskPhaseModel.getId(), simulatePhaseModel);
+ startTime += taskPhaseModel.getOperatConditDuration();
+ }
+ }
+
+ // 閫掑綊鍑芥暟
+ private void node2Tree(boolean repairDiracFlag,
+ Long taskId,
+ TaskPhaseModel taskPhaseModel,
+ Long productId,
+ String productName,
+ String productNamePath,
+ List<XhProductModel> productList,
+ List<ParamData> paramDataList,
+ List<OperatConditModel> gkModelsAssembled,
+ List<Algorithm> algorithmList,
+ List<ModelNode> modelNodeAndVnodeList,
+ List<TaskBinoParam> binoParams,
+ ModelNode node,
+ SimulateNode simulateNode) {
+ if ("node".equals(node.getNodeType())) {
+ simulateNode.setIsActualNode(true);
+ Long dataId = node.getDataId();
+ XhProductModel product = productList.stream().filter(item ->
+ dataId.equals(item.getId())).collect(Collectors.toList()).get(0);
+ if ("3,4,10".contains(product.getProductType())) {
+ // 绯荤粺銆佸垎绯荤粺銆佽櫄鍗曞厓
+ OperatConditModel gkModel = gkModelsAssembled.stream().filter(item ->
+ dataId.equals(item.getProductId())).collect(Collectors.toList()).get(0);
+ List<Algorithm> algorithmListSub = algorithmDao.getListByModelId(gkModel.getModelId());
+ List<ModelNode> modelNodeAndVnodeListSub = modelNodeAlgorithmDao.getListByModelId(gkModel.getModelId());
+ Algorithm endAlgo = algorithmListSub.stream().filter(item ->
+ "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);
+ node2Tree(repairDiracFlag,
+ taskId,
+ taskPhaseModel,
+ product.getId(),
+ product.getName(),
+ product.getNamePath(),
+ productList,
+ paramDataList,
+ gkModelsAssembled,
+ algorithmListSub,
+ modelNodeAndVnodeListSub,
+ binoParams,
+ computerNode, simulateNode);
+ } else if ("5".equals(product.getProductType())) {
+ // 璁惧
+ simulateNode.setIsLeafNode(true);
+ simulateNode.setFailureRate(1.0);
+ Integer deviceNo = node.getDeviceNo();
+ simulateNode.setId(dataId.toString() + "-" + deviceNo);
+ simulateNode.setName(product.getName() + "-" + deviceNo);
+ simulateNode.setNamePath(product.getNamePath());
+
+ ParamData paramData = paramDataList.stream().filter(item ->
+ dataId.equals(item.getProductId())).collect(Collectors.toList()).get(0);
+ Double ratio = paramData.getTaskMtbcfOperatingRatio();
+ if (null != ratio && ratio != 1.0) {
+ // 闂存柇鍨嬭澶囩殑澶勭悊
+ simulateNode.setRunningRatio(ratio);
+ double cycon = taskPhaseModel.getOperatConditDuration() * ratio;
+ double cycdown = taskPhaseModel.getOperatConditDuration() - cycon;
+ simulateNode.setCycOnDuration(cycon);
+ simulateNode.setCycOffDuration(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 -> dataId.equals(item.getProductId()))
+ .collect(Collectors.toList()).get(0);
+ }
+ if (1 == paramData.getRepairable() &&
+ isRepairDirac(repairDiracFlag, taskPhaseModel, product.getId())) {
+ simulateNode.setIsRepairDirac(true);
+ } else {
+ simulateNode.setIsRepairDirac(false);
+ simulateNode.setFailureModel(createFailureModel(paramData, taskBinoParam));
+ }
+ if (1 == paramData.getRepairable()) {
+ // 鍙淮淇�
+ simulateNode.setRepairModel(createRepairModel(paramData));
+ }
+ }
+ } else {
+ // vnode锛堣繍绠楄妭鐐癸級
+ Algorithm algo = algorithmList.stream().filter(item ->
+ node.getId().equals(item.getId())).collect(Collectors.toList()).get(0);
+ if (null == productId) {
+ simulateNode.setIsActualNode(false);
+ simulateNode.setId(algo.getId().toString());
+ } else {
+ simulateNode.setIsActualNode(true);
+ simulateNode.setId(productId.toString());
+ simulateNode.setName(productName);
+ simulateNode.setNamePath(productNamePath);
+ }
+ if (SimulateNode.LOGIC_TYPE_SERIES.equals(algo.getAlgorithmType())) {
+ simulateNode.setLogicType(SimulateNode.LOGIC_TYPE_SERIES);
+ } else if (SimulateNode.LOGIC_TYPE_PARALLEL.equals(algo.getAlgorithmType())) {
+ simulateNode.setLogicType(SimulateNode.LOGIC_TYPE_PARALLEL);
+ } else if (SimulateNode.LOGIC_TYPE_VOTE.equals(algo.getAlgorithmType())) {
+ simulateNode.setLogicType(SimulateNode.LOGIC_TYPE_VOTE);
+ simulateNode.setVoteNum(algo.getVoteNum());
+ } else if ("switch".equals(algo.getAlgorithmType())) {
+ simulateNode.setLogicType(SimulateNode.LOGIC_TYPE_STANDBY);
+ simulateNode.setVoteNum(algo.getVoteNum());
+ } else if ("warm_switch".equals(algo.getAlgorithmType())) {
+ simulateNode.setLogicType(SimulateNode.LOGIC_TYPE_WARM_STANDBY);
+ simulateNode.setVoteNum(algo.getVoteNum());
+ } else if (SimulateNode.LOGIC_TYPE_BRIDGE.equals(algo.getAlgorithmType())) {
+ simulateNode.setLogicType(SimulateNode.LOGIC_TYPE_BRIDGE);
+ }
+ String[] computerNodeListStr = algo.getComputerList().split(",");
+ for (String nodeStr : computerNodeListStr) {
+ SimulateNode sn = new SimulateNode();
+ simulateNode.getChildren().add(sn);
+ ModelNode mn = modelNodeAndVnodeList.stream().filter(item ->
+ nodeStr.equals(item.getId().toString())).collect(Collectors.toList()).get(0);
+ node2Tree(repairDiracFlag,
+ taskId,
+ taskPhaseModel,
+ null,
+ null,
+ null,
+ productList,
+ paramDataList,
+ gkModelsAssembled,
+ algorithmList,
+ modelNodeAndVnodeList,
+ binoParams,
+ mn, sn);
+ }
+ }
+ }
+
+ private void doSimulate(int sCnt, SimulatAssess simulatAssess,
+ SimulateStaticDataDto simulateStaticDataDto,
+ SimulateDynamicDataDto simulateDynamicDataDto) {
+ // 1. 浠跨湡浜嬩欢鍒濆鍖�
+ initSimulateEvent(simulateStaticDataDto, simulateDynamicDataDto);
+ // 2. 浠跨湡鏃堕挓鍒濆鍖�
+ double lastTime = 0.0;
+ // 3. 浠跨湡浜嬩欢姝诲惊鐜紙浠跨湡缁撴潫浜嬩欢閫�鍑猴級
+ for (;;) {
+ boolean hasModelChgEvent = false;
+ // 3.1 浠庝豢鐪熶簨浠跺垪琛ㄤ腑鏌ヨ鍑轰簨浠舵椂闂存渶灏忕殑浜嬩欢闆嗗悎
+ List<SimulateEvent> minEventList = getMinEventList(simulateDynamicDataDto.getEventList());
+ double currentTime = minEventList.get(0).getTime();
+ // 3.2 鏈�灏忔椂闂翠簨浠堕泦鍚堝鐞�
+ List<SimulateEvent> endEvents = minEventList.stream().filter(item ->
+ SimulateEvent.TYPE_END==item.getType()).collect(Collectors.toList());
+ if (endEvents.size() > 0) {
+ break;
+ }
+ List<SimulateEvent> modelChgEvents = minEventList.stream().filter(item ->
+ SimulateEvent.TYPE_MODEL_CHG==item.getType()).collect(Collectors.toList());
+ if (modelChgEvents.size() > 0) {
+ hasModelChgEvent = true;
+ SimulateEvent modelChgEvent = modelChgEvents.get(0);
+ // 3.2.1 鏂伴樁娈垫暟鎹姞杞�
+ loadNewModelData(simulateStaticDataDto, simulateDynamicDataDto, modelChgEvent);
+ }
+ List<SimulateNode> leafNodes = simulateDynamicDataDto.getNodeList().stream().filter(item ->
+ item.getIsLeafNode()).collect(Collectors.toList());
+ for (SimulateNode leafNode : leafNodes) {
+ // 3.2.2 鑰楁椂鍙婄姸鎬佸鐞嗭紙瀵规墍鏈夊彾瀛愯妭鐐瑰鐞嗭級
+ handleLifeAndStatus(currentTime-lastTime, currentTime, leafNode, simulateDynamicDataDto.getNodeList());
+ }
+ if (hasModelChgEvent) {
+ // 3.2.3 闃舵宸ュ喌妯″瀷鍒囨崲澶勭悊
+ // 浜岄」鍒嗗竷璁惧澶勭悊
+ // 绉婚櫎璇ラ樁娈靛垏鎹簨浠�
+ removeEvent(simulateDynamicDataDto, modelChgEvents.get(0));
+ }
+ List<SimulateEvent> cycoffEvents = minEventList.stream().filter(item ->
+ SimulateEvent.TYPE_CYCOFF==item.getType()).collect(Collectors.toList());
+ for (SimulateEvent cycoffEvent : cycoffEvents) {
+ // 3.2.4 cycoff浜嬩欢澶勭悊
+ SimulateNode node = simulateDynamicDataDto.getNodeList().stream().filter(item ->
+ cycoffEvent.getNodeId().equals(item.getId())).collect(Collectors.toList()).get(0);
+ node.setStatus(SimulateStatus.STATUS_CYCDOWN);
+ // 绉婚櫎璇ycoff浜嬩欢
+ removeEvent(simulateDynamicDataDto, cycoffEvent);
+ }
+ // 3.2.5 杩唬澶勭悊
+
+ }
+ }
+
+ private void removeEvent(SimulateDynamicDataDto simulateDynamicDataDto, SimulateEvent event) {
+ Iterator<SimulateEvent> iterator = simulateDynamicDataDto.getEventList().iterator();
+ while (iterator.hasNext()) {
+ SimulateEvent item = iterator.next();
+ if (event.getId().equals(item.getId())) iterator.remove();
+ }
+ }
+
+ private void handleLifeAndStatus(double deltaTime,
+ double currentTime,
+ SimulateNode node,
+ List<SimulateNode> nodeList) {
+ // 鑰楁椂澶勭悊
+ if (SimulateStatus.STATUS_ACTIVE.equals(node.getStatus()) ||
+ SimulateStatus.STATUS_WARM.equals(node.getStatus())) {
+ node.setLifeTime(node.getLifeTime()-deltaTime*node.getFailureRate());
+ }
+ if (node.getRepairTime()>0 && node.getRepairModel()!=null) {
+ double repairTime = node.getRepairTime()-deltaTime;
+ if (repairTime < 0) repairTime = 0;
+ node.setRepairTime(repairTime);
+ }
+ // 鐘舵�佸鐞�
+ if (SimulateStatus.STATUS_ACTIVE.equals(node.getStatus()) &&
+ node.getLifeTime()<=0) {
+ if (node.getRepairModel()==null) {
+ node.setStatus(SimulateStatus.STATUS_FAILED);
+ } else {
+ node.setStatus(SimulateStatus.STATUS_MAINTENANCE);
+ double repairTime = createRepairTime(node.getRepairModel());
+ node.setRepairTime(repairTime);
+ node.setLifeTime(0.0);
+ node.getFailureEvent().setType(SimulateEvent.TYPE_EXPECT_REPAIR);
+ node.getFailureEvent().setTime(currentTime+repairTime);
+ }
+ setMayChangeStatus(node, nodeList);
+ }
+ if (SimulateStatus.STATUS_MAINTENANCE.equals(node.getStatus()) &&
+ node.getRepairTime()<=0) {
+ node.setStatus(SimulateStatus.STATUS_ACTIVE);
+ double lifeTime = createLifeTime(node.getFailureModel());
+ node.setLifeTime(lifeTime);
+ node.setRepairTime(0.0);
+ node.getFailureEvent().setType(SimulateEvent.TYPE_EXPECT_FAIL);
+ node.getFailureEvent().setTime(currentTime+lifeTime);
+ setMayChangeStatus(node, nodeList);
+ }
+ }
+
+ private void setMayChangeStatus(SimulateNode node,
+ List<SimulateNode> nodeList) {
+ node.setMayChangeStatus(true);
+ for (String pid : node.getPids()) {
+ SimulateNode pNode = nodeList.stream().filter(item ->
+ pid.equals(item.getId())).collect(Collectors.toList()).get(0);
+ pNode.setMayChangeStatus(true);
+ }
+ }
+
+ private void loadNewModelData(SimulateStaticDataDto simulateStaticDataDto,
+ SimulateDynamicDataDto simulateDynamicDataDto,
+ SimulateEvent modelChgEvent) {
+ // 鍒犻櫎浠跨湡鍔ㄦ�佹暟鎹腑鐨勮櫄鑺傜偣
+ Iterator<SimulateNode> iterator = simulateDynamicDataDto.getNodeList().iterator();
+ while (iterator.hasNext()) {
+ SimulateNode item = iterator.next();
+ if (!item.getIsActualNode()) iterator.remove();
+ }
+ // 鎵�鏈夊疄鑺傜偣鍒濆鍖栦负鏈娇鐢�
+ for (SimulateNode node : simulateDynamicDataDto.getNodeList()) {
+ node.setIsUsed(false);
+ }
+ // 鍔犲叆璇ラ樁娈靛伐鍐垫ā鍨嬬殑鎵�鏈夎櫄鑺傜偣
+ SimulateModelData modelData = simulateStaticDataDto.getModelDataMap().get(Long.valueOf(modelChgEvent.getNodeId()));
+ for (SimulateNode vnode : modelData.getVirtualNodeList()) {
+ simulateDynamicDataDto.getNodeList().add(vnode.clone());
+ }
+ // 鎶婅闃舵宸ュ喌妯″瀷涓殑鎵�鏈夊疄鑺傜偣鐨勫唴瀹规嫹璐濆埌浠跨湡鍔ㄦ�佹暟鎹腑鐨勫疄鑺傜偣
+ for (SimulateNode anode : modelData.getActualNodeList()) {
+ SimulateNode node = simulateDynamicDataDto.getNodeList().stream().filter(item ->
+ anode.getId().equals(item.getId())).collect(Collectors.toList()).get(0);
+ node.setPid(anode.getPid());
+ node.setNamePath(anode.getNamePath());
+ node.setPids(anode.getCids());
+ node.setCids(anode.getCids());
+ node.setIsLeafNode(anode.getIsLeafNode());
+ node.setIsUsed(anode.getIsUsed());
+ node.setFailureRate(anode.getFailureRate());
+// node.setRunningRatio(anode.getRunningRatio());
+// node.setCycOnDuration(anode.getCycOnDuration());
+// node.setCycOffDuration(anode.getCycOffDuration());
+ node.setFailureModel(anode.getFailureModel());
+ node.setRepairModel(anode.getRepairModel());
+ node.setIsRepairDirac(anode.getIsRepairDirac());
+ node.setLogicType(anode.getLogicType());
+ node.setVoteNum(anode.getVoteNum());
+ node.setNodeNo(anode.getNodeNo());
+ }
+ // 鎶婅闃舵宸ュ喌妯″瀷涓殑cycoff浜嬩欢鍔犲叆鍒颁豢鐪熶簨浠跺垪琛�
+ List<SimulateEvent> cycEvents = simulateStaticDataDto.getCycEventMap().get(Long.valueOf(modelChgEvent.getNodeId()));
+ for (SimulateEvent event : cycEvents) {
+ simulateDynamicDataDto.getEventList().add(event);
+ }
+ }
+
+ private List<SimulateEvent> getMinEventList(List<SimulateEvent> eventList) {
+ List<SimulateEvent> result = new ArrayList<>();
+ double minTime = Double.MAX_VALUE;
+ for (SimulateEvent event : eventList) {
+ if (event.getTime() <= minTime) {
+ minTime = event.getTime();
+ result.add(event);
+ }
+ }
+ return result;
+ }
+
+ private void initSimulateEvent(SimulateStaticDataDto simulateStaticDataDto,
+ SimulateDynamicDataDto simulateDynamicDataDto) {
+ simulateDynamicDataDto.getEventList().clear();
+ simulateDynamicDataDto.getEventList().addAll(simulateStaticDataDto.getStaticEventList());
+
+ List<SimulateNode> leafNodeList = simulateDynamicDataDto.getNodeList().stream().filter(item ->
+ item.getIsLeafNode()).collect(Collectors.toList());
+ for (SimulateNode leafNode : leafNodeList) {
+ double lifeTime = createLifeTime(leafNode.getFailureModel());
+ // 涓轰簡鎻愰珮鏁堢巼锛屽姩鎬佷簨浠跺垪琛ㄥ強璁惧鑺傜偣閲屽悓鏃朵繚瀛橀鏈熸晠闅�/淇浜嬩欢瀹炰綋鐨勬寚閽�
+ SimulateEvent event = new SimulateEvent();
+ event.setId(UUIDUtil.generateId());
+ event.setType(SimulateEvent.TYPE_EXPECT_FAIL);
+ event.setTime(lifeTime);
+ event.setNodeId(leafNode.getId());
+ simulateDynamicDataDto.getEventList().add(event);
+ leafNode.setFailureEvent(event);
+ leafNode.setLifeTime(lifeTime);
+ leafNode.setRepairTime(0.0);
+ leafNode.setStatus(SimulateStatus.STATUS_ACTIVE);
+ }
+ }
+
+ private double createLifeTime(FailureModel failureModel) {
+ return 0.0;
+ }
+
+ private double createRepairTime(RepairModel repairModel) {
+ return 0.0;
+ }
+
+ */
}
--
Gitblit v1.9.1