dao

Documentation

Index

• type Dao
  • func New(dbInfo *config.DBInfo, svrInfo *config.ServerInfo, cosInfo *config.CosInfo) *Dao
  • func (d *Dao) AllocNewUserID(ctx context.Context) (uid int64, err error)
  • func (d *Dao) ArticleDetail(ctx context.Context, uid, articleId int64) (*model.Articles, error)
  • func (d *Dao) ArticleList(ctx context.Context, page, findType int, uid, cid int64, kw string) ([]*model.Articles, error)
  • func (d *Dao) BatchAddGroupMember(ctx context.Context, groupMembers []*model.GroupMembers) error
  • func (d *Dao) BatchSetGroupConversationName(ctx context.Context, conversationInfo *model.Conversations) error
  • func (d *Dao) CheckUserExist(ctx context.Context, username string) (err error, exist bool)
  • func (d *Dao) Download(ctx context.Context, bucket, key string, timeout int) ([]byte, error)
  • func (d *Dao) DownloadFile(ctx context.Context, bucket, key string) error
  • func (d *Dao) EditArticle(ctx context.Context, articleInfo *model.Articles) error
  • func (d *Dao) GenGroupID() int64
  • func (d *Dao) GenMsgID() int64
  • func (d *Dao) GetContactDetailInfo(ctx context.Context, uid, contactId int64) (error, *model.UserContact)
  • func (d *Dao) GetContactInfo(ctx context.Context, uid, contactId int64) (error, *model.Contacts)
  • func (d *Dao) GetContactList(ctx context.Context, uid int64, status int) (error, []*model.UserContact)
  • func (d *Dao) GetConversation(ctx context.Context, uid, contactId int64) (error, *model.Conversations)
  • func (d *Dao) GetConversationList(ctx context.Context, uid, sequence int64) (error, []*model.ConversationDetails)
  • func (d *Dao) GetGroupDetailInfo(ctx context.Context, groupId, uid int64) (error, *model.GroupDetailInfo)
  • func (d *Dao) GetGroupInfo(ctx context.Context, GroupId int64) (error, *model.Groups)
  • func (d *Dao) GetGroupList(ctx context.Context, uid int64) (err error, groupList []*model.GroupInfoList)
  • func (d *Dao) GetGroupMemberInfo(ctx context.Context, groupId, uid int64) (error, *model.GroupMembers)
  • func (d *Dao) GetGroupMemberInfoList(ctx context.Context, groupId, sequence int64) (error, []*model.GroupMemberInfoList)
  • func (d *Dao) GetGroupMemberList(ctx context.Context, groupId int64) (error, []*model.GroupMembers)
  • func (d *Dao) GetPresignUrl(ctx context.Context, bucket, key string, expireHour time.Duration) (string, error)
  • func (d *Dao) GetUserInfoByUid(ctx context.Context, uid int64) (error, *model.UserInfo)
  • func (d *Dao) GetUserInfoByUserName(ctx context.Context, username string) (error, *model.UserInfo)
  • func (d *Dao) MakeRawUrl(ctx context.Context, disableSSL bool, domain, bucket, key string) (string, error)
  • func (d *Dao) ParseUrlKey(ctx context.Context, urlStr string) (string, error)
  • func (d *Dao) RawDownload(ctx context.Context, url string) ([]byte, error)
  • func (d *Dao) SetContactInfo(ctx context.Context, contact *model.Contacts) error
  • func (d *Dao) SetConversation(ctx context.Context, conversationInfo *model.Conversations) error
  • func (d *Dao) SetGroupInfo(ctx context.Context, groupInfo *model.Groups) error
  • func (d *Dao) SetGroupMemberInfo(ctx context.Context, groupUserInfo *model.GroupMembers) error
  • func (d *Dao) SetUserInfo(ctx context.Context, userInfo *model.UserInfo) error
  • func (d *Dao) UploadFile(ctx context.Context, bucket, key string, reader io.Reader, ...) error

Types

type Dao

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

Dao is Data Access Object

func New

func New(dbInfo *config.DBInfo, svrInfo *config.ServerInfo, cosInfo *config.CosInfo) *Dao

New creates Dao instance dsn eg: "user:pass@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local"

func (*Dao) AllocNewUserID

func (d *Dao) AllocNewUserID(ctx context.Context) (uid int64, err error)

AllocNewUserID 获取新用户ID

func (*Dao) ArticleDetail

func (d *Dao) ArticleDetail(ctx context.Context, uid, articleId int64) (*model.Articles, error)

func (*Dao) ArticleList

func (d *Dao) ArticleList(ctx context.Context, page, findType int, uid, cid int64, kw string) ([]*model.Articles, error)

ArticleList 拉取文章列表 todo：先把page当成ID查

func (*Dao) BatchAddGroupMember

func (d *Dao) BatchAddGroupMember(ctx context.Context, groupMembers []*model.GroupMembers) error

func (*Dao) BatchSetGroupConversationName

func (d *Dao) BatchSetGroupConversationName(ctx context.Context, conversationInfo *model.Conversations) error

func (*Dao) CheckUserExist

func (d *Dao) CheckUserExist(ctx context.Context, username string) (err error, exist bool)

