db

package
v0.0.0-...-9bd7499 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var UserDBLock sync.RWMutex
View Source 
var UserDBMap map[string]*DataBase

Functions

This section is empty.

Types

type DataBase 

type DataBase struct {
	// contains filtered or unexported fields
}

func NewDataBase 

func NewDataBase(loginUserID string, dbDir string, operationID string) (*DataBase, error)

func (*DataBase) AddMemberCount 

func (d *DataBase) AddMemberCount(groupID string) error

func (*DataBase) BatchInsertConversationList 

func (d *DataBase) BatchInsertConversationList(conversationList []*model_struct.LocalConversation) error

func (*DataBase) BatchInsertConversationUnreadMessageList 

func (d *DataBase) BatchInsertConversationUnreadMessageList(messageList []*model_struct.LocalConversationUnreadMessage) error

func (*DataBase) BatchInsertDepartmentMember 

func (d *DataBase) BatchInsertDepartmentMember(departmentMemberList []*model_struct.LocalDepartmentMember) error

func (*DataBase) BatchInsertExceptionMsg 

func (d *DataBase) BatchInsertExceptionMsg(MessageList []*model_struct.LocalErrChatLog) error

func (*DataBase) BatchInsertExceptionMsgController 

func (d *DataBase) BatchInsertExceptionMsgController(MessageList []*model_struct.LocalErrChatLog) error

func (*DataBase) BatchInsertGroupMember 

func (d *DataBase) BatchInsertGroupMember(groupMemberList []*model_struct.LocalGroupMember) error

func (*DataBase) BatchInsertMessageList 

func (d *DataBase) BatchInsertMessageList(MessageList []*model_struct.LocalChatLog) error

func (*DataBase) BatchInsertMessageListController 

func (d *DataBase) BatchInsertMessageListController(MessageList []*model_struct.LocalChatLog) error

func (*DataBase) BatchInsertTempCacheMessageList 

func (d *DataBase) BatchInsertTempCacheMessageList(MessageList []*model_struct.TempCacheLocalChatLog) error

func (*DataBase) BatchSpecialUpdateMessageList 

func (d *DataBase) BatchSpecialUpdateMessageList(MessageList []*model_struct.LocalChatLog) error

func (*DataBase) BatchUpdateConversationList 

func (d *DataBase) BatchUpdateConversationList(conversationList []*model_struct.LocalConversation) error

func (*DataBase) BatchUpdateMessageList 

func (d *DataBase) BatchUpdateMessageList(MessageList []*model_struct.LocalChatLog) error

func (*DataBase) CleaAllConversation 

func (d *DataBase) CleaAllConversation() error

Clear All conversation, which is used to delete the conversation history message and clear the conversation at the same time. The GetAllConversation or GetConversationListSplit interface can still be obtained, but there is no latest message.

func (*DataBase) ClearConversation 

func (d *DataBase) ClearConversation(conversationID string) error

Clear the conversation, which is used to delete the conversation history message and clear the conversation at the same time. The GetAllConversation or GetConversationListSplit interface can still be obtained, but there is no latest message.

func (*DataBase) ClearWorkMomentsNotification 

func (d *DataBase) ClearWorkMomentsNotification() (err error)

func (*DataBase) CloseDB 

func (d *DataBase) CloseDB(operationID string) error

func (*DataBase) ConversationIfExists 

func (d *DataBase) ConversationIfExists(conversationID string) (bool, error)

func (*DataBase) DecrConversationUnreadCount 

func (d *DataBase) DecrConversationUnreadCount(conversationID string, count int64) (err error)

func (*DataBase) DeleteAdminGroupRequest 

func (d *DataBase) DeleteAdminGroupRequest(groupID, userID string) error

func (*DataBase) DeleteAllMessage 

func (d *DataBase) DeleteAllMessage() error

func (*DataBase) DeleteAllSuperGroup 

func (d *DataBase) DeleteAllSuperGroup() error

func (*DataBase) DeleteBlack 

func (d *DataBase) DeleteBlack(blockUserID string) error

func (*DataBase) DeleteConversation 

func (d *DataBase) DeleteConversation(conversationID string) error

func (*DataBase) DeleteConversationUnreadMessageList 

func (d *DataBase) DeleteConversationUnreadMessageList(conversationID string, sendTime int64) int64

func (*DataBase) DeleteDepartment 

func (d *DataBase) DeleteDepartment(departmentID string) error

func (*DataBase) DeleteDepartmentMember 

