diff --git a/clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/StatementService.java b/clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/StatementService.java index b4aeae21a..fba4befe3 100644 --- a/clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/StatementService.java +++ b/clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/StatementService.java @@ -134,12 +134,12 @@ public class StatementService extends QueueConsumer implements InitializingBean if (accountRequests.size() > 0) { 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) {