Package ru.bgcrm.dao.message

Class MessageDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

ru.bgcrm.dao.message.MessageDAO

public class MessageDAO
extends CommonDAO

Nested Class Summary

Nested classes/interfaces inherited from class ru.bgcrm.dao.CommonDAO

CommonDAO.ObjectExtractor<T>, CommonDAO.RecordUpdater<T extends Id>

Field Summary

Fields inherited from class ru.bgcrm.dao.CommonDAO

con, dateFormat_DDMMYYYY, dateFormat_DDMMYYYY_HHMM, log, SQL_AND, SQL_DELETE, SQL_DESC, SQL_FROM, SQL_GROUP_BY, SQL_INNER_JOIN, SQL_INSERT, SQL_INSERT_IGNORE, SQL_LEFT_JOIN, SQL_LEFT_OUTER_JOIN, SQL_LIMIT, SQL_ON_DUP_KEY_UPDATE, SQL_OR, SQL_ORDER_BY, SQL_REPLACE, SQL_SELECT, SQL_SELECT_ALL_FROM, SQL_SELECT_COUNT_ROWS, SQL_SET, SQL_UPDATE, SQL_WHERE

Constructor Summary

Constructors

Constructor	Description
MessageDAO(Connection con)

Method Summary

Modifier and Type	Method	Description
void	deleteMessage(int id)
Message	getMessageById(int id)
Message	getMessageBySystemId(int typeId, String systemId)
List<Message>	getProcessMessageList(int processId, int beforeMessageId)
int	getUnreadIncomingMessageCount(int processId, int userId)	Количество непрочитанных конкретным пользователем входящих сообщений процесса (BPU-7152).
List<Message>	getUnsendMessageList(int type, int maxCount)
void	markMessageRead(int userId, int messageId)	Отметить сообщение прочитанным пользователем.
int	markProcessMessagesRead(int userId, int processId)	Отметить прочитанными все входящие сообщения процесса.
void	searchMessageList(SearchResult<Message> searchResult, Integer processId, Integer typeId, Integer direction, Boolean processed, Boolean withAttach, Date dateFrom, Date dateTo, String from)
void	searchMessageList(SearchResult<Message> searchResult, Integer processId, Integer typeId, Integer direction, Boolean processed, Boolean withAttach, Date dateFrom, Date dateTo, String from, boolean reverseOrder)
void	searchMessageList(SearchResult<Message> searchResult, Integer processId, List<Integer> typeIds, Integer direction, Boolean processed, Boolean withAttach, Date dateFrom, Date dateTo, String from, boolean reverseOrder)
void	updateMessage(Message message)
void	updateMessageProcess(Message message)

Methods inherited from class ru.bgcrm.dao.CommonDAO

buildPlaceholders, deleteById, execute, execute, execute, executeBatch, executeInsert, executeUpdate, getById, getFoundRows, getFoundRows, getGroupedIds, getGroupedIds, getIds, getIds, getLikePattern, getLikePatternEnd, getLikePatternStart, getLikePatternSub, getMySQLLimit, getPeriodSql, lastInsertId, setPeriodParamValue, setRecordCount, sqlToBgException, update, updateColumn, updateIds, updateIds

Methods inherited from class java.lang.Object

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

Constructor Details

MessageDAO

public MessageDAO(Connection con)

Method Details

getMessageById

public Message getMessageById(int id)
                       throws BGException

Throws:

BGException

getUnreadIncomingMessageCount

public int getUnreadIncomingMessageCount(int processId,
 int userId)
                                  throws BGException

Количество непрочитанных конкретным пользователем входящих сообщений процесса (BPU-7152). Непрочитанное = входящее сообщение процесса, по которому нет строки в message_read для этого пользователя. Персонально: у разных пользователей счётчик разный. Отметку прочтения ставит markMessageRead(int, int).

Parameters:

processId - идентификатор процесса

userId - идентификатор пользователя, для которого считаем непрочитанные

Returns:

число входящих сообщений процесса, ещё не прочитанных этим пользователем

Throws:

BGException

markMessageRead

public void markMessageRead(int userId,
 int messageId)
                     throws BGException

Отметить сообщение прочитанным пользователем. Идемпотентно: повторный вызов не меняет время первого прочтения (INSERT IGNORE).

Parameters:

userId - кто прочитал

messageId - что прочитал

Throws:

BGException

markProcessMessagesRead

public int markProcessMessagesRead(int userId,
 int processId)
                            throws BGException

Отметить прочитанными все входящие сообщения процесса. Идемпотентно, как и markMessageRead(int, int): уже отмеченные сохраняют время первого прочтения.

Parameters:

userId - кто прочитал

processId - процесс, чьи входящие отмечаются

Returns:

сколько сообщений отмечено этим вызовом

Throws:

BGException

getMessageBySystemId

public Message getMessageBySystemId(int typeId,
 String systemId)
                             throws BGException

Throws:

BGException

updateMessage

public void updateMessage(Message message)
                   throws BGException

Throws:

BGException

updateMessageProcess

public void updateMessageProcess(Message message)
                          throws BGException

Throws:

BGException

deleteMessage

public void deleteMessage(int id)
                   throws BGException

Throws:

BGException

getUnsendMessageList

public List<Message> getUnsendMessageList(int type,
 int maxCount)
                                   throws BGException

Throws:

BGException

searchMessageList

public void searchMessageList(SearchResult<Message> searchResult,
 Integer processId,
 Integer typeId,
 Integer direction,
 Boolean processed,
 Boolean withAttach,
 Date dateFrom,
 Date dateTo,
 String from)
                       throws BGException

Throws:

BGException

searchMessageList

public void searchMessageList(SearchResult<Message> searchResult,
 Integer processId,
 Integer typeId,
 Integer direction,
 Boolean processed,
 Boolean withAttach,
 Date dateFrom,
 Date dateTo,
 String from,
 boolean reverseOrder)
                       throws BGException

Throws:

BGException

searchMessageList

public void searchMessageList(SearchResult<Message> searchResult,
 Integer processId,
 List<Integer> typeIds,
 Integer direction,
 Boolean processed,
 Boolean withAttach,
 Date dateFrom,
 Date dateTo,
 String from,
 boolean reverseOrder)
                       throws BGException

Throws:

BGException

getProcessMessageList

public List<Message> getProcessMessageList(int processId,
 int beforeMessageId)
                                    throws BGException

Throws:

BGException