voucher/internal/data/repoimpl/order.go

package repoimpl

import (
	"context"
	"gorm.io/gorm"
	"time"
	"unicode/utf8"
	err2 "voucher/api/err"
	"voucher/internal/biz/bo"
	"voucher/internal/biz/repo"
	"voucher/internal/biz/vo"
	"voucher/internal/data"
	"voucher/internal/data/model"
)

// OrderRepoImpl .
type OrderRepoImpl struct {
	Base[model.Order, bo.OrderBo]
	db *data.Db
}

// NewOrderRepoImpl .
func NewOrderRepoImpl(db *data.Db) repo.OrderRepo {
	return &OrderRepoImpl{db: db}
}

func (p *OrderRepoImpl) DB(ctx context.Context) *gorm.DB {
	return p.db.DB(ctx).Model(model.Order{})
}

func (p *OrderRepoImpl) FindInBatches(ctx context.Context, w *bo.FindInBatchesUseBo, fun func(ctx context.Context, rows []*bo.OrderBo) error) error {

	var results = make([]*model.Order, 0)

	result := p.db.DB(ctx).
		Where("type = ?", w.Type).
		Where("status IN (?)", []uint8{vo.OrderStatusSuccess.GetValue(), vo.OrderStatusUse.GetValue()}).
		Where("receive_success_time BETWEEN ? AND ?", w.StartTime, w.EndTime).
		Where("product_no <>", "001"). // 跳过压测的订单数据
		FindInBatches(&results, 100, func(tx *gorm.DB, batch int) error {
			// tx.RowsAffected 提供当前批处理中记录的计数（the count of records in the current batch）
			// 'batch' 变量表示当前批号（the current batch number）
			// 返回 error 将阻止更多的批处理
			return fun(ctx, p.ToBos(results))
		})

	if result.Error != nil {
		return result.Error
	}

	return nil
}

func (p *OrderRepoImpl) Create(ctx context.Context, req *bo.OrderBo) (*bo.OrderBo, error) {
	now := time.Now()

	info := &model.Order{
		OrderNo:     req.OrderNo,
		OutBizNo:    req.OutBizNo,
		ProductNo:   req.ProductNo,
		BatchNo:     req.BatchNo,
		Account:     req.Account,
		AccountType: req.AccountType.GetValue(),
		Status:      req.Status.GetValue(),
		Type:        req.Type.GetValue(),
		AppID:       req.AppID,
		MerchantNo:  req.MerchantNo,
		Channel:     req.Channel.GetValue(),
		NotifyUrl:   req.NotifyUrl,
		Attach:      req.Attach,
		CreateTime:  &now,
		UpdateTime:  &now,
	}

	tx := p.db.DB(ctx).Create(info)
	if tx.Error != nil {
		return nil, tx.Error
	}

	return p.ToBo(info), nil
}

func (p *OrderRepoImpl) GetByOutBizNo(ctx context.Context, t vo.OrderType, outBizNo string) (*bo.OrderBo, error) {
	info := &model.Order{}

	tx := p.DB(ctx).Where(model.Order{Type: t.GetValue(), OutBizNo: outBizNo}).Find(&info)

	if tx.Error != nil {
		return nil, tx.Error
	}

	if tx.RowsAffected == 0 {
		return nil, err2.ErrorDbNotFound("订单数据不存在")
	}

	return p.ToBo(info), nil
}

func (p *OrderRepoImpl) GetByID(ctx context.Context, id uint64) (*bo.OrderBo, error) {
	info := &model.Order{}

	tx := p.DB(ctx).Where(model.Order{ID: id}).Find(&info)

	if tx.Error != nil {
		return nil, tx.Error
	}

	if tx.RowsAffected == 0 {
		return nil, err2.ErrorDbNotFound("订单数据不存在")
	}

	return p.ToBo(info), nil
}

