dao

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2022 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dao 

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

func New 

func New(c *config.Config) *Dao

func (*Dao) DeleteGroupCache 

func (d *Dao) DeleteGroupCache(groupId int64) error

func (*Dao) GetAdminNumByGroupId 

func (d *Dao) GetAdminNumByGroupId(groupId int64) (int32, error)

GetAdminNumByGroupId 查询群内管理员数量

func (*Dao) GetAllGroupInfo 

func (d *Dao) GetAllGroupInfo() ([]*biz.GroupInfo, error)

GetAllGroupInfo .

func (*Dao) GetGroupApplyById 

func (d *Dao) GetGroupApplyById(id int64) (*db.GroupApply, error)

GetGroupApplyById 通过 ID 获得群审批详情

func (*Dao) GetGroupApplys 

func (d *Dao) GetGroupApplys(groupId int64, limit, offset int32) ([]*db.GroupApply, error)

func (*Dao) GetGroupCache 

func (d *Dao) GetGroupCache(groupId int64) (*biz.GroupInfo, error)

GetGroupCache get group from groupId

func (*Dao) GetGroupIdsByMemberId 

func (d *Dao) GetGroupIdsByMemberId(memberId string) ([]int64, error)

GetGroupIdsByMemberId 查询用户所有加入的群 ID

func (*Dao) GetGroupInfoByGroupId 

func (d *Dao) GetGroupInfoByGroupId(ctx context.Context, groupId int64) (*biz.GroupInfo, error)

GetGroupInfoByGroupId 查询群信息

func (*Dao) GetGroupInfoByGroupMarkId 

func (d *Dao) GetGroupInfoByGroupMarkId(groupMarkId string) (*biz.GroupInfo, error)

GetGroupInfoByGroupMarkId 查询群信息

func (*Dao) GetGroupInfosByGroupIds 

func (d *Dao) GetGroupInfosByGroupIds(ctx context.Context, groupIds []int64) ([]*biz.GroupInfo, error)

GetGroupInfosByGroupIds 查询群信息s

func (*Dao) GetGroupMemberByGroupIdAndMemberId 

func (d *Dao) GetGroupMemberByGroupIdAndMemberId(ctx context.Context, groupId int64, memberId string) (*biz.GroupMember, error)

GetGroupMemberByGroupIdAndMemberId 查询一个群成员信息

func (*Dao) GetGroupMemberMuteTime 

func (d *Dao) GetGroupMemberMuteTime(groupId int64, memberId string) (int64, error)

GetGroupMemberMuteTime 查询群成员禁言时间

func (*Dao) GetGroupMemberWithMuteTimeByGroupIdAndMemberId 

func (d *Dao) GetGroupMemberWithMuteTimeByGroupIdAndMemberId(groupId int64, memberId string) (*biz.GroupMember, error)

GetGroupMemberWithMuteTimeByGroupIdAndMemberId 查询一个带禁言时间的群成员信息 没用 删掉

func (*Dao) GetGroupMembersByGroupIdWithLimit 

func (d *Dao) GetGroupMembersByGroupIdWithLimit(groupId, n, m int64) ([]*biz.GroupMember, error)

GetGroupMembersByGroupIdWithLimit 查询群内前 n 个群成员信息

func (*Dao) GetGroupMembersMutedByGroupId 

func (d *Dao) GetGroupMembersMutedByGroupId(groupId int64) ([]*biz.GroupMember, error)

GetGroupMembersMutedByGroupId 查询群内被禁言的群成员信息

func (*Dao) GetGroupMuteNum 

func (d *Dao) GetGroupMuteNum(groupId int64) (int32, error)

GetGroupMuteNum 查询群内禁言人数

func (*Dao) GetLogWithTrace 

func (d *Dao) GetLogWithTrace(ctx context.Context) zerolog.Logger

func (*Dao) GetMemberTypeMemberIdAndGroupId 

func (d *Dao) GetMemberTypeMemberIdAndGroupId(groupMemberId string, groupId int64) (int32, error)

func (*Dao) GetMembersByGroupId 

func (d *Dao) GetMembersByGroupId(groupId int64) ([]*biz.GroupMember, error)

GetMembersByGroupId 查询群里的所有成员信息

func (*Dao) GetRandRedisExpire 

func (d *Dao) GetRandRedisExpire() time.Duration

func (*Dao) GetTrace 

func (d *Dao) GetTrace(ctx context.Context) string

func (*Dao) InsertGroupApplys 

func (d *Dao) InsertGroupApplys(tx *mysql.MysqlTx, groupApplys []*db.GroupApply) error

InsertGroupApplys 插入加群审批

