dm;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMAddressesProcessor.java

@@ -105,6 +105,7 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (addressesList.size() > 0 && ct > 1000) {
+                    tl += addressesList.size();
                     log.info("DM.execute.limit.result:{}", dmAddressesService.saveBatch(addressesList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMCollectionProcessor.java

@@ -96,6 +96,7 @@ public class DMCollectionProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (collectionList.size() > 0 && ct > 1000) {
+                    tl += collectionList.size();
                     log.info("DM.execute.limit.result:{}", dmCollectionService.saveBatch(collectionList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMEntersProcessor.java

@@ -109,6 +109,7 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (entersList.size() > 0 && ct > 1000) {
+                    tl += entersList.size();
                     log.info("DM.execute.limit.result:{}", dmEntersService.saveBatch(entersList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMMemberCodeProcessor.java

@@ -260,6 +260,7 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (memberCodeList.size() > 0 && ct > 1000) {
+                    tl += memberCodeList.size();
                     log.info("DM.execute.limit.result:{}", dmMemberCodeService.saveBatch(memberCodeList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMMemberOrderProcessor.java

@@ -141,6 +141,7 @@ public class DMMemberOrderProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (memberOrderList.size() > 0 && ct > 1000) {
+                    tl += memberOrderList.size();
                     log.info("DM.execute.limit.result:{}", dmMemberOrderService.saveBatch(memberOrderList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMRealNameProcessor.java

@@ -108,6 +108,7 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (realNameList.size() > 0 && ct > 1000) {
+                    tl += realNameList.size();
                     log.info("DM.execute.limit.result:{}", dmRealNameService.saveBatch(realNameList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMThirdPartsProcessor.java

@@ -117,6 +117,7 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (thirdPartyList.size() > 0 && ct > 1000) {
+                    tl += thirdPartyList.size();
                     log.info("DM.execute.limit.result:{}", dmThirdPartyService.saveBatch(thirdPartyList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMUserInformationProcessor.java

@@ -157,6 +157,7 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (userList.size() > 0 && ct > 1000) {
+                    tl += userList.size();
                     log.info("DM.execute.result:{} - {}", dmUserService.saveBatch(userList), dmUserInfoService.saveBatch(userInfoList));
                 }
                 row.close();

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMUserMemberProcessor.java

@@ -108,6 +108,7 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
                     }
                 }
                 if (userMemberList.size() > 0 && ct > 1000) {
+                    tl += userMemberList.size();
                     log.info("DM.execute.limit.result:{}", dmUserMemberService.saveBatch(userMemberList));
                 }
                 row.close();