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

Merge branch 'master' of https://gitee.com/rowger_217/im-system

Browse Source
This commit is contained in:
rowger
2023-11-30 15:26:30 +08:00
parent 4a702750d8 060609ae40
commit a040df2548
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
hs-im-server/im-service/src/main/java/com/lld/im/service/message/service/MessageSyncService.java
View File

@@ -173,6 +173,17 @@ public class MessageSyncService {
} }
public List<ImMessageHistoryVo> chatHistory(ChatHistoryReq chatHistoryReq){ public List<ImMessageHistoryVo> chatHistory(ChatHistoryReq chatHistoryReq){
// 1.清空缓存里对应的未读消息
String key = chatHistoryReq.getAppId() + ":" + Constants.RedisConstants.OfflineMessage + ":" + chatHistoryReq.getOperater();
ZSetOperations zSetOperations = redisTemplate.opsForZSet();
Set querySet = zSetOperations.range(key,0,-1);
for (Object o : querySet) {
OfflineMessageContent offlineMessageContent = JSONObject.parseObject(o.toString(), OfflineMessageContent.class);
if (chatHistoryReq.getUserId().equals(offlineMessageContent.getFromId()) || chatHistoryReq.getUserId().equals(offlineMessageContent.getToId())){
zSetOperations.remove(key,o);
}
}
// 2.获取聊天记录记录
List<ImMessageHistoryVo> imMessageHistoryVos = new ArrayList<>(); List<ImMessageHistoryVo> imMessageHistoryVos = new ArrayList<>();
Page<ImMessageHistoryEntity> objectPage = new Page<>(chatHistoryReq.getOffset(),chatHistoryReq.getLimit()); Page<ImMessageHistoryEntity> objectPage = new Page<>(chatHistoryReq.getOffset(),chatHistoryReq.getLimit());
LambdaQueryWrapper<ImMessageHistoryEntity> and = new LambdaQueryWrapper<ImMessageHistoryEntity>().eq(ImMessageHistoryEntity::getOwnerId, chatHistoryReq.getOperater()) LambdaQueryWrapper<ImMessageHistoryEntity> and = new LambdaQueryWrapper<ImMessageHistoryEntity>().eq(ImMessageHistoryEntity::getOwnerId, chatHistoryReq.getOperater())