取消调试

src/main/java/common/service/impl/ShareIncomeServiceImpl.java

@@ -146,8 +146,6 @@ public class ShareIncomeServiceImpl implements ShareIncomeService {
             });
         }
         if ("tkio".equals(platform)) {
-            contracts = Arrays.asList(contractRepository.findByCode("BJ-TKIO-20200821-0125"));
-
             this.shareIncome4ContractTKIO_2(contracts, start, end);
         } else {
             try (Stream<Contract> streamContract = contracts.parallelStream()) {

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

@@ -419,35 +419,14 @@ public class TrackingFlowTask {
         // dateInterval.add("2021-06-30");
         // emails = Arrays.asList("1291269883@qq.com");
 
-        if (lastEmail != null) {
-            List<String> unSyncEmails = new ArrayList<>();
-            boolean addflag = false;
-            for (String email : emails) {
-                if (email != null && email.equals(lastEmail)) {
-                    addflag = true;
-                }
-
-                if (addflag) {
-                    unSyncEmails.add(email);
-                }
-            }
-
-            if (!unSyncEmails.isEmpty()) {
-                emails = unSyncEmails;
-            }
-        }
-
-
         for (String dsone : dateInterval) {
             StopWatch stopWatch = new StopWatch();
             stopWatch.start();
             CompletableFuture[] futures = emails.stream().map(em ->
                     CompletableFuture.supplyAsync(() -> {
-                                reset(dsone, em);
-                                return Thread.currentThread().getName() + em;
-                            }
-
-                            , executorService).exceptionally((t) -> {
+                        reset(dsone, em);
+                        return Thread.currentThread().getName() + em;
+                    }, executorService).exceptionally((t) -> {
                         logger.error("erro on " + em + "-" + dsone, t);
                         return "-1";
                     })).toArray(size -> new CompletableFuture[size]);