Versions in this module Expand all Collapse all v1 v1.1.0 Nov 12, 2023 v1.0.0 Oct 17, 2023 Changes in this version + var Contact = NewContactDao() + var Group = NewGroupDao() + var GroupMember = NewGroupMemberDao() + var Robot = NewRobotDao() + var Sequence = NewSequenceDao() + var TalkRecords = NewTalkRecordsDao() + var TalkRecordsVote = NewTalkRecordsVoteDao() + var User = NewUserDao() + func Aggregate(ctx context.Context, database, collection string, pipeline []bson.M, ...) error + func AggregateByPage(ctx context.Context, database, collection, countField string, ...) error + func CountDocuments(ctx context.Context, database, collection string, ...) (int64, error) + func DeleteById(ctx context.Context, database, collection string, id interface{}) error + func DeleteMany(ctx context.Context, database, collection string, ...) (int64, error) + func DeleteOne(ctx context.Context, database, collection string, ...) (int64, error) + func Find(ctx context.Context, database, collection string, ...) error + func FindById(ctx context.Context, database, collection string, id, result interface{}) error + func FindByIds(ctx context.Context, database, collection string, ids, result interface{}) error + func FindByPage(ctx context.Context, database, collection string, paging *db.Paging, ...) error + func FindOne(ctx context.Context, database, collection string, ...) error + func Insert(ctx context.Context, database string, document interface{}) (string, error) + func Inserts(ctx context.Context, database string, documents []interface{}) ([]string, error) + func UpdateById(ctx context.Context, database, collection string, id, update interface{}, ...) error + func UpdateMany(ctx context.Context, database, collection string, ...) error + func UpdateOne(ctx context.Context, database, collection string, ...) error + type ContactDao struct + func NewContactDao(database ...string) *ContactDao + func (d *ContactDao) GetContactIds(ctx context.Context, uid int) []int + type GroupDao struct + func NewGroupDao(database ...string) *GroupDao + func (d *GroupDao) FindGroupByGroupId(ctx context.Context, groupId int) (*entity.Group, error) + type GroupMemberDao struct + func NewGroupMemberDao(database ...string) *GroupMemberDao + func (d *GroupMemberDao) GetMemberIds(ctx context.Context, groupId int) []int + func (d *GroupMemberDao) GetUserGroupIds(ctx context.Context, uid int) []int + type IMongoDB interface + type MongoDB struct + func NewMongoDB(database, collection string) *MongoDB[T] + func (m *MongoDB[T]) Aggregate(ctx context.Context, pipeline []bson.M, result interface{}) error + func (m *MongoDB[T]) AggregateByPage(ctx context.Context, countField string, paging *db.Paging, ...) error + func (m *MongoDB[T]) CountDocuments(ctx context.Context, filter map[string]interface{}) (int64, error) + func (m *MongoDB[T]) DeleteById(ctx context.Context, id interface{}) error + func (m *MongoDB[T]) DeleteMany(ctx context.Context, filter map[string]interface{}) (int64, error) + func (m *MongoDB[T]) DeleteOne(ctx context.Context, filter map[string]interface{}) (int64, error) + func (m *MongoDB[T]) Find(ctx context.Context, filter map[string]interface{}, sortFields ...string) ([]*T, error) + func (m *MongoDB[T]) FindById(ctx context.Context, id interface{}) (*T, error) + func (m *MongoDB[T]) FindByIds(ctx context.Context, ids interface{}) ([]*T, error) + func (m *MongoDB[T]) FindByPage(ctx context.Context, paging *db.Paging, filter map[string]interface{}, ...) ([]*T, error) + func (m *MongoDB[T]) FindOne(ctx context.Context, filter map[string]interface{}, sortFields ...string) (*T, error) + func (m *MongoDB[T]) Insert(ctx context.Context, document interface{}) (string, error) + func (m *MongoDB[T]) Inserts(ctx context.Context, documents []interface{}) ([]string, error) + func (m *MongoDB[T]) UpdateById(ctx context.Context, id, update interface{}, isUpsert ...bool) error + func (m *MongoDB[T]) UpdateMany(ctx context.Context, filter map[string]interface{}, update interface{}, ...) error + func (m *MongoDB[T]) UpdateOne(ctx context.Context, filter map[string]interface{}, update interface{}, ...) error + type RobotDao struct + func NewRobotDao(database ...string) *RobotDao + func (d *RobotDao) GetLoginRobot(ctx context.Context) (*entity.Robot, error) + func (d *RobotDao) GetRobotByUserId(ctx context.Context, userId int) (*entity.Robot, error) + func (d *RobotDao) GetRobotList(ctx context.Context, userIds ...int) ([]*entity.Robot, error) + func (d *RobotDao) GetRobotUserList(ctx context.Context) ([]*entity.User, error) + type SequenceDao struct + func NewSequenceDao(database ...string) *SequenceDao + func (d *SequenceDao) BatchGet(ctx context.Context, userId int, receiverId int, num int64) []int64 + func (d *SequenceDao) Get(ctx context.Context, userId int, receiverId int) int64 + type TalkRecordsDao struct + func NewTalkRecordsDao(database ...string) *TalkRecordsDao + func (d *TalkRecordsDao) FindByRecordId(ctx context.Context, recordId int) (*entity.TalkRecords, error) + func (d *TalkRecordsDao) GetTalkRecord(ctx context.Context, recordId int) (*entity.TalkRecords, *entity.User, error) + func (d *TalkRecordsDao) HandleTalkRecords(ctx context.Context, items []*model.TalkRecordsItem) ([]*model.TalkRecordsItem, error) + type TalkRecordsVoteDao struct + func NewTalkRecordsVoteDao(database ...string) *TalkRecordsVoteDao + func (d *TalkRecordsVoteDao) GetVoteAnswerUser(ctx context.Context, vid string) ([]int, error) + func (d *TalkRecordsVoteDao) GetVoteStatistics(ctx context.Context, vid string) (*model.VoteStatistics, error) + func (d *TalkRecordsVoteDao) SetVoteAnswerUser(ctx context.Context, vid string) ([]int, error) + func (d *TalkRecordsVoteDao) SetVoteStatistics(ctx context.Context, vid string) (*model.VoteStatistics, error) + type UserDao struct + func NewUserDao(database ...string) *UserDao + func (d *UserDao) FindUserByUserId(ctx context.Context, userId int) (*entity.User, error) + func (d *UserDao) FindUserListByUserIds(ctx context.Context, userIds []int) ([]*entity.User, error)
Go to main page