com.seeyon.ctp.common.usermessage

接口 UserMessageManager

public interface UserMessageManager

发送系统/个人消息接口

版本:

1.0 2007-3-8

作者:

maok, Tanmf

方法概要

限定符和类型	方法和说明
Map	countMessage() 分时间段及消息类型统计消息 时间段：本月，本季度，本年 消息类型：个人消息，系统消息
Integer[]	countNewMessage(Long memberId) 统计某人未读新消息的数目 return {系统消息数目，在线消息数目}
void	deleteMessage(Long userId, String deleteType, List<Long> ids) 删除聊天记录
void	deleteReadMessage()
List<UserHistoryMessage>	getAllHistoryMessage(Constants.UserMessage_TYPE type, Long userId, Long id, boolean search, String area, String time, String content) 获取当前所有聊天记录
List<UserHistoryMessage>	getAllHistoryMessage(Constants.UserMessage_TYPE type, Long userId, Long id, boolean search, String area, String time, String content, boolean isPage) 获取当前所有聊天记录,不分页
List<UserHistoryMessage>	getAllPersonMessages(long userInternalID, String condition, String textfield, String textfield1) 获取当前全部的个人消息列表,包括我发的和发给我的
List<UserHistoryMessage>	getAllPersonMessages(long userInternalID, String condition, String textfield, String textfield1, Boolean isPage)
List<UserHistoryMessage>	getAllSystemMessages(long userInternalID, String condition, String textfield, String textfield1) 获取当前全部的系统消息列表
List<UserHistoryMessage>	getAllSystemMessages(long userInternalID, String condition, String textfield, String textfield1, Boolean isPage)
List<UserHistoryMessage>	getAllSystemMessages(long userInternalID, String condition, String textfield, String textfield1, Boolean isPage, String readType)
int	getCachedUserCount() 消息缓存中已缓存的用户个数
List<UserHistoryMessage>	getHistoryMessageTree(Long userId) 获取所有聊天对象
List<String>	getMessageAttachmentNames(long senderId, long recieverId, int size) 取得消息附件
Map<String,String>	getMessageLinkTypes()
String	getNewMessagesAndOnlineSize()
List<UserHistoryMessage>	getSystemHistoryMessages(FlipInfo fi, Map<String,String> params) 查询当前人的历史消息列表
int	getThisHistoryMessage(Constants.UserMessage_TYPE type, Long userId, Long id, String createDate) 获取当前聊天记录的总数
List<UserHistoryMessage>	getThisHistoryMessage(Constants.UserMessage_TYPE type, Long userId, Long id, String createDate, int start, int pageSize) 获取当前聊天记录
List<Ent_UserMessage>	getUnresolvedMessagesForMB(long userInternalID)
UserHistoryMessage	getUserHistoryMsgById(Long id) 根据历史消息id获取历史消息
String	getUserOnlineMessage()
int	getWaitingParseQLength() 获取等待解析的队列长度
int	getWaitingSaveQLength() 获取等待入库的队列长度
void	initMessageState()
boolean	isCachedUserMessage(long userInternalID) 用户消息是否被缓存
void	processPcAndMobileOnlineAtSameTime(Long userId, String pLang, String userAgentFrom, Map<Constants.login_sign,OnlineUser.LoginInfo> loginInfoMapper, String loginType) 异步处理：登录时PC和移动端同时在线时的消息提醒
void	removeAllMessages(long userInternalID, int messageType) 清空我接收到的消息
void	removeMessage(String condition, Long longfield) 根据消息的保留时间或每人的最大消息数量清除消息
void	removeMessage(String startTime, String endTime) 根据消息阅读状态及时间段清除消息
void	saveMessage(Ent_UserMessage msg) 保存消息
void	savePatchHistory(List<UserHistoryMessage> ms) 批量保存历史消息记录
void	sendIMMessage(int type, Constants.UserMessage_TYPE messageType, Long referenceId, String content, long senderId, List<Long> receiverIds, String creationDate) 发送在线IM消息 实现策略：直接写入历史消息
void	sendMessage(UserMessage userMessage) 发送消息
void	sendPersonMessage(Constants.UserMessage_TYPE messageType, Long referenceId, String content, long senderId, List<Long> receiverIds, String creationDate) 发送个人消息 实现策略：直接写入消息表
void	sendPersonMessage(String content, long senderId, long... receiverId) 发送个人消息 实现策略：直接写入消息表
void	sendSystemMessage(MessageContent content, ApplicationCategoryEnum messageCategroy, long senderId, Collection<MessageReceiver> receivers, Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	sendSystemMessage(MessageContent content, ApplicationCategoryEnum messageCategroy, long senderId, MessageReceiver receiver, Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	sendSystemMessage(MessageContent content, int messageCategroy, long senderId, Collection<MessageReceiver> receivers, Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	sendSystemMessage(MessageContent content, int messageCategroy, long senderId, Date creationDate, Collection<MessageReceiver> receivers, Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	setMessageReadedSate(Long memberId, int msgTypte) 修改 消息的读状态
void	updateMessageFlagByZhixin(List<Long> messageIdArray) 致信消息已读后同步修改数据库标示
void	updateSystemMessageState(long id) 更新系统消息未读状态
void	updateSystemMessageStateByCategory(long userId, int messageCategory) 更新系统消息未读状态
void	updateSystemMessageStateByUser(long userInternalID) 更新用户系统消息未读状态
void	updateSystemMessageStateByUserAndReference(long userInternalID, long referenceId) 更新指定用户指定业务的消息状态。

方法详细资料

initMessageState

void initMessageState()

deleteReadMessage

void deleteReadMessage()

getAllSystemMessages

List<UserHistoryMessage> getAllSystemMessages(long userInternalID,
                                              String condition,
                                              String textfield,
                                              String textfield1)
                                       throws BusinessException

获取当前全部的系统消息列表

参数:

userInternalID - 用户内部ID

condition - 查询条件，默认为null，支持：用户姓名，消息内容，时间段

textfield -

textfield1 -

返回:

抛出:

BusinessException

getAllSystemMessages

List<UserHistoryMessage> getAllSystemMessages(long userInternalID,
                                              String condition,
                                              String textfield,
                                              String textfield1,
                                              Boolean isPage)
                                       throws BusinessException

抛出:

BusinessException

getAllSystemMessages

List<UserHistoryMessage> getAllSystemMessages(long userInternalID,
                                              String condition,
                                              String textfield,
                                              String textfield1,
                                              Boolean isPage,
                                              String readType)
                                       throws BusinessException

抛出:

BusinessException

getAllPersonMessages

List<UserHistoryMessage> getAllPersonMessages(long userInternalID,
                                              String condition,
                                              String textfield,
                                              String textfield1)
                                       throws BusinessException

获取当前全部的个人消息列表,包括我发的和发给我的

参数:

userInternalID - 用户内部ID

condition - 查询条件，默认为null，支持：用户姓名，消息内容，时间段

textfield -

textfield1 -

返回:

抛出:

BusinessException

getAllPersonMessages

List<UserHistoryMessage> getAllPersonMessages(long userInternalID,
                                              String condition,
                                              String textfield,
                                              String textfield1,
                                              Boolean isPage)
                                       throws BusinessException

抛出:

BusinessException

getThisHistoryMessage

int getThisHistoryMessage(Constants.UserMessage_TYPE type,
                          Long userId,
                          Long id,
                          String createDate)
                   throws BusinessException

获取当前聊天记录的总数

抛出:

BusinessException

getThisHistoryMessage

List<UserHistoryMessage> getThisHistoryMessage(Constants.UserMessage_TYPE type,
                                               Long userId,
                                               Long id,
                                               String createDate,
                                               int start,
                                               int pageSize)
                                        throws BusinessException

获取当前聊天记录

抛出:

BusinessException

getHistoryMessageTree

List<UserHistoryMessage> getHistoryMessageTree(Long userId)
                                        throws BusinessException

获取所有聊天对象

抛出:

BusinessException

getAllHistoryMessage

List<UserHistoryMessage> getAllHistoryMessage(Constants.UserMessage_TYPE type,
                                              Long userId,
                                              Long id,
                                              boolean search,
                                              String area,
                                              String time,
                                              String content)
                                       throws BusinessException

获取当前所有聊天记录

抛出:

BusinessException

getAllHistoryMessage

List<UserHistoryMessage> getAllHistoryMessage(Constants.UserMessage_TYPE type,
                                              Long userId,
                                              Long id,
                                              boolean search,
                                              String area,
                                              String time,
                                              String content,
                                              boolean isPage)
                                       throws BusinessException

获取当前所有聊天记录,不分页

抛出:

BusinessException

deleteMessage

void deleteMessage(Long userId,
                   String deleteType,
                   List<Long> ids)
            throws BusinessException

删除聊天记录

抛出:

BusinessException

sendMessage

void sendMessage(UserMessage userMessage)
          throws BusinessException

发送消息

参数:

userMessage -

抛出:

BusinessException

sendSystemMessage

void sendSystemMessage(MessageContent content,
                       ApplicationCategoryEnum messageCategroy,
                       long senderId,
                       MessageReceiver receiver,
                       Object... messageFilterArgs)
                throws BusinessException

发送系统消息
实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表

参数:

content - 消息体

messageCategroy - 消息所属应用分类 在com.seeyon.ctp.common.constants.ApplicationCategoryEnum中定义

senderId - 发送在和ID

receiver - 接收者

messageFilterArgs - 消息转移的参数，与对应的UserMessageFilter对应

抛出:

BusinessException

另请参阅:

ApplicationCategoryEnum

sendSystemMessage

void sendSystemMessage(MessageContent content,
                       ApplicationCategoryEnum messageCategroy,
                       long senderId,
                       Collection<MessageReceiver> receivers,
                       Object... messageFilterArgs)
                throws BusinessException

发送系统消息
实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表

参数:

content - 消息体

messageCategroy - 消息所属应用分类 在com.seeyon.ctp.common.constants.ApplicationCategoryEnum中定义

senderId - 发送在和ID

receivers - 接收者

messageFilterArgs - 消息转移的参数，与对应的UserMessageFilter对应

抛出:

BusinessException

另请参阅:

ApplicationCategoryEnum

sendSystemMessage

void sendSystemMessage(MessageContent content,
                       int messageCategroy,
                       long senderId,
                       Collection<MessageReceiver> receivers,
                       Object... messageFilterArgs)
                throws BusinessException

发送系统消息
实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表

参数:

content - 消息体

messageCategroy - 消息所属应用分类 在com.seeyon.ctp.common.constants.ApplicationCategoryEnum中定义 如果是插件，需要在插件定义文件中配置applicationCategory属性

senderId - 发送在和ID

receivers - 接收者

messageFilterArgs - 消息转移的参数，与对应的UserMessageFilter对应

抛出:

BusinessException

另请参阅:

ApplicationCategoryEnum

sendSystemMessage

void sendSystemMessage(MessageContent content,
                       int messageCategroy,
                       long senderId,
                       Date creationDate,
                       Collection<MessageReceiver> receivers,
                       Object... messageFilterArgs)
                throws BusinessException

发送系统消息
实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表

参数:

content - 消息体

messageCategroy - 消息所属应用分类 在com.seeyon.ctp.common.constants.ApplicationCategoryEnum中定义 如果是插件，需要在插件定义文件中配置applicationCategory属性

senderId - 发送在和ID

creationDate - 发送时间

receivers - 接收者

messageFilterArgs - 消息转移的参数，与对应的UserMessageFilter对应

抛出:

BusinessException

另请参阅:

ApplicationCategoryEnum

saveMessage

void saveMessage(Ent_UserMessage msg)
          throws BusinessException

保存消息

参数:

msg -

抛出:

BusinessException

sendPersonMessage

void sendPersonMessage(String content,
                       long senderId,
                       long... receiverId)
                throws BusinessException

发送个人消息
实现策略：直接写入消息表

参数:

content -

senderId -

receiverId -

抛出:

BusinessException

sendPersonMessage

void sendPersonMessage(Constants.UserMessage_TYPE messageType,
                       Long referenceId,
                       String content,
                       long senderId,
                       List<Long> receiverIds,
                       String creationDate)
                throws BusinessException

发送个人消息
实现策略：直接写入消息表

参数:

content -

senderId -

receiverIds -

抛出:

BusinessException

sendIMMessage

void sendIMMessage(int type,
                   Constants.UserMessage_TYPE messageType,
                   Long referenceId,
                   String content,
                   long senderId,
                   List<Long> receiverIds,
                   String creationDate)
            throws BusinessException

发送在线IM消息
实现策略：直接写入历史消息

参数:

content -

senderId -

receiverIds -

抛出:

BusinessException

removeAllMessages

void removeAllMessages(long userInternalID,
                       int messageType)
                throws BusinessException

清空我接收到的消息

参数:

userInternalID -

抛出:

BusinessException

countMessage

Map countMessage()
          throws BusinessException

分时间段及消息类型统计消息 时间段：本月，本季度，本年 消息类型：个人消息，系统消息

参数:

userInternalID -

返回:

抛出:

BusinessException

removeMessage

void removeMessage(String startTime,
                   String endTime)
            throws BusinessException

根据消息阅读状态及时间段清除消息

参数:

startTime -

endTime -

isRead -

抛出:

BusinessException

removeMessage

void removeMessage(String condition,
                   Long longfield)
            throws BusinessException

根据消息的保留时间或每人的最大消息数量清除消息

参数:

condition -

longfield -

抛出:

BusinessException

getMessageAttachmentNames

List<String> getMessageAttachmentNames(long senderId,
                                       long recieverId,
                                       int size)

取得消息附件

参数:

senderId -

recieverId -

size -

返回:

getNewMessagesAndOnlineSize

String getNewMessagesAndOnlineSize()

返回:

countNewMessage

Integer[] countNewMessage(Long memberId)
                   throws BusinessException

统计某人未读新消息的数目 return {系统消息数目，在线消息数目}

抛出:

BusinessException

setMessageReadedSate

void setMessageReadedSate(Long memberId,
                          int msgTypte)

修改 消息的读状态

参数:

memberId -

msgTypte -

updateSystemMessageState

void updateSystemMessageState(long id)
                       throws BusinessException

更新系统消息未读状态

参数:

id -

抛出:

BusinessException

updateSystemMessageStateByCategory

void updateSystemMessageStateByCategory(long userId,
                                        int messageCategory)
                                 throws BusinessException

更新系统消息未读状态

参数:

category -

抛出:

BusinessException

updateSystemMessageStateByUser

void updateSystemMessageStateByUser(long userInternalID)
                             throws BusinessException

更新用户系统消息未读状态

参数:

userInternalID -

抛出:

BusinessException

updateSystemMessageStateByUserAndReference

void updateSystemMessageStateByUserAndReference(long userInternalID,
                                                long referenceId)

更新指定用户指定业务的消息状态。

参数:

userInternalID - 用户Id

referenceId - 业务标识

getWaitingSaveQLength

int getWaitingSaveQLength()

获取等待入库的队列长度

返回:

getWaitingParseQLength

int getWaitingParseQLength()

获取等待解析的队列长度

返回:

getCachedUserCount

int getCachedUserCount()

消息缓存中已缓存的用户个数

返回:

isCachedUserMessage

boolean isCachedUserMessage(long userInternalID)

用户消息是否被缓存

参数:

userInternalID -

返回:

getUnresolvedMessagesForMB

List<Ent_UserMessage> getUnresolvedMessagesForMB(long userInternalID)
                                          throws BusinessException

抛出:

BusinessException

getUserOnlineMessage

String getUserOnlineMessage()
                     throws BusinessException

抛出:

BusinessException

updateMessageFlagByZhixin

void updateMessageFlagByZhixin(List<Long> messageIdArray)
                        throws Exception

致信消息已读后同步修改数据库标示

参数:

messageIdArray -

抛出:

Exception

getMessageLinkTypes

Map<String,String> getMessageLinkTypes()

savePatchHistory

void savePatchHistory(List<UserHistoryMessage> ms)

批量保存历史消息记录

参数:

ms -

processPcAndMobileOnlineAtSameTime

void processPcAndMobileOnlineAtSameTime(Long userId,
                                        String pLang,
                                        String userAgentFrom,
                                        Map<Constants.login_sign,OnlineUser.LoginInfo> loginInfoMapper,
                                        String loginType)

异步处理：登录时PC和移动端同时在线时的消息提醒

参数:

userId -

pLang -

userAgentFrom -

loginInfoMapper -

getSystemHistoryMessages

List<UserHistoryMessage> getSystemHistoryMessages(FlipInfo fi,
                                                  Map<String,String> params)
                                           throws BusinessException

查询当前人的历史消息列表

参数:

fi -

params(String - condition;String field;String readType;String field1=null;)

返回:

抛出:

BusinessException

getUserHistoryMsgById

UserHistoryMessage getUserHistoryMsgById(Long id)
                                  throws BusinessException

根据历史消息id获取历史消息

参数:

id -

返回:

UserHistoryMessage

抛出:

BusinessException