From d4767d5937bccc3e3d4b0d4ce6899b29218963d8 Mon Sep 17 00:00:00 2001 From: ialbert Date: Mon, 12 Dec 2022 13:12:58 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-35 --- .../clearing/dbf/importer/logic/stages/ImportToDB.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/ImportToDB.java b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/ImportToDB.java index 59f0d63d0..f0259951f 100644 --- a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/ImportToDB.java +++ b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/ImportToDB.java @@ -9,6 +9,7 @@ import ru.spcex.clearing.dbf.importer.logic.data.enums.ETable; import ru.spcex.clearing.dbf.importer.logic.data.enums.StageResult; import ru.spcex.clearing.dbf.importer.logic.data.tables.AbstractTable; import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService; +import ru.spcex.platform.utils.log.ExceptionUtils; import java.io.ByteArrayInputStream; import java.io.IOException; @@ -51,12 +52,19 @@ public class ImportToDB extends Stage { table.setFileId(fileId); for (int i = 0; i < dbfReader.getRecordCount(); i++) { Object[] entity = dbfReader.nextRecord(); + if (entity == null) { + log.warn("record index {} null", i); + continue; + } table.injectEntity(table.getEntity(entity)); } kafkaMessenger.notifySystemIfNeeded(currTable, fileId); } catch (IOException exception) { log.warn(exception.getMessage()); return StageResult.ERROR; + } catch (Throwable e) { + log.error(ExceptionUtils.getStackTrace(e)); + return StageResult.ERROR; }