anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

如果用户不在群中，不再进行群组信息更新

Browse Source
This commit is contained in:
heavyrian2012
2024-04-25 10:45:21 +08:00
parent 85a4c806c1
commit 3ab1c7553d
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+3
View File
@@ -2101,6 +2101,9 @@ public class MemoryMessagesStore implements IMessagesStore {
if (groupInfo != null && groupInfo.getUpdateDt() > request.getUpdateDt()) { if (groupInfo != null && groupInfo.getUpdateDt() > request.getUpdateDt()) {
if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser)) { if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser)) {
WFCMessage.GroupMember gm = getGroupMember(groupInfo.getTargetId(), fromUser); WFCMessage.GroupMember gm = getGroupMember(groupInfo.getTargetId(), fromUser);
if((gm == null || gm.getType() == GroupMemberType_Removed) && request.getUpdateDt() > 0) {
continue;
}
if(gm == null) { if(gm == null) {
groupInfo = groupInfo.toBuilder().setMemberUpdateDt(-1).build(); groupInfo = groupInfo.toBuilder().setMemberUpdateDt(-1).build();
} else if(gm.getType() == GroupMemberType_Removed) { } else if(gm.getType() == GroupMemberType_Removed) {