diff --git a/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDB.java b/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDB.java index 45cb994d8..99e5150da 100644 --- a/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDB.java +++ b/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDB.java @@ -7,8 +7,8 @@ import ru.spcex.clearing.swt.importer.logic.data.ResultContainer; import ru.spcex.clearing.swt.importer.logic.data.enums.ETable; import ru.spcex.clearing.swt.importer.logic.data.enums.StageResult; import ru.spcex.clearing.swt.importer.logic.data.tables.AbstractTable; -import ru.spcex.clearing.swt.importer.util.SWTHeaderData; import ru.spcex.clearing.swt.importer.util.SWTReader; +import ru.spcex.clearing.swt.importer.util.SWTRecord; import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService; import ru.spcex.platform.utils.log.ExceptionUtils; @@ -55,10 +55,11 @@ public class ImportToDB extends Stage { table.setFileId(fileId); int counter = 0; do { - counter++; SWTRecord record = swtReader.nextRecord(); if (record.isNotEmpty()) { table.injectEntity(table.getEntity(record)); + counter++; + log.debug("{} entity stored.", counter); } else continue; } while (swtReader.hasNextRecord()); kafkaMessenger.notifySystemIfNeeded(currTable, fileId);