func (d *DataBase) DeleteDepartmentMember(departmentID string, userID string) error

func (*DataBase) DeleteFriend 

func (d *DataBase) DeleteFriend(friendUserID string) error

func (*DataBase) DeleteFriendRequestBothUserID 

func (d *DataBase) DeleteFriendRequestBothUserID(fromUserID, toUserID string) error

func (*DataBase) DeleteGroup 

func (d *DataBase) DeleteGroup(groupID string) error

func (*DataBase) DeleteGroupAllMembers 

func (d *DataBase) DeleteGroupAllMembers(groupID string) error

func (*DataBase) DeleteGroupMember 

func (d *DataBase) DeleteGroupMember(groupID, userID string) error

func (*DataBase) DeleteGroupRequest 

func (d *DataBase) DeleteGroupRequest(groupID, userID string) error

func (*DataBase) DeleteSuperGroup 

func (d *DataBase) DeleteSuperGroup(groupID string) error

func (*DataBase) GetAbnormalMsgSeq 

func (d *DataBase) GetAbnormalMsgSeq() (uint32, error)

func (*DataBase) GetAbnormalMsgSeqList 

func (d *DataBase) GetAbnormalMsgSeqList() ([]uint32, error)

func (*DataBase) GetAdminGroupApplication 

func (d *DataBase) GetAdminGroupApplication() ([]*model_struct.LocalAdminGroupRequest, error)

func (*DataBase) GetAllConversationList 

func (d *DataBase) GetAllConversationList() ([]*model_struct.LocalConversation, error)

func (*DataBase) GetAllConversationListToSync 

func (d *DataBase) GetAllConversationListToSync() ([]*model_struct.LocalConversation, error)

func (*DataBase) GetAllDepartmentList 

func (d *DataBase) GetAllDepartmentList() ([]*model_struct.LocalDepartment, error)

func (*DataBase) GetAllDepartmentMemberList 

func (d *DataBase) GetAllDepartmentMemberList() ([]*model_struct.LocalDepartmentMember, error)

func (*DataBase) GetAllFriendList 

func (d *DataBase) GetAllFriendList() ([]*model_struct.LocalFriend, error)

func (*DataBase) GetAllGroupInfoByGroupIDOrGroupName 

func (d *DataBase) GetAllGroupInfoByGroupIDOrGroupName(keyword string, isSearchGroupID bool, isSearchGroupName bool) ([]*model_struct.LocalGroup, error)

func (*DataBase) GetAllGroupMemberList 

func (d *DataBase) GetAllGroupMemberList() ([]model_struct.LocalGroupMember, error)

func (*DataBase) GetAllGroupMemberUserIDList 

func (d *DataBase) GetAllGroupMemberUserIDList() ([]model_struct.LocalGroupMember, error)

func (*DataBase) GetAllUnDeleteMessageSeqList 

func (d *DataBase) GetAllUnDeleteMessageSeqList() ([]uint32, error)

func (*DataBase) GetBlackInfoByBlockUserID 

func (d *DataBase) GetBlackInfoByBlockUserID(blockUserID string) (*model_struct.LocalBlack, error)

func (*DataBase) GetBlackInfoList 

func (d *DataBase) GetBlackInfoList(blockUserIDList []string) ([]*model_struct.LocalBlack, error)

func (*DataBase) GetBlackList 

func (d *DataBase) GetBlackList() ([]*model_struct.LocalBlack, error)

func (*DataBase) GetBlackListUserID 

func (d *DataBase) GetBlackListUserID() (blackListUid []string, err error)

func (*DataBase) GetConversation 

func (d *DataBase) GetConversation(conversationID string) (*model_struct.LocalConversation, error)

func (*DataBase) GetConversationByUserID 

func (d *DataBase) GetConversationByUserID(userID string) (*model_struct.LocalConversation, error)

func (*DataBase) GetConversationListSplit 

func (d *DataBase) GetConversationListSplit(offset, count int) ([]*model_struct.LocalConversation, error)

func (*DataBase) GetDepartmentInfo 

func (d *DataBase) GetDepartmentInfo(departmentID string) (*model_struct.LocalDepartment, error)

func (*DataBase) GetDepartmentMemberListByDepartmentID 

func (d *DataBase) GetDepartmentMemberListByDepartmentID(departmentID string, args ...int) ([]*model_struct.LocalDepartmentMember, error)

func (*DataBase) GetDepartmentMemberListByUserID 

