treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

launcher-service вернул dcbdea0abf

Browse source
This commit is contained in:
AKurakin 2023-01-13 14:19:03 +03:00
parent 12479c89b7
commit 1f959be4f5
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/queue/scheduler/LauncherController.java
View file

@ -81,20 +81,20 @@ public class LauncherController extends AbstractQueueController {
} }
launcherCommand.setTask(dictionaryName); launcherCommand.setTask(dictionaryName);
launcherCommand.setUserId(user.getId()); launcherCommand.setUserId(user.getId());
// //пока здесь // пока здесь, это требуется для сохранения истории
// saveLauncher(dictionaryName, user.getId()); saveLauncher(dictionaryName, user.getId());
//топики ограничиваются наличием в taskDictionary //топики ограничиваются наличием в taskDictionary
//подписываются на разные топики в разных модулях, см. ru.spcex.platform.enumeration.Task#topic //подписываются на разные топики в разных модулях, см. ru.spcex.platform.enumeration.Task#topic
return processRequest("launcher-" + dictionaryName, launcherCommand); return processRequest("launcher-" + dictionaryName, launcherCommand);
} }
// private void saveLauncher(String taskCode, Long userId) { private void saveLauncher(String taskCode, Long userId) {
// Launcher launcherCommandHistory = new Launcher(); Launcher launcherCommandHistory = new Launcher();
// launcherCommandHistory.setTask(taskCode); launcherCommandHistory.setTask(taskCode);
// launcherCommandHistory.setSenderId(userId); launcherCommandHistory.setSenderId(userId);
// launcherCommandHistory.setCreated(Instant.now()); launcherCommandHistory.setCreated(Instant.now());
// launcherImdg.insert(launcherCommandHistory); launcherImdg.insert(launcherCommandHistory);
// } }
@Autowired @Autowired
private IMessageResolver errorResolver; private IMessageResolver errorResolver;