|
|
package repository
|
|
|
|
|
|
import (
|
|
|
"fmt"
|
|
|
|
|
|
"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/domain"
|
|
|
"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/infrastructure/pg/models"
|
|
|
"gitlab.fjmaimaimai.com/mmm-go/partnermg/pkg/infrastructure/pg/transaction"
|
...
|
...
|
@@ -10,6 +12,19 @@ type PartnerInfoRepository struct { |
|
|
transactionContext *transaction.TransactionContext
|
|
|
}
|
|
|
|
|
|
func (repository *PartnerInfoRepository) transformPgModelToDomainModel(PartnerInfoModel *models.PartnerInfo) (*domain.PartnerInfo, error) {
|
|
|
m := &domain.PartnerInfo{}
|
|
|
|
|
|
return m, err
|
|
|
}
|
|
|
|
|
|
func NewPartnerInfoRepository(transactionContext *transaction.TransactionContext) (*PartnerInfoRepository, error) {
|
|
|
if transactionContext == nil {
|
|
|
return nil, fmt.Errorf("transactionContext参数不能为nil")
|
|
|
}
|
|
|
return &PartnerInfoRepository{transactionContext: transactionContext}, nil
|
|
|
}
|
|
|
|
|
|
func (repository *PartnerInfoRepository) Save(dm *domain.PartnerInfo) (*domain.PartnerInfo, error) {
|
|
|
var (
|
|
|
err error
|
...
|
...
|
@@ -85,16 +100,3 @@ func (repository *PartnerInfoRepository) Find(queryOptions map[string]interface{ |
|
|
}
|
|
|
return int64(query.AffectRow), PartnerInfos, nil
|
|
|
} |
|
|
|
|
|
func (repository *PartnerInfoRepository) transformPgModelToDomainModel(PartnerInfoModel *models.PartnerInfo) (*domain.PartnerInfo, error) {
|
|
|
m := &domain.PartnerInfo{}
|
|
|
err := GobModelTransform(m, PartnerInfoModel)
|
|
|
return m, err
|
|
|
}
|
|
|
|
|
|
func NewPartnerInfoRepository(transactionContext *transaction.TransactionContext) (*PartnerInfoRepository, error) {
|
|
|
if transactionContext == nil {
|
|
|
return nil, ERR_EMPTY_TC
|
|
|
}
|
|
|
return &PartnerInfoRepository{transactionContext: transactionContext}, nil
|
|
|
} |
...
|
...
|
|