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 ee60bcceb..af31235ca 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 @@ -60,7 +60,9 @@ public class ImportToDB extends Stage { log.warn("record index {} null", counter); continue; } - table.injectEntity(table.getEntity(swtHeaderData, entity)); + if (entity.length > 0) { + table.injectEntity(table.getEntity(swtHeaderData, entity)); + } } kafkaMessenger.notifySystemIfNeeded(currTable, fileId); } catch (IOException exception) {