更新消息已读逻辑调整

core/src/main/java/com/wecloud/im/enums/ReadMsgStatusEnum.java

+package com.wecloud.im.enums;
+
+import io.geekidea.springbootplus.framework.common.enums.BaseEnum;
+
+/**
+ * @Author wenzhida
+ * @Date 2022/3/11 16:24
+ * @Description 消息是否已读枚举
+ */
+public enum ReadMsgStatusEnum implements BaseEnum {
+
+    /**
+     * 0 - 未读
+     */
+    UNREAD(0, "未读"),
+
+    /**
+     * 1 - 已读
+     */
+    READ(1, "已读");
+
+    ReadMsgStatusEnum(int code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+
+    private final Integer code;
+    private final String desc;
+
+
+    @Override
+    public Integer getCode() {
+        return this.code;
+    }
+
+    @Override
+    public String getDesc() {
+        return this.desc;
+    }
+}

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

@@ -8,6 +8,7 @@ import com.wecloud.im.entity.ImConversationMembers;
 import com.wecloud.im.entity.ImInbox;
 import com.wecloud.im.entity.ImInbox;
 import com.wecloud.im.entity.ImMessage;
 import com.wecloud.im.entity.ImMessage;
 import com.wecloud.im.entity.ImMessageOnlineSend;
 import com.wecloud.im.entity.ImMessageOnlineSend;
+import com.wecloud.im.enums.ReadMsgStatusEnum;
 import com.wecloud.im.mapper.ImInboxMapper;
 import com.wecloud.im.mapper.ImInboxMapper;
 import com.wecloud.im.param.ImMsgReceivedStatusUpdate;
 import com.wecloud.im.param.ImMsgReceivedStatusUpdate;
 import com.wecloud.im.param.MsgReadStatusUpdateParam;
 import com.wecloud.im.param.MsgReadStatusUpdateParam;
@@ -160,6 +161,7 @@ public class ImInboxServiceImpl extends BaseServiceImpl<ImInboxMapper, ImInbox>
         // 获取该用户该会话所有未读消息 msgId 列表
         // 获取该用户该会话所有未读消息 msgId 列表
         List<ImInbox> imInboxList = this.list(new QueryWrapper<ImInbox>().lambda()
         List<ImInbox> imInboxList = this.list(new QueryWrapper<ImInbox>().lambda()
                 .eq(ImInbox::getFkConversationId, param.getConversationId())
                 .eq(ImInbox::getFkConversationId, param.getConversationId())
+                .eq(ImInbox::getReadMsgStatus, ReadMsgStatusEnum.UNREAD.getCode())
                 .le(ImInbox::getFkMsgId, param.getMsgIdEnd())
                 .le(ImInbox::getFkMsgId, param.getMsgIdEnd())
                 .eq(ImInbox::getReceiver, currentClient.getId()));
                 .eq(ImInbox::getReceiver, currentClient.getId()));
         if (CollectionUtils.isEmpty(imInboxList)) {
         if (CollectionUtils.isEmpty(imInboxList)) {