From ed8a4c0e059c96b98e7893da2a536722754c5691 Mon Sep 17 00:00:00 2001 From: ialbert Date: Fri, 14 Oct 2022 13:08:40 +0300 Subject: [PATCH] StatementService account request fix --- .../clearing/balance/service/StatementService.java | 10 ++++++---- 1 file changed, 6 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 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) {