跑流量

src/main/java/track/task/TrackingFlowTask.java

@@ -414,7 +414,7 @@ public class TrackingFlowTask {
         ExecutorService executorService = Executors.newFixedThreadPool(30);
 
         List<String> emails = contractRepository.findDistinctEmailByPlatform("tkio");
-        emails = emails.stream().limit(40).collect(Collectors.toList());
+        // emails = emails.stream().limit(40).collect(Collectors.toList());
         List<String> dateInterval = DateUtil.getDateInterval("2021-05-25", "2021-07-15");
         // dateInterval.add("2021-06-30");
         // emails = Arrays.asList("1291269883@qq.com");