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 ad0c6afd2..df16b4332 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 @@ -145,10 +145,12 @@ public class StatementService extends QueueConsumer implements InitializingBean kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests)); } } - ExportToFileRequest exportRequest = new ExportToFileRequest(); - exportRequest.setSdfGroupId(generationIdForGroup); - exportRequest.setNameOfTable("DF-02"); - kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest); + if (accountRequests.size() == 0) { + ExportToFileRequest exportRequest = new ExportToFileRequest(); + exportRequest.setSdfGroupId(generationIdForGroup); + exportRequest.setNameOfTable("DF-02"); + kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest); + } } private Statement createFlow(SDf01 sdf01, Company company, Account account) {