script_repo

Documentation

Index

• func RegisterLibDefinition(i LibDefinitionRepo)
• func RegisterMigrate(i ScriptMigrateRepo)
• func RegisterScript(i ScriptRepo)
• func RegisterScriptAccess(i ScriptAccessRepo)
• func RegisterScriptCategory(i ScriptCategoryRepo)
• func RegisterScriptCategoryList(i ScriptCategoryListRepo)
• func RegisterScriptCode(i ScriptCodeRepo)
• func RegisterScriptDateStatistics(i ScriptDateStatisticsRepo)
• func RegisterScriptDomain(i ScriptDomainRepo)
• func RegisterScriptGroup(i ScriptGroupRepo)
• func RegisterScriptGroupMember(i ScriptGroupMemberRepo)
• func RegisterScriptInvite(i ScriptInviteRepo)
• func RegisterScriptScore(i ScriptScoreRepo)
• func RegisterScriptStatistics(i ScriptStatisticsRepo)
• func RegisterScriptWatch(i ScriptWatchRepo)
• type LibDefinitionRepo
  • func LibDefinition() LibDefinitionRepo
  • func NewLibDefinitionRepo() LibDefinitionRepo
• type ScriptAccessRepo
  • func NewScriptAccess() ScriptAccessRepo
  • func ScriptAccess() ScriptAccessRepo
• type ScriptCategoryListRepo
  • func NewScriptCategoryListRepo() ScriptCategoryListRepo
  • func ScriptCategoryList() ScriptCategoryListRepo
• type ScriptCategoryRepo
  • func NewScriptCategoryRepo() ScriptCategoryRepo
  • func ScriptCategory() ScriptCategoryRepo
• type ScriptCodeRepo
  • func NewScriptCodeRepo() ScriptCodeRepo
  • func ScriptCode() ScriptCodeRepo
• type ScriptDateStatisticsRepo
  • func NewScriptDateStatistics() ScriptDateStatisticsRepo
  • func ScriptDateStatistics() ScriptDateStatisticsRepo
• type ScriptDomainRepo
  • func Domain() ScriptDomainRepo
  • func NewScriptDomainRepo() ScriptDomainRepo
• type ScriptGroupMemberRepo
  • func NewScriptGroupMember() ScriptGroupMemberRepo
  • func ScriptGroupMember() ScriptGroupMemberRepo
• type ScriptGroupRepo
  • func NewScriptGroup() ScriptGroupRepo
  • func ScriptGroup() ScriptGroupRepo
• type ScriptInviteRepo
  • func NewScriptInvite() ScriptInviteRepo
  • func ScriptInvite() ScriptInviteRepo
• type ScriptMigrateRepo
  • func Migrate() ScriptMigrateRepo
  • func NewMigrateRepo() ScriptMigrateRepo
• type ScriptRepo
  • func NewScriptRepo() ScriptRepo
  • func Script() ScriptRepo
• type ScriptScoreRepo
  • func NewScriptScore() ScriptScoreRepo
  • func ScriptScore() ScriptScoreRepo
• type ScriptStatisticsRepo
  • func NewScriptStatistics() ScriptStatisticsRepo
  • func ScriptStatistics() ScriptStatisticsRepo
• type ScriptWatchRepo
  • func NewScriptWatchRepo() ScriptWatchRepo
  • func ScriptWatch() ScriptWatchRepo
• type SearchOptions

Functions

func RegisterLibDefinition

func RegisterLibDefinition(i LibDefinitionRepo)

func RegisterMigrate

func RegisterMigrate(i ScriptMigrateRepo)

func RegisterScript

func RegisterScript(i ScriptRepo)

func RegisterScriptAccess

func RegisterScriptAccess(i ScriptAccessRepo)

func RegisterScriptCategory

func RegisterScriptCategory(i ScriptCategoryRepo)

func RegisterScriptCategoryList

func RegisterScriptCategoryList(i ScriptCategoryListRepo)

func RegisterScriptCode

func RegisterScriptCode(i ScriptCodeRepo)

func RegisterScriptDateStatistics

func RegisterScriptDateStatistics(i ScriptDateStatisticsRepo)

func RegisterScriptDomain

func RegisterScriptDomain(i ScriptDomainRepo)

func RegisterScriptGroup

func RegisterScriptGroup(i ScriptGroupRepo)

func RegisterScriptGroupMember

