data

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2024 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Expiration          = 5 * 24 * time.Hour
	RecycleExpiration   = 2 * 30 * 24 * time.Hour
	BlackListExpiration = 1 * time.Minute
)
View Source 
const RedisNull = "redis_Null"

Variables

View Source 
var ProviderSet = wire.NewSet(
	NewData,
	NewDB,
	NewRedisDB,
	NewStudentAndCourseDBRepo,
	NewStudentAndCourseCacheRepo,
	NewClassInfoDBRepo,
	NewClassInfoCacheRepo,
	NewTransaction,
	NewJxbDBRepo,
)

ProviderSet is data providers.

Functions

func NewDB 

func NewDB(c *conf.Data, logfile *os.File) *gorm.DB

NewDB 连接mysql数据库

func NewRedisDB 

func NewRedisDB(c *conf.Data) *redis.Client

NewRedisDB 连接redis

func NewTransaction 

func NewTransaction(d *Data) biz.Transaction

NewTransaction .

Types

type ClassInfoCacheRepo 

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

func NewClassInfoCacheRepo 

func NewClassInfoCacheRepo(rdb *redis.Client, logger classLog.Clogger) *ClassInfoCacheRepo

func (ClassInfoCacheRepo) AddClaInfosToCache 

func (c ClassInfoCacheRepo) AddClaInfosToCache(ctx context.Context, key string, classInfos []*model.ClassInfo) error

AddClaInfosToCache 将整个课表转换成json格式，然后存到缓存中去

func (ClassInfoCacheRepo) DeleteClassInfoFromCache 

func (c ClassInfoCacheRepo) DeleteClassInfoFromCache(ctx context.Context, classInfosKey ...string) error

func (ClassInfoCacheRepo) GetClassInfosFromCache 

func (c ClassInfoCacheRepo) GetClassInfosFromCache(ctx context.Context, key string) ([]*model.ClassInfo, error)

type ClassInfoDBRepo 

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

func NewClassInfoDBRepo 

func NewClassInfoDBRepo(data *Data, logger classLog.Clogger) *ClassInfoDBRepo

func (ClassInfoDBRepo) AddClassInfoToDB 

func (c ClassInfoDBRepo) AddClassInfoToDB(ctx context.Context, classInfo *model.ClassInfo) error

func (ClassInfoDBRepo) DeleteClassInfoInDB 

func (c ClassInfoDBRepo) DeleteClassInfoInDB(ctx context.Context, ID string) error

func (ClassInfoDBRepo) GetClassInfoFromDB 

func (c ClassInfoDBRepo) GetClassInfoFromDB(ctx context.Context, ID string) (*model.ClassInfo, error)

func (ClassInfoDBRepo) GetClassInfos 

func (c ClassInfoDBRepo) GetClassInfos(ctx context.Context, stuId, xnm, xqm string) ([]*model.ClassInfo, error)

func (ClassInfoDBRepo) SaveClassInfosToDB 

func (c ClassInfoDBRepo) SaveClassInfosToDB(ctx context.Context, classInfos []*model.ClassInfo) error

func (ClassInfoDBRepo) UpdateClassInfoInDB 

func (c ClassInfoDBRepo) UpdateClassInfoInDB(ctx context.Context, classInfo *model.ClassInfo) error

type Data 

type Data struct {
	Mysql *gorm.DB
}

Data .

func NewData 

func NewData(c *conf.Data, mysqlDB *gorm.DB, logger log.Logger) (*Data, func(), error)

NewData .

func (*Data) DB 

func (d *Data) DB(ctx context.Context) *gorm.DB

DB 在事务执行ORM操作的话 得需要使用这个方法获取tx！

func (*Data) InTx 

func (d *Data) InTx(ctx context.Context, fn func(ctx context.Context) error) error

type JxbDBRepo 

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

func NewJxbDBRepo 

func NewJxbDBRepo(data *Data, logger classLog.Clogger) *JxbDBRepo

func (*JxbDBRepo) FindStuIdsByJxbId 

func (j *JxbDBRepo) FindStuIdsByJxbId(ctx context.Context, jxbId string) ([]string, error)

func (*JxbDBRepo) SaveJxb 

func (j *JxbDBRepo) SaveJxb(ctx context.Context, jxbId, stuId string) error

type StudentAndCourseCacheRepo 

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

func NewStudentAndCourseCacheRepo 

func NewStudentAndCourseCacheRepo(rdb *redis.Client, logger classLog.Clogger) *StudentAndCourseCacheRepo

func (StudentAndCourseCacheRepo) CheckRecycleIdIsExist 

func (s StudentAndCourseCacheRepo) CheckRecycleIdIsExist(ctx context.Context, RecycledBinKey, classId string) bool

func (StudentAndCourseCacheRepo) GetRecycledClassIds 

func (s StudentAndCourseCacheRepo) GetRecycledClassIds(ctx context.Context, key string) ([]string, error)

func (StudentAndCourseCacheRepo) RecycleClassId 

func (s StudentAndCourseCacheRepo) RecycleClassId(ctx context.Context, recycleBinKey string, classId ...string) error

func (StudentAndCourseCacheRepo) RemoveClassFromRecycledBin 

func (s StudentAndCourseCacheRepo) RemoveClassFromRecycledBin(ctx context.Context, RecycledBinKey, classId string) error

type StudentAndCourseDBRepo 

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

func NewStudentAndCourseDBRepo 

func NewStudentAndCourseDBRepo(data *Data, logger classLog.Clogger) *StudentAndCourseDBRepo

func (StudentAndCourseDBRepo) CheckExists 

func (s StudentAndCourseDBRepo) CheckExists(ctx context.Context, xnm, xqm, stuId, classId string) bool

func (StudentAndCourseDBRepo) CheckIfManuallyAdded 

func (s StudentAndCourseDBRepo) CheckIfManuallyAdded(ctx context.Context, classID string) bool

func (StudentAndCourseDBRepo) DeleteStudentAndCourseInDB 

func (s StudentAndCourseDBRepo) DeleteStudentAndCourseInDB(ctx context.Context, ID ...string) error

func (StudentAndCourseDBRepo) GetClassNum 

func (s StudentAndCourseDBRepo) GetClassNum(ctx context.Context, stuID, year, semester string, isManuallyAdded bool) (num int64, err error)

func (StudentAndCourseDBRepo) SaveManyStudentAndCourseToDB 

func (s StudentAndCourseDBRepo) SaveManyStudentAndCourseToDB(ctx context.Context, scs []*model.StudentCourse) error

func (StudentAndCourseDBRepo) SaveStudentAndCourseToDB 

func (s StudentAndCourseDBRepo) SaveStudentAndCourseToDB(ctx context.Context, sc *model.StudentCourse) 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.