未读消息数量

core/src/main/java/com/wecloud/im/service/impl/ImInboxServiceImpl.java

@@ -30,13 +30,18 @@ public class ImInboxServiceImpl extends BaseServiceImpl<ImInboxMapper, ImInbox>
 
 
     @Autowired
     @Autowired
     private ImInboxMapper imInboxMapper;
     private ImInboxMapper imInboxMapper;
+
     @Autowired
     @Autowired
     private ImClientService imClientService;
     private ImClientService imClientService;
 
 
     @Override
     @Override
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     public Boolean updateImMsgReceived(ImMsgReceivedStatusUpdate imMsgReceivedUpdate) {
     public Boolean updateImMsgReceived(ImMsgReceivedStatusUpdate imMsgReceivedUpdate) {
-        // 不做接收事件处理
+        ImClient curentClient = imClientService.getCurrentClient();
+        // 修改已接收状态
+//        imInboxMapper.updateImMsgReceivedByIds(curentClient.getId(), imMsgReceivedUpdate.getMsgIds());
+        // 修改已读状态
+        imInboxMapper.updateImMsgReadByIds(curentClient.getId(), imMsgReceivedUpdate.getMsgIds());
         return true;
         return true;
     }
     }
 
 
@@ -60,6 +65,9 @@ public class ImInboxServiceImpl extends BaseServiceImpl<ImInboxMapper, ImInbox>
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     public Boolean updateImMsgRead(MsgReadStatusUpdateParam msgReadStatusUpdateParam) {
     public Boolean updateImMsgRead(MsgReadStatusUpdateParam msgReadStatusUpdateParam) {
         // 小虎豆不做单条消息修改已读
         // 小虎豆不做单条消息修改已读
+        ImClient curentClient = imClientService.getCurrentClient();
+        // 修改已读状态
+        imInboxMapper.updateImMsgReadByIds(curentClient.getId(), msgReadStatusUpdateParam.getMsgIds());
         return true;
         return true;
 
 
     }
     }