From 1f959be4f5e6303b9d19dc2b70b5db0e73191df3 Mon Sep 17 00:00:00 2001 From: AKurakin Date: Fri, 13 Jan 2023 14:19:03 +0300 Subject: [PATCH] =?UTF-8?q?launcher-service=20=D0=B2=D0=B5=D1=80=D0=BD?= =?UTF-8?q?=D1=83=D0=BB=20dcbdea0abfacd23cc8e106f2ece89b820cb0fc51?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../queue/scheduler/LauncherController.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) 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 5d123699e..a6e7bb993 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 @@ -81,20 +81,20 @@ public class LauncherController extends AbstractQueueController { } launcherCommand.setTask(dictionaryName); launcherCommand.setUserId(user.getId()); -// //пока здесь -// saveLauncher(dictionaryName, 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); -// } + 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;