indexdb

package
v0.0.0-...-13b6049 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const TIMEOUT = 5

Variables

View Source 
var ErrTimoutFromJavaScript = errors.New("invoke javascript timeout，maybe should check  function from javascript")
View Source 
var ErrType = errors.New("from javascript data type err")
View Source 
var PrimaryKeyNull = errors.New("primary key is null err")

Functions

func Exec 

func Exec(args ...interface{}) (output interface{}, err error)

Types

type Black 

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

func NewBlack 

func NewBlack(loginUserID string) *Black

func (Black) DeleteBlack 

func (i Black) DeleteBlack(blockUserID string) error

func (Black) GetBlackInfoByBlockUserID 

func (i Black) GetBlackInfoByBlockUserID(blockUserID string) (result *model_struct.LocalBlack, err error)

func (Black) GetBlackInfoList 

func (i Black) GetBlackInfoList(blockUserIDList []string) (result []*model_struct.LocalBlack, err error)

func (Black) GetBlackListDB 

func (i Black) GetBlackListDB() (result []*model_struct.LocalBlack, err error)

func (Black) GetBlackListUserID 

func (i Black) GetBlackListUserID() (result []string, err error)

func (Black) InsertBlack 

func (i Black) InsertBlack(black *model_struct.LocalBlack) error

func (Black) UpdateBlack 

func (i Black) UpdateBlack(black *model_struct.LocalBlack) error

type CallbackData 

type CallbackData struct {
	ErrCode int32       `json:"errCode"`
	ErrMsg  string      `json:"errMsg"`
	Data    interface{} `json:"data"`
}

type Friend 

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

func NewFriend 

func NewFriend(loginUserID string) *Friend

func (Friend) DeleteFriendDB 

func (i Friend) DeleteFriendDB(friendUserID string) error

func (Friend) GetAllFriendList 

func (i Friend) GetAllFriendList() (result []*model_struct.LocalFriend, err error)

func (Friend) GetFriendInfoByFriendUserID 

func (i Friend) GetFriendInfoByFriendUserID(FriendUserID string) (*model_struct.LocalFriend, error)

func (Friend) GetFriendInfoList 

func (i Friend) GetFriendInfoList(friendUserIDList []string) (result []*model_struct.LocalFriend, err error)

func (Friend) InsertFriend 

func (i Friend) InsertFriend(friend *model_struct.LocalFriend) error

func (Friend) SearchFriendList 

func (i Friend) SearchFriendList(keyword string, isSearchUserID, isSearchNickname, isSearchRemark bool) (result []*model_struct.LocalFriend, err error)

func (Friend) UpdateFriend 

func (i Friend) UpdateFriend(friend *model_struct.LocalFriend) error

type FriendRequest 

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

func NewFriendRequest 

func NewFriendRequest(loginUserID string) *FriendRequest

func (FriendRequest) DeleteFriendRequestBothUserID 

func (i FriendRequest) DeleteFriendRequestBothUserID(fromUserID, toUserID string) error

func (FriendRequest) GetFriendApplicationByBothID 

func (i FriendRequest) GetFriendApplicationByBothID(fromUserID, toUserID string) (*model_struct.LocalFriendRequest, error)

func (FriendRequest) GetRecvFriendApplication 

func (i FriendRequest) GetRecvFriendApplication() (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) GetSendFriendApplication 

func (i FriendRequest) GetSendFriendApplication() (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) InsertFriendRequest 

func (i FriendRequest) InsertFriendRequest(friendRequest *model_struct.LocalFriendRequest) error

func (FriendRequest) UpdateFriendRequest 

func (i FriendRequest) UpdateFriendRequest(friendRequest *model_struct.LocalFriendRequest) error

type IndexDB 

type IndexDB struct {
	LocalUsers
	LocalConversations
	*LocalChatLogs
	LocalSuperGroupChatLogs
	LocalSuperGroup
	LocalConversationUnreadMessages
	LocalGroups
	LocalGroupMember
	LocalGroupRequest
	LocalCacheMessage
	*FriendRequest
	*Black
	*Friend
	// contains filtered or unexported fields
}

func NewIndexDB 

func NewIndexDB(loginUserID string) *IndexDB

func (IndexDB) BatchInsertConversationList 

func (i IndexDB) BatchInsertConversationList(conversationList []*model_struct.LocalConversation) error

