open-source/MallChat
1
0
Fork 0
mirror of https://github.com/zongzibinbin/MallChat.git synced 2026-03-14 06:03:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix:

Browse Source 
1.已读未读数排除自己
This commit is contained in:
zhongzb
2023-08-20 15:30:36 +08:00
parent 5c0ec34760
commit 68a4296b7b
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
mallchat-common/src/main/java/com/abin/mallchat/common/chat/dao/ContactDao.java
View File

@@ -33,6 +33,7 @@ public class ContactDao extends ServiceImpl<ContactMapper, Contact> {
public Integer getReadCount(Message message) { public Integer getReadCount(Message message) {
return lambdaQuery() return lambdaQuery()
.eq(Contact::getRoomId, message.getRoomId()) .eq(Contact::getRoomId, message.getRoomId())
.ne(Contact::getUid, message.getFromUid())//不需要查询出自己
.ge(Contact::getReadTime, message.getCreateTime()) .ge(Contact::getReadTime, message.getCreateTime())
.count(); .count();
} }

2
mallchat-common/src/main/java/com/abin/mallchat/common/chat/service/impl/ContactServiceImpl.java
View File

@@ -66,7 +66,7 @@ public class ContactServiceImpl implements ContactService {
Integer readCount = contactDao.getReadCount(message); Integer readCount = contactDao.getReadCount(message);
readInfoDTO.setReadCount(readCount); readInfoDTO.setReadCount(readCount);
if (needUnread) { if (needUnread) {
readInfoDTO.setUnReadCount(finalTotalCount - readCount); readInfoDTO.setUnReadCount(finalTotalCount - readCount - 1);
} }
return readInfoDTO; return readInfoDTO;
}).collect(Collectors.toMap(MsgReadInfoDTO::getMsgId, Function.identity())); }).collect(Collectors.toMap(MsgReadInfoDTO::getMsgId, Function.identity()));