lizixuan
/
m2pool_web_backend
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update 游客和用户未读数新增

This commit is contained in:
yyb 2025-04-28 16:19:54 +08:00
parent 099e973f64
commit 340f81a513
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/StompServiceImpl.java
View File

@ -22,8 +22,7 @@ import javax.annotation.Resource;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.Date; import java.util.Date;
import static com.m2pool.chat.constant.UserType.CUSTOMER; import static com.m2pool.chat.constant.UserType.*;
import static com.m2pool.chat.constant.UserType.TOURIST;
@Service @Service
public class StompServiceImpl implements StompService { public class StompServiceImpl implements StompService {
@ -64,8 +63,15 @@ public class StompServiceImpl implements StompService {
ChatRoom chatRoom = chatRoomMapper.selectById(userMessageVo.getRoomId()); ChatRoom chatRoom = chatRoomMapper.selectById(userMessageVo.getRoomId());
if (chatRoom != null ){ if (chatRoom != null ){
if(LOGIN_USER.equals(principal.getType())){
build.setClientReadNum(chatRoom.getServiceReadNum() + 1);
}else {
build.setClientReadNum(chatRoom.getClientReadNum() + 1); build.setClientReadNum(chatRoom.getClientReadNum() + 1);
} }
}
//当前用户发送其他人, 发送给指定用户. 否则默认发送给当前发送者 //当前用户发送其他人, 发送给指定用户. 否则默认发送给当前发送者
if (bool){ if (bool){
messagingTemplate.convertAndSendToUser(userMessageVo.getEmail(), Destination.QUEUE + "/" + userMessageVo.getEmail(),build); messagingTemplate.convertAndSendToUser(userMessageVo.getEmail(), Destination.QUEUE + "/" + userMessageVo.getEmail(),build);