wangli/riven
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3114) - 动态控制 Stream 状态

Browse Source
This commit is contained in:
wangli 2024-10-28 21:24:21 +08:00
parent 1a249dbfae
commit 42b6618acf
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
riven-dingtalk/src/main/java/cn/axzo/riven/dingtalk/controller/DingtalkController.java
View File

@ -39,18 +39,17 @@ public class DingtalkController {
@PostMapping("/enabled")
public CommonResponse<String> changeStream(@RequestParam String appId, @RequestParam Boolean enable) {
OpenDingTalkClient client = clientMap.getOrDefault(appId, null);
if (Objects.isNull(client)) {
return CommonResponse.error("动态调整 Stream 的连接");
}
try {
if (enable) {
if (enable && Objects.isNull(client)) {
ThirdApplicationReq query = new ThirdApplicationReq();
query.setAppId(appId);
List<ThirdApplication> applications = thirdApplicationService.genericQuery(query);
autoConnector.startStream(applications);
} else {
client.stop();
clientMap.remove(appId);
if(Objects.nonNull(client)) {
client.stop();
clientMap.remove(appId);
}
}
} catch (Exception e) {
return CommonResponse.error(e.getMessage());