聊天记录已读未读状态更新

server-api/src/main/java/com/antai/sport/http/server/server/api/business/user/dto/NewMessageItemVO.java

+package com.antai.sport.http.server.server.api.business.user.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@ApiModel("未读消息统计")
+@Data
+public class NewMessageItemVO {
+    @ApiModelProperty("聊天房间key")
+    private String roomKey;
+    @ApiModelProperty("消息数量")
+    private Integer messageNum;
+}

server-api/src/main/java/com/antai/sport/http/server/server/api/business/user/dto/NewMessageVO.java

 package com.antai.sport.http.server.server.api.business.user.dto;
 
 import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import java.util.List;
+
 @ApiModel("是否有新消息对象")
 @Data
 public class NewMessageVO {
+    @ApiModelProperty("是否有未处理好友请求")
     private Boolean hasNewFriendRequest;
+    @ApiModelProperty("是否有未读消息")
     private Boolean hasNewMessage;
+    @ApiModelProperty("未读消息记录")
+    private List<NewMessageItemVO> newMessageCount;
 }

server-api/src/main/java/com/antai/sport/http/server/server/api/business/user/mapper/SportUserSummaryBusinessMapper.java

 package com.antai.sport.http.server.server.api.business.user.mapper;
 
 import com.antai.sport.http.server.repository.sport.entity.SportUserSummary;
+import com.antai.sport.http.server.server.api.business.user.dto.NewMessageItemVO;
 import com.antai.sport.http.server.server.api.business.user.dto.NewMessageVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 public interface SportUserSummaryBusinessMapper {
     int updateUserPraise(@Param("userId") Long userId, @Param("sportType") Integer sportType);
     SportUserSummary selectBySportTypeAndUserId(@Param("userId") Long userId, @Param("sportType") Integer sportType);
     NewMessageVO getUserNewMessage(@Param("sportUserId") Long sportUserId);
+    List<NewMessageItemVO> getUserNewMessageItem(@Param("sportUserId") Long sportUserId);
 }

server-api/src/main/java/com/antai/sport/http/server/server/api/business/user/service/SportUserService.java

@@ -127,6 +127,8 @@ public class SportUserService {
     }
 
     public NewMessageVO getUserNewMessage(Long sportUserId) {
-        return sportUserSummaryBusinessMapper.getUserNewMessage(sportUserId);
+        NewMessageVO result = sportUserSummaryBusinessMapper.getUserNewMessage(sportUserId);
+        result.setNewMessageCount(sportUserSummaryBusinessMapper.getUserNewMessageItem(sportUserId));
+        return result;
     }
 }

server-api/src/main/resources/mapper/user/SportUserSummaryBuisnessMapper.xml

@@ -24,4 +24,13 @@
                 where status = 1
                   and receiver_id = #{sportUserId}) as hasNewMessage
     </select>
+
+    <select id="getUserNewMessageItem"
+            resultType="com.antai.sport.http.server.server.api.business.user.dto.NewMessageItemVO">
+        select room_key, count(1) as message_num
+        from sport_chat_history
+        where status = 1
+          and receiver_id = #{sportUserId}
+        group by room_key
+    </select>
 </mapper>
\ No newline at end of file