func (IndexDB) BatchInsertDepartmentMember 

func (i IndexDB) BatchInsertDepartmentMember(departmentMemberList []*model_struct.LocalDepartmentMember) error

func (IndexDB) BatchInsertExceptionMsgController 

func (i IndexDB) BatchInsertExceptionMsgController(MessageList []*model_struct.LocalErrChatLog) error

func (IndexDB) BatchInsertMessageListController 

func (i IndexDB) BatchInsertMessageListController(MessageList []*model_struct.LocalChatLog) error

func (IndexDB) BatchSpecialUpdateMessageList 

func (i IndexDB) BatchSpecialUpdateMessageList(MessageList []*model_struct.LocalChatLog) error

func (IndexDB) BatchUpdateConversationList 

func (i IndexDB) BatchUpdateConversationList(conversationList []*model_struct.LocalConversation) error

func (IndexDB) BatchUpdateMessageList 

func (i IndexDB) BatchUpdateMessageList(MessageList []*model_struct.LocalChatLog) error

func (IndexDB) CleaAllConversation 

func (i IndexDB) CleaAllConversation() error

func (IndexDB) ClearConversation 

func (i IndexDB) ClearConversation(conversationID string) error

func (IndexDB) ClearWorkMomentsNotification 

func (i IndexDB) ClearWorkMomentsNotification() (err error)

func (IndexDB) Close 

func (i IndexDB) Close() error

func (IndexDB) ConversationIfExists 

func (i IndexDB) ConversationIfExists(conversationID string) (bool, error)

func (IndexDB) DecrConversationUnreadCount 

func (i IndexDB) DecrConversationUnreadCount(conversationID string, count int64) error

func (IndexDB) DeleteAdminGroupRequest 

func (i IndexDB) DeleteAdminGroupRequest(groupID, userID string) error

func (IndexDB) DeleteConversation 

func (i IndexDB) DeleteConversation(conversationID string) error

func (IndexDB) DeleteDepartment 

func (i IndexDB) DeleteDepartment(departmentID string) error

func (IndexDB) DeleteDepartmentMember 

func (i IndexDB) DeleteDepartmentMember(departmentID string, userID string) error

func (IndexDB) GetAdminGroupApplication 

func (i IndexDB) GetAdminGroupApplication() ([]*model_struct.LocalAdminGroupRequest, error)

func (IndexDB) GetAllDepartmentList 

func (i IndexDB) GetAllDepartmentList() ([]*model_struct.LocalDepartment, error)

func (IndexDB) GetAllDepartmentMemberList 

func (i IndexDB) GetAllDepartmentMemberList() ([]*model_struct.LocalDepartmentMember, error)

func (IndexDB) GetConversationByUserID 

func (i IndexDB) GetConversationByUserID(userID string) (*model_struct.LocalConversation, error)

func (IndexDB) GetConversationListSplitDB 

func (i IndexDB) GetConversationListSplitDB(offset, count int) (result []*model_struct.LocalConversation, err error)

func (IndexDB) GetDepartmentInfo 

func (i IndexDB) GetDepartmentInfo(departmentID string) (*model_struct.LocalDepartment, error)

func (IndexDB) GetDepartmentList 

func (i IndexDB) GetDepartmentList(departmentList *[]*model_struct.LocalDepartment, departmentID string) error

func (IndexDB) GetDepartmentMemberListByDepartmentID 

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

func (IndexDB) GetDepartmentMemberListByUserID 

func (i IndexDB) GetDepartmentMemberListByUserID(userID string) ([]*model_struct.LocalDepartmentMember, error)

func (IndexDB) GetGroupMinSeq 

func (i IndexDB) GetGroupMinSeq(groupID string) (uint32, error)

func (IndexDB) GetJoinedSuperGroupIDList 

func (i IndexDB) GetJoinedSuperGroupIDList() ([]string, error)

func (IndexDB) GetMessageController 

func (i IndexDB) GetMessageController(msg *sdk_struct.MsgStruct) (*model_struct.LocalChatLog, error)

func (IndexDB) GetMessageListController 

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

func (IndexDB) GetMessageListNoTimeController 

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

func (IndexDB) GetMinSeq 

func (i IndexDB) GetMinSeq(ID string) (uint32, error)

func (IndexDB) GetMsgSeqByClientMsgIDController 

