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

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

Browse source
This commit is contained in:
ialbert 2022-12-12 13:12:58 +03:00
parent 70bfd94b64
commit d4767d5937
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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.enums.StageResult;
import ru.spcex.clearing.dbf.importer.logic.data.tables.AbstractTable; import ru.spcex.clearing.dbf.importer.logic.data.tables.AbstractTable;
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 java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.IOException; import java.io.IOException;
@ -51,12 +52,19 @@ public class ImportToDB extends Stage {
table.setFileId(fileId); table.setFileId(fileId);
for (int i = 0; i < dbfReader.getRecordCount(); i++) { for (int i = 0; i < dbfReader.getRecordCount(); i++) {
Object[] entity = dbfReader.nextRecord(); Object[] entity = dbfReader.nextRecord();
if (entity == null) {
log.warn("record index {} null", i);
continue;
}
table.injectEntity(table.getEntity(entity)); table.injectEntity(table.getEntity(entity));
} }
kafkaMessenger.notifySystemIfNeeded(currTable, fileId); kafkaMessenger.notifySystemIfNeeded(currTable, fileId);
} catch (IOException exception) { } catch (IOException exception) {
log.warn(exception.getMessage()); log.warn(exception.getMessage());
return StageResult.ERROR; return StageResult.ERROR;
} catch (Throwable e) {
log.error(ExceptionUtils.getStackTrace(e));
return StageResult.ERROR;
} }