func (*Dao) InsertGroupInfo 

func (d *Dao) InsertGroupInfo(tx *mysql.MysqlTx, form *db.GroupInfo) (int64, int64, error)

func (*Dao) InsertGroupMember 

func (d *Dao) InsertGroupMember(tx *mysql.MysqlTx, form *db.GroupMember) (int64, int64, error)

InsertGroupMember . no usage

func (*Dao) InsertGroupMembers 

func (d *Dao) InsertGroupMembers(tx *mysql.MysqlTx, groupMembers []*db.GroupMember) error

InsertGroupMembers 批量插入群成员

func (*Dao) MaintainAESKeyAndPubName 

func (d *Dao) MaintainAESKeyAndPubName(form *db.GroupInfo) (int64, int64, error)

func (*Dao) MaintainGroupType 

func (d *Dao) MaintainGroupType(form *db.GroupInfo) (int64, int64, error)

func (*Dao) NewTx 

func (d *Dao) NewTx() (*mysql.MysqlTx, error)

func (*Dao) SaveGroup 

func (d *Dao) SaveGroup(group *biz.GroupInfo, duration time.Duration) error

func (*Dao) UpdateGroupApply 

func (d *Dao) UpdateGroupApply(operatorId string, applyStatus int32, rejectReason string, id int64) error

func (*Dao) UpdateGroupInfoAvatar 

func (d *Dao) UpdateGroupInfoAvatar(ctx context.Context, groupId int64, avatar string) error

UpdateGroupInfoAvatar 更新群头像

func (*Dao) UpdateGroupInfoFriendType 

func (d *Dao) UpdateGroupInfoFriendType(ctx context.Context, groupId int64, friendType int32) error

UpdateGroupInfoFriendType 更新群内加好友设置

func (*Dao) UpdateGroupInfoIntroduce 

func (d *Dao) UpdateGroupInfoIntroduce(form *db.GroupInfo) (int64, int64, error)

UpdateGroupInfoIntroduce . no usage

func (*Dao) UpdateGroupInfoJoinType 

func (d *Dao) UpdateGroupInfoJoinType(ctx context.Context, groupId int64, joinType int32) error

UpdateGroupInfoJoinType 更新加群设置

func (*Dao) UpdateGroupInfoMaximum 

func (d *Dao) UpdateGroupInfoMaximum(form *db.GroupInfo) (int64, int64, error)

UpdateGroupInfoMaximum . no usage

func (*Dao) UpdateGroupInfoMemberNum 

func (d *Dao) UpdateGroupInfoMemberNum(ctx context.Context, groupId int64) (int32, error)

UpdateGroupInfoMemberNum 更新群成员数量

func (*Dao) UpdateGroupInfoMuteType 

func (d *Dao) UpdateGroupInfoMuteType(ctx context.Context, groupId int64, muteType int32) error

UpdateGroupInfoMuteType 更新群禁言设置

func (*Dao) UpdateGroupInfoName 

func (d *Dao) UpdateGroupInfoName(ctx context.Context, groupId int64, name, publicName string) error

UpdateGroupInfoName 更新群名称

func (*Dao) UpdateGroupInfoOwnerIdWithTx 

func (d *Dao) UpdateGroupInfoOwnerIdWithTx(tx *mysql.MysqlTx, form *db.GroupInfo) (int64, int64, error)

func (*Dao) UpdateGroupInfoStatus 

func (d *Dao) UpdateGroupInfoStatus(form *db.GroupInfo) (int64, int64, error)

UpdateGroupInfoStatus . no usage

func (*Dao) UpdateGroupInfoStatusWithTx 

func (d *Dao) UpdateGroupInfoStatusWithTx(tx *mysql.MysqlTx, form *db.GroupInfo) (int64, int64, error)

func (*Dao) UpdateGroupMemberMuteTimes 

func (d *Dao) UpdateGroupMemberMuteTimes(ctx context.Context, tx *mysql.MysqlTx, groupMemberMutes []*db.GroupMemberMute) error

func (*Dao) UpdateGroupMemberName 

func (d *Dao) UpdateGroupMemberName(groupId int64, memberId, memberName string) error

UpdateGroupMemberName 更新群成员昵称

func (*Dao) UpdateGroupMemberType 

func (d *Dao) UpdateGroupMemberType(ctx context.Context, groupId int64, mnemberId string, memberType int32) error

UpdateGroupMemberType 更新群成员类型

func (*Dao) UpdateGroupMemberTypeWithTx 

func (d *Dao) UpdateGroupMemberTypeWithTx(tx *mysql.MysqlTx, form *db.GroupMember) (int64, int64, error)

Source Files

View all Source files

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.