wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3345: 解决查询不到账号的问题

Browse Source
This commit is contained in:
yanglin 2025-02-18 16:16:43 +08:00
parent d4af3adae3
commit 88ab9bcc65
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
im-center-server/src/main/java/cn/axzo/im/group/GroupManager.java
View File

@ -116,7 +116,8 @@ public class GroupManager {
} }
public GroupAddMembersResponse addMembers(GroupAddMembersRequest request) { public GroupAddMembersResponse addMembers(GroupAddMembersRequest request) {
Group group = getGroupForUpdateOrThrow(request.getTid()); Group group = groupDao.findByTid(request.getTid(), false).orElse(null);
//noinspection DataFlowIssue
BizAssertions.assertFalse(group.isDismissed(), "群已经解散"); BizAssertions.assertFalse(group.isDismissed(), "群已经解散");
groupSupport.log(group.getTid(), "add-members", request); groupSupport.log(group.getTid(), "add-members", request);
// sync members 1 // sync members 1
@ -128,10 +129,9 @@ public class GroupManager {
.collect(toSet()); .collect(toSet());
if (addPersons.isEmpty()) if (addPersons.isEmpty())
return new GroupAddMembersResponse(); return new GroupAddMembersResponse();
ImAccounts imAccounts = accountService.getOrCreateImAccounts(addPersons);
BizAssertions.assertTrue(group.addMoreMembers(prePersons.size() + addPersons.size()), BizAssertions.assertTrue(group.addMoreMembers(prePersons.size() + addPersons.size()),
"群聊人数上限{}人, 请删除部分已选人员", group.getMemberLimit()); "群聊人数上限{}人, 请删除部分已选人员", group.getMemberLimit());
ImAccounts imAccounts = accountService.getOrCreateImAccounts(addPersons);
return transactionTemplate.execute(unused -> {
if (imAccounts.isAccountEmpty()) { if (imAccounts.isAccountEmpty()) {
notification.send("添加群成员[{},{}], 有效群成员IM账号列表为空. 请求成员信息: {}", notification.send("添加群成员[{},{}], 有效群成员IM账号列表为空. 请求成员信息: {}",
group.getTid(), group.getName(), JSON.toJSONString(request.getMembers())); group.getTid(), group.getName(), JSON.toJSONString(request.getMembers()));
@ -141,6 +141,8 @@ public class GroupManager {
.buildAddMembersRequest(group, group.getOwnerAccount(), imAccounts); .buildAddMembersRequest(group, group.getOwnerAccount(), imAccounts);
// add members // add members
rateLimiter.requireAddMember(); rateLimiter.requireAddMember();
return transactionTemplate.execute(unused -> {
getGroupForUpdateOrThrow(group.getTid());
NimGroupAddMembersResponse nimResponse = nimClient.addGroupMembers(nimRequest); NimGroupAddMembersResponse nimResponse = nimClient.addGroupMembers(nimRequest);
log.info("添加群成员, request={}, response={}", nimRequest, nimResponse); log.info("添加群成员, request={}, response={}", nimRequest, nimResponse);
BizAssertions.assertTrue(nimResponse.isSuccess(), "添加群成员失败: {}", nimResponse.getDesc()); BizAssertions.assertTrue(nimResponse.isSuccess(), "添加群成员失败: {}", nimResponse.getDesc());