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