func (p *OrderRepoImpl) GetByOrderNo(ctx context.Context, orderNo string) (*bo.OrderBo, error) {
	info := &model.Order{}

	tx := p.DB(ctx).Where(model.Order{OrderNo: orderNo}).Find(&info)

	if tx.Error != nil {
		return nil, tx.Error
	}

	if tx.RowsAffected == 0 {
		return nil, err2.ErrorDbNotFound("订单数据不存在")
	}

	return p.ToBo(info), nil
}

func (p *OrderRepoImpl) GetByMBV(ctx context.Context, merchantNo, batchNo, voucherNo string) (*bo.OrderBo, error) {
	info := &model.Order{}

	tx := p.DB(ctx).Where(model.Order{MerchantNo: merchantNo, BatchNo: batchNo, VoucherNo: voucherNo}).Find(&info)

	if tx.Error != nil {
		return nil, tx.Error
	}

	if tx.RowsAffected == 0 {
		return nil, err2.ErrorDbNotFound("订单数据不存在")
	}

	return p.ToBo(info), nil
}

func (p *OrderRepoImpl) Ing(ctx context.Context, id uint64) error {
	now := time.Now()

	res := p.db.DB(ctx).
		Where(model.Order{
			ID:     id,
			Status: vo.OrderStatusWait.GetValue(),
		}).
		Updates(model.Order{
			Status:     vo.OrderStatusIng.GetValue(),
			UpdateTime: &now,
		})

	if res.Error != nil {
		return res.Error
	}

	return nil
}

func (p *OrderRepoImpl) Success(ctx context.Context, id uint64, voucherNo string) error {
	now := time.Now()

	res := p.db.DB(ctx).
		Where(model.Order{
			ID:     id,
			Status: vo.OrderStatusIng.GetValue(),
		}).
		Updates(model.Order{
			Status:             vo.OrderStatusSuccess.GetValue(),
			VoucherNo:          voucherNo,
			ReceiveSuccessTime: &now,
			UpdateTime:         &now,
		})

	if res.Error != nil {
		return res.Error
	}

	return nil
}

func (p *OrderRepoImpl) Available(ctx context.Context, id uint64) error {
	now := time.Now()

	res := p.db.DB(ctx).
		Where(model.Order{
			ID:     id,
			Status: vo.OrderStatusUse.GetValue(),
		}).
		Updates(model.Order{
			Status:             vo.OrderStatusSuccess.GetValue(),
			ReceiveSuccessTime: &now, // 领取成功时间重置
			UpdateTime:         &now,
		})

	if res.Error != nil {
		return res.Error
	}

	return nil
}

func (p *OrderRepoImpl) Fail(ctx context.Context, id uint64, remark string) error {
	now := time.Now()

	if utf8.RuneCountInString(remark) > 100 {
		runes := []rune(remark)
		if len(runes) > 100 {
			remark = string(runes[:100])
		}
	}

	res := p.db.DB(ctx).
		Where(model.Order{
			ID: id,
		}).
		Updates(model.Order{
			Status:     vo.OrderStatusFail.GetValue(),
			Remark:     remark,
			UpdateTime: &now,
		})

	if res.Error != nil {
		return res.Error
	}

	return nil
}

func (p *OrderRepoImpl) Used(ctx context.Context, id uint64) error {
	now := time.Now()

	res := p.db.DB(ctx).
		Where(model.Order{
			ID: id,
		}).
		Updates(model.Order{
			Status:      vo.OrderStatusUse.GetValue(),
			LastUseTime: &now,
			UpdateTime:  &now,
		})

	if res.Error != nil {
		return res.Error
	}

	return nil
}

func (p *OrderRepoImpl) Expired(ctx context.Context, id uint64) error {
	now := time.Now()

	res := p.db.DB(ctx).
		Where(model.Order{
			ID: id,
		}).
		Updates(model.Order{
			Status:     vo.OrderStatusExpired.GetValue(),
			UpdateTime: &now,
		})

	if res.Error != nil {
		return res.Error
	}

	return nil
}