func RegisterScriptGroupMember(i ScriptGroupMemberRepo)

func RegisterScriptInvite

func RegisterScriptInvite(i ScriptInviteRepo)

func RegisterScriptScore

func RegisterScriptScore(i ScriptScoreRepo)

func RegisterScriptStatistics

func RegisterScriptStatistics(i ScriptStatisticsRepo)

func RegisterScriptWatch

func RegisterScriptWatch(i ScriptWatchRepo)

Types

type LibDefinitionRepo

type LibDefinitionRepo interface {
	Find(ctx context.Context, id int64) (*script_entity.LibDefinition, error)
	Create(ctx context.Context, libDefinition *script_entity.LibDefinition) error
	Update(ctx context.Context, libDefinition *script_entity.LibDefinition) error
	Delete(ctx context.Context, id int64) error
}

func LibDefinition

func LibDefinition() LibDefinitionRepo

func NewLibDefinitionRepo

func NewLibDefinitionRepo() LibDefinitionRepo

type ScriptAccessRepo

type ScriptAccessRepo interface {
	Find(ctx context.Context, scriptId int64, id int64) (*script_entity.ScriptAccess, error)
	FindPage(ctx context.Context, scriptId int64, page httputils.PageRequest) ([]*script_entity.ScriptAccess, int64, error)
	Create(ctx context.Context, scriptAccess *script_entity.ScriptAccess) error
	Update(ctx context.Context, scriptAccess *script_entity.ScriptAccess) error
	Delete(ctx context.Context, id int64) error

	FindByLinkID(ctx context.Context, scriptId int64, linkId int64, accessType script_entity.AccessType) ([]*script_entity.ScriptAccess, error)
}

func NewScriptAccess

func NewScriptAccess() ScriptAccessRepo

func ScriptAccess

func ScriptAccess() ScriptAccessRepo

type ScriptCategoryListRepo

type ScriptCategoryListRepo interface {
	Find(ctx context.Context, id int64) (*entity.ScriptCategoryList, error)
	Create(ctx context.Context, scriptCategoryList *entity.ScriptCategoryList) error
	Update(ctx context.Context, scriptCategoryList *entity.ScriptCategoryList) error
	Delete(ctx context.Context, id int64) error

	FindByName(ctx context.Context, name string) (*entity.ScriptCategoryList, error)
}

func NewScriptCategoryListRepo

func NewScriptCategoryListRepo() ScriptCategoryListRepo

func ScriptCategoryList

func ScriptCategoryList() ScriptCategoryListRepo

type ScriptCategoryRepo

type ScriptCategoryRepo interface {
	Find(ctx context.Context, id int64) (*entity.ScriptCategory, error)
	Create(ctx context.Context, scriptCategory *entity.ScriptCategory) error
	Update(ctx context.Context, scriptCategory *entity.ScriptCategory) error
	Delete(ctx context.Context, id int64) error

	LinkCategory(ctx context.Context, script, category int64) error
	List(ctx context.Context, script int64) ([]*entity.ScriptCategory, error)
}

func NewScriptCategoryRepo

func NewScriptCategoryRepo() ScriptCategoryRepo

func ScriptCategory

func ScriptCategory() ScriptCategoryRepo

type ScriptCodeRepo

type ScriptCodeRepo interface {
	Find(ctx context.Context, id int64) (*entity.Code, error)
	Create(ctx context.Context, scriptCode *entity.Code) error
	Update(ctx context.Context, scriptCode *entity.Code) error
	Delete(ctx context.Context, scriptCode *entity.Code) error

	FindByVersion(ctx context.Context, scriptId int64, version string, withcode bool) (*entity.Code, error)
	// FindByVersionAll 查找所有,包括删除的
	FindByVersionAll(ctx context.Context, scriptId int64, version string) (*entity.Code, error)
	FindLatest(ctx context.Context, scriptId int64, offset int, withcode bool) (*entity.Code, error)
	FindPreLatest(ctx context.Context, scriptId int64, offset int, withcode bool) (*entity.Code, error)
	FindAllLatest(ctx context.Context, scriptId int64, offset int, withcode bool) (*entity.Code, error)
	List(ctx context.Context, id int64, request httputils.PageRequest) ([]*entity.Code, int64, error)
}

func NewScriptCodeRepo

func NewScriptCodeRepo() ScriptCodeRepo

func ScriptCode

func ScriptCode() ScriptCodeRepo

