repository

Documentation

Index

• type AdminRepository
  • func (repo *AdminRepository) Get(id int) (adminEntity *entity.Admin, e error)
• type Builder
• type CartRepository
  • func (repo *CartRepository) DeleteAll(userID int) (e error)
  • func (repo *CartRepository) FindAll(userID int) (entitys []*entity.Cart, e error)
  • func (repo *CartRepository) FindByGoodsID(userID, goodsID int) (cartEntity *entity.Cart, e error)
  • func (repo *CartRepository) New(userID, goodsID, num int) (cartEntity *entity.Cart, e error)
  • func (repo *CartRepository) Save(entity *entity.Cart) error
• type DeliveryRepository
  • func (repo *DeliveryRepository) New() (deliveryEntity *entity.Delivery, err error)
  • func (repo *DeliveryRepository) Save(deliveryEntity *entity.Delivery) error
• type GORMRepository
• type GoodsRepository
  • func (repo *GoodsRepository) BeginRequest(worker freedom.Worker)
  • func (repo *GoodsRepository) Finds(IDs []int) (entitys []*entity.Goods, e error)
  • func (repo *GoodsRepository) FindsByPage(page, pageSize int, tag string) (entitys []*entity.Goods, e error)
  • func (repo *GoodsRepository) Get(ID int) (goodsEntity *entity.Goods, e error)
  • func (repo *GoodsRepository) New(name, tag string, price, stock int) (entityGoods *entity.Goods, e error)
  • func (repo *GoodsRepository) Save(entity *entity.Goods) 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) BeginRequest(worker freedom.Worker)
  • func (repo *OrderRepository) Find(orderNo string, userID int) (orderEntity *entity.Order, e error)
  • func (repo *OrderRepository) Finds(userID int, page, pageSize int) (entitys []*entity.Order, totalPage int, e error)
  • func (repo *OrderRepository) Get(orderNo string) (orderEntity *entity.Order, e error)
  • func (repo *OrderRepository) New() (orderEntity *entity.Order, e error)
  • func (repo *OrderRepository) Save(orderEntity *entity.Order) (e 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
• type UserRepository
  • func (repo *UserRepository) FindByName(userName string) (userEntity *entity.User, e error)
  • func (repo *UserRepository) Get(ID int) (userEntity *entity.User, e error)
  • func (repo *UserRepository) New(uservo vo.RegisterUserReq, money int) (entityUser *entity.User, e error)
  • func (repo *UserRepository) Save(entity *entity.User) error

Types

type AdminRepository

type AdminRepository struct {
	freedom.Repository
}

AdminRepository .

func (*AdminRepository) Get

func (repo *AdminRepository) Get(id int) (adminEntity *entity.Admin, e error)

Get .

type Builder

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

Builder .

type CartRepository

type CartRepository struct {
	freedom.Repository
}

CartRepository .

func (*CartRepository) DeleteAll

func (repo *CartRepository) DeleteAll(userID int) (e error)

DeleteAll 删除全部购物车

func (*CartRepository) FindAll

func (repo *CartRepository) FindAll(userID int) (entitys []*entity.Cart, e error)

FindAll 获取用户购物车实体

func (*CartRepository) FindByGoodsID

func (repo *CartRepository) FindByGoodsID(userID, goodsID int) (cartEntity *entity.Cart, e error)

FindByGoodsID 获取用户某商品的购物车

func (*CartRepository) New

func (repo *CartRepository) New(userID, goodsID, num int) (cartEntity *entity.Cart, e error)

New 新增购物车

func (*CartRepository) Save

func (repo *CartRepository) Save(entity *entity.Cart) error

Save 保存购物车

type DeliveryRepository

type DeliveryRepository struct {
	freedom.Repository
}

DeliveryRepository .

func (*DeliveryRepository) New

func (repo *DeliveryRepository) New() (deliveryEntity *entity.Delivery, err error)

New 创建实体

func (*DeliveryRepository) Save

func (repo *DeliveryRepository) Save(deliveryEntity *entity.Delivery) error

Save 保存实体

type GORMRepository

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

GORMRepository .

type GoodsRepository

type GoodsRepository struct {
	freedom.Repository
	Cache        store.EntityCache         //实体缓存组件
	EventManager *domainevent.EventManager //领域事件组件
}

GoodsRepository .

func (*GoodsRepository) BeginRequest

func (repo *GoodsRepository) BeginRequest(worker freedom.Worker)

BeginRequest .

func (*GoodsRepository) Finds

func (repo *GoodsRepository) Finds(IDs []int) (entitys []*entity.Goods, e error)

Finds .

func (*GoodsRepository) FindsByPage

func (repo *GoodsRepository) FindsByPage(page, pageSize int, tag string) (entitys []*entity.Goods, e error)

FindsByPage .

func (*GoodsRepository) Get

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

Get 通过ID 获取商品实体.

func (*GoodsRepository) New

func (repo *GoodsRepository) New(name, tag string, price, stock int) (entityGoods *entity.Goods, e error)

New .

func (*GoodsRepository) Save

func (repo *GoodsRepository) Save(entity *entity.Goods) 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
	Cache        store.EntityCache         //实体缓存组件
	EventManager *domainevent.EventManager //领域事件组件
}

OrderRepository .

func (*OrderRepository) BeginRequest

func (repo *OrderRepository) BeginRequest(worker freedom.Worker)

BeginRequest .

func (*OrderRepository) Find

func (repo *OrderRepository) Find(orderNo string, userID int) (orderEntity *entity.Order, e error)

Find .

func (*OrderRepository) Finds

func (repo *OrderRepository) Finds(userID int, page, pageSize int) (entitys []*entity.Order, totalPage int, e error)

Finds .

func (*OrderRepository) Get

func (repo *OrderRepository) Get(orderNo string) (orderEntity *entity.Order, e error)

Get .

func (*OrderRepository) New

func (repo *OrderRepository) New() (orderEntity *entity.Order, e error)

New 新建订单实体 .

func (*OrderRepository) Save

func (repo *OrderRepository) Save(orderEntity *entity.Order) (e error)

Save 保存订单实体

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 .

type UserRepository

type UserRepository struct {
	freedom.Repository
	EventRepository *domainevent.EventManager //领域事件组件
}

UserRepository .

func (*UserRepository) FindByName

func (repo *UserRepository) FindByName(userName string) (userEntity *entity.User, e error)

FindByName .

func (*UserRepository) Get

func (repo *UserRepository) Get(ID int) (userEntity *entity.User, e error)

Get .

func (*UserRepository) New

func (repo *UserRepository) New(uservo vo.RegisterUserReq, money int) (entityUser *entity.User, e error)

New .

func (*UserRepository) Save

func (repo *UserRepository) Save(entity *entity.User) error

Save .