diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java index 2189b0065..d8ec4bde6 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java @@ -68,9 +68,9 @@ public class StatementService extends QueueConsumer implements InitializingBean } private void process(BaseRequest systemRequest) { - log.debug("Receiving StatementRequest id={}", systemRequest.getId()); StatementRequest statementRequest = systemRequest.getRequestPayload(); SdfTable table = statementRequest.getTable(); + log.debug("Receiving StatementRequest id={}; table {}", systemRequest.getId(), table); Optional completePairKey = saveRequest(statementRequest); if (completePairKey.isPresent()) { @@ -133,6 +133,8 @@ public class StatementService extends QueueConsumer implements InitializingBean AbstractExecutor service = executorsMap.get(SdfTable.SDF_04); if (service != null) { service.execute(sdfGroup, statementRequest); + } else { + log.warn("Executor for SDF_04 not set"); } } @@ -143,6 +145,8 @@ public class StatementService extends QueueConsumer implements InitializingBean AbstractExecutor service = executorsMap.get(SdfTable.SDF_08); if (service != null) { service.execute(sdfGroup, statementRequest); + } else { + log.warn("Executor for SDF_08 not set"); } } 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 2b1d634d8..3e42efde8 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 @@ -54,6 +54,7 @@ public class ImportToDB extends Stage { Long fileId = hazelcastService.getImdgIdGenerator().nextId(); table.setFileId(fileId); int counter = 0; + int storedCounter = 0; SWTHeaderData swtHeaderData = swtReader.getSWTHeader(); do { counter++; @@ -63,7 +64,9 @@ public class ImportToDB extends Stage { continue; } table.injectEntity(table.getEntity(swtHeaderData, entity)); + storedCounter++; } while (swtReader.hasNextRecord()); + log.debug("{} record read; {} entity stored.", counter, storedCounter); kafkaMessenger.notifySystemIfNeeded(currTable, fileId); } catch (IOException exception) { log.warn(exception.getMessage());