type ScriptDateStatisticsRepo

type ScriptDateStatisticsRepo interface {
	Find(ctx context.Context, id int64) (*entity.ScriptDateStatistics, error)
	Create(ctx context.Context, scriptDateStatistics *entity.ScriptDateStatistics) error
	Update(ctx context.Context, scriptDateStatistics *entity.ScriptDateStatistics) error
	Delete(ctx context.Context, id int64) error

	FindByScriptID(ctx context.Context, scriptId int64, t time.Time) (*entity.ScriptDateStatistics, error)
	IncrDownload(ctx context.Context, scriptId int64, t time.Time) error
	IncrUpdate(ctx context.Context, scriptId int64, t time.Time) error
}

func NewScriptDateStatistics

func NewScriptDateStatistics() ScriptDateStatisticsRepo

func ScriptDateStatistics

func ScriptDateStatistics() ScriptDateStatisticsRepo

type ScriptDomainRepo

type ScriptDomainRepo interface {
	Find(ctx context.Context, id int64) (*script_entity.ScriptDomain, error)
	Create(ctx context.Context, scriptDomain *script_entity.ScriptDomain) error
	Update(ctx context.Context, scriptDomain *script_entity.ScriptDomain) error
	Delete(ctx context.Context, id int64) error

	List(ctx context.Context, scriptId int64) ([]*script_entity.ScriptDomain, error)
}

func Domain

func Domain() ScriptDomainRepo

func NewScriptDomainRepo

func NewScriptDomainRepo() ScriptDomainRepo

type ScriptGroupMemberRepo

type ScriptGroupMemberRepo interface {
	Find(ctx context.Context, scriptId, id int64) (*script_entity.ScriptGroupMember, error)
	FindPage(ctx context.Context, scriptId, groupId int64, page httputils.PageRequest) ([]*script_entity.ScriptGroupMember, int64, error)
	Create(ctx context.Context, scriptGroupMember *script_entity.ScriptGroupMember) error
	Update(ctx context.Context, scriptGroupMember *script_entity.ScriptGroupMember) error
	Delete(ctx context.Context, id int64) error

	FindByUserId(ctx context.Context, scriptId, userId int64) ([]*script_entity.ScriptGroupMember, error)
}

func NewScriptGroupMember

func NewScriptGroupMember() ScriptGroupMemberRepo

func ScriptGroupMember

func ScriptGroupMember() ScriptGroupMemberRepo

type ScriptGroupRepo

type ScriptGroupRepo interface {
	Find(ctx context.Context, scriptId, id int64) (*script_entity.ScriptGroup, error)
	FindPage(ctx context.Context, scriptId int64, req *api.GroupListRequest) ([]*script_entity.ScriptGroup, int64, error)
	Create(ctx context.Context, scriptGroup *script_entity.ScriptGroup) error
	Update(ctx context.Context, scriptGroup *script_entity.ScriptGroup) error
	Delete(ctx context.Context, id int64) error
}

func NewScriptGroup

func NewScriptGroup() ScriptGroupRepo

func ScriptGroup

func ScriptGroup() ScriptGroupRepo

type ScriptInviteRepo

type ScriptInviteRepo interface {
	Find(ctx context.Context, scriptId int64, id int64) (*script_entity.ScriptInvite, error)
	FindByCode(ctx context.Context, code string) (*script_entity.ScriptInvite, error)
	FindAccessPage(ctx context.Context, scriptId int64, page httputils.PageRequest) ([]*script_entity.ScriptInvite, int64, error)
	FindGroupPage(ctx context.Context, scriptId int64, groupId int64, page httputils.PageRequest) ([]*script_entity.ScriptInvite, int64, error)
	Create(ctx context.Context, scriptInvite *script_entity.ScriptInvite) error
	Update(ctx context.Context, scriptInvite *script_entity.ScriptInvite) error
	Delete(ctx context.Context, scriptId int64, id int64) error
}

func NewScriptInvite

func NewScriptInvite() ScriptInviteRepo

func ScriptInvite

func ScriptInvite() ScriptInviteRepo

type ScriptMigrateRepo

type ScriptMigrateRepo interface {
	// Save 保存脚本数据到elasticsearch
	Save(ctx context.Context, s *entity.ScriptSearch) error
	// List 列出脚本数据
	List(ctx context.Context, start, size int) ([]*entity.Script, error)
	// Convert 转换为es储存的数据
	Convert(ctx context.Context, e *entity.Script) (*entity.ScriptSearch, error)
	// Update 更新数据
	Update(ctx context.Context, s *entity.ScriptSearch) error
	// Delete 删除数据,但是是软删除
	Delete(ctx context.Context, id int64) error
}

