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

Больше логов SDF08...

Browse source
This commit is contained in:
AKurakin 2023-06-09 12:14:22 +03:00
parent 8f7a64122c
commit 79c56c4571
2 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java
View file

@ -68,9 +68,9 @@ public class StatementService extends QueueConsumer implements InitializingBean
} }
private void process(BaseRequest<StatementRequest> systemRequest) { private void process(BaseRequest<StatementRequest> systemRequest) {
log.debug("Receiving StatementRequest id={}", systemRequest.getId());
StatementRequest statementRequest = systemRequest.getRequestPayload(); StatementRequest statementRequest = systemRequest.getRequestPayload();
SdfTable table = statementRequest.getTable(); SdfTable table = statementRequest.getTable();
log.debug("Receiving StatementRequest id={}; table {}", systemRequest.getId(), table);
Optional<Long> completePairKey = saveRequest(statementRequest); Optional<Long> completePairKey = saveRequest(statementRequest);
if (completePairKey.isPresent()) { if (completePairKey.isPresent()) {
@ -133,6 +133,8 @@ public class StatementService extends QueueConsumer implements InitializingBean
AbstractExecutor service = executorsMap.get(SdfTable.SDF_04); AbstractExecutor service = executorsMap.get(SdfTable.SDF_04);
if (service != null) { if (service != null) {
service.execute(sdfGroup, statementRequest); 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); AbstractExecutor service = executorsMap.get(SdfTable.SDF_08);
if (service != null) { if (service != null) {
service.execute(sdfGroup, statementRequest); service.execute(sdfGroup, statementRequest);
} else {
log.warn("Executor for SDF_08 not set");
} }
} }

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

@ -54,6 +54,7 @@ public class ImportToDB extends Stage {
Long fileId = hazelcastService.getImdgIdGenerator().nextId(); Long fileId = hazelcastService.getImdgIdGenerator().nextId();
table.setFileId(fileId); table.setFileId(fileId);
int counter = 0; int counter = 0;
int storedCounter = 0;
SWTHeaderData swtHeaderData = swtReader.getSWTHeader(); SWTHeaderData swtHeaderData = swtReader.getSWTHeader();
do { do {
counter++; counter++;
@ -63,7 +64,9 @@ public class ImportToDB extends Stage {
continue; continue;
} }
table.injectEntity(table.getEntity(swtHeaderData, entity)); table.injectEntity(table.getEntity(swtHeaderData, entity));
storedCounter++;
} while (swtReader.hasNextRecord()); } while (swtReader.hasNextRecord());
log.debug("{} record read; {} entity stored.", counter, storedCounter);
kafkaMessenger.notifySystemIfNeeded(currTable, fileId); kafkaMessenger.notifySystemIfNeeded(currTable, fileId);
} catch (IOException exception) { } catch (IOException exception) {
log.warn(exception.getMessage()); log.warn(exception.getMessage());