...
|
...
|
@@ -13,6 +13,8 @@ type OrderLogRepository struct { |
|
|
transactionContext *transaction.TransactionContext
|
|
|
}
|
|
|
|
|
|
var _ domain.OrderLogRepository = (*OrderLogRepository)(nil)
|
|
|
|
|
|
func NewOrderInfoRepository(transactionContext *transaction.TransactionContext) (*OrderLogRepository, error) {
|
|
|
if transactionContext == nil {
|
|
|
return nil, fmt.Errorf("transactionContext参数不能为nil")
|
...
|
...
|
@@ -20,7 +22,7 @@ func NewOrderInfoRepository(transactionContext *transaction.TransactionContext) |
|
|
return &OrderLogRepository{transactionContext: transactionContext}, nil
|
|
|
}
|
|
|
|
|
|
func (reponsitory OrderLogRepository) transformPgModelToDomainModel(m *models.OrderLog) (data domain.OrderLog, err error) {
|
|
|
func (repository OrderLogRepository) transformPgModelToDomainModel(m *models.OrderLog) (data domain.OrderLog, err error) {
|
|
|
return domain.OrderLog{
|
|
|
OrderId: m.OrderId,
|
|
|
Operator: m.Operator,
|
...
|
...
|
@@ -34,10 +36,43 @@ func (reponsitory OrderLogRepository) transformPgModelToDomainModel(m *models.Or |
|
|
}, nil
|
|
|
}
|
|
|
|
|
|
func (reponsitory OrderLogRepository) Add(data domain.OrderLog) error {
|
|
|
return nil
|
|
|
func (repository OrderLogRepository) Add(data *domain.OrderLog) error {
|
|
|
db := repository.transactionContext.GetDB()
|
|
|
m := models.OrderLog{
|
|
|
OrderId: data.OrderId,
|
|
|
Operator: data.Operator,
|
|
|
OperatorId: data.OperatorId,
|
|
|
OperatorType: data.OperatorType,
|
|
|
LogAction: data.LogAction,
|
|
|
Descript: data.Descript,
|
|
|
Content: data.Content,
|
|
|
DataFrom: data.DataFrom,
|
|
|
}
|
|
|
_, err := db.Model(&m).Insert()
|
|
|
data.AlterTime = m.AlterTime
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
func (reponsitory OrderLogRepository) Find(data domain.OrderLog) ([]domain.OrderLog, int, error) {
|
|
|
return nil, 0, nil
|
|
|
func (repository OrderLogRepository) Find(queryOptions domain.OrderLogFindQuery) ([]domain.OrderLog, error) {
|
|
|
db := repository.transactionContext.GetDB()
|
|
|
logModels := []models.OrderLog{}
|
|
|
var err error
|
|
|
query := db.Model(&logModels)
|
|
|
if queryOptions.OrderId > 0 {
|
|
|
query = query.Where("order_id=?", queryOptions.OrderId)
|
|
|
}
|
|
|
query.Limit(1000)
|
|
|
err = query.Select()
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
logReturn := []domain.OrderLog{}
|
|
|
for i := range logModels {
|
|
|
domainLog, err := repository.transformPgModelToDomainModel(&logModels[i])
|
|
|
if err != nil {
|
|
|
return logReturn, err
|
|
|
}
|
|
|
logReturn = append(logReturn, domainLog)
|
|
|
}
|
|
|
return logReturn, nil
|
|
|
} |
...
|
...
|
|