kedaya_haitao/common
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

feat 通过sellerId和providerId获取对象

Browse Source
This commit is contained in:
timerzz 2024-08-30 13:39:16 +08:00
parent 55f4cbdd6b
commit 56c30cfe59
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
structs/storage/provider.go
View File

@ -12,6 +12,7 @@ import (
type ProviderApi interface { type ProviderApi interface {
Get(id uint) (provider v2.Provider, err error) Get(id uint) (provider v2.Provider, err error)
GetByProvider(providerId v2.ProviderId) (provider v2.Provider, err error)
List(query PageListQuery) (providers []v2.Provider, total int64, err error) List(query PageListQuery) (providers []v2.Provider, total int64, err error)
Create(provider v2.Provider) error Create(provider v2.Provider) error
Update(provider v2.Provider) error Update(provider v2.Provider) error
@ -51,6 +52,11 @@ func (p *providerApi) Get(id uint) (provider v2.Provider, err error) {
return return
} }
func (p *providerApi) GetByProvider(providerId v2.ProviderId) (provider v2.Provider, err error) {
err = p.db.Where("provider_id = ?", providerId).Preload("CalculateProcess").First(&provider).Error
return
}
func (p *providerApi) List(query PageListQuery) (providers []v2.Provider, total int64, err error) { func (p *providerApi) List(query PageListQuery) (providers []v2.Provider, total int64, err error) {
err = p.db.Scopes(query.Scoper.Scope).Model(&v2.Provider{}).Count(&total).Error err = p.db.Scopes(query.Scoper.Scope).Model(&v2.Provider{}).Count(&total).Error
if err != nil { if err != nil {

6
structs/storage/seller.go
View File

@ -12,6 +12,7 @@ import (
type SellerApi interface { type SellerApi interface {
Get(id uint) (seller v2.Seller, err error) Get(id uint) (seller v2.Seller, err error)
GetBySellerId(sellerId v2.SellerId) (seller v2.Seller, err error)
List(query PageListQuery) (sellers []v2.Seller, total int64, err error) List(query PageListQuery) (sellers []v2.Seller, total int64, err error)
Create(seller v2.Seller) error Create(seller v2.Seller) error
Update(seller v2.Seller) error Update(seller v2.Seller) error
@ -51,6 +52,11 @@ func (p *sellerApi) Get(id uint) (seller v2.Seller, err error) {
return return
} }
func (p *sellerApi) GetBySellerId(sellerId v2.SellerId) (seller v2.Seller, err error) {
err = p.db.Where("seller_id = ?", sellerId).Preload("CalculateProcess").First(&seller).Error
return
}
func (p *sellerApi) List(query PageListQuery) (sellers []v2.Seller, total int64, err error) { func (p *sellerApi) List(query PageListQuery) (sellers []v2.Seller, total int64, err error) {
err = p.db.Scopes(query.Scoper.Scope).Model(&v2.Seller{}).Count(&total).Error err = p.db.Scopes(query.Scoper.Scope).Model(&v2.Seller{}).Count(&total).Error
if err != nil { if err != nil {