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

send to export anyway

Browse source
This commit is contained in:
etreschenkov 2022-09-30 13:55:38 +03:00
parent 5670dbd48d
commit 95cb6c0eff
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -134,12 +134,12 @@ public class StatementService extends QueueConsumer implements InitializingBean
if (accountRequests.size() > 0) { if (accountRequests.size() > 0) {
kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests)); kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests));
} else {
ExportToFileRequest exportRequest = new ExportToFileRequest();
exportRequest.setSdfGroupId(statementRequest.getSdf01GroupId());
exportRequest.setNameOfTable("DF-02");
} }
} }
ExportToFileRequest exportRequest = new ExportToFileRequest();
exportRequest.setSdfGroupId(statementRequest.getSdf01GroupId());
exportRequest.setNameOfTable("DF-02");
kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest);
} }
private Statement createFlow(SDf01 sdf01, Company company, Account account) { private Statement createFlow(SDf01 sdf01, Company company, Account account) {