| | |
| | | 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.taskReliability.model.*; |
| | | import com.zt.life.modules.mainPart.utils.GetStringSpace; |
| | | import com.zt.life.modules.mainPart.utils.OSUtils.ProcessUtils; |
| | | import io.swagger.models.auth.In; |
| | | import org.apache.commons.beanutils.PropertyUtils; |
| | | import org.apache.commons.io.IOUtils; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.dom4j.Document; |
| | |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.*; |
| | | import java.nio.file.FileAlreadyExistsException; |
| | | import java.util.*; |
| | | import java.util.regex.Matcher; |
| | | import java.util.regex.Pattern; |
| | | import java.util.stream.Collectors; |
| | | |
| | | |
| | |
| | | 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 = null; |
| | | if (isRepairDirac(simulatAssess.getRepairDiracFlag(), taskPhaseModel, product.getId())) { |
| | |
| | | } |
| | | } |
| | | } |
| | | /* |
| | | 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; |
| | | } |
| | | |
| | | */ |
| | | } |