repositories

Documentation

Index

• func RsyncDingDingData(ding *common.DingDing) (err error)
• type DepartmentRepository
  • func NewDepartmentRepository(db *gorm.DB) DepartmentRepository
• type MessageRepository
  • func NewMessageRepository(db *gorm.DB, ding *common.DingDing) MessageRepository
• type MovieRepository
  • func NewMovieRepository(source map[int64]*datamodels.Movie) MovieRepository
• type UserRepository
  • func NewUserRepository(db *gorm.DB) UserRepository

Functions

func RsyncDingDingData

func RsyncDingDingData(ding *common.DingDing) (err error)

从dingding中同步部门和用户数据

Types

type DepartmentRepository

type DepartmentRepository interface {
	// 通过id获取部门
	GetById(id int64) (department *datamodels.Department, err error)
	// 通过部门名字获取部门
	GetByName(name string) (department *datamodels.Department, err error)
	// 获取部门列表
	List(offset int, limit int) (departments []*datamodels.Department, err error)
	// 获取部门用户
	GetDepartmentUsers(department *datamodels.Department) (users []*datamodels.User, err error)
}

Repository：可以直接访问数据源，并可以直接操作数据的层 部门操作的接口

func NewDepartmentRepository

func NewDepartmentRepository(db *gorm.DB) DepartmentRepository

实例化一个部门操作实例

type MessageRepository

type MessageRepository interface {
	//	获取消息
	GetById(id int64) (message *datamodels.Message, err error)
	// 获取消息列表
	List(offset int, limit int) (messages []*datamodels.Message, err error)
	// 发送工作消息
	SendWorkerMessage(workMessage *common.WorkerMessage, message *datamodels.Message) (success bool, err error)
}

消息Repository接口

func NewMessageRepository

func NewMessageRepository(db *gorm.DB, ding *common.DingDing) MessageRepository

实例化Message Repository

type MovieRepository

type MovieRepository interface {
	GetAll() []*datamodels.Movie
	GetById(int64) (movie *datamodels.Movie, ok bool)
}

func NewMovieRepository

func NewMovieRepository(source map[int64]*datamodels.Movie) MovieRepository

type UserRepository

type UserRepository interface {
	// 根据ID获取到用户
	GetById(id string) (user *datamodels.User, err error)
	// 根据名字获取用户
	GetByName(name string) (user *datamodels.User, err error)
	// 通过ID或者名字获取到用户
	GetByIdOrName(idOrName string) (user *datamodels.User, err error)
	// 根据手机号获取用户
	GetByMobile(mobile string) (user *datamodels.User, err error)
	// 获取用户列表
	List(offset int, limit int) (users []*datamodels.User, err error)
	// 获取用户的所有部门
	GetUserDepartments(user *datamodels.User) (departments []*datamodels.Department, err error)
	//	获取用户的消息列表
	GetUserMessagesList(user *datamodels.User, offset int, limit int) (messages []*datamodels.Message, err error)
}

用户Repository接口

func NewUserRepository

func NewUserRepository(db *gorm.DB) UserRepository