From 415d5697d88f63546d12a7b79f54e747d50cc1d0 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Mon, 5 Jun 2023 17:06:45 +0300
Subject: [PATCH] session closing

---
 .../java/ru/spcex/clearing/session/stage/FinalMkrSession.java    | 1 +
 .../ru/spcex/clearing/session/stage/IntermediateMkrSession.java  | 1 +
 .../ru/spcex/clearing/session/stage/PrimaryAuctionB0Session.java | 1 +
 .../ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java | 1 +
 .../ru/spcex/clearing/session/stage/PrimaryAuctionT0Session.java | 1 +
 .../ru/spcex/clearing/session/stage/ReturnDepositSession.java    | 1 +
 .../spcex/clearing/session/stage/SecondaryAuctionT0Session.java  | 1 +
 7 files changed, 7 insertions(+)

diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/FinalMkrSession.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/FinalMkrSession.java
index c15a83f38..a63815c1d 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/FinalMkrSession.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/FinalMkrSession.java
@@ -187,6 +187,7 @@ public class FinalMkrSession extends AbstractSession implements InitializingBean
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/IntermediateMkrSession.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/IntermediateMkrSession.java
index f16863c52..8fbb17d97 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/IntermediateMkrSession.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/IntermediateMkrSession.java
@@ -192,6 +192,7 @@ public class IntermediateMkrSession extends AbstractSession implements Initializ
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionB0Session.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionB0Session.java
index 19b668450..1f64973bb 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionB0Session.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionB0Session.java
@@ -180,6 +180,7 @@ public class PrimaryAuctionB0Session extends AbstractSession implements Initiali
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java
index c3904fc86..445d976ae 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java
@@ -178,6 +178,7 @@ public class PrimaryAuctionBnSession extends AbstractSession implements Initiali
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionT0Session.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionT0Session.java
index c52bd0260..ebd12cdcd 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionT0Session.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionT0Session.java
@@ -179,6 +179,7 @@ public class PrimaryAuctionT0Session extends AbstractSession implements Initiali
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/ReturnDepositSession.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/ReturnDepositSession.java
index 736ae4b4b..de4867b1c 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/ReturnDepositSession.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/ReturnDepositSession.java
@@ -166,6 +166,7 @@ public class ReturnDepositSession extends AbstractSession implements Initializin
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java
index d6f72a96b..d2c752416 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/SecondaryAuctionT0Session.java
@@ -179,6 +179,7 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia
                 payload.setSection(currSession.getSection());
                 payload.setSessionId(currSession.getId());
                 runStage(TaskType.EndStageNotification, payload, endStageNotification);
+                endSession();
             }
         } catch (StageException e) {
             //already logged