func (*Dao) Download

func (d *Dao) Download(ctx context.Context, bucket, key string, timeout int) ([]byte, error)

Download 从cos下载文件，返回字节流

func (*Dao) DownloadFile

func (d *Dao) DownloadFile(ctx context.Context, bucket, key string) error

DownloadFile 从cos下载文件，存储到本地

func (*Dao) EditArticle

func (d *Dao) EditArticle(ctx context.Context, articleInfo *model.Articles) error

EditArticle 新增/更新

func (*Dao) GenGroupID

func (d *Dao) GenGroupID() int64

GenGroupID 生成群ID。复用雪花

func (*Dao) GenMsgID

func (d *Dao) GenMsgID() int64

GenMsgID 生成消息ID。雪花算法，保证递增

func (*Dao) GetContactDetailInfo

func (d *Dao) GetContactDetailInfo(ctx context.Context, uid, contactId int64) (error, *model.UserContact)

GetContactDetailInfo 获取uid好友contactId的详细信息

func (*Dao) GetContactInfo

func (d *Dao) GetContactInfo(ctx context.Context, uid, contactId int64) (error, *model.Contacts)

GetContactInfo 获取uid好友contactId的基础信息

func (*Dao) GetContactList

func (d *Dao) GetContactList(ctx context.Context, uid int64, status int) (error, []*model.UserContact)

GetContactList 获取我的好友列表信息 SELECT contacts.uid as uid, contacts.contact_id as contact_id, user_infos.nickname as nickname, user_infos.gender as gender, user_infos.motto as motto, user_infos.avatar as avatar, contacts.remark_name as remark_name, contacts.status as status FROM `contacts` left join user_infos on contacts.uid=user_infos.uid where contacts.uid=10000\G;

func (*Dao) GetConversation

func (d *Dao) GetConversation(ctx context.Context, uid, contactId int64) (error, *model.Conversations)

func (*Dao) GetConversationList

func (d *Dao) GetConversationList(ctx context.Context, uid, sequence int64) (error, []*model.ConversationDetails)

GetConversationList 差量获取会话列表

func (*Dao) GetGroupDetailInfo

func (d *Dao) GetGroupDetailInfo(ctx context.Context, groupId, uid int64) (error, *model.GroupDetailInfo)

func (*Dao) GetGroupInfo

func (d *Dao) GetGroupInfo(ctx context.Context, GroupId int64) (error, *model.Groups)

func (*Dao) GetGroupList

func (d *Dao) GetGroupList(ctx context.Context, uid int64) (err error, groupList []*model.GroupInfoList)

func (*Dao) GetGroupMemberInfo

func (d *Dao) GetGroupMemberInfo(ctx context.Context, groupId, uid int64) (error, *model.GroupMembers)

func (*Dao) GetGroupMemberInfoList

func (d *Dao) GetGroupMemberInfoList(ctx context.Context, groupId, sequence int64) (error, []*model.GroupMemberInfoList)

func (*Dao) GetGroupMemberList

func (d *Dao) GetGroupMemberList(ctx context.Context, groupId int64) (error, []*model.GroupMembers)

func (*Dao) GetPresignUrl

func (d *Dao) GetPresignUrl(ctx context.Context, bucket, key string, expireHour time.Duration) (string, error)

GetPresignUrl .

func (*Dao) GetUserInfoByUid

func (d *Dao) GetUserInfoByUid(ctx context.Context, uid int64) (error, *model.UserInfo)

GetUserInfoByUid 获取用户信息

func (*Dao) GetUserInfoByUserName

func (d *Dao) GetUserInfoByUserName(ctx context.Context, username string) (error, *model.UserInfo)

GetUserInfoByUserName 获取用户信息

func (*Dao) MakeRawUrl

func (d *Dao) MakeRawUrl(ctx context.Context, disableSSL bool, domain, bucket, key string) (string, error)

func (*Dao) ParseUrlKey

func (d *Dao) ParseUrlKey(ctx context.Context, urlStr string) (string, error)

ParseUrlKey 从url解析path路径剥离bucket

func (*Dao) RawDownload

func (d *Dao) RawDownload(ctx context.Context, url string) ([]byte, error)

RawDownload 直接从url下载字节流

func (*Dao) SetContactInfo

func (d *Dao) SetContactInfo(ctx context.Context, contact *model.Contacts) error

func (*Dao) SetConversation

func (d *Dao) SetConversation(ctx context.Context, conversationInfo *model.Conversations) error

func (*Dao) SetGroupInfo

func (d *Dao) SetGroupInfo(ctx context.Context, groupInfo *model.Groups) error

func (*Dao) SetGroupMemberInfo

func (d *Dao) SetGroupMemberInfo(ctx context.Context, groupUserInfo *model.GroupMembers) error

func (*Dao) SetUserInfo

func (d *Dao) SetUserInfo(ctx context.Context, userInfo *model.UserInfo) error

SetUserInfo 设置用户信息

func (*Dao) UploadFile

func (d *Dao) UploadFile(ctx context.Context, bucket, key string, reader io.Reader, ftype, md5Str string) error

UploadFile .