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

StatementService fix

Browse source
This commit is contained in:
ialbert 2022-10-14 18:01:42 +03:00
parent e1dd66c502
commit f406c7eda3
1 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -141,16 +141,14 @@ public class StatementService extends QueueConsumer implements InitializingBean
statement.setOperationStatus(OperationStatus.Executed.getKey()); statement.setOperationStatus(OperationStatus.Executed.getKey());
} }
statementImdg.update(statement); statementImdg.update(statement);
if (accountRequests.size() > 0) {
kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests));
}
} }
if (accountRequests.size() == 0) { if (accountRequests.size() == 0) {
ExportToFileRequest exportRequest = new ExportToFileRequest(); ExportToFileRequest exportRequest = new ExportToFileRequest();
exportRequest.setSdfGroupId(generationIdForGroup); exportRequest.setSdfGroupId(generationIdForGroup);
exportRequest.setNameOfTable("DF-02"); exportRequest.setNameOfTable("DF-02");
kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest); kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest);
} else {
kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(statementRequest.getSdf01GroupId(), accountRequests));
} }
} }