!1008 MALL-KEFU: 优化消息已读处理逻辑

Merge pull request !1008 from puhui999/develop

!1008 MALL-KEFU: 优化消息已读处理逻辑
Merge pull request !1008 from puhui999/develop
芋道源码 · Gitee
2 parents b7e4f8e4 4a395955
Showing 4 changed files with 20 additions and 13 deletions
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/controller/admin/kefu/KeFuConversationController.java
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/dal/mysql/kefu/KeFuMessageMapper.java
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/kefu/KeFuConversationServiceImpl.java
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/kefu/KeFuMessageServiceImpl.java
@@ -34,8 +34,8 @@ public class KeFuConversationController {
     @Resource
     private MemberUserApi memberUserApi;
-    @PostMapping("/update-conversation-pinned")
-    @Operation(summary = "置顶客服会话")
+    @PutMapping("/update-conversation-pinned")
+    @Operation(summary = "置顶/取消置顶客服会话")
     @PreAuthorize("@ss.hasPermission('promotion:kefu-conversation:update')")
     public CommonResult<Boolean> updateConversationPinned(@Valid @RequestBody KeFuConversationUpdatePinnedReqVO updateReqVO) {
         conversationService.updateConversationPinnedByAdmin(updateReqVO);
@@ -27,9 +27,11 @@ public interface KeFuMessageMapper extends BaseMapperX&lt;KeFuMessageDO&gt; {
                 .orderByDesc(KeFuMessageDO::getCreateTime));
     }
-    default List<KeFuMessageDO> selectListByConversationIdAndReadStatus(Long conversationId, Boolean readStatus) {
+    default List<KeFuMessageDO> selectListByConversationIdAndUserTypeAndReadStatus(Long conversationId, Integer userType,
+                                                                                   Boolean readStatus) {
         return selectList(new LambdaQueryWrapper<KeFuMessageDO>()
                 .eq(KeFuMessageDO::getConversationId, conversationId)
+                .ne(KeFuMessageDO::getSenderType, userType) // 管理员：查询出未读的会员消息，会员：查询出未读的客服消息
                 .eq(KeFuMessageDO::getReadStatus, readStatus));
     }
@@ -38,7 +40,7 @@ public interface KeFuMessageMapper extends BaseMapperX&lt;KeFuMessageDO&gt; {
                 .in(KeFuMessageDO::getId, ids));
     }
-    default PageResult<KeFuMessageDO> selectPage(AppKeFuMessagePageReqVO pageReqVO){
+    default PageResult<KeFuMessageDO> selectPage(AppKeFuMessagePageReqVO pageReqVO) {
         return selectPage(pageReqVO, new LambdaQueryWrapperX<KeFuMessageDO>()
                 .eqIfPresent(KeFuMessageDO::getConversationId, pageReqVO.getConversationId())
                 .orderByDesc(KeFuMessageDO::getCreateTime));
@@ -41,6 +41,10 @@ public class KeFuConversationServiceImpl implements KeFuConversationService {
     @Override
     public void updateConversationPinnedByAdmin(KeFuConversationUpdatePinnedReqVO updateReqVO) {
+        // 校验存在
+        validateKefuConversationExists(updateReqVO.getId());
+
+        // 更新管理员会话置顶状态
         conversationMapper.updateById(new KeFuConversationDO().setId(updateReqVO.getId()).setAdminPinned(updateReqVO.getAdminPinned()));
     }
@@ -67,7 +67,7 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
         conversationService.updateConversationLastMessage(kefuMessage);
         // 3. 发送消息
-        getSelf().sendAsyncMessage(UserTypeEnum.MEMBER.getValue(), conversation.getUserId(), kefuMessage);
+        getSelf().sendAsyncMessageToMember(conversation.getUserId(), KEFU_MESSAGE_TYPE, kefuMessage);
         return kefuMessage.getId();
     }
@@ -83,7 +83,7 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
         // 2. 更新会话消息冗余
         conversationService.updateConversationLastMessage(kefuMessage);
         // 3. 发送消息
-        getSelf().sendAsyncMessageToAdmin(kefuMessage);
+        getSelf().sendAsyncMessageToAdmin(KEFU_MESSAGE_TYPE, kefuMessage);
         return kefuMessage.getId();
     }
@@ -97,7 +97,7 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
             throw exception(KEFU_CONVERSATION_NOT_EXISTS);
         }
         // 1.3 查询会话所有的未读消息 (tips: 多个客服，一个人点了，就都点了)
-        List<KeFuMessageDO> messageList = keFuMessageMapper.selectListByConversationIdAndReadStatus(conversationId, Boolean.FALSE);
+        List<KeFuMessageDO> messageList = keFuMessageMapper.selectListByConversationIdAndUserTypeAndReadStatus(conversationId, userType, Boolean.FALSE);
         if (CollUtil.isEmpty(messageList)) {
             return;
         }
@@ -109,10 +109,11 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
         conversationService.updateAdminUnreadMessageCountToZero(conversationId);
         // 2.3 发送消息通知会员，管理员已读 -> 会员更新发送的消息状态
-        // TODO @puhui999：待定~
         KeFuMessageDO keFuMessage = getFirst(filterList(messageList, message -> UserTypeEnum.MEMBER.getValue().equals(message.getSenderType())));
         assert keFuMessage != null; // 断言避免警告
-        webSocketSenderApi.sendObject(UserTypeEnum.MEMBER.getValue(), keFuMessage.getSenderId(), KEFU_MESSAGE_ADMIN_READ, StrUtil.EMPTY);
+        getSelf().sendAsyncMessageToMember(keFuMessage.getSenderId(), KEFU_MESSAGE_ADMIN_READ, StrUtil.EMPTY);
+        // 2.4 通知所有管理员消息已读
+        getSelf().sendAsyncMessageToAdmin(KEFU_MESSAGE_ADMIN_READ, StrUtil.EMPTY);
     }
     private void validateReceiverExist(Long receiverId, Integer receiverType) {
@@ -125,13 +126,13 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
     }
     @Async
-    public void sendAsyncMessage(Integer userType, Long userId, Object content) {
-        webSocketSenderApi.sendObject(userType, userId, KEFU_MESSAGE_TYPE, content);
+    public void sendAsyncMessageToMember(Long userId, String messageType, Object content) {
+        webSocketSenderApi.sendObject(UserTypeEnum.MEMBER.getValue(), userId, messageType, content);
     }
     @Async
-    public void sendAsyncMessageToAdmin(Object content) {
-        webSocketSenderApi.sendObject(UserTypeEnum.ADMIN.getValue(), KEFU_MESSAGE_TYPE, content);
+    public void sendAsyncMessageToAdmin(String messageType, Object content) {
+        webSocketSenderApi.sendObject(UserTypeEnum.ADMIN.getValue(), messageType, content);
     }
     @Override