func (d *DataBase) GetDepartmentMemberListByUserID(userID string) ([]*model_struct.LocalDepartmentMember, error)

func (*DataBase) GetFriendApplicationByBothID 

func (d *DataBase) GetFriendApplicationByBothID(fromUserID, toUserID string) (*model_struct.LocalFriendRequest, error)

func (*DataBase) GetFriendInfoByFriendUserID 

func (d *DataBase) GetFriendInfoByFriendUserID(FriendUserID string) (*model_struct.LocalFriend, error)

func (*DataBase) GetFriendInfoList 

func (d *DataBase) GetFriendInfoList(friendUserIDList []string) ([]*model_struct.LocalFriend, error)

func (*DataBase) GetGroupAdminID 

func (d *DataBase) GetGroupAdminID(groupID string) ([]string, error)

func (*DataBase) GetGroupInfoByGroupID 

func (d *DataBase) GetGroupInfoByGroupID(groupID string) (*model_struct.LocalGroup, error)

func (*DataBase) GetGroupMemberCount 

func (d *DataBase) GetGroupMemberCount(groupID string) (uint32, error)

func (*DataBase) GetGroupMemberInfoByGroupIDUserID 

func (d *DataBase) GetGroupMemberInfoByGroupIDUserID(groupID, userID string) (*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberInfoIfOwnerOrAdmin 

func (d *DataBase) GetGroupMemberInfoIfOwnerOrAdmin() ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListByGroupID 

func (d *DataBase) GetGroupMemberListByGroupID(groupID string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListSplit 

func (d *DataBase) GetGroupMemberListSplit(groupID string, filter int32, offset, count int) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberListSplitByJoinTimeFilter 

func (d *DataBase) GetGroupMemberListSplitByJoinTimeFilter(groupID string, offset, count int, joinTimeBegin, joinTimeEnd int64, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberOwner 

func (d *DataBase) GetGroupMemberOwner(groupID string) (*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberOwnerAndAdmin 

func (d *DataBase) GetGroupMemberOwnerAndAdmin(groupID string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupMemberUIDListByGroupID 

func (d *DataBase) GetGroupMemberUIDListByGroupID(groupID string) (result []string, err error)

func (*DataBase) GetGroupMinSeq 

func (d *DataBase) GetGroupMinSeq(groupID string) (uint32, error)

func (*DataBase) GetGroupOwnerAndAdminByGroupID 

func (d *DataBase) GetGroupOwnerAndAdminByGroupID(groupID string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetGroupSomeMemberInfo 

func (d *DataBase) GetGroupSomeMemberInfo(groupID string, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*DataBase) GetHiddenConversationList 

func (d *DataBase) GetHiddenConversationList() ([]*model_struct.LocalConversation, error)

func (*DataBase) GetJoinedGroupList 

func (d *DataBase) GetJoinedGroupList() ([]*model_struct.LocalGroup, error)

func (*DataBase) GetJoinedSuperGroupIDList 

func (d *DataBase) GetJoinedSuperGroupIDList() ([]string, error)

func (*DataBase) GetJoinedSuperGroupList 

func (d *DataBase) GetJoinedSuperGroupList() ([]*model_struct.LocalGroup, error)

func (*DataBase) GetJoinedWorkingGroupIDList 

func (d *DataBase) GetJoinedWorkingGroupIDList() ([]string, error)

func (*DataBase) GetJoinedWorkingGroupList 

func (d *DataBase) GetJoinedWorkingGroupList() ([]*model_struct.LocalGroup, error)

func (*DataBase) GetLoginUser 

func (d *DataBase) GetLoginUser(userID string) (*model_struct.LocalUser, error)

func (*DataBase) GetLostMsgSeqList 

func (d *DataBase) GetLostMsgSeqList(minSeqInSvr uint32) ([]uint32, error)

func (*DataBase) GetMessage 

func (d *DataBase) GetMessage(ClientMsgID string) (*model_struct.LocalChatLog, error)

func (*DataBase) GetMessageController 

func (d *DataBase) GetMessageController(msg *sdk_struct.MsgStruct) (*model_struct.LocalChatLog, error)

func (*DataBase) GetMessageList 

func (d *DataBase) GetMessageList(sourceID string, sessionType, count int, startTime int64, isReverse bool) (result []*model_struct.LocalChatLog, err error)

group ,index_recv_id and index_send_time only one can be used,when index_recv_id be used,temp B tree use for order by,Query speed decrease

func (*DataBase) GetMessageListController 

func (d *DataBase) GetMessageListController(sourceID string, sessionType, count int, startTime int64, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMessageListNoTime 

func (d *DataBase) GetMessageListNoTime(sourceID string, sessionType, count int, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMessageListNoTimeController 

func (d *DataBase) GetMessageListNoTimeController(sourceID string, sessionType, count int, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMinSeq 

func (d *DataBase) GetMinSeq(ID string) (uint32, error)

func (*DataBase) GetMsgSeqByClientMsgID 

func (d *DataBase) GetMsgSeqByClientMsgID(clientMsgID string) (uint32, error)

func (*DataBase) GetMsgSeqByClientMsgIDController 

func (d *DataBase) GetMsgSeqByClientMsgIDController(m *sdk_struct.MsgStruct) (uint32, error)

func (*DataBase) GetMsgSeqListByGroupID 

func (d *DataBase) GetMsgSeqListByGroupID(groupID string) ([]uint32, error)

func (*DataBase) GetMsgSeqListByPeerUserID 

func (d *DataBase) GetMsgSeqListByPeerUserID(userID string) ([]uint32, error)

func (*DataBase) GetMsgSeqListBySelfUserID 

func (d *DataBase) GetMsgSeqListBySelfUserID(userID string) ([]uint32, error)

func (*DataBase) GetMultipleConversation 

func (d *DataBase) GetMultipleConversation(conversationIDList []string) (result []*model_struct.LocalConversation, err error)

func (*DataBase) GetMultipleMessage 

func (d *DataBase) GetMultipleMessage(msgIDList []string) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetMultipleMessageController 

func (d *DataBase) GetMultipleMessageController(msgIDList []string, groupID string, sessionType int32) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetNormalMsgSeq 

func (d *DataBase) GetNormalMsgSeq() (uint32, error)

func (*DataBase) GetParentDepartmentList 

func (d *DataBase) GetParentDepartmentList(departmentID string) ([]*model_struct.LocalDepartment, error)

func (*DataBase) GetReadDiffusionGroupIDList 

func (d *DataBase) GetReadDiffusionGroupIDList() ([]string, error)

func (*DataBase) GetRecvFriendApplication 

func (d *DataBase) GetRecvFriendApplication() ([]*model_struct.LocalFriendRequest, error)

func (*DataBase) GetSendFriendApplication 

func (d *DataBase) GetSendFriendApplication() ([]*model_struct.LocalFriendRequest, error)

func (*DataBase) GetSendGroupApplication 

func (d *DataBase) GetSendGroupApplication() ([]*model_struct.LocalGroupRequest, error)

func (*DataBase) GetSendingMessageList 

func (d *DataBase) GetSendingMessageList() (result []*model_struct.LocalChatLog, err error)

func (*DataBase) GetSubDepartmentList 

func (d *DataBase) GetSubDepartmentList(departmentID string, args ...int) ([]*model_struct.LocalDepartment, error)

func (*DataBase) GetSuperGroupAbnormalMsgSeq 

func (d *DataBase) GetSuperGroupAbnormalMsgSeq(groupID string) (uint32, error)

func (*DataBase) GetSuperGroupInfoByGroupID 

func (d *DataBase) GetSuperGroupInfoByGroupID(groupID string) (*model_struct.LocalGroup, error)

func (*DataBase) GetSuperGroupNormalMsgSeq 

func (d *DataBase) GetSuperGroupNormalMsgSeq(groupID string) (uint32, error)

func (*DataBase) GetTestMessage 

func (d *DataBase) GetTestMessage(seq uint32) (*model_struct.LocalChatLog, error)

func (*DataBase) GetTotalUnreadMsgCount 

func (d *DataBase) GetTotalUnreadMsgCount() (totalUnreadCount int32, err error)

func (*DataBase) GetUserMinSeq 

func (d *DataBase) GetUserMinSeq() (uint32, error)

func (*DataBase) GetWorkMomentsNotification 

func (d *DataBase) GetWorkMomentsNotification(offset, count int) (WorkMomentsNotifications []*LocalWorkMomentsNotification, err error)

func (*DataBase) GetWorkMomentsNotificationLimit 

func (d *DataBase) GetWorkMomentsNotificationLimit(pageNumber, showNumber int) (WorkMomentsNotifications []*LocalWorkMomentsNotification, err error)

func (*DataBase) GetWorkMomentsUnReadCount 

func (d *DataBase) GetWorkMomentsUnReadCount() (workMomentsNotificationUnReadCount LocalWorkMomentsNotificationUnreadCount, err error)

func (*DataBase) IncrConversationUnreadCount 

func (d *DataBase) IncrConversationUnreadCount(conversationID string) error

func (*DataBase) IncrWorkMomentsNotificationUnreadCount 

func (d *DataBase) IncrWorkMomentsNotificationUnreadCount() error

func (*DataBase) InitWorkMomentsNotificationUnreadCount 

func (d *DataBase) InitWorkMomentsNotificationUnreadCount() error

func (*DataBase) InsertAdminGroupRequest 

func (d *DataBase) InsertAdminGroupRequest(groupRequest *model_struct.LocalAdminGroupRequest) error

func (*DataBase) InsertBlack 

func (d *DataBase) InsertBlack(black *model_struct.LocalBlack) error

func (*DataBase) InsertConversation 

func (d *DataBase) InsertConversation(conversationList *model_struct.LocalConversation) error

func (*DataBase) InsertDepartment 

func (d *DataBase) InsertDepartment(department *model_struct.LocalDepartment) error

func (*DataBase) InsertDepartmentMember 

func (d *DataBase) InsertDepartmentMember(departmentMember *model_struct.LocalDepartmentMember) error

func (*DataBase) InsertFriend 

func (d *DataBase) InsertFriend(friend *model_struct.LocalFriend) error

func (*DataBase) InsertFriendRequest 

func (d *DataBase) InsertFriendRequest(friendRequest *model_struct.LocalFriendRequest) error

func (*DataBase) InsertGroup 

func (d *DataBase) InsertGroup(groupInfo *model_struct.LocalGroup) error

func (*DataBase) InsertGroupMember 

func (d *DataBase) InsertGroupMember(groupMember *model_struct.LocalGroupMember) error

func (*DataBase) InsertGroupRequest 

func (d *DataBase) InsertGroupRequest(groupRequest *model_struct.LocalGroupRequest) error

func (*DataBase) InsertLoginUser 

func (d *DataBase) InsertLoginUser(user *model_struct.LocalUser) error

func (*DataBase) InsertMessage 

func (d *DataBase) InsertMessage(Message *model_struct.LocalChatLog) error

func (*DataBase) InsertMessageController 

func (d *DataBase) InsertMessageController(message *model_struct.LocalChatLog) error

func (*DataBase) InsertSuperGroup 

func (d *DataBase) InsertSuperGroup(groupInfo *model_struct.LocalGroup) error

func (*DataBase) InsertTempCacheMessage 

func (d *DataBase) InsertTempCacheMessage(Message *model_struct.TempCacheLocalChatLog) error

func (*DataBase) InsertWorkMomentsNotification 

func (d *DataBase) InsertWorkMomentsNotification(jsonDetail string) error

func (*DataBase) IsExistsInErrChatLogBySeq 

func (d *DataBase) IsExistsInErrChatLogBySeq(seq int64) bool

func (*DataBase) MarkAllWorkMomentsNotificationAsRead 

func (d *DataBase) MarkAllWorkMomentsNotificationAsRead() (err error)

func (*DataBase) MessageIfExists 

func (d *DataBase) MessageIfExists(ClientMsgID string) (bool, error)

func (*DataBase) MessageIfExistsBySeq 

func (d *DataBase) MessageIfExistsBySeq(seq int64) (bool, error)

func (*DataBase) RemoveConversationDraft 

func (d *DataBase) RemoveConversationDraft(conversationID, draftText string) error

func (*DataBase) ResetAllConversation 

func (d *DataBase) ResetAllConversation() error

Reset ALL conversation is equivalent to deleting the conversation, and the GetAllConversation or GetConversationListSplit interface will no longer be obtained.

func (*DataBase) ResetConversation 

func (d *DataBase) ResetConversation(conversationID string) error

Reset the conversation is equivalent to deleting the conversation, and the GetAllConversation or GetConversationListSplit interface will no longer be obtained.

func (*DataBase) SearchDepartment 

func (d *DataBase) SearchDepartment(keyWord string, offset, count int) ([]*model_struct.LocalDepartment, error)

func (*DataBase) SearchDepartmentMember 

func (d *DataBase) SearchDepartmentMember(keyWord string, isSearchUserName, isSearchEmail, isSearchMobile, isSearchPosition, isSearchTelephone, isSearchUserEnglishName, isSearchUserID bool, offset, count int) ([]*model_struct.SearchDepartmentMemberResult, error)

func (*DataBase) SearchFriendList 

func (d *DataBase) SearchFriendList(keyword string, isSearchUserID, isSearchNickname, isSearchRemark bool) ([]*model_struct.LocalFriend, error)

func (*DataBase) SearchGroupMembers 

func (d *DataBase) SearchGroupMembers(keyword string, groupID string, isSearchMemberNickname, isSearchUserID bool, offset, count int) (result []*model_struct.LocalGroupMember, err error)

func (*DataBase) SearchMessageByContentType 

func (d *DataBase) SearchMessageByContentType(contentType []int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchMessageByContentTypeAndKeyword 

func (d *DataBase) SearchMessageByContentTypeAndKeyword(contentType []int, keywordList []string, keywordListMatchType int, startTime, endTime int64) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchMessageByContentTypeAndKeywordController 

func (d *DataBase) SearchMessageByContentTypeAndKeywordController(contentType []int, keywordList []string, keywordListMatchType int, startTime, endTime int64, operationID string) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchMessageByContentTypeController 

func (d *DataBase) SearchMessageByContentTypeController(contentType []int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchMessageByKeyword 

func (d *DataBase) SearchMessageByKeyword(contentType []int, keywordList []string, keywordListMatchType int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SearchMessageByKeywordController 

func (d *DataBase) SearchMessageByKeywordController(contentType []int, keywordList []string, keywordListMatchType int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SetConversationDraft 

func (d *DataBase) SetConversationDraft(conversationID, draftText string) error

func (*DataBase) SetMinSeq 

func (d *DataBase) SetMinSeq(ID string, minSeq uint32) error

func (*DataBase) SetMultipleConversationRecvMsgOpt 

func (d *DataBase) SetMultipleConversationRecvMsgOpt(conversationIDList []string, opt int) (err error)

func (*DataBase) SubtractMemberCount 

func (d *DataBase) SubtractMemberCount(groupID string) error

func (*DataBase) SuperBatchInsertExceptionMsg 

func (d *DataBase) SuperBatchInsertExceptionMsg(MessageList []*model_struct.LocalErrChatLog, groupID string) error

func (*DataBase) SuperGroupBatchInsertMessageList 

func (d *DataBase) SuperGroupBatchInsertMessageList(MessageList []*model_struct.LocalChatLog, groupID string) error

func (*DataBase) SuperGroupBatchUpdateMessageList 

func (d *DataBase) SuperGroupBatchUpdateMessageList(MessageList []*model_struct.LocalChatLog) error

func (*DataBase) SuperGroupDeleteAllMessage 

func (d *DataBase) SuperGroupDeleteAllMessage(groupID string) error

func (*DataBase) SuperGroupGetAllUnDeleteMessageSeqList 

func (d *DataBase) SuperGroupGetAllUnDeleteMessageSeqList() ([]uint32, error)

func (*DataBase) SuperGroupGetMessage 

func (d *DataBase) SuperGroupGetMessage(msg *sdk_struct.MsgStruct) (*model_struct.LocalChatLog, error)

func (*DataBase) SuperGroupGetMessageList 

func (d *DataBase) SuperGroupGetMessageList(sourceID string, sessionType, count int, startTime int64, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupGetMessageListNoTime 

func (d *DataBase) SuperGroupGetMessageListNoTime(sourceID string, sessionType, count int, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupGetMsgSeqByClientMsgID 

func (d *DataBase) SuperGroupGetMsgSeqByClientMsgID(clientMsgID string, groupID string) (uint32, error)

func (*DataBase) SuperGroupGetMsgSeqListByGroupID 

func (d *DataBase) SuperGroupGetMsgSeqListByGroupID(groupID string) ([]uint32, error)

func (*DataBase) SuperGroupGetMsgSeqListByPeerUserID 

func (d *DataBase) SuperGroupGetMsgSeqListByPeerUserID(userID string) ([]uint32, error)

func (*DataBase) SuperGroupGetMsgSeqListBySelfUserID 

func (d *DataBase) SuperGroupGetMsgSeqListBySelfUserID(userID string) ([]uint32, error)

func (*DataBase) SuperGroupGetMultipleMessage 

func (d *DataBase) SuperGroupGetMultipleMessage(conversationIDList []string, groupID string) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupGetNormalMinSeq 

func (d *DataBase) SuperGroupGetNormalMinSeq(groupID string) (uint32, error)

func (*DataBase) SuperGroupGetNormalMsgSeq 

func (d *DataBase) SuperGroupGetNormalMsgSeq() (uint32, error)

func (*DataBase) SuperGroupGetSendingMessageList 

func (d *DataBase) SuperGroupGetSendingMessageList(groupID string) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupGetTestMessage 

func (d *DataBase) SuperGroupGetTestMessage(seq uint32) (*model_struct.LocalChatLog, error)

func (*DataBase) SuperGroupInsertMessage 

func (d *DataBase) SuperGroupInsertMessage(Message *model_struct.LocalChatLog, groupID string) error

func (*DataBase) SuperGroupIsExistsInErrChatLogBySeq 

func (d *DataBase) SuperGroupIsExistsInErrChatLogBySeq(seq int64) bool

func (*DataBase) SuperGroupMessageIfExists 

func (d *DataBase) SuperGroupMessageIfExists(ClientMsgID string) (bool, error)

func (*DataBase) SuperGroupMessageIfExistsBySeq 

func (d *DataBase) SuperGroupMessageIfExistsBySeq(seq int64) (bool, error)

func (*DataBase) SuperGroupSearchMessageByContentType 

func (d *DataBase) SuperGroupSearchMessageByContentType(contentType []int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupSearchMessageByContentTypeAndKeyword 

func (d *DataBase) SuperGroupSearchMessageByContentTypeAndKeyword(contentType []int, keywordList []string, keywordListMatchType int, startTime, endTime int64, groupID string) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupSearchMessageByKeyword 

func (d *DataBase) SuperGroupSearchMessageByKeyword(contentType []int, keywordList []string, keywordListMatchType int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*DataBase) SuperGroupUpdateColumnsMessage 

func (d *DataBase) SuperGroupUpdateColumnsMessage(ClientMsgID, groupID string, args map[string]interface{}) error

func (*DataBase) SuperGroupUpdateGroupMessageHasRead 

func (d *DataBase) SuperGroupUpdateGroupMessageHasRead(msgIDList []string, groupID string) error

func (*DataBase) SuperGroupUpdateMessage 

func (d *DataBase) SuperGroupUpdateMessage(c *model_struct.LocalChatLog) error

func (*DataBase) SuperGroupUpdateMessageStatusBySourceID 

func (d *DataBase) SuperGroupUpdateMessageStatusBySourceID(sourceID string, status, sessionType int32) error

func (*DataBase) SuperGroupUpdateMessageTimeAndStatus 

func (d *DataBase) SuperGroupUpdateMessageTimeAndStatus(msg *sdk_struct.MsgStruct) error

func (*DataBase) SuperGroupUpdateMsgSenderFaceURL 

func (d *DataBase) SuperGroupUpdateMsgSenderFaceURL(sendID, faceURL string, sType int) error

func (*DataBase) SuperGroupUpdateMsgSenderFaceURLAndSenderNickname 

func (d *DataBase) SuperGroupUpdateMsgSenderFaceURLAndSenderNickname(sendID, faceURL, nickname string, sessionType int) error

func (*DataBase) SuperGroupUpdateMsgSenderNickname 

func (d *DataBase) SuperGroupUpdateMsgSenderNickname(sendID, nickname string, sType int) error

func (*DataBase) UnPinConversation 

func (d *DataBase) UnPinConversation(conversationID string, isPinned int) error

func (*DataBase) UpdateAdminGroupRequest 

func (d *DataBase) UpdateAdminGroupRequest(groupRequest *model_struct.LocalAdminGroupRequest) error

func (*DataBase) UpdateAllConversation 

func (d *DataBase) UpdateAllConversation(conversation *model_struct.LocalConversation) error

func (*DataBase) UpdateBlack 

func (d *DataBase) UpdateBlack(black *model_struct.LocalBlack) error

func (*DataBase) UpdateColumnsConversation 

func (d *DataBase) UpdateColumnsConversation(conversationID string, args map[string]interface{}) error

func (*DataBase) UpdateColumnsMessage 

func (d *DataBase) UpdateColumnsMessage(ClientMsgID string, args map[string]interface{}) error

func (*DataBase) UpdateColumnsMessageController 

func (d *DataBase) UpdateColumnsMessageController(ClientMsgID string, groupID string, sessionType int32, args map[string]interface{}) error

func (*DataBase) UpdateColumnsMessageList 

func (d *DataBase) UpdateColumnsMessageList(clientMsgIDList []string, args map[string]interface{}) error

func (*DataBase) UpdateConversation 

func (d *DataBase) UpdateConversation(c *model_struct.LocalConversation) error

func (*DataBase) UpdateConversationForSync 

func (d *DataBase) UpdateConversationForSync(c *model_struct.LocalConversation) error

func (*DataBase) UpdateDepartment 

func (d *DataBase) UpdateDepartment(department *model_struct.LocalDepartment) error

func (*DataBase) UpdateDepartmentMember 

func (d *DataBase) UpdateDepartmentMember(departmentMember *model_struct.LocalDepartmentMember) error

func (*DataBase) UpdateFriend 

func (d *DataBase) UpdateFriend(friend *model_struct.LocalFriend) error

func (*DataBase) UpdateFriendRequest 

func (d *DataBase) UpdateFriendRequest(friendRequest *model_struct.LocalFriendRequest) error

func (*DataBase) UpdateGroup 

func (d *DataBase) UpdateGroup(groupInfo *model_struct.LocalGroup) error

func (*DataBase) UpdateGroupMember 

func (d *DataBase) UpdateGroupMember(groupMember *model_struct.LocalGroupMember) error

func (*DataBase) UpdateGroupMemberField 

func (d *DataBase) UpdateGroupMemberField(groupID, userID string, args map[string]interface{}) error

func (*DataBase) UpdateGroupMessageHasRead 

func (d *DataBase) UpdateGroupMessageHasRead(msgIDList []string, sessionType int32) error

func (*DataBase) UpdateGroupMessageHasReadController 

func (d *DataBase) UpdateGroupMessageHasReadController(msgIDList []string, groupID string, sessionType int32) error

func (*DataBase) UpdateGroupRequest 

func (d *DataBase) UpdateGroupRequest(groupRequest *model_struct.LocalGroupRequest) error

func (*DataBase) UpdateLoginUser 

func (d *DataBase) UpdateLoginUser(user *model_struct.LocalUser) error

func (*DataBase) UpdateLoginUserByMap 

func (d *DataBase) UpdateLoginUserByMap(user *model_struct.LocalUser, args map[string]interface{}) error

func (*DataBase) UpdateMessage 

func (d *DataBase) UpdateMessage(c *model_struct.LocalChatLog) error

func (*DataBase) UpdateMessageController 

func (d *DataBase) UpdateMessageController(c *model_struct.LocalChatLog) error

func (*DataBase) UpdateMessageStatusBySourceID 

func (d *DataBase) UpdateMessageStatusBySourceID(sourceID string, status, sessionType int32) error

func (*DataBase) UpdateMessageStatusBySourceIDController 

func (d *DataBase) UpdateMessageStatusBySourceIDController(sourceID string, status, sessionType int32) error

func (*DataBase) UpdateMessageTimeAndStatus 

func (d *DataBase) UpdateMessageTimeAndStatus(clientMsgID string, serverMsgID string, sendTime int64, status int32) error

func (*DataBase) UpdateMessageTimeAndStatusController 

func (d *DataBase) UpdateMessageTimeAndStatusController(msg *sdk_struct.MsgStruct) error

func (*DataBase) UpdateMsgSenderFaceURL 

func (d *DataBase) UpdateMsgSenderFaceURL(sendID, faceURL string, sType int) error

func (*DataBase) UpdateMsgSenderFaceURLAndSenderNickname 

func (d *DataBase) UpdateMsgSenderFaceURLAndSenderNickname(sendID, faceURL, nickname string, sessionType int) error

func (*DataBase) UpdateMsgSenderNickname 

func (d *DataBase) UpdateMsgSenderNickname(sendID, nickname string, sType int) error

func (*DataBase) UpdateSingleMessageHasRead 

func (d *DataBase) UpdateSingleMessageHasRead(sendID string, msgIDList []string) error

func (*DataBase) UpdateSuperGroup 

func (d *DataBase) UpdateSuperGroup(groupInfo *model_struct.LocalGroup) error

type LocalWorkMomentsNotification 

type LocalWorkMomentsNotification struct {
	JsonDetail string `gorm:"column:json_detail"`
	CreateTime int64  `gorm:"create_time"`
}

func (LocalWorkMomentsNotification) TableName 

func (LocalWorkMomentsNotification) TableName() string

type LocalWorkMomentsNotificationUnreadCount 

type LocalWorkMomentsNotificationUnreadCount struct {
	UnreadCount int `gorm:"unread_count" json:"unreadCount"`
}

func (LocalWorkMomentsNotificationUnreadCount) TableName 

func (LocalWorkMomentsNotificationUnreadCount) TableName() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.