王耀栋--工作台模块代码,任务详情

simulation-resource-server/src/main/java/com/css/simulation/resource/project/impl/SimulationProjectServiceImpl.java

@@ -710,6 +710,9 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
 
 
         ///TODO 1.获取仿真结果文件
+        InputStream fileInputStream = null;
+        InputStreamReader inputStreamReader = null;
+        BufferedReader bufferedReader = null;
         try {
             //2.解析仿真文件
             //time
@@ -735,8 +738,8 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
             List<Double> yawrate_list = new ArrayList<>();//摆角速度
 
             File file = new File("E:\\仿真云平台\\任务详情界面数据\\Ego(1).csv");
-            InputStream fileInputStream = new FileInputStream(file);
-            InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream,"utf-8");
+            fileInputStream = new FileInputStream(file);
+            inputStreamReader = new InputStreamReader(fileInputStream,"utf-8");
 
 /*            MinioParameter minioParameter = new MinioParameter();
 //            minioParameter.setObjectName(po.getRunResultFilePath()+"/ego.csv");
@@ -746,7 +749,7 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
             InputStream inputStream = body.asInputStream();
             InputStreamReader inputStreamReader = new InputStreamReader(inputStream,"utf-8");*/
 
-            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
+            bufferedReader = new BufferedReader(inputStreamReader);
             String line;
             int lineIndex = 0;
             while((line = bufferedReader.readLine()) != null){
@@ -896,6 +899,20 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
             e.printStackTrace();
 
         }finally {
+            try {
+                if(fileInputStream != null){
+                    fileInputStream.close();
+                }
+                if(inputStreamReader != null){
+                    inputStreamReader.close();
+                }
+                if(bufferedReader != null){
+                    bufferedReader.close();
+                }
+            }catch (IOException e){
+                e.printStackTrace();
+
+            }
 
         }