func (i IndexDB) GetMsgSeqByClientMsgIDController(m *sdk_struct.MsgStruct) (uint32, error)

func (IndexDB) GetMultipleConversationDB 

func (i IndexDB) GetMultipleConversationDB(conversationIDList []string) (result []*model_struct.LocalConversation, err error)

func (IndexDB) GetMultipleMessageController 

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

func (IndexDB) GetParentDepartment 

func (i IndexDB) GetParentDepartment(departmentID string) (model_struct.LocalDepartment, error)

func (IndexDB) GetParentDepartmentList 

func (i IndexDB) GetParentDepartmentList(departmentID string) ([]*model_struct.LocalDepartment, error)

func (IndexDB) GetReadDiffusionGroupIDList 

func (i IndexDB) GetReadDiffusionGroupIDList() ([]string, error)

func (IndexDB) GetSubDepartmentList 

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

func (IndexDB) GetTotalUnreadMsgCountDB 

func (i IndexDB) GetTotalUnreadMsgCountDB() (totalUnreadCount int32, err error)

func (IndexDB) GetUserMinSeq 

func (i IndexDB) GetUserMinSeq() (uint32, error)

func (IndexDB) GetWorkMomentsNotification 

func (i IndexDB) GetWorkMomentsNotification(offset, count int) (WorkMomentsNotifications []*db.LocalWorkMomentsNotification, err error)

func (IndexDB) GetWorkMomentsNotificationLimit 

func (i IndexDB) GetWorkMomentsNotificationLimit(pageNumber, showNumber int) (WorkMomentsNotifications []*db.LocalWorkMomentsNotification, err error)

func (IndexDB) GetWorkMomentsUnReadCount 

func (i IndexDB) GetWorkMomentsUnReadCount() (workMomentsNotificationUnReadCount db.LocalWorkMomentsNotificationUnreadCount, err error)

func (IndexDB) IncrConversationUnreadCount 

func (i IndexDB) IncrConversationUnreadCount(conversationID string) error

func (IndexDB) IncrWorkMomentsNotificationUnreadCount 

func (i IndexDB) IncrWorkMomentsNotificationUnreadCount() error

func (IndexDB) InitDB 

func (i IndexDB) InitDB(userID string, dataDir string) error

func (IndexDB) InitSuperLocalChatLog 

func (i IndexDB) InitSuperLocalChatLog(groupID string)

func (IndexDB) InitWorkMomentsNotificationUnreadCount 

func (i IndexDB) InitWorkMomentsNotificationUnreadCount() error

func (IndexDB) InsertAdminGroupRequest 

func (i IndexDB) InsertAdminGroupRequest(groupRequest *model_struct.LocalAdminGroupRequest) error

func (IndexDB) InsertConversation 

func (i IndexDB) InsertConversation(conversationList *model_struct.LocalConversation) error

func (IndexDB) InsertDepartment 

func (i IndexDB) InsertDepartment(department *model_struct.LocalDepartment) error

func (IndexDB) InsertDepartmentMember 

func (i IndexDB) InsertDepartmentMember(departmentMember *model_struct.LocalDepartmentMember) error

func (IndexDB) InsertMessageController 

func (i IndexDB) InsertMessageController(message *model_struct.LocalChatLog) error

func (IndexDB) InsertWorkMomentsNotification 

func (i IndexDB) InsertWorkMomentsNotification(jsonDetail string) error

func (IndexDB) MarkAllWorkMomentsNotificationAsRead 

func (i IndexDB) MarkAllWorkMomentsNotificationAsRead() (err error)

func (IndexDB) RemoveConversationDraft 

func (i IndexDB) RemoveConversationDraft(conversationID, draftText string) error

func (IndexDB) ResetAllConversation 

func (i IndexDB) ResetAllConversation() error

func (IndexDB) ResetConversation 

func (i IndexDB) ResetConversation(conversationID string) error

func (IndexDB) SearchDepartment 

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

func (IndexDB) SearchDepartmentMember 

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

func (IndexDB) SearchMessageByContentTypeAndKeywordController 

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

func (IndexDB) SearchMessageByContentTypeController 

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

func (IndexDB) SearchMessageByKeywordController 

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

func (IndexDB) SetChatLogFailedStatus 

func (i IndexDB) SetChatLogFailedStatus()

