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

StatementService account request fix

Browse source
This commit is contained in:
ialbert 2022-10-14 13:08:40 +03:00
parent 9884d8228e
commit ed8a4c0e05
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -145,11 +145,13 @@ public class StatementService extends QueueConsumer implements InitializingBean
kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests)); kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests));
} }
} }
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);
} }
}
private Statement createFlow(SDf01 sdf01, Company company, Account account) { private Statement createFlow(SDf01 sdf01, Company company, Account account) {
Statement statement = new Statement(); Statement statement = new Statement();