From b42429445c22164e951d514348115ee593379026 Mon Sep 17 00:00:00 2001
From: jinlin <jinlin>
Date: 星期六, 02 十一月 2024 18:44:54 +0800
Subject: [PATCH] 增加下载xml,禁止一键排版以及修改型号节点上级节点

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

diff --git a/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java b/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java
index e9557ad..93e99b1 100644
--- a/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java
+++ b/modules/mainPart/src/main/java/com/zt/life/modules/mainPart/taskReliability/service/SimulatAssessService.java
@@ -5,11 +5,13 @@
 import cn.hutool.json.XML;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.spire.pdf.tables.table.convert.Convert;
+import com.zt.common.db.query.QueryFilter;
 import com.zt.common.exception.RenException;
 import com.zt.common.service.BaseService;
 import com.zt.common.servlet.Result;
 import com.zt.common.utils.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,8 +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 io.swagger.models.auth.In;
 import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.StringUtils;
 import org.dom4j.Document;
 import org.dom4j.DocumentHelper;
 import org.dom4j.Element;
@@ -43,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.nio.file.FileAlreadyExistsException;
 import java.util.*;
@@ -114,7 +121,6 @@
     Map<Integer, String> templetsStrMap2 = new HashMap<>();
 
     private JSONObject xmlJSONObj;