func (IndexDB) SetConversationDraft 

func (i IndexDB) SetConversationDraft(conversationID, draftText string) error

func (IndexDB) SetMinSeq 

func (i IndexDB) SetMinSeq(ID string, minSeq uint32) error

func (IndexDB) SetMultipleConversationRecvMsgOpt 

func (i IndexDB) SetMultipleConversationRecvMsgOpt(conversationIDList []string, opt int) (err error)

func (IndexDB) SuperGroupDeleteAllMessage 

func (i IndexDB) SuperGroupDeleteAllMessage(groupID string) error

func (IndexDB) SuperGroupGetAllUnDeleteMessageSeqList 

func (i IndexDB) SuperGroupGetAllUnDeleteMessageSeqList() ([]uint32, error)

func (IndexDB) SuperGroupGetMsgSeqByClientMsgID 

func (i IndexDB) SuperGroupGetMsgSeqByClientMsgID(clientMsgID string, groupID string) (uint32, error)

func (IndexDB) SuperGroupGetMsgSeqListByGroupID 

func (i IndexDB) SuperGroupGetMsgSeqListByGroupID(groupID string) ([]uint32, error)

func (IndexDB) SuperGroupGetMsgSeqListByPeerUserID 

func (i IndexDB) SuperGroupGetMsgSeqListByPeerUserID(userID string) ([]uint32, error)

func (IndexDB) SuperGroupGetMsgSeqListBySelfUserID 

func (i IndexDB) SuperGroupGetMsgSeqListBySelfUserID(userID string) ([]uint32, error)

func (IndexDB) SuperGroupGetNormalMsgSeq 

func (i IndexDB) SuperGroupGetNormalMsgSeq() (uint32, error)

func (IndexDB) SuperGroupGetSendingMessageList 

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

func (IndexDB) SuperGroupGetTestMessage 

func (i IndexDB) SuperGroupGetTestMessage(seq uint32) (*model_struct.LocalChatLog, error)

func (IndexDB) SuperGroupMessageIfExistsBySeq 

func (i IndexDB) SuperGroupMessageIfExistsBySeq(seq int64) (bool, error)

func (IndexDB) SuperGroupUpdateColumnsMessage 

func (i IndexDB) SuperGroupUpdateColumnsMessage(clientMsgID, groupID string, args map[string]interface{}) error

func (IndexDB) SuperGroupUpdateGroupMessageHasRead 

func (i IndexDB) SuperGroupUpdateGroupMessageHasRead(msgIDList []string, groupID string) error

func (IndexDB) SuperGroupUpdateMessageStatusBySourceID 

func (i IndexDB) SuperGroupUpdateMessageStatusBySourceID(sourceID string, status, sessionType int32) error

func (IndexDB) SuperGroupUpdateMsgSenderFaceURL 

func (i IndexDB) SuperGroupUpdateMsgSenderFaceURL(sendID, faceURL string, sType int) error

func (IndexDB) SuperGroupUpdateMsgSenderFaceURLAndSenderNickname 

func (i IndexDB) SuperGroupUpdateMsgSenderFaceURLAndSenderNickname(sendID, faceURL, nickname string, sessionType int) error

func (IndexDB) SuperGroupUpdateMsgSenderNickname 

func (i IndexDB) SuperGroupUpdateMsgSenderNickname(sendID, nickname string, sType int) error

func (IndexDB) UnPinConversation 

func (i IndexDB) UnPinConversation(conversationID string, isPinned int) error

func (IndexDB) UpdateAdminGroupRequest 

func (i IndexDB) UpdateAdminGroupRequest(groupRequest *model_struct.LocalAdminGroupRequest) error

func (IndexDB) UpdateAllConversation 

func (i IndexDB) UpdateAllConversation(conversation *model_struct.LocalConversation) error

func (IndexDB) UpdateColumnsMessageController 

func (i IndexDB) UpdateColumnsMessageController(ClientMsgID string, groupID string, sessionType int32, args map[string]interface{}) error

func (IndexDB) UpdateConversation 

func (i IndexDB) UpdateConversation(c *model_struct.LocalConversation) error

func (IndexDB) UpdateConversationForSync 

func (i IndexDB) UpdateConversationForSync(c *model_struct.LocalConversation) error

func (IndexDB) UpdateDepartment 

