From dcbdea0abfacd23cc8e106f2ece89b820cb0fc51 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Wed, 7 Dec 2022 19:22:32 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-100=20?=
 =?UTF-8?q?=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8=D0=BB=20=D1=81=D0=BE=D1=85?=
 =?UTF-8?q?=D1=80=D0=B0=D0=BD=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BE=D0=B1=D1=8A?=
 =?UTF-8?q?=D0=B5=D0=BA=D1=82=D0=BE=D0=B2=20Launcher?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../queue/scheduler/LauncherController.java         | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/queue/scheduler/LauncherController.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/queue/scheduler/LauncherController.java
index 8f1eeadae..f5429d6c9 100644
--- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/queue/scheduler/LauncherController.java
+++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/queue/scheduler/LauncherController.java
@@ -29,6 +29,7 @@ import ru.spcex.platform.imdg.api.ImdgProvider;
 import ru.spcex.platform.utils.enumeration.EnumMessage;
 import ru.spcex.platform.utils.enumeration.IMessageResolver;
 
+import java.time.Instant;
 import java.util.Collection;
 import java.util.Map;
 import java.util.concurrent.ExecutionException;
@@ -39,6 +40,7 @@ public class LauncherController extends AbstractQueueController {
     private final IStateLoader stateLoader;
     private final Imdg<User> userImdg;
     private final Imdg<AbstractDictionary> taskDictionary;
+    private final Imdg<Launcher> launcherImdg;
 
     @Autowired
     public LauncherController(IStateLoader stateLoader, IOperator operator, ImdgProvider imdgProvider) {
@@ -46,6 +48,7 @@ public class LauncherController extends AbstractQueueController {
         this.stateLoader = stateLoader;
         this.userImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_User, User.class);
         this.taskDictionary = imdgProvider.getImdg(IMDGDistributedNames.Map_TaskDictionary, AbstractDictionary.class);
+        this.launcherImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Launcher, Launcher.class);
     }
 
     @ApiOperation(value = "get all Launchers.")
@@ -78,11 +81,21 @@ public class LauncherController extends AbstractQueueController {
         }
         launcherCommand.setTask(dictionaryName);
         launcherCommand.setUserId(user.getId());
+        //пока здесь
+        saveLauncher(dictionaryName, user.getId());
         //топики ограничиваются наличием в taskDictionary
         //подписываются на разные топики в разных модулях, см. ru.spcex.platform.enumeration.Task#topic
         return processRequest("launcher-" + dictionaryName, launcherCommand);
     }
 
+    private void saveLauncher(String taskCode, Long userId) {
+        Launcher launcherCommandHistory = new Launcher();
+        launcherCommandHistory.setTask(taskCode);
+        launcherCommandHistory.setSenderId(userId);
+        launcherCommandHistory.setCreated(Instant.now());
+        launcherImdg.insert(launcherCommandHistory);
+    }
+
     @Autowired
     private IMessageResolver errorResolver;