From c94fe7d4dbeb21add6b0705ea0f70a3b424b3f31 Mon Sep 17 00:00:00 2001
From: psemenkov <psemenkov@mfd.ru>
Date: Fri, 9 Jun 2023 18:58:07 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-316=20?=
 =?UTF-8?q?=D0=9F=D0=BE=D0=BF=D1=80=D0=B0=D0=B2=D0=B8=D0=BB=20=D0=B2=D1=8B?=
 =?UTF-8?q?=D0=B2=D0=BE=D0=B4=20=D0=B2=20=D0=BB=D0=BE=D0=B3.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../spcex/clearing/swt/importer/logic/stages/ImportToDB.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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);