func (i IndexDB) UpdateDepartment(department *model_struct.LocalDepartment) error

func (IndexDB) UpdateDepartmentMember 

func (i IndexDB) UpdateDepartmentMember(departmentMember *model_struct.LocalDepartmentMember) error

func (IndexDB) UpdateGroupMessageHasRead 

func (i IndexDB) UpdateGroupMessageHasRead(msgIDList []string, sessionType int32) error

func (IndexDB) UpdateGroupMessageHasReadController 

func (i IndexDB) UpdateGroupMessageHasReadController(msgIDList []string, groupID string, sessionType int32) error

func (IndexDB) UpdateMessageController 

func (i IndexDB) UpdateMessageController(c *model_struct.LocalChatLog) error

func (IndexDB) UpdateMessageStatusBySourceIDController 

func (i IndexDB) UpdateMessageStatusBySourceIDController(sourceID string, status, sessionType int32) error

func (IndexDB) UpdateMessageTimeAndStatusController 

func (i IndexDB) UpdateMessageTimeAndStatusController(msg *sdk_struct.MsgStruct) error

type LocalCacheMessage 

type LocalCacheMessage struct {
}

func (*LocalCacheMessage) BatchInsertTempCacheMessageList 

func (i *LocalCacheMessage) BatchInsertTempCacheMessageList(MessageList []*model_struct.TempCacheLocalChatLog) error

func (*LocalCacheMessage) InsertTempCacheMessage 

func (i *LocalCacheMessage) InsertTempCacheMessage(Message *model_struct.TempCacheLocalChatLog) error

type LocalChatLogs 

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

func NewLocalChatLogs 

func NewLocalChatLogs(loginUserID string) *LocalChatLogs

func (*LocalChatLogs) BatchInsertExceptionMsg 

func (i *LocalChatLogs) BatchInsertExceptionMsg(MessageList []*model_struct.LocalErrChatLog) error

func (*LocalChatLogs) BatchInsertMessageList 

func (i *LocalChatLogs) BatchInsertMessageList(messageList []*model_struct.LocalChatLog) error

func (*LocalChatLogs) DeleteAllMessage 

func (i *LocalChatLogs) DeleteAllMessage() error

func (*LocalChatLogs) GetAbnormalMsgSeq 

func (i *LocalChatLogs) GetAbnormalMsgSeq() (uint32, error)

func (*LocalChatLogs) GetAbnormalMsgSeqList 

func (i *LocalChatLogs) GetAbnormalMsgSeqList() (result []uint32, err error)

func (*LocalChatLogs) GetAllUnDeleteMessageSeqList 

func (i *LocalChatLogs) GetAllUnDeleteMessageSeqList() (result []uint32, err error)

func (*LocalChatLogs) GetLostMsgSeqList 

func (i *LocalChatLogs) GetLostMsgSeqList(minSeqInSvr uint32) (result []uint32, err error)

func (*LocalChatLogs) GetMessage 

func (i *LocalChatLogs) GetMessage(clientMsgID string) (*model_struct.LocalChatLog, error)

func (*LocalChatLogs) GetMessageList 

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

func (*LocalChatLogs) GetMessageListNoTime 

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

func (*LocalChatLogs) GetMsgSeqByClientMsgID 

func (i *LocalChatLogs) GetMsgSeqByClientMsgID(clientMsgID string) (uint32, error)

func (*LocalChatLogs) GetMsgSeqListByGroupID 

func (i *LocalChatLogs) GetMsgSeqListByGroupID(groupID string) (result []uint32, err error)

func (*LocalChatLogs) GetMsgSeqListByPeerUserID 

func (i *LocalChatLogs) GetMsgSeqListByPeerUserID(userID string) (result []uint32, err error)

func (*LocalChatLogs) GetMsgSeqListBySelfUserID 

func (i *LocalChatLogs) GetMsgSeqListBySelfUserID(userID string) (result []uint32, err error)

func (*LocalChatLogs) GetMultipleMessage 

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

func (*LocalChatLogs) GetNormalMsgSeq 

func (i *LocalChatLogs) GetNormalMsgSeq() (uint32, error)

func (*LocalChatLogs) GetSendingMessageList 

func (i *LocalChatLogs) GetSendingMessageList() (result []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) GetSuperGroupAbnormalMsgSeq 

