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-05 15:27:01 +08:00
parent 0cd729a16c
commit 353fbf7945
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncHandler.java
View File

@ -45,7 +45,7 @@ class GroupMessageSyncHandler implements Runnable {
private final MessageSyncController controller;
private final Group group;
private boolean removeDuplicateSleeped = false;
private boolean removeDuplicateSlept = false;
@Override
public void run() {
@ -128,9 +128,9 @@ class GroupMessageSyncHandler implements Runnable {
List<GroupMessage> notSaved = Sets.difference(
UniqueMessage.from(toSave), UniqueMessage.from(saved))
.stream().map(UniqueMessage::getGroupMessage).collect(toList());
if (!notSaved.isEmpty() && !removeDuplicateSleeped) {
if (!notSaved.isEmpty() && !removeDuplicateSlept) {
randomSleep();
removeDuplicateSleeped = true;
removeDuplicateSlept = true;
}
saveMessages(notSaved);
}