Package com.flowable.engage.engine.impl.persistence.entity.data.impl

Class MybatisConversationStatusDataManager

java.lang.Object

org.flowable.common.engine.impl.db.AbstractDataManager<EntityImpl>

com.flowable.engage.engine.impl.persistence.entity.data.AbstractEngageDataManager<ConversationStatusEntity>

com.flowable.engage.engine.impl.persistence.entity.data.impl.MybatisConversationStatusDataManager

All Implemented Interfaces:

ConversationStatusDataManager, DataManager<ConversationStatusEntity>

public class MybatisConversationStatusDataManager
extends AbstractEngageDataManager<ConversationStatusEntity>
implements ConversationStatusDataManager

Author:

Filip Hrisafov

Field Summary

Fields inherited from class com.flowable.engage.engine.impl.persistence.entity.data.AbstractEngageDataManager

engageEngineConfiguration

Fields inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

MAX_ENTRIES_IN_CLAUSE

Constructor Summary

Constructors

Constructor	Description
MybatisConversationStatusDataManager(EngageEngineConfiguration engageEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
long	countByCriteria(ConversationStatusQueryImpl query)
ConversationStatusEntity	create()
void	deleteByConversationId(String conversationId)
List<ConversationStatusEntity>	findByConversation(String conversationId)
List<ConversationStatus>	findByCriteria(ConversationStatusQueryImpl query)
List<ConversationStatusEntity>	findByUserAndConversation(String userId, String conversationId)
ConversationStatusEntity	findByUserAndConversationAndFilter(String userId, String conversationId, String filterId)
Class<? extends ConversationStatusEntity>	getManagedEntityClass()
int	increaseUnreadMessageCountsForConversation(List<String> userIds, String conversationId)
int	resetConversationStatusesToEverythingRead(String conversationId, Date creationTime)
long	unreadCountByUserAndConversationAndNoFilter(String userId, String conversationId)
Map<String,Long>	unreadCountByUserAndFilters(String userId, List<String> filterIds)
long	unreadCountByUserAndNoFilter(String userId)
Map<String,Long>	unreadCountPerConversationByUserAndNoFilterAndOnlyUnread(String userId)
Map<String,Long>	unreadCountsByUserAndFilterAndConversations(String userId, String filterId, Collection<String> conversationIds)
int	updateAllStatusesForReadMessage(String userId, String conversationId, String messageId, Date creationTime)

Methods inherited from class com.flowable.engage.engine.impl.persistence.entity.data.AbstractEngageDataManager

getIdGenerator

Methods inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

bulkDelete, bulkDeleteEntities, bulkUpdateEntities, createSafeInValuesList, delete, delete, deleteCachedEntities, deleteCachedEntities, executeChangeWithInClause, findById, findByQuery, getCommandContext, getDbSqlSession, getEntity, getEntityCache, getList, getList, getList, getList, getList, getListFromCache, getListFromCache, getManagedEntitySubClasses, getSession, insert, isEntityInserted, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.data.DataManager

delete, delete, findById, insert, update

Constructor Detail

MybatisConversationStatusDataManager

public MybatisConversationStatusDataManager(EngageEngineConfiguration engageEngineConfiguration)

Method Detail

getManagedEntityClass

public Class<? extends ConversationStatusEntity> getManagedEntityClass()

Specified by:

getManagedEntityClass in class AbstractDataManager<ConversationStatusEntity>

create

public ConversationStatusEntity create()

Specified by:

create in interface DataManager<ConversationStatusEntity>

findByConversation

public List<ConversationStatusEntity> findByConversation(String conversationId)

Specified by:

findByConversation in interface ConversationStatusDataManager

findByUserAndConversation

public List<ConversationStatusEntity> findByUserAndConversation(String userId,
                                                                String conversationId)

Specified by:

findByUserAndConversation in interface ConversationStatusDataManager

findByUserAndConversationAndFilter

public ConversationStatusEntity findByUserAndConversationAndFilter(String userId,
                                                                   String conversationId,
                                                                   String filterId)

Specified by:

findByUserAndConversationAndFilter in interface ConversationStatusDataManager

unreadCountByUserAndConversationAndNoFilter

public long unreadCountByUserAndConversationAndNoFilter(String userId,
                                                        String conversationId)

Specified by:

unreadCountByUserAndConversationAndNoFilter in interface ConversationStatusDataManager

unreadCountByUserAndNoFilter

public long unreadCountByUserAndNoFilter(String userId)

Specified by:

unreadCountByUserAndNoFilter in interface ConversationStatusDataManager

unreadCountsByUserAndFilterAndConversations

public Map<String,Long> unreadCountsByUserAndFilterAndConversations(String userId,
                                                                          String filterId,
                                                                          Collection<String> conversationIds)

Specified by:

unreadCountsByUserAndFilterAndConversations in interface ConversationStatusDataManager

unreadCountByUserAndFilters

public Map<String,Long> unreadCountByUserAndFilters(String userId,
                                                          List<String> filterIds)

Specified by:

unreadCountByUserAndFilters in interface ConversationStatusDataManager

unreadCountPerConversationByUserAndNoFilterAndOnlyUnread

public Map<String,Long> unreadCountPerConversationByUserAndNoFilterAndOnlyUnread(String userId)

Specified by:

unreadCountPerConversationByUserAndNoFilterAndOnlyUnread in interface ConversationStatusDataManager

updateAllStatusesForReadMessage

public int updateAllStatusesForReadMessage(String userId,
                                           String conversationId,
                                           String messageId,
                                           Date creationTime)

Specified by:

updateAllStatusesForReadMessage in interface ConversationStatusDataManager

resetConversationStatusesToEverythingRead

public int resetConversationStatusesToEverythingRead(String conversationId,
                                                     Date creationTime)

Specified by:

resetConversationStatusesToEverythingRead in interface ConversationStatusDataManager

increaseUnreadMessageCountsForConversation

public int increaseUnreadMessageCountsForConversation(List<String> userIds,
                                                      String conversationId)

Specified by:

increaseUnreadMessageCountsForConversation in interface ConversationStatusDataManager

deleteByConversationId

public void deleteByConversationId(String conversationId)

Specified by:

deleteByConversationId in interface ConversationStatusDataManager

findByCriteria

public List<ConversationStatus> findByCriteria(ConversationStatusQueryImpl query)

Specified by:

findByCriteria in interface ConversationStatusDataManager

countByCriteria

public long countByCriteria(ConversationStatusQueryImpl query)

Specified by:

countByCriteria in interface ConversationStatusDataManager