ScriptMigrateRepo 迁移到es或者其它数据库中

func Migrate

func Migrate() ScriptMigrateRepo

func NewMigrateRepo

func NewMigrateRepo() ScriptMigrateRepo

type ScriptRepo

type ScriptRepo interface {
	Find(ctx context.Context, id int64) (*entity.Script, error)
	Create(ctx context.Context, script *entity.Script) error
	Update(ctx context.Context, script *entity.Script) error
	Delete(ctx context.Context, id int64) error

	Search(ctx context.Context, options *SearchOptions, page httputils.PageRequest) ([]*entity.Script, int64, error)
	// FindSyncScript 查找需要自动同步的脚本
	FindSyncScript(ctx context.Context, page httputils.PageRequest) ([]*entity.Script, error)
	FindSyncPrefix(ctx context.Context, uid int64, prefix string) ([]*entity.Script, error)
}

func NewScriptRepo

func NewScriptRepo() ScriptRepo

func Script

func Script() ScriptRepo

type ScriptScoreRepo

type ScriptScoreRepo interface {
	Find(ctx context.Context, id int64) (*script_entity.ScriptScore, error)
	Create(ctx context.Context, scriptScore *script_entity.ScriptScore) error
	Update(ctx context.Context, scriptScore *script_entity.ScriptScore) error
	Delete(ctx context.Context, id int64) error
	// ScoreList 获取评分列表
	ScoreList(ctx context.Context, scriptId int64, page httputils.PageRequest) ([]*script_entity.ScriptScore, int64, error)
	// FindByUser 查询该用户在该脚本下是否有过评分
	FindByUser(ctx context.Context, uid, scriptId int64) (*script_entity.ScriptScore, error)
	// LastScore 最新的评分
	LastScore(ctx context.Context, page httputils.PageRequest) ([]int64, error)
}

func NewScriptScore

func NewScriptScore() ScriptScoreRepo

func ScriptScore

func ScriptScore() ScriptScoreRepo

type ScriptStatisticsRepo

type ScriptStatisticsRepo interface {
	Find(ctx context.Context, id int64) (*entity.ScriptStatistics, error)
	Create(ctx context.Context, scriptStatistics *entity.ScriptStatistics) error
	Update(ctx context.Context, scriptStatistics *entity.ScriptStatistics) error
	Delete(ctx context.Context, id int64) error

	FindByScriptID(ctx context.Context, scriptId int64) (*entity.ScriptStatistics, error)
	// IncrDownload 增加下载量,不会去重
	IncrDownload(ctx context.Context, scriptId int64) error
	IncrUpdate(ctx context.Context, scriptId int64) error
	// IncrScore 分数统计,当用户分数变更时可以使用之前的分数和之后的分数进行计算,num为0
	IncrScore(ctx context.Context, scriptId, score int64, num int) error
}

func NewScriptStatistics

func NewScriptStatistics() ScriptStatisticsRepo

func ScriptStatistics

func ScriptStatistics() ScriptStatisticsRepo

type ScriptWatchRepo

type ScriptWatchRepo interface {
	Find(ctx context.Context, id int64) (*script_entity.ScriptWatch, error)
	Create(ctx context.Context, scriptWatch *script_entity.ScriptWatch) error
	Update(ctx context.Context, scriptWatch *script_entity.ScriptWatch) error
	Delete(ctx context.Context, id int64) error

	// FindAll 查询出所有符合条件的记录
	FindAll(ctx context.Context, script int64, level script_entity.ScriptWatchLevel) ([]*script_entity.ScriptWatch, error)
	FindByUser(ctx context.Context, script, user int64) (*script_entity.ScriptWatch, error)
	Watch(ctx context.Context, script, user int64, level script_entity.ScriptWatchLevel) error
}

func NewScriptWatchRepo

func NewScriptWatchRepo() ScriptWatchRepo

func ScriptWatch

func ScriptWatch() ScriptWatchRepo

type SearchOptions

type SearchOptions struct {
	Keyword  string
	Type     int
	Sort     string
	UserID   int64
	Self     bool
	Category []int64
	Domain   string
}