ReliabilitySimulation.git

			@@ -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;
			@@ -107,19 +115,10 @@
			String templetStr = "{\"cells\":[]}";
			Map<String, JSONObject> templetsMap = new HashMap<>();
			Map<String, String> templetsStrMap = new HashMap<>();
			Map<Integer, String> templetsStrMap2 = new HashMap<>();

			private JSONObject xmlJSONObj;


			/**
			* 分页查询
			*
			* @param queryFilter
			* @return
			*/
			/* public List<SimulatAssess> page(QueryFilter queryFilter) {
			return baseDao.getList(queryFilter.getQueryParams());
			}*/


			/**
			* 删除
			@@ -150,7 +149,10 @@
			return baseDao.getChildren(productId, taskId);
			}

			public String getTimeDiagram(Long productId, Long taskId, Long fzId) {
			public TimeDiagramDto getTimeDiagram(Long productId, Long taskId, Long fzId, double smallWidth, double minPointNum) {
			TimeDiagramDto timeDiagramDto = new TimeDiagramDto();
			timeDiagramDto.setSmallWidth(smallWidth);
			timeDiagramDto.setMinPointNum(minPointNum);
			String filePath = path + "/" + fzId + "/" + "status.json";
			ObjectMapper mapper = new ObjectMapper();
			String jsonStr = null;
			@@ -178,7 +180,10 @@
			JSONObject jsonObject = new JSONObject(templetStr);
			JSONArray jsonArray = jsonObject.getJSONArray("cells");

			this.getPetsInfo();
			JSONObject jsonObject3 = new JSONObject(templetStr);
			JSONArray jsonArray3 = jsonObject3.getJSONArray("cells");

			String modelStr2 = this.getPetsInfo();
			double x1 = 0;
			double x2 = 0;
			int y = -10;
			@@ -187,32 +192,52 @@
			int groupHeight = 20;

			double pointNumPerHour = 60.0 / simulatAssess.getSamplPeriod();

			//时序图线
			List<TimeDiagramStatusDto> statusDtoList = new ArrayList<>();
			List<TimeDiagramStatusDto> statusDtoListOld = new ArrayList<>();
			for (int i = 0; i < list.size(); i++) {
			x1 = 0;
			groupY = groupHeight * i;
			ProductStatusDto dto = list.get(i);
			double startTime = 0.0;
			int status2 = 5;
			for (StatusDto status : dto.getStatusList()) {
			switch (status.getStatus()) {
			case "O":
			y = groupY;
			status2 = 5;
			break;
			case "F":
			y = groupY;// + spaceHeight;
			status2 = 1;
			break;
			case "I":
			y = groupY;// + spaceHeight;
			status2 = 3;
			break;
			case "S":
			y = groupY;// + spaceHeight;
			status2 = 2;
			break;
			case "M":
			y = groupY;// + 2 * spaceHeight;
			status2 = 4;
			break;
			}
			x2 = x1 + status.getTimes() * pointNumPerHour + 5;
			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());
			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/startTimes".split("/"), String.format("%.1f", startTime));
			JsonUtils2.setJsonValueByPath(lineJson, "data/endTimes".split("/"), String.format("%.1f", startTime + status.getTimes()));
			JsonUtils2.setJsonValueByPath(lineJson, "id".split("/"), UUIDUtil.generateId().toString());
			startTime = startTime + status.getTimes();
			x1 = x2 - 5;
			jsonArray.add(lineJson);
			}
			@@ -220,30 +245,16 @@
			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);
			jsonArray.add(textJson);
			}

			//图例
			int spaceWitdth = 80;
			x1 = -spaceWitdth;
			x2 = -11;
			y = -110;
			String[] tlArr = "O,F,I,S,M".split(",");
			for (String s : tlArr) {
			JSONObject f = templetsMap.get(s);
			x1 = x1 + spaceWitdth;
			x2 = x2 + spaceWitdth;
			setlineXy(f, x1, y, x2, y, null);
			jsonArray.add(f);
			JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y + 10);
			jsonArray3.add(textJson);
			}

			//阶段模型及刻度
			x1 = 0;
			x2 = 0;
			double y1 = -80;
			y = -60;
			double y2 = -50;
			double y1 = -60;
			y = -40;
			double y2 = -30;

			JSONObject modelJson = new JSONObject(templetsStrMap.get("model"));
			setlineXy(modelJson, 1, y1, 1, y2, null);
			@@ -274,17 +285,18 @@
			JSONObject textJson = new JSONObject(templetsStrMap.get("text"));
			JsonUtils2.setJsonValueByPath(textJson, "data/dataId".split("/"), modelId);
			JsonUtils2.setJsonValueByPath(textJson, "id".split("/"), UUIDUtil.generateId().toString());
			JsonUtils2.setJsonValueByPath(textJson, "attrs/label/textWrap/text".split("/"), "模型"+(i+1));
			JsonUtils2.setJsonValueByPath(textJson, "attrs/label/textWrap/text".split("/"), "模型" + (i + 1));
			JsonUtils2.setJsonValueByPath(textJson, "attrs/label/textWrap/modelName".split("/"), modelName);

			JsonUtils2.setJsonValueByPath(textJson, "size/width".split("/"), mapSpace.get("width")+10);
			JsonUtils2.setJsonValueByPath(textJson, "size/width".split("/"), mapSpace.get("width") + 10);

			double x11 = x1 + ((gkPoint - mapSpace.get("width")+12) / 2);
			double x11 = x1 + ((gkPoint - mapSpace.get("width") + 12) / 2);
			JsonUtils2.setJsonValueByPath(textJson, "position/x".split("/"), x11);
			JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y1-10);
			JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y1 - 10);
			jsonArray.add(textJson);
			x1 = x2;
			}

			JSONObject modelJson3 = new JSONObject(templetsStrMap.get("model"));
			setlineXy(modelJson3, 0, y, x2, y, null);
			jsonArray.add(modelJson3);
			@@ -306,15 +318,137 @@

			double x11 = x - mapSpace.get("width") / 2 - 5;
			JsonUtils2.setJsonValueByPath(textJson, "position/x".split("/"), x11);
			JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y2-10);
			JsonUtils2.setJsonValueByPath(textJson, "position/y".split("/"), y2 - 10);
			jsonArray.add(textJson);

			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();

			return jsonObject.toString();
			List<List<TimeDiagramStatusDto>> lineArray = new ArrayList();
			lineArray.add(statusDtoList);
			lineArray.add(statusDtoListNew);

			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;
			isFirst = false;
			}
			x2 = i + timeDiagramDto.getMinPointNum() - 1;
			}
			tmpStatusDtoList.add(new TimeDiagramStatusDto(x1, x2, lastStatus));
			smallStatusDtoList.add(tmpStatusDtoList);
			}

			JSONObject jsonObject2 = new JSONObject(modelStr2);
			JSONArray jsonArray2 = jsonObject2.getJSONArray("cells");
			y = 10;
			for (int i = 0; i < smallStatusDtoList.size(); i++) {
			for (TimeDiagramStatusDto status : smallStatusDtoList.get(i)) {
			JSONObject lineJson = new JSONObject(templetsStrMap2.get(status.getStatus()));
			setlineXy(lineJson, status.getX1(), y, status.getX2() + 5, y, "");
			JsonUtils2.setJsonValueByPath(lineJson, "data/status".split("/"), status.getStatus());
			JsonUtils2.setJsonValueByPath(lineJson, "id".split("/"), UUIDUtil.generateId().toString());
			jsonArray2.add(lineJson);
			}
			y = y + 25;
			}

			//图例
			int spaceWitdth = 80;
			x1 = 0;
			x2 = spaceWitdth - 11;
			y = 60;
			String[] tlArr = "O,F,I,S,M".split(",");
			for (String s : tlArr) {
			JSONObject f = templetsMap.get(s);
			x1 = x1 + spaceWitdth;
			x2 = x2 + spaceWitdth;
			setlineXy(f, x1, y, x2, y, null);
			jsonArray2.add(f);
			}
			timeDiagramDto.setDiagramJson(jsonObject.toString());
			timeDiagramDto.setSmallDiagramJson(jsonObject2.toString());
			timeDiagramDto.setTextDiagramJson(jsonObject3.toString());

			return timeDiagramDto;
			}

			private int getPointStatus(List<TimeDiagramStatusDto> dtoList, double x1, double x2) {
			int status = 5;
			boolean findStart = false;
			for (int i = 0; i < dtoList.size(); i++) {
			if (x2 <= dtoList.get(i).getX1()) {
			break;
			}

			if (!findStart) {
			if (dtoList.get(i).getX1() >= x1 && x1 <= dtoList.get(i).getX2()) {
			status = dtoList.get(i).getStatus();
			findStart = true;
			}
			}

			if (dtoList.get(i).getX2() >= x2) {
			if (dtoList.get(i).getStatus() < status)
			status = dtoList.get(i).getStatus();
			}
			}
			return status;
			}


			public void setlineXy(JSONObject lineJson, double x1, double y1, double x2, double y2, String text) {
			JsonUtils2.setJsonValueByPath(lineJson, "source/x".split("/"), x1);
			@@ -327,12 +461,14 @@
			}
			}

			public void getPetsInfo() {
			public String getPetsInfo() {
			Map<String, Object> params = new HashMap<String, Object>();
			params.put("projectId", 10000);
			params.put("diagramId", 10000);
			String modelStr2 = "";
			List<TimeDiagram> list_style = baseDao.getTimeDiagram(params);
			if (list_style.size() > 0) {
			modelStr2 = list_style.get(0).getContent2();
			String modelStr = list_style.get(0).getContent();
			JSONObject modelJson = new JSONObject(modelStr);
			JSONArray modelJsonArray = modelJson.getJSONArray("cells");
			@@ -346,22 +482,27 @@
			if ("运行".equals(nodeMarker)) {
			templetsMap.put("O", jsonObject);
			templetsStrMap.put("O", jsonObject.toString());
			templetsStrMap2.put(5, jsonObject.toString());
			}
			if ("故障".equals(nodeMarker)) {
			templetsMap.put("F", jsonObject);
			templetsStrMap.put("F", jsonObject.toString());
			templetsStrMap2.put(1, jsonObject.toString());
			}
			if ("空闲".equals(nodeMarker)) {
			templetsMap.put("I", jsonObject);
			templetsStrMap.put("I", jsonObject.toString());
			templetsStrMap2.put(3, jsonObject.toString());
			}
			if ("备份".equals(nodeMarker)) {
			templetsMap.put("S", jsonObject);
			templetsStrMap.put("S", jsonObject.toString());
			templetsStrMap2.put(2, jsonObject.toString());
			}
			if ("未用".equals(nodeMarker)) {
			templetsMap.put("M", jsonObject);
			templetsStrMap.put("M", jsonObject.toString());
			templetsStrMap2.put(4, jsonObject.toString());
			}
			if ("模型".equals(nodeMarker)) {
			JsonUtils2.setJsonValueByPath(tmpJSONObject, "attrs/text/text".split("/"), "");
			@@ -400,16 +541,46 @@
			}
			}
			}
			return modelStr2;
			}

			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;
			}

			@@ -424,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++) {
			@@ -438,6 +609,9 @@
			}
			}
			if (status != null \|\| times != null) {
			if (StringUtils.isBlank(status)) {
			status = "M";
			}
			StatusDto statusDto = new StatusDto();
			statusDto.setTimes(times);
			statusDto.setStatus(status);
			@@ -473,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.error("模型不完整，请检查模型定义及参数配置。");
			return result;
			return chkResult;
			}
			return result;
			}

			public Boolean simulate(SimulatAssess simulatAssess) {
			Boolean result = false;
			// 2. 组装供算法库仿真的模型xml
			assembleModelXml(simulatAssess);

			@@ -492,12 +669,21 @@
			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 {
			setParamToRedis(simulatAssess);
			try {
			setParamToRedis(simulatAssess);
			} catch (Exception e) {
			throw new RenException("访问Redis失败。请检查Redis是否已启动。");
			}

			Process process = null;
			String command = "python " + reliaSimMain;
			@@ -509,8 +695,10 @@
			} else if (System.getProperty("os.name").toLowerCase().indexOf("linux") > -1) {
			process = Runtime.getRuntime().exec(new String[]{"/bin/sh", "-c", command});
			} else {
			throw new Exception("暂不支持该操作系统，进行启动算法库计算！");
			throw new RenException("暂不支持该操作系统，进行启动算法库计算！");
			}
			long pid = ProcessUtils.getProcessId(process);
			logger.info("算法库PID：" + pid);
			is = process.getInputStream();
			// 以命令行方式调用算法库时，接口约定返回的结果是utf-8编码
			br = new BufferedReader(new InputStreamReader(is, "utf-8"));
			@@ -520,17 +708,19 @@
			if (line != null) {
			ReliaSimLibResult rtn = com.alibaba.fastjson.JSONObject.parseObject(line, ReliaSimLibResult.class);
			if ("0".equals(rtn.getCode())) {
			logger.info("启动算法库成功。");
			result = Result.ok();
			logger.info("启动可靠性仿真评估算法库成功。");
			newProcess(simulatAssess, pid, command);
			update(simulatAssess);
			result = true;
			} else {
			String errorMsg = rtn.getErrorMsg();
			throw new RuntimeException("启动算法库失败: errorMsg=" + errorMsg);
			throw new RenException("启动可靠性仿真评估算法库失败: errorMsg=" + errorMsg);
			}
			}
			} catch (Exception e) {
			logger.error("启动算法库仿真时发生Exception：", e);
			} catch (IOException e) {
			logger.error("启动可靠性仿真评估算法库仿真时发生Exception：", e);
			e.printStackTrace();
			result = Result.error(e.getMessage());
			throw new RenException("启动可靠性仿真评估算法库失败: errorMsg=" + e.getMessage());
			} finally {
			if (is != null) {
			try {
			@@ -549,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) {
			@@ -583,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. 计算各任务阶段的运行时长
			@@ -602,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(),
			@@ -635,7 +837,7 @@
			insert(simulatAssess);
			} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException("组装算法库仿真计算用模型XML失败: " + e.getMessage());
			throw new RenException("组装算法库仿真计算用模型XML失败: " + e.getMessage());
			}
			}

			@@ -669,12 +871,13 @@
			}

			public void addTasksTag(List<TaskPhaseModel> taskPhaseModelAll,
			Element root) {
			Element root) {
			Element tasksTag = root.addElement("tasks");
			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 ->
			@@ -697,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:
			@@ -739,6 +942,10 @@
			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;
			}
			@@ -746,7 +953,7 @@
			}

			public void calcTaskPhaseModelDuration(TaskPhase taskPhase,
			List<TaskPhaseModel> taskPhaseModelAll) {
			List<TaskPhaseModel> taskPhaseModelAll) {
			List<TaskPhaseModel> taskPhaseModels = taskPhaseModelDao.getListByPhaseId(taskPhase.getId());
			double totalRate = taskPhaseModels.stream().mapToDouble(TaskPhaseModel::getOperatConditDurationRate).sum();
			double sum = 0.0;
			@@ -781,7 +988,8 @@
			return taskPhases;
			}

			private void addModelsTag(Long taskId,
			private void addModelsTag(SimulatAssess simulatAssess,
			Long taskId,
			Long productId,
			String productName,
			String productNamePath,
			@@ -795,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 ->
			@@ -807,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,
			@@ -825,7 +1035,8 @@
			}

			// 递归函数
			private void node2DOM(Long taskId,
			private void node2DOM(SimulatAssess simulatAssess,
			Long taskId,
			TaskPhaseModel taskPhaseModel,
			Long modelId,
			Long productId,
			@@ -855,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(),
			@@ -871,16 +1083,18 @@
			failureModels, repairModels);
			} else if ("5".equals(product.getProductType())) {
			// 设备
			Integer deviceNo = node.getDeviceNo();
			Element nodeTag = parent.addElement("node");
			nodeTag.addAttribute("name", dataId.toString());
			nodeTag.addAttribute("real_name", product.getName());
			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;
			@@ -894,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());
			@@ -932,6 +1161,7 @@
			element.addAttribute("k", algo.getVoteNum().toString());
			} else if ("switch".equals(algo.getAlgorithmType())) {
			element.addAttribute("type", "standby");
			element.addAttribute("k", algo.getVoteNum().toString());
			} else if ("bridge".equals(algo.getAlgorithmType())) {
			element.addAttribute("type", "bridge");
			}
			@@ -939,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,
			@@ -974,7 +1205,8 @@
			break;
			case 3:
			// 二项分布
			if (taskBinoParam.getSimulatTimes().intValue() == taskBinoParam.getSuccessTimes().intValue()) {
			if ((taskBinoParam.getSimulatTimes() == null && taskBinoParam.getSuccessTimes() == null) \|\|
			(taskBinoParam.getSimulatTimes().intValue() == taskBinoParam.getSuccessTimes().intValue())) {
			// 相等则为成败型
			failureModel.setType(FailureModel.TYPE_FIX);
			failureModel.setParam1(taskBinoParam.getSuccessRate());
			@@ -993,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;
			@@ -1020,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 {
			@@ -1038,62 +1301,84 @@
			} catch (IOException e) {
			e.printStackTrace();
			}

			}

			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;
			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");

			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();
			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.setMtbfTime(mtbfTime);
			data.setIsWeak(0);

			list.add(data);
			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);
			}
			}
			}
			}
			List<WeakDto> treeList = TreeUtils.build(list);
			this.getIsweak(treeList.get(0).getChildren());
			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 (productList.size() > 0) {
			treeList = TreeUtils.build(productList);
			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;
			if (dto.getMtbfTime() != null) {
			if (dto.getProductType() == 10)
			continue;
			if (minDto == null) {
			minDto = dto;
			}
			if (dto.getMtbfTime() < minDto.getMtbfTime()) {
			minDto = dto;
			}
			}
			}
			minDto.setIsWeak(1);
			@@ -1102,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";
			@@ -1167,7 +1463,7 @@
			}
			}
			xmlJSONObj = XML.toJSONObject(xml);
			simulatAssess.setShowProductId(simulatAssess.getProductId());
			simulatAssess.setShowProductId(simulatAssess.getProductId().toString());
			SimulaDataDto data = this.getResultData(simulatAssess);
			return data;
			}
			@@ -1179,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(" ");
			// 遍历子字符串数组，将每个元素转换为double并存储到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(" ");
			// 遍历子字符串数组，将每个元素转换为double并存储到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);
			// 移除该cycoff事件
			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;
			}

			*/
			}