treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-316

Browse source 
Поправил вывод в лог.
This commit is contained in:
psemenkov 2023-06-09 18:58:07 +03:00
parent 7d47af9e18
commit c94fe7d4db
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDB.java
View file

@ -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.ETable;
import ru.spcex.clearing.swt.importer.logic.data.enums.StageResult; 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.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.SWTReader;
import ru.spcex.clearing.swt.importer.util.SWTRecord;
import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService; import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService;
import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.log.ExceptionUtils;
@ -55,10 +55,11 @@ public class ImportToDB extends Stage {
table.setFileId(fileId); table.setFileId(fileId);
int counter = 0; int counter = 0;
do { do {
counter++;
SWTRecord record = swtReader.nextRecord(); SWTRecord record = swtReader.nextRecord();
if (record.isNotEmpty()) { if (record.isNotEmpty()) {
table.injectEntity(table.getEntity(record)); table.injectEntity(table.getEntity(record));
counter++;
log.debug("{} entity stored.", counter);
} else continue; } else continue;
} while (swtReader.hasNextRecord()); } while (swtReader.hasNextRecord());
kafkaMessenger.notifySystemIfNeeded(currTable, fileId); kafkaMessenger.notifySystemIfNeeded(currTable, fileId);