From 1f42a6badcd9d1070b0cfbaa8b83931d605b333d Mon Sep 17 00:00:00 2001 From: ialbert Date: Sat, 27 May 2023 12:25:02 +0300 Subject: [PATCH] BalanceRevise session step 0 send command to dbf-exporter SDF-56 --- .../ru/spcex/clearing/session/stage/impl/BalanceRevise.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java index 4f606bb1e..8ffe640dd 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java @@ -11,6 +11,8 @@ import ru.clearing.classes.statics.data.registry.Registry; import ru.clearing.classes.statics.data.sdf.SDf56; import ru.clearing.classes.statics.data.statement.Statement; import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.platform.messaging.domain.Consts; +import ru.spcex.clearing.platform.messaging.domain.cud.importexport.SwtExporterRequest; import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender; import ru.spcex.clearing.session.stage.ISessionStage; import ru.spcex.clearing.session.stage.StageResult; @@ -186,6 +188,9 @@ public class BalanceRevise implements ISessionStage { sDf56.setGenerationTime(now); sDf56.setGenerationId(idGenerator.nextId()); sDf56Imdg.insert(sDf56); + SwtExporterRequest requestForExporter = new SwtExporterRequest(); + requestForExporter.setType(SwtTable.SDF_56); + kafkaSender.sendRequestToQueue(Consts.SWT_EXPORTER, requestForExporter); log.debug("successfully processed, new id {}", sDf56.getId()); } }