package repo import ( "fmt" "time" "github.com/1Panel-dev/1Panel/core/constant" "gorm.io/gorm" ) type DBOption func(*gorm.DB) *gorm.DB type ICommonRepo interface { WithByID(id uint) DBOption WithByName(name string) DBOption WithByType(tp string) DBOption WithOrderBy(orderStr string) DBOption WithOrderRuleBy(orderBy, order string) DBOption WithByGroupID(groupID uint) DBOption WithLikeName(name string) DBOption WithIdsIn(ids []uint) DBOption WithByDate(startTime, endTime time.Time) DBOption WithByStartDate(startTime time.Time) DBOption WithByStatus(status string) DBOption WithByFrom(from string) DBOption } type CommonRepo struct{} func NewCommonRepo() ICommonRepo { return &CommonRepo{} } func (c *CommonRepo) WithByID(id uint) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("id = ?", id) } } func (c *CommonRepo) WithByName(name string) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("name = ?", name) } } func (c *CommonRepo) WithByDate(startTime, endTime time.Time) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("start_time > ? AND start_time < ?", startTime, endTime) } } func (c *CommonRepo) WithByStartDate(startTime time.Time) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("start_time < ?", startTime) } } func (c *CommonRepo) WithByType(tp string) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("type = ?", tp) } } func (c *CommonRepo) WithByGroupID(groupID uint) DBOption { return func(g *gorm.DB) *gorm.DB { if groupID == 0 { return g } return g.Where("group_id = ?", groupID) } } func (c *CommonRepo) WithByStatus(status string) DBOption { return func(g *gorm.DB) *gorm.DB { if len(status) == 0 { return g } return g.Where("status = ?", status) } } func (c *CommonRepo) WithByFrom(from string) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("`from` = ?", from) } } func (c *CommonRepo) WithLikeName(name string) DBOption { return func(g *gorm.DB) *gorm.DB { if len(name) == 0 { return g } return g.Where("name like ?", "%"+name+"%") } } func (c *CommonRepo) WithOrderBy(orderStr string) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Order(orderStr) } } func (c *CommonRepo) WithOrderRuleBy(orderBy, order string) DBOption { switch order { case constant.OrderDesc: order = "desc" case constant.OrderAsc: order = "asc" default: orderBy = "created_at" order = "desc" } return func(g *gorm.DB) *gorm.DB { return g.Order(fmt.Sprintf("%s %s", orderBy, order)) } } func (c *CommonRepo) WithIdsIn(ids []uint) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("id in (?)", ids) } } func (c *CommonRepo) WithIdsNotIn(ids []uint) DBOption { return func(g *gorm.DB) *gorm.DB { return g.Where("id not in (?)", ids) } }