增加异常数据定时推送任务

src/main/java/com/jkcredit/traffic/record/task/PushRecordsTask.java

@@ -16,11 +16,26 @@ import org.springframework.stereotype.Component;
 public class PushRecordsTask {
     @Value("${originalRecords.path}")
     private String originalRecordsPath;
+    @Value("${errorRecords.path}")
+    private String errorRecordsPath;
+
     @Autowired
     TrafficRecordsAnalyseService trafficRecordsAnalyseService;
 
     @Scheduled(cron = "0 0 0/1 * * ?")
+//    @Scheduled(cron = "0 0/2 * * * ?")
     public void push() {
         trafficRecordsAnalyseService.pushTrafficRecords(originalRecordsPath);
     }
+
+    @Scheduled(cron = "0 0 0/1 * * ?")
+//    @Scheduled(cron = "0 0/2 * * * ?")
+    public void pushErrorRecords() {
+        log.info("pushErrorRecordsScheduledBegin");
+        long startTime = System.currentTimeMillis();
+        trafficRecordsAnalyseService.pushErrorRecords(errorRecordsPath);
+        log.info("pushErrorRecordsScheduledEnd:{}", (System.currentTimeMillis() - startTime));
+    }
+
+
 }

src/main/resources/application-dev.yml

@@ -15,6 +15,6 @@ errorRecords:
 tempFolder:
   path: /Users/jkxy/Desktop/test/temp
 originalRecords:
-  path: /home/jkxy-01/data/naruto
+  path: /Users/jkxy/Desktop/test/output
 pushProcess:
   path: /Users/jkxy/Desktop/test/process.csv