From 7d971cd054bb6ddd9073eabd8e8e3fe6cd39586d Mon Sep 17 00:00:00 2001 From: ialbert Date: Sat, 27 May 2023 12:53:32 +0300 Subject: [PATCH] DealRevise SDF56 command to kafka --- .../spcex/clearing/session/stage/impl/BalanceRevise.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 8ffe640dd..bb6dae9ad 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 @@ -12,7 +12,7 @@ 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.domain.cud.clearing.SdfClearingRequest; import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender; import ru.spcex.clearing.session.stage.ISessionStage; import ru.spcex.clearing.session.stage.StageResult; @@ -188,9 +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); + SdfClearingRequest requestForExporter = new SdfClearingRequest(); + requestForExporter.setGroupId(sDf56.getGenerationId()); + kafkaSender.sendRequestToQueue(Consts.SDF56_PROCESS, requestForExporter); log.debug("successfully processed, new id {}", sDf56.getId()); } }