From f406c7eda343cc471c4b5a2a02efe015c9c8a785 Mon Sep 17 00:00:00 2001 From: ialbert Date: Fri, 14 Oct 2022 18:01:42 +0300 Subject: [PATCH] StatementService fix --- .../ru/spcex/clearing/balance/service/StatementService.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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)); } }