修改推送异常数据存储，每次失败立刻存储，并清空内存中的异常数据

src/main/java/com/jkcredit/traffic/record/service/TrafficRecordsAnalyseServiceImpl.java

@@ -104,10 +104,6 @@ public class TrafficRecordsAnalyseServiceImpl implements TrafficRecordsAnalyseSe
             boolean deleteResult = FileUtil.INSTANCE.deleteDirectory(tempFolder);
             log.info("deleteTempDir:{}, deleteResult:{}", tempFolder, deleteResult);
         }
-        if (FileUtil.copyOnWriteArrayList.size() != 0) {
-            log.info("trafficRecordPushErrorSize:{}", FileUtil.copyOnWriteArrayList.size());
-            FileUtil.INSTANCE.write(errorRecordsPath + System.currentTimeMillis() + ".csv");
-        }
         log.info("pushTrafficRecordEnd, costTime:{}", System.currentTimeMillis() - startTime);
         return new CommonResponseObject().success();
     }
@@ -137,10 +133,6 @@ public class TrafficRecordsAnalyseServiceImpl implements TrafficRecordsAnalyseSe
             boolean deleteResult = FileUtil.INSTANCE.deleteFile(files.get(i).getAbsolutePath());
             log.info("deleteErrorRecordsFile:{}, deleteResult:{}", files.get(i).getAbsolutePath(), deleteResult);
         }
-        if (FileUtil.copyOnWriteArrayList.size() != 0) {
-            log.info("trafficRecordPushErrorSize:{}", FileUtil.copyOnWriteArrayList.size());
-            FileUtil.INSTANCE.write(errorRecordsPath + System.currentTimeMillis() + ".csv");
-        }
         log.info("pushErrorRecordsEnd, costTime:{}", System.currentTimeMillis() - startTime);
         return new CommonResponseObject().success();
     }
@@ -326,6 +318,8 @@ public class TrafficRecordsAnalyseServiceImpl implements TrafficRecordsAnalyseSe
         if (errorData.size() != 0) {
             // 异常数据写入本地文件
             FileUtil.INSTANCE.addAll(errorData);
+            log.info("trafficRecordPushErrorSize:{}", FileUtil.copyOnWriteArrayList.size());
+            FileUtil.INSTANCE.write(errorRecordsPath + System.currentTimeMillis() + ".csv");
         }
     }
 }

src/main/java/com/jkcredit/traffic/record/util/CsvUtil.java

@@ -32,7 +32,7 @@ public class CsvUtil {
             System.out.println("完成" + filePath + "入库，耗时：" + (end - start) + " ms");
         } catch (Exception e) {
             e.printStackTrace();
-            log.error("writeCsv:", e);
+            log.error("writeCsvException:", e);
         }
     }
 

src/main/java/com/jkcredit/traffic/record/util/FileUtil.java

@@ -1,6 +1,7 @@
 package com.jkcredit.traffic.record.util;
 
 import java.io.File;
+import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
 
@@ -19,7 +20,7 @@ public enum FileUtil {
 
     public void write(String path) {
         CsvUtil.writeCsv(copyOnWriteArrayList, path);
-        copyOnWriteArrayList = new CopyOnWriteArrayList<>();
+        copyOnWriteArrayList = Collections.emptyList();
     }
 
     public boolean deleteFile(String sPath) {