-
 
     /**
      * 鍒嗛〉鏌ヨ
@@ -332,7 +338,8 @@
 
         List<TimeDiagramStatusDto> statusDtoListNew = new ArrayList<>();
         while (statusDtoListOld.size() > 0) {
-            statusDtoListOld.stream().sorted(Comparator.comparing(TimeDiagramStatusDto::getX1)).collect(Collectors.toList());
+            //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);
@@ -352,12 +359,14 @@
                         currentStatusDto.setX2(nextStatusDto.getX1());
                         statusDtoListNew.add(new TimeDiagramStatusDto(nextStatusDto.getX1(), nextStatusDto.getX2(), nextStatusDto.getStatus()));
                     } else if (nextStatusDto.getX1() > currentStatusDto.getX1() && nextStatusDto.getX2() < currentStatusDto.getX2()) {
-                        currentStatusDto.setX2(nextStatusDto.getX1());
                         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.getX2() > currentStatusDto.getX2()) {
+                    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()));
                     }
                 }
@@ -548,13 +557,36 @@
     }
 
     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) {
+            if (item.getSameSbNum() > 1) {
+                for (int i = 1; i <= item.getSameSbNum(); i++) {
+                    try {
+                        ProductStatusDto newRow = item.clone();
+                        newRow.setDeviceNo(i);
+                        newRow.setName(item.getName() + "-" + i);
+                        newRow.setDataId(item.getId().toString() + "-" + i);
+                        childList.add(newRow);
+                    } catch (CloneNotSupportedException e) {
+                        e.printStackTrace();
+                    }
+                }
+            } else {
+                item.setDeviceNo(0);
+                item.setDataId(item.getId().toString());
+                childList.add(item);
+            }
+        }
+        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;
     }
 
@@ -629,7 +661,6 @@
         return result;
     }
 
-    @Transactional(rollbackFor = Exception.class)
     public Boolean simulate(SimulatAssess simulatAssess) {
         Boolean result = false;
         // 2. 缁勮渚涚畻娉曞簱浠跨湡鐨勬ā鍨媥ml
@@ -639,6 +670,11 @@
         result = callReliaSimLib(simulatAssess);
 
         return result;
+    }
+
+    public List<SimulatAssess> process(QueryFilter queryFilter) {
+        List<SimulatAssess> page = baseDao.getProcessList(queryFilter.getParams());
+        return queryFilter.getPageList(page);
     }
 
     private Boolean callReliaSimLib(SimulatAssess simulatAssess) {
@@ -664,6 +700,8 @@
             } else {
                 throw new RenException("鏆備笉鏀寔璇ユ搷浣滅郴缁燂紝杩涜鍚姩绠楁硶搴撹绠楋紒");
             }
+            long pid = ProcessUtils.getProcessId(process);
+            logger.info("绠楁硶搴揚ID锛�" + pid);
             is = process.getInputStream();
             // 浠ュ懡浠よ鏂瑰紡璋冪敤绠楁硶搴撴椂锛屾帴鍙g害瀹氳繑鍥炵殑缁撴灉鏄痷tf-8缂栫爜
             br = new BufferedReader(new InputStreamReader(is, "utf-8"));
@@ -674,6 +712,8 @@
                 ReliaSimLibResult rtn = com.alibaba.fastjson.JSONObject.parseObject(line, ReliaSimLibResult.class);
                 if ("0".equals(rtn.getCode())) {
                     logger.info("鍚姩鍙潬鎬т豢鐪熻瘎浼扮畻娉曞簱鎴愬姛銆�");
+                    newProcess(simulatAssess, pid, command);
+                    update(simulatAssess);
                     result = true;
                 } else {
                     String errorMsg = rtn.getErrorMsg();
@@ -702,6 +742,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) {
@@ -758,7 +806,8 @@
             Element root = document.addElement("des");
             root.addAttribute("name", "General system");
             addTasksTag(taskPhaseModelAll, root);
-            addModelsTag(taskId,
+            addModelsTag(simulatAssess,
+                    taskId,
                     productId,
                     product.getName(),
                     product.getNamePath(),
@@ -895,6 +944,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;
             }
@@ -937,7 +990,8 @@
         return taskPhases;
     }
 
-    private void addModelsTag(Long taskId,
+    private void addModelsTag(SimulatAssess simulatAssess,
+                              Long taskId,
                               Long productId,
                               String productName,
                               String productNamePath,
@@ -963,7 +1017,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,
@@ -981,7 +1036,8 @@
     }
 
     // 閫掑綊鍑芥暟
-    private void node2DOM(Long taskId,
+    private void node2DOM(SimulatAssess simulatAssess,
+                          Long taskId,
                           TaskPhaseModel taskPhaseModel,
                           Long modelId,
                           Long productId,
@@ -1011,7 +1067,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(),
@@ -1027,9 +1084,10 @@
                         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", deviceNo == 0 ? dataId.toString() : dataId.toString() + "-" + deviceNo);
+                nodeTag.addAttribute("real_name", deviceNo == 0 ? product.getName() : product.getName() + "-" + deviceNo);
                 nodeTag.addAttribute("name_path", product.getNamePath());
                 nodeTag.addAttribute("type", "node");
 
@@ -1061,7 +1119,12 @@
 
                 if (1 == paramData.getRepairable()) {
                     // 鍙淮淇�
-                    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());
@@ -1096,7 +1159,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,
@@ -1151,23 +1215,46 @@
         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;
@@ -1178,8 +1265,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 {
@@ -1199,50 +1285,46 @@
 
         }
 
-        List<WeakDto> productList = baseDao.getProductList(taskId, productId);
-        for (WeakDto dto : productList) {
-            map.put(dto.getId(), dto);
-        }
+        Map<Long, WeakDto> map = new HashMap<>();
         JSONObject xmlJSONObj = XML.toJSONObject(xml);
         JSONArray jsonArray = xmlJSONObj.getJSONObject("ResultNodes").getJSONArray("ResultNode");
         for (int i = 0; i < jsonArray.size(); i++) {
             WeakDto data = new WeakDto();
             Long productId1;
-            Object nameValue = jsonArray.getJSONObject(i).get("name");
-            if (nameValue instanceof Long) {
-                productId1 = (Long) nameValue;
-                if (map.get(productId1) != null) {
-                    WeakDto weakDto = map.get(productId1);
-                    Double mtbfTime = null;
+            String nameValue = jsonArray.getJSONObject(i).get("name").toString();
+            if (StringUtils.isNotBlank(nameValue)) {
+                productId1 = Convert.toLong(nameValue.split("-")[0]);
 
-                    Double mtbf = (Double) jsonArray.getJSONObject(i).get("mttf");
-                    Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
-                    Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
-
-                    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 = (Double) jsonArray.getJSONObject(i).get("mttf");
+                Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
+                Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
+                WeakDto weakDto = new WeakDto();
+                weakDto.setId(productId1);
+                weakDto.setMtbf(mtbf);
+                weakDto.setMttr(mttr);
+                weakDto.setMsr(msr);
+                if (map.get(productId1) == null) {
+                    map.put(productId1, weakDto);
+                } else {
+                    if (weakDto.getMsr() < map.get(productId1).getMsr()) {
+                        map.put(productId1, weakDto);
                     }
-
-                    data.setMtbfTime(mtbfTime);
-                    data.setIsWeak(0);
-
-                    list.add(data);
                 }
             }
         }
+        List<WeakDto> productList = baseDao.getProductList(taskId, productId);
+        for (WeakDto item : productList) {
+            WeakDto dto = map.get(item.getId());
+            item.setMtbf(dto.getMtbf());
+            item.setMttr(dto.getMttr());
+            item.setMsr(dto.getMsr());
+            item.setMtbfTime(dto.getMtbf() / item.getTimeRate());
+            item.setIsWeak(0);
+        }
+
         List<WeakDto> treeList = new ArrayList<>();
-        if (list.size() > 0) {
-            treeList = TreeUtils.build(list);
+        if (productList.size() > 0) {
+            treeList = TreeUtils.build(productList);
             this.getIsweak(treeList.get(0).getChildren());
         }
 
@@ -1300,7 +1382,7 @@
 
             simulatAssessList.add(simulatAssess);
             result = simulateChecK(simulatAssess);
-            if (result!=null){
+            if (result != null) {
                 simulatResult.setType("errorList");
                 simulatResult.setErrList(result);
                 return simulatResult;
@@ -1344,7 +1426,7 @@
             }
         }
         xmlJSONObj = XML.toJSONObject(xml);
-        simulatAssess.setShowProductId(simulatAssess.getProductId());
+        simulatAssess.setShowProductId(simulatAssess.getProductId().toString());
         SimulaDataDto data = this.getResultData(simulatAssess);
         return data;
     }
@@ -1356,50 +1438,47 @@
         samplPeriod = samplPeriod / 60;
         JSONArray jsonArray = xmlJSONObj.getJSONObject("ResultNodes").getJSONArray("ResultNode");
         for (int i = 0; i < jsonArray.size(); i++) {
-            Long productId = null;
-            Object nameValue = jsonArray.getJSONObject(i).get("name");
-            if (nameValue instanceof Long) {
-                productId = (Long) nameValue;
-                if (productId.equals(simulatAssess.getShowProductId())) {
-                    Object object = jsonArray.getJSONObject(i).get("phase");
-                    List<Double> doubleArray = new ArrayList<>();
-                    List<Double> xList = new ArrayList<>();
-                    String availability = null;
-                    if (object instanceof JSONArray) {
-                        JSONArray jsonArray2 = jsonArray.getJSONObject(i).getJSONArray("phase");
-                        for (int j = 0; j < jsonArray2.size(); j++) {
-                            if (availability != null) {
-                                availability = availability + " " + jsonArray2.getJSONObject(j).get("availability");
-                            } else {
-                                availability = (String) jsonArray2.getJSONObject(j).get("availability");
-                            }
+            String nameValue = jsonArray.getJSONObject(i).get("name").toString();
+            if (nameValue.equals(simulatAssess.getShowProductId())) {
+                Object object = jsonArray.getJSONObject(i).get("phase");
+                List<Double> doubleArray = new ArrayList<>();
+                List<Double> xList = new ArrayList<>();
+                String availability = null;
+                if (object instanceof JSONArray) {
+                    JSONArray jsonArray2 = jsonArray.getJSONObject(i).getJSONArray("phase");
+                    for (int j = 0; j < jsonArray2.size(); j++) {
+                        if (availability != null) {
+                            availability = availability + " " + jsonArray2.getJSONObject(j).get("availability");
+                        } else {
+                            availability = (String) jsonArray2.getJSONObject(j).get("availability");
                         }
-                    } else {
-                        JSONObject jsonObject2 = jsonArray.getJSONObject(i).getJSONObject("phase");
-                        availability = (String) jsonObject2.get("availability");
                     }
-
-                    String[] arr = availability.split(" ");
-                    // 閬嶅巻瀛愬瓧绗︿覆鏁扮粍锛屽皢姣忎釜鍏冪礌杞崲涓篸ouble骞跺瓨鍌ㄥ埌double鏁扮粍涓�
-                    Double j = 0.0;
-                    for (int a = 0; a < arr.length; a++) {
-                        j = samplPeriod + j;
-                        doubleArray.add(Double.parseDouble(arr[a]));
-                        xList.add(j);
-                    }
-
-                    param.setXData(xList);
-                    param.setYData(doubleArray);
-                    Double mtbf = (Double) jsonArray.getJSONObject(i).get("mttf");
-                    Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
-                    Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
-                    data.setMtbf(mtbf);
-                    data.setMttr(mttr);
-                    data.setMsr(msr);
+                } else {
+                    JSONObject jsonObject2 = jsonArray.getJSONObject(i).getJSONObject("phase");
+                    availability = (String) jsonObject2.get("availability");
                 }
-                data.setCurveParam(param);
+
+                String[] arr = availability.split(" ");
+                // 閬嶅巻瀛愬瓧绗︿覆鏁扮粍锛屽皢姣忎釜鍏冪礌杞崲涓篸ouble骞跺瓨鍌ㄥ埌double鏁扮粍涓�
+                Double j = 0.0;
+                for (int a = 0; a < arr.length; a++) {
+                    j = samplPeriod + j;
+                    doubleArray.add(Double.parseDouble(arr[a]));
+                    xList.add(j);
+                }
+
+                param.setXData(xList);
+                param.setYData(doubleArray);
+                Double mtbf = (Double) jsonArray.getJSONObject(i).get("mttf");
+                Double mttr = (Double) jsonArray.getJSONObject(i).get("mttr");
+                Double msr = (Double) jsonArray.getJSONObject(i).get("msr");
+                data.setMtbf(mtbf);
+                data.setMttr(mttr);
+                data.setMsr(msr);
             }
+            data.setCurveParam(param);
         }
+
         return data;
     }
 
@@ -1532,4 +1611,84 @@
         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 {
+                    // 浣跨敤 ObjectMapper 鐨� readValue 鏂规硶锛屽皢鏂囦欢涓殑 JSON 鏁版嵁杞崲涓轰竴涓� Java 瀵硅薄
+                    // 杩欓噷浣跨敤 Object 绫讳綔涓烘硾鍨嬪弬鏁帮紝琛ㄧず浠绘剰绫诲瀷鐨勫璞�
+                    Object obj = mapper.readValue(new File(filePath), Object.class);
+                    // 浣跨敤 ObjectMapper 鐨� writeValueAsString 鏂规硶锛屽皢 Java 瀵硅薄杞崲涓� JSON 瀛楃涓�
+                    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();
+            }
+        }
+    }
 }

--
Gitblit v1.9.1