Package com.bytedesk.core.message

Class MessageRestServiceVip

java.lang.Object

com.bytedesk.core.message.MessageRestServiceVip

@Service
public class MessageRestServiceVip
extends Object

企业版消息服务 - 包含未读消息等高级功能

Since:

2025-08-14

Author:

Jackning (270580156@qq.com)

Field Summary

Fields

Modifier and Type	Field	Description
private final AuthService	authService
private final MessageRepository	messageRepository

Constructor Summary

Constructors

Constructor	Description
MessageRestServiceVip()

Method Summary

Modifier and Type	Method	Description
private MessageResponse	convertToResponse(MessageEntity entity)	转换消息实体为响应对象
MessageResponse	markAsRead(String messageUid)	标记消息为已读
Integer	markThreadAsRead(String threadUid)	批量标记会话中所有消息为已读
org.springframework.data.domain.Page<MessageResponse>	queryUnread(MessageRequest request)	根据 topic 查询未读消息 参考 ThreadEntity.getUnreadCount 的逻辑

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

messageRepository

private final MessageRepository messageRepository

authService

private final AuthService authService

Constructor Details

MessageRestServiceVip

public MessageRestServiceVip()

Method Details

queryUnread

public org.springframework.data.domain.Page<MessageResponse> queryUnread(MessageRequest request)

根据 topic 查询未读消息 参考 ThreadEntity.getUnreadCount 的逻辑

markAsRead

@CachePut(value="message",
          key="#messageUid")
public MessageResponse markAsRead(String messageUid)

标记消息为已读

Parameters:

messageUid - 消息UID

Returns:

更新后的消息响应

markThreadAsRead

@CacheEvict(value="message",
            allEntries=true)
public Integer markThreadAsRead(String threadUid)

批量标记会话中所有消息为已读

Parameters:

threadUid - 会话UID

Returns:

更新的消息数量

convertToResponse

private MessageResponse convertToResponse(MessageEntity entity)

转换消息实体为响应对象