func (i *LocalChatLogs) GetSuperGroupAbnormalMsgSeq(groupID string) (uint32, error)

func (*LocalChatLogs) GetTestMessage 

func (i *LocalChatLogs) GetTestMessage(seq uint32) (*model_struct.LocalChatLog, error)

func (*LocalChatLogs) InitSuperLocalErrChatLog 

func (i *LocalChatLogs) InitSuperLocalErrChatLog(groupID string)

func (*LocalChatLogs) InsertMessage 

func (i *LocalChatLogs) InsertMessage(message *model_struct.LocalChatLog) error

func (*LocalChatLogs) IsExistsInErrChatLogBySeq 

func (i *LocalChatLogs) IsExistsInErrChatLogBySeq(seq int64) bool

func (*LocalChatLogs) MessageIfExists 

func (i *LocalChatLogs) MessageIfExists(clientMsgID string) (bool, error)

func (*LocalChatLogs) MessageIfExistsBySeq 

func (i *LocalChatLogs) MessageIfExistsBySeq(seq int64) (bool, error)

func (*LocalChatLogs) SearchMessageByContentType 

func (i *LocalChatLogs) SearchMessageByContentType(contentType []int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (messages []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) SearchMessageByContentTypeAndKeyword 

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

func (*LocalChatLogs) SearchMessageByKeyword 

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

func (*LocalChatLogs) SuperBatchInsertExceptionMsg 

func (i *LocalChatLogs) SuperBatchInsertExceptionMsg(MessageList []*model_struct.LocalErrChatLog, groupID string) error

func (*LocalChatLogs) SuperGroupSearchMessageByContentType 

func (i *LocalChatLogs) SuperGroupSearchMessageByContentType(contentType []int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (messages []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) UpdateColumnsMessage 

func (i *LocalChatLogs) UpdateColumnsMessage(clientMsgID string, args map[string]interface{}) error

func (*LocalChatLogs) UpdateColumnsMessageList 

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

func (*LocalChatLogs) UpdateGroupMessageHasRead 

func (i *LocalChatLogs) UpdateGroupMessageHasRead(msgIDList []string, sessionType int32) error

func (*LocalChatLogs) UpdateMessage 

func (i *LocalChatLogs) UpdateMessage(c *model_struct.LocalChatLog) error

func (*LocalChatLogs) UpdateMessageStatusBySourceID 

func (i *LocalChatLogs) UpdateMessageStatusBySourceID(sourceID string, status, sessionType int32) error

func (*LocalChatLogs) UpdateMessageTimeAndStatus 

func (i *LocalChatLogs) UpdateMessageTimeAndStatus(clientMsgID string, serverMsgID string, sendTime int64, status int32) error

func (*LocalChatLogs) UpdateMsgSenderFaceURL 

func (i *LocalChatLogs) UpdateMsgSenderFaceURL(sendID, faceURL string, sType int) error

func (*LocalChatLogs) UpdateMsgSenderFaceURLAndSenderNickname 

func (i *LocalChatLogs) UpdateMsgSenderFaceURLAndSenderNickname(sendID, faceURL, nickname string, sessionType int) error

func (*LocalChatLogs) UpdateMsgSenderNickname 

func (i *LocalChatLogs) UpdateMsgSenderNickname(sendID, nickname string, sType int) error

func (*LocalChatLogs) UpdateSingleMessageHasRead 

func (i *LocalChatLogs) UpdateSingleMessageHasRead(sendID string, msgIDList []string) error

type LocalConversationUnreadMessages 

type LocalConversationUnreadMessages struct {
}

func (*LocalConversationUnreadMessages) BatchInsertConversationUnreadMessageList 

func (i *LocalConversationUnreadMessages) BatchInsertConversationUnreadMessageList(messageList []*model_struct.LocalConversationUnreadMessage) error

func (*LocalConversationUnreadMessages) DeleteConversationUnreadMessageList 

func (i *LocalConversationUnreadMessages) DeleteConversationUnreadMessageList(conversationID string, sendTime int64) int64

type LocalConversations 

type LocalConversations struct {
}

func (*LocalConversations) GetAllConversationListDB 

func (i *LocalConversations) GetAllConversationListDB() (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetAllConversationListToSync 

func (i *LocalConversations) GetAllConversationListToSync() (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetConversation 

func (i *LocalConversations) GetConversation(conversationID string) (*model_struct.LocalConversation, error)

func (*LocalConversations) GetHiddenConversationList 

func (i *LocalConversations) GetHiddenConversationList() (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) UpdateColumnsConversation 

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

type LocalGroupMember 

type LocalGroupMember struct {
}

func (*LocalGroupMember) BatchInsertGroupMember 

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

func (*LocalGroupMember) DeleteGroupAllMembers 

func (i *LocalGroupMember) DeleteGroupAllMembers(groupID string) error

func (*LocalGroupMember) DeleteGroupMember 

func (i *LocalGroupMember) DeleteGroupMember(groupID, userID string) error

func (*LocalGroupMember) GetAllGroupMemberList 

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

func (*LocalGroupMember) GetAllGroupMemberUserIDList 

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

func (*LocalGroupMember) GetGroupAdminID 

func (i *LocalGroupMember) GetGroupAdminID(groupID string) ([]string, error)

func (*LocalGroupMember) GetGroupMemberCount 

func (i *LocalGroupMember) GetGroupMemberCount(groupID string) (uint32, error)

func (*LocalGroupMember) GetGroupMemberInfoByGroupIDUserID 

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

func (*LocalGroupMember) GetGroupMemberInfoIfOwnerOrAdmin 

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

func (*LocalGroupMember) GetGroupMemberListByGroupID 

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

func (*LocalGroupMember) GetGroupMemberListSplit 

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

func (*LocalGroupMember) GetGroupMemberListSplitByJoinTimeFilter 

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

func (*LocalGroupMember) GetGroupMemberOwner 

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

func (*LocalGroupMember) GetGroupMemberOwnerAndAdmin 

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

func (*LocalGroupMember) GetGroupMemberUIDListByGroupID 

func (i *LocalGroupMember) GetGroupMemberUIDListByGroupID(groupID string) (result []string, err error)

func (*LocalGroupMember) GetGroupOwnerAndAdminByGroupID 

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

func (*LocalGroupMember) GetGroupSomeMemberInfo 

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

func (*LocalGroupMember) InsertGroupMember 

func (i *LocalGroupMember) InsertGroupMember(groupMember *model_struct.LocalGroupMember) error

func (*LocalGroupMember) SearchGroupMembersDB 

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

func (*LocalGroupMember) UpdateGroupMember 

func (i *LocalGroupMember) UpdateGroupMember(groupMember *model_struct.LocalGroupMember) error

func (*LocalGroupMember) UpdateGroupMemberField 

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

type LocalGroupRequest 

type LocalGroupRequest struct {
}

func (*LocalGroupRequest) DeleteGroupRequest 

func (i *LocalGroupRequest) DeleteGroupRequest(groupID, userID string) error

func (*LocalGroupRequest) GetSendGroupApplication 

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

func (*LocalGroupRequest) InsertGroupRequest 

func (i *LocalGroupRequest) InsertGroupRequest(groupRequest *model_struct.LocalGroupRequest) error

func (*LocalGroupRequest) UpdateGroupRequest 

func (i *LocalGroupRequest) UpdateGroupRequest(groupRequest *model_struct.LocalGroupRequest) error

type LocalGroups 

type LocalGroups struct{}

func (*LocalGroups) AddMemberCount 

func (i *LocalGroups) AddMemberCount(groupID string) error

func (*LocalGroups) DeleteGroup 

func (i *LocalGroups) DeleteGroup(groupID string) error

func (*LocalGroups) GetAllGroupInfoByGroupIDOrGroupName 

func (i *LocalGroups) GetAllGroupInfoByGroupIDOrGroupName(keyword string, isSearchGroupID bool, isSearchGroupName bool) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) GetGroupInfoByGroupID 

func (i *LocalGroups) GetGroupInfoByGroupID(groupID string) (*model_struct.LocalGroup, error)

func (*LocalGroups) GetJoinedGroupListDB 

func (i *LocalGroups) GetJoinedGroupListDB() (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) InsertGroup 

func (i *LocalGroups) InsertGroup(groupInfo *model_struct.LocalGroup) error

func (*LocalGroups) SubtractMemberCount 

func (i *LocalGroups) SubtractMemberCount(groupID string) error

func (*LocalGroups) UpdateGroup 

func (i *LocalGroups) UpdateGroup(groupInfo *model_struct.LocalGroup) error

该函数需要全更新

type LocalSuperGroup 

type LocalSuperGroup struct{}

func (*LocalSuperGroup) DeleteAllSuperGroup 

func (i *LocalSuperGroup) DeleteAllSuperGroup() error

func (*LocalSuperGroup) DeleteSuperGroup 

func (i *LocalSuperGroup) DeleteSuperGroup(groupID string) error

func (*LocalSuperGroup) GetJoinedSuperGroupList 

func (i *LocalSuperGroup) GetJoinedSuperGroupList() (result []*model_struct.LocalGroup, err error)

func (*LocalSuperGroup) GetJoinedWorkingGroupIDList 

func (i *LocalSuperGroup) GetJoinedWorkingGroupIDList() ([]string, error)

func (*LocalSuperGroup) GetJoinedWorkingGroupList 

func (i *LocalSuperGroup) GetJoinedWorkingGroupList() (result []*model_struct.LocalGroup, err error)

func (*LocalSuperGroup) GetSuperGroupInfoByGroupID 

func (i *LocalSuperGroup) GetSuperGroupInfoByGroupID(groupID string) (*model_struct.LocalGroup, error)

func (*LocalSuperGroup) InsertSuperGroup 

func (i *LocalSuperGroup) InsertSuperGroup(groupInfo *model_struct.LocalGroup) error

func (*LocalSuperGroup) UpdateSuperGroup 

func (i *LocalSuperGroup) UpdateSuperGroup(g *model_struct.LocalGroup) error

type LocalSuperGroupChatLogs 

type LocalSuperGroupChatLogs struct{}

func (*LocalSuperGroupChatLogs) GetSuperGroupNormalMsgSeq 

func (i *LocalSuperGroupChatLogs) GetSuperGroupNormalMsgSeq(groupID string) (uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupBatchInsertMessageList 

func (i *LocalSuperGroupChatLogs) SuperGroupBatchInsertMessageList(messageList []*model_struct.LocalChatLog, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupBatchUpdateMessageList 

func (i *LocalSuperGroupChatLogs) SuperGroupBatchUpdateMessageList(MessageList []*model_struct.LocalChatLog) error

func (*LocalSuperGroupChatLogs) SuperGroupGetMessage 

func (i *LocalSuperGroupChatLogs) SuperGroupGetMessage(message *sdk_struct.MsgStruct) (*model_struct.LocalChatLog, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMessageList 

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

func (*LocalSuperGroupChatLogs) SuperGroupGetMessageListNoTime 

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

func (*LocalSuperGroupChatLogs) SuperGroupGetMultipleMessage 

func (i *LocalSuperGroupChatLogs) SuperGroupGetMultipleMessage(msgIDList []string, groupID string) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupGetNormalMinSeq 

func (i *LocalSuperGroupChatLogs) SuperGroupGetNormalMinSeq(groupID string) (uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupInsertMessage 

func (i *LocalSuperGroupChatLogs) SuperGroupInsertMessage(message *model_struct.LocalChatLog, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupIsExistsInErrChatLogBySeq 

func (i *LocalSuperGroupChatLogs) SuperGroupIsExistsInErrChatLogBySeq(seq int64) bool

func (*LocalSuperGroupChatLogs) SuperGroupMessageIfExists 

func (i *LocalSuperGroupChatLogs) SuperGroupMessageIfExists(ClientMsgID string) (bool, error)

func (*LocalSuperGroupChatLogs) SuperGroupSearchMessageByContentTypeAndKeyword 

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

func (*LocalSuperGroupChatLogs) SuperGroupSearchMessageByKeyword 

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

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMessage 

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMessage(c *model_struct.LocalChatLog) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMessageTimeAndStatus 

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMessageTimeAndStatus(msg *sdk_struct.MsgStruct) error

type LocalUsers 

type LocalUsers struct {
}

func (*LocalUsers) GetLoginUser 

func (l *LocalUsers) GetLoginUser(userID string) (*model_struct.LocalUser, error)

func (*LocalUsers) InsertLoginUser 

func (l *LocalUsers) InsertLoginUser(user *model_struct.LocalUser) error

func (*LocalUsers) UpdateLoginUser 

func (l *LocalUsers) UpdateLoginUser(user *model_struct.LocalUser) error

func (*LocalUsers) UpdateLoginUserByMap 

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

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.