From 7c4fb50cff4b66790baadd14ef878c7aa54a20ae Mon Sep 17 00:00:00 2001
From: etreschenkov <etreschenkov@mfd.ru>
Date: Mon, 29 May 2023 12:49:57 +0300
Subject: [PATCH] send sdf05 to export

---
 .../session/stage/impl/FinishingSession.java  | 28 +++++++++++++++++++
 1 file changed, 28 insertions(+)

diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/FinishingSession.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/FinishingSession.java
index 65e1138f4..a1154e5d8 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/FinishingSession.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/FinishingSession.java
@@ -7,8 +7,10 @@ import org.springframework.beans.factory.config.ConfigurableBeanFactory;
 import org.springframework.context.annotation.Scope;
 import org.springframework.stereotype.Service;
 import ru.clearing.classes.statics.data.registry.Registry;
+import ru.clearing.classes.statics.data.sdf.SDf05;
 import ru.spcex.clearing.imdg.IMDGDistributedNames;
 import ru.spcex.clearing.platform.messaging.domain.Consts;
+import ru.spcex.clearing.platform.messaging.domain.cud.balance.ExportToFileRequest;
 import ru.spcex.clearing.platform.messaging.domain.cud.reports.ReportRequestWithRegistryId;
 import ru.spcex.clearing.platform.messaging.domain.cud.reports.ReportRequestWithSessionId;
 import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
@@ -26,6 +28,10 @@ import ru.spcex.platform.imdg.api.predicate.specific.RegistryCodeSqlBuilder;
 import ru.spcex.platform.utils.enumeration.EnumMessage;
 import ru.spcex.platform.utils.enumeration.IMessageResolver;
 
+import java.math.BigDecimal;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.LocalTime;
 import java.util.Collection;
 
 import static ru.spcex.clearing.error.ClearingErrorInternal.SessionGeneralError;
@@ -35,13 +41,17 @@ import static ru.spcex.clearing.error.ClearingErrorInternal.SessionGeneralError;
 public class FinishingSession implements ISessionStage {
     private final Logger log = LoggerFactory.getLogger(getClass());
 
+    private final ImdgProvider imdgProvider;
     private final Imdg<Registry> registryImdg;
+    private final Imdg<SDf05> sDf05Imdg;
     private final KafkaSender kafkaSender;
     private final IMessageResolver msgResolver;
 
     @Autowired
     public FinishingSession(ImdgProvider imdgProvider, KafkaSender kafkaSender, IMessageResolver msgResolver) {
+        this.imdgProvider = imdgProvider;
         this.registryImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Registry, Registry.class);
+        this.sDf05Imdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SDf05, SDf05.class);
         this.kafkaSender = kafkaSender;
         this.msgResolver = msgResolver;
     }
@@ -80,6 +90,7 @@ public class FinishingSession implements ISessionStage {
                 return sResult;
             }
         }
+        sendSdf05();
         StageResult<Collection<Registry>> res = new StageResult<>(null, true);
         return res;
     }
@@ -124,4 +135,21 @@ public class FinishingSession implements ISessionStage {
         log.trace("Selected {} registry's by sql: {}", result.size(), condition);
         return result;
     }
+
+    private void sendSdf05() {
+        SDf05 sdf05 = new SDf05();
+        sdf05.setId(imdgProvider.getImdgIdGenerator().nextId());
+        sdf05.setTp(BigDecimal.valueOf(753));
+        sdf05.setDt(LocalDate.now());
+        sdf05.setTm(LocalTime.now());
+        sdf05.setPr("3");
+        sdf05.setGenerationTime(Instant.now());
+        sdf05.setGenerationId(imdgProvider.getImdgIdGenerator().nextId());
+        sDf05Imdg.insert(sdf05);
+
+        ExportToFileRequest exportRequest = new ExportToFileRequest();
+        exportRequest.setSdfGroupId(sdf05.getGenerationId());
+        exportRequest.setNameOfTable("DF-05");
+        kafkaSender.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest);
+    }
 }