From 340f81a51310d36f3195ef530732422503526669 Mon Sep 17 00:00:00 2001 From: yyb <1416014977@qq.com> Date: Mon, 28 Apr 2025 16:19:54 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=B8=B8=E5=AE=A2=E5=92=8C=E7=94=A8?= =?UTF-8?q?=E6=88=B7=E6=9C=AA=E8=AF=BB=E6=95=B0=E6=96=B0=E5=A2=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../m2pool/chat/service/impl/StompServiceImpl.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/StompServiceImpl.java b/m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/StompServiceImpl.java index 0903364..783d8d9 100644 --- a/m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/StompServiceImpl.java +++ b/m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/StompServiceImpl.java @@ -22,8 +22,7 @@ import javax.annotation.Resource; import java.time.LocalDateTime; import java.util.Date; -import static com.m2pool.chat.constant.UserType.CUSTOMER; -import static com.m2pool.chat.constant.UserType.TOURIST; +import static com.m2pool.chat.constant.UserType.*; @Service public class StompServiceImpl implements StompService { @@ -63,9 +62,16 @@ public class StompServiceImpl implements StompService { //获取当前聊天室对象 ChatRoom chatRoom = chatRoomMapper.selectById(userMessageVo.getRoomId()); - if (chatRoom != null){ - build.setClientReadNum(chatRoom.getClientReadNum() + 1); + if (chatRoom != null ){ + if(LOGIN_USER.equals(principal.getType())){ + build.setClientReadNum(chatRoom.getServiceReadNum() + 1); + }else { + build.setClientReadNum(chatRoom.getClientReadNum() + 1); + } + } + + //当前用户发送其他人, 发送给指定用户. 否则默认发送给当前发送者 if (bool){ messagingTemplate.convertAndSendToUser(userMessageVo.getEmail(), Destination.QUEUE + "/" + userMessageVo.getEmail(),build);