treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

BalanceRevise session step 0 send command to dbf-exporter SDF-56

Browse source
This commit is contained in:
ialbert 2023-05-27 12:25:02 +03:00
parent bd33c77b47
commit 1f42a6badc
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java
View file

@ -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.sdf.SDf56;
import ru.clearing.classes.statics.data.statement.Statement; import ru.clearing.classes.statics.data.statement.Statement;
import ru.spcex.clearing.imdg.IMDGDistributedNames; 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.platform.messaging.service.sender.KafkaSender;
import ru.spcex.clearing.session.stage.ISessionStage; import ru.spcex.clearing.session.stage.ISessionStage;
import ru.spcex.clearing.session.stage.StageResult; import ru.spcex.clearing.session.stage.StageResult;
@ -186,6 +188,9 @@ public class BalanceRevise implements ISessionStage {
sDf56.setGenerationTime(now); sDf56.setGenerationTime(now);
sDf56.setGenerationId(idGenerator.nextId()); sDf56.setGenerationId(idGenerator.nextId());
sDf56Imdg.insert(sDf56); 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()); log.debug("successfully processed, new id {}", sDf56.getId());
} }
} }