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;