repository

Documentation

Index

• func GoodsListToMap(list []*po.Goods, inErr error) (result map[int]*po.Goods, e error)
• func GoodsToPoint(object po.Goods, inErr error) (result *po.Goods, e error)
• func OrderListToMap(list []*po.Order, inErr error) (result map[int]*po.Order, e error)
• func OrderToPoint(object po.Order, inErr error) (result *po.Order, e error)
• type Builder
• type GORMRepository
• type GoodsRepository
  • func (repo *GoodsRepository) Get(ID int) (result *entity.Goods, e error)
  • func (repo *GoodsRepository) GetAll() (result []*entity.Goods, e error)
  • func (repo *GoodsRepository) Save(goods *entity.Goods) (e error)
• type Limiter
  • func NewAscLimiter(column string, size int) *Limiter
  • func NewDescLimiter(column string, size int) *Limiter
  • func (limiter *Limiter) Execute(db *gorm.DB, object interface{}) (e error)
• type OrderRepository
  • func (repo *OrderRepository) Create(goodsID, num, userID int) error
  • func (repo *OrderRepository) Get(ID, userID int) (result *entity.Order, e error)
  • func (repo *OrderRepository) GetAll(userID int) (result []*entity.Order, e error)
  • func (repo *OrderRepository) Pay(orderID, userID int) error
• type Pager
  • func NewAscPager(column string, columns ...string) *Pager
  • func NewDescPager(column string, columns ...string) *Pager
  • func (p *Pager) Execute(db *gorm.DB, object interface{}) (e error)
  • func (p *Pager) Order() interface{}
  • func (p *Pager) SetPage(page, pageSize int) *Pager
  • func (p *Pager) TotalPage() int

Functions

func GoodsListToMap

func GoodsListToMap(list []*po.Goods, inErr error) (result map[int]*po.Goods, e error)

GoodsListToMap

func GoodsToPoint

func GoodsToPoint(object po.Goods, inErr error) (result *po.Goods, e error)

GoodsToPoint

func OrderListToMap

func OrderListToMap(list []*po.Order, inErr error) (result map[int]*po.Order, e error)

OrderListToMap

func OrderToPoint

func OrderToPoint(object po.Order, inErr error) (result *po.Order, e error)

OrderToPoint

Types

type Builder

type Builder interface {
	Execute(db *gorm.DB, object interface{}) error
}

Builder .

type GORMRepository

type GORMRepository interface {
	Worker() freedom.Worker
	// contains filtered or unexported methods
}

GORMRepository .

type GoodsRepository

type GoodsRepository struct {
	freedom.Repository
	EventManager *domainevent.EventManager
}

GoodsRepository .

func (*GoodsRepository) Get

func (repo *GoodsRepository) Get(ID int) (result *entity.Goods, e error)

Get .

func (*GoodsRepository) GetAll

func (repo *GoodsRepository) GetAll() (result []*entity.Goods, e error)

GetAll .

func (*GoodsRepository) Save

func (repo *GoodsRepository) Save(goods *entity.Goods) (e error)

Save .

type Limiter

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

Limiter .

func NewAscLimiter

func NewAscLimiter(column string, size int) *Limiter

NewAscLimiter .

func NewDescLimiter

func NewDescLimiter(column string, size int) *Limiter

NewDescLimiter .

func (*Limiter) Execute

func (limiter *Limiter) Execute(db *gorm.DB, object interface{}) (e error)

Execute .

type OrderRepository

type OrderRepository struct {
	freedom.Repository
	EventManager *domainevent.EventManager
	Producer     kafka.Producer
}

OrderRepository .

func (*OrderRepository) Create

func (repo *OrderRepository) Create(goodsID, num, userID int) error

Create .

func (*OrderRepository) Get

func (repo *OrderRepository) Get(ID, userID int) (result *entity.Order, e error)

Get .

func (*OrderRepository) GetAll

func (repo *OrderRepository) GetAll(userID int) (result []*entity.Order, e error)

GetAll .

func (*OrderRepository) Pay

func (repo *OrderRepository) Pay(orderID, userID int) error

Pay 订单支付.

type Pager

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

Pager .

func NewAscPager

func NewAscPager(column string, columns ...string) *Pager

NewAscPager .

func NewDescPager

func NewDescPager(column string, columns ...string) *Pager

NewDescPager .

func (*Pager) Execute

func (p *Pager) Execute(db *gorm.DB, object interface{}) (e error)

Execute .

func (*Pager) Order

func (p *Pager) Order() interface{}

Order .

func (*Pager) SetPage

func (p *Pager) SetPage(page, pageSize int) *Pager

SetPage .

func (*Pager) TotalPage

func (p *Pager) TotalPage() int

TotalPage .