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

http://jira.mfd.msk:8088/browse/CLS-100 добавил сохранение объектов Launcher

Browse source
This commit is contained in:
ialbert 2022-12-07 19:22:32 +03:00
parent 834150563a
commit dcbdea0abf
1 changed files with 13 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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;