com.seeyon.ctp.common.usermessage

接口 UserMessageManager

public interface UserMessageManager

发送系统/个人消息接口

方法概要

限定符和类型	方法和说明
void	deleteReadMessage()
void	deleteSystemMessageByCategory(long userId, int messageCategory) 根据消息分类清空人员系统消息
void	deleteSystemMessageByUser(long userId) 清空人员系统消息
void	deleteUserMessageForM3(java.util.List<java.lang.Long> ids) 没m3按id更新history已读状态时删除对应的usermessage
java.util.List<UserHistoryMessage>	getAllSystemMessages(long userInternalID, java.lang.String condition, java.lang.String textfield, java.lang.String textfield1) 获取当前全部的系统消息列表
java.util.List<UserHistoryMessage>	getAllSystemMessages(long userInternalID, java.lang.String condition, java.lang.String textfield, java.lang.String textfield1, java.lang.Boolean isPage)
java.util.List<UserHistoryMessage>	getAllSystemMessages(long userInternalID, java.lang.String condition, java.lang.String textfield, java.lang.String textfield1, java.lang.Boolean isPage, java.lang.String readType)
int	getCachedUserCount() 消息缓存中已缓存的用户个数
int	getCommentZishu()
java.util.Map<java.lang.String,java.lang.String>	getMessageLinkTypes()
java.lang.String	getNewMessagesAndOnlineSize()
int	getNotReadSystemMessageCount(long userInternalID) 获取用户未读消息个数
java.util.List<UserHistoryMessage>	getSystemHistoryMessages(FlipInfo fi, java.util.Map<java.lang.String,java.lang.String> params) 根据条件获取人员历史消息
java.util.List<Ent_UserMessage>	getUnresolvedMessagesForMB(long userInternalID)
UserHistoryMessage	getUserHistoryMsgById(java.lang.Long id) 根据历史消息id获取历史消息
java.lang.String	getUserOnlineMessage()
int	getWaitingParseQLength() 获取等待解析的队列长度
int	getWaitingSaveQLength() 获取等待入库的队列长度
void	initMessageState()
boolean	isCachedUserMessage(long userInternalID) 用户消息是否被缓存
void	processPcAndMobileOnlineAtSameTime(java.lang.Long userId, java.lang.String pLang, java.lang.String userAgentFrom, java.util.Map<Constants.login_sign,OnlineUser.LoginInfo> loginInfoMapper, java.lang.String loginType) 异步处理：登录时PC和移动端同时在线时的消息提醒
void	removeAllMessages(long userInternalID) 清空我接收到的消息
void	removeMessage(java.lang.String condition, java.lang.Long longfield) 根据消息的保留时间或每人的最大消息数量清除消息
void	removeMessage(java.lang.String startTime, java.lang.String endTime) 根据消息阅读状态及时间段清除消息
void	saveMessage(Ent_UserMessage msg) 保存消息
void	savePatchHistory(java.util.List<UserHistoryMessage> ms) 批量保存历史消息记录
void	sendMessage(UserMessage userMessage) 发送消息
void	sendSystemMessage(MessageContent content, ApplicationCategoryEnum messageCategroy, long senderId, java.util.Collection<MessageReceiver> receivers, java.lang.Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	sendSystemMessage(MessageContent content, ApplicationCategoryEnum messageCategroy, long senderId, MessageReceiver receiver, java.lang.Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	sendSystemMessage(MessageContent content, int messageCategroy, long senderId, java.util.Collection<MessageReceiver> receivers, java.lang.Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	sendSystemMessage(MessageContent content, int messageCategroy, long senderId, java.util.Date creationDate, java.util.Collection<MessageReceiver> receivers, java.lang.Object... messageFilterArgs) 发送系统消息 实现策略：先调用异步任务接口TaskManager.sendTaskToQueue，然后由异步任务调度器调度消息解析器，然后写入消息表
void	startAyncEngine() 启动消息异步处理引擎
void	stopAyncEngine() 停止消息异步处理引擎
void	updateSystemMessageCountByCategory(long userId, int messageCategory) 根据消息分类更新人员系统消息计数状态
void	updateSystemMessageCountByUser(long userId) 更新人员系统消息计数状态
void	updateSystemMessageState(long id) 根据消息ID更新系统消息未读状态
void	updateSystemMessageStateByCategory(long userId, int messageCategory) 根据消息分类更新人员系统消息未读状态
void	updateSystemMessageStateByUser(long userId) 更新人员系统消息未读状态
void	updateSystemMessageStateByUserAndReference(long userInternalID, long referenceId) 更新指定用户指定业务的消息状态。

方法详细资料

initMessageState

void initMessageState()

deleteReadMessage

void deleteReadMessage()

getAllSystemMessages

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

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

参数:

userInternalID - 用户内部ID

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

textfield -

textfield1 -

返回:

抛出:

BusinessException

getAllSystemMessages

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

抛出:

BusinessException

getAllSystemMessages

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

抛出:

BusinessException

sendMessage

void sendMessage(UserMessage userMessage)
          throws BusinessException

发送消息

参数:

userMessage -

抛出:

BusinessException

sendSystemMessage

void sendSystemMessage(MessageContent content,
                       ApplicationCategoryEnum messageCategroy,
                       long senderId,
                       MessageReceiver receiver,
                       java.lang.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,
                       java.util.Collection<MessageReceiver> receivers,
                       java.lang.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,
                       java.util.Collection<MessageReceiver> receivers,
                       java.lang.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,
                       java.util.Date creationDate,
                       java.util.Collection<MessageReceiver> receivers,
                       java.lang.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

removeAllMessages

void removeAllMessages(long userInternalID)
                throws BusinessException

清空我接收到的消息

参数:

userInternalID -

抛出:

BusinessException

removeMessage

void removeMessage(java.lang.String startTime,
                   java.lang.String endTime)
            throws BusinessException

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

参数:

startTime -

endTime -

isRead -

抛出:

BusinessException

removeMessage

void removeMessage(java.lang.String condition,
                   java.lang.Long longfield)
            throws BusinessException

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

参数:

condition -

longfield -

抛出:

BusinessException

getNewMessagesAndOnlineSize

java.lang.String getNewMessagesAndOnlineSize()

返回:

getCommentZishu

int getCommentZishu()

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

java.util.List<Ent_UserMessage> getUnresolvedMessagesForMB(long userInternalID)
                                                    throws BusinessException

抛出:

BusinessException

getUserOnlineMessage

java.lang.String getUserOnlineMessage()
                               throws BusinessException

抛出:

BusinessException

getMessageLinkTypes

java.util.Map<java.lang.String,java.lang.String> getMessageLinkTypes()

savePatchHistory

void savePatchHistory(java.util.List<UserHistoryMessage> ms)

批量保存历史消息记录

参数:

ms -

processPcAndMobileOnlineAtSameTime

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

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

参数:

userId -

pLang -

userAgentFrom -

loginInfoMapper -

getUserHistoryMsgById

UserHistoryMessage getUserHistoryMsgById(java.lang.Long id)
                                  throws BusinessException

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

参数:

id -

返回:

UserHistoryMessage

抛出:

BusinessException

getNotReadSystemMessageCount

int getNotReadSystemMessageCount(long userInternalID)
                          throws BusinessException

获取用户未读消息个数

抛出:

BusinessException

deleteUserMessageForM3

void deleteUserMessageForM3(java.util.List<java.lang.Long> ids)
                     throws BusinessException

没m3按id更新history已读状态时删除对应的usermessage

参数:

ids -

抛出:

BusinessException

startAyncEngine

void startAyncEngine()

启动消息异步处理引擎

stopAyncEngine

void stopAyncEngine()

停止消息异步处理引擎

getSystemHistoryMessages

java.util.List<UserHistoryMessage> getSystemHistoryMessages(FlipInfo fi,
                                                            java.util.Map<java.lang.String,java.lang.String> params)
                                                     throws BusinessException

根据条件获取人员历史消息

参数:

fi - 分页信息

params - userId 人员ID isAt @我的，1 isReply 回复我的，1 isTrack 跟踪事项的，1 important 重要程度值 senderIds 指定人id，以逗号分隔（领导的，指定他人） templateIds 指定模板id，以逗号分隔

返回:

抛出:

BusinessException

updateSystemMessageStateByUser

void updateSystemMessageStateByUser(long userId)
                             throws BusinessException

更新人员系统消息未读状态

参数:

userId - 人员ID

抛出:

BusinessException

updateSystemMessageCountByUser

void updateSystemMessageCountByUser(long userId)
                             throws BusinessException

更新人员系统消息计数状态

参数:

userId - 人员ID

抛出:

BusinessException

updateSystemMessageStateByCategory

void updateSystemMessageStateByCategory(long userId,
                                        int messageCategory)
                                 throws BusinessException

根据消息分类更新人员系统消息未读状态

参数:

userId - 人员ID

messageCategory - 消息分类

抛出:

BusinessException

updateSystemMessageCountByCategory

void updateSystemMessageCountByCategory(long userId,
                                        int messageCategory)
                                 throws BusinessException

根据消息分类更新人员系统消息计数状态

参数:

userId - 人员ID

messageCategory - 消息分类

抛出:

BusinessException

updateSystemMessageState

void updateSystemMessageState(long id)
                       throws BusinessException

根据消息ID更新系统消息未读状态

参数:

id - 消息ID

抛出:

BusinessException

deleteSystemMessageByUser

void deleteSystemMessageByUser(long userId)
                        throws BusinessException

清空人员系统消息

参数:

userId - 人员ID

抛出:

BusinessException

deleteSystemMessageByCategory

void deleteSystemMessageByCategory(long userId,
                                   int messageCategory)
                            throws BusinessException

根据消息分类清空人员系统消息

参数:

userId - 人员ID

messageCategory - 消息分类

抛出:

BusinessException