ZF/weiyu
1
0
Fork 0
mirror of https://gitee.com/270580156/weiyu.git synced 2026-05-18 05:08:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

update modules/core: mod 1 files

Browse Source
This commit is contained in:
jack ning
2025-07-07 15:31:19 +08:00
parent 448bb5ef15
commit 6268573cf5
1 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
modules/core/src/main/java/com/bytedesk/core/thread/ThreadRestService.java
View File

@@ -2,7 +2,7 @@
* @Author: jackning 270580156@qq.com
* @Date: 2024-01-29 16:21:24
* @LastEditors: jackning 270580156@qq.com
* @LastEditTime: 2025-07-07 15:27:50
* @LastEditTime: 2025-07-07 15:30:39
* @Description: bytedesk.com https://github.com/Bytedesk/bytedesk
* Please be aware of the BSL license restrictions before installing Bytedesk IM –
* selling, reselling, or hosting Bytedesk IM as a service is a breach of the terms and automatically terminates your rights under the license.
@@ -624,7 +624,25 @@ public class ThreadRestService
.build();
topicRestService.remove(topicRequest);
//
List<String> invites =
List<String> invites = thread.getInvites();
if (invites != null && !invites.isEmpty()) {
for (String invite : invites) {
UserProtobuf user = UserProtobuf.fromJson(invite);
String agentUid = user.getUid();
// 获取Agent的UserUid用于取消订阅
Optional<AgentEntity> agentOptional = agentRestService.findByUid(agentUid);
if (agentOptional.isPresent()) {
String userUid = agentOptional.get().getUserUid();
// 移除被邀请人的话题订阅
String topic = savedEntity.getTopic();
TopicRequest topicRequest = TopicRequest.builder()
.topic(topic)
.userUid(userUid)
.build();
topicRestService.remove(topicRequest);
}
}
}
}
// 发布关闭事件
bytedeskEventPublisher.publishEvent(new ThreadCloseEvent(this, updateThread));