points

package
v0.0.0-...-1dec894 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 15, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PointsTypeConsume  = 1 // 消费赠送
	PointsTypeRecharge = 2 // 充值赠送
	PointsTypeAdjust   = 3 // 手动调整
	PointsTypeExchange = 4 // 兑换扣减
	PointsTypeExpire   = 5 // 过期扣减
)

积分变动类型常量

View Source 
const (
	ExchangeStatusPending   = 1 // 待核销
	ExchangeStatusVerified  = 2 // 已核销
	ExchangeStatusCancelled = 3 // 已取消
)

兑换记录状态常量

Variables

This section is empty.

Functions

func DecrStockInRedis 

func DecrStockInRedis(ruleID int64) (int64, error)

DecrStockInRedis 在Redis中原子减库存

func GetStockFromRedis 

func GetStockFromRedis(ruleID int64) (int, error)

GetStockFromRedis 从Redis获取库存

func IncrStockInRedis 

func IncrStockInRedis(ruleID int64) (int64, error)

IncrStockInRedis 在Redis中原子增库存（回滚用）

func SetStockToRedis 

func SetStockToRedis(ruleID int64, stock int) error

SetStockToRedis 设置Redis库存

Types

type ExchangeRecord 

type ExchangeRecord struct {
	ID           int64      `gorm:"column:id;primaryKey" json:"id"`
	RecordNo     string     `gorm:"column:record_no;uniqueIndex;size:64;not null" json:"record_no"`
	UserID       int64      `gorm:"column:user_id;index;not null" json:"user_id"`
	RuleID       int64      `gorm:"column:rule_id;index;not null" json:"rule_id"`
	StoreID      int64      `gorm:"column:store_id;index;not null" json:"store_id"`
	PointsCost   int        `gorm:"column:points_cost;not null" json:"points_cost"`
	ProductName  string     `gorm:"column:product_name;size:100;not null" json:"product_name"`
	Status       int8       `gorm:"column:status;default:1;index" json:"status"` // 1-待核销, 2-已核销, 3-已取消
	VerifyCode   string     `gorm:"column:verify_code;uniqueIndex;size:20" json:"verify_code,omitempty"`
	VerifiedAt   *time.Time `gorm:"column:verified_at" json:"verified_at,omitempty"`
	VerifiedBy   *int64     `gorm:"column:verified_by" json:"verified_by,omitempty"`
	CancelledAt  *time.Time `gorm:"column:cancelled_at" json:"cancelled_at,omitempty"`
	CancelReason string     `gorm:"column:cancel_reason;size:255" json:"cancel_reason,omitempty"`
	CreatedAt    time.Time  `gorm:"column:created_at;index" json:"created_at"`
	UpdatedAt    time.Time  `gorm:"column:updated_at" json:"updated_at"`
}

ExchangeRecord 积分兑换记录

func (ExchangeRecord) TableName 

func (ExchangeRecord) TableName() string

TableName 指定表名

type ExchangeRule 

type ExchangeRule struct {
	ID             int64      `gorm:"column:id;primaryKey" json:"id"`
	StoreID        int64      `gorm:"column:store_id;index;not null" json:"store_id"`
	Title          string     `gorm:"column:title;size:100;not null" json:"title"`
	Description    string     `gorm:"column:description;size:255" json:"description,omitempty"`
	PointsCost     int        `gorm:"column:points_cost;not null" json:"points_cost"`
	ProductType    int8       `gorm:"column:product_type;not null" json:"product_type"` // 1-实物, 2-优惠券, 3-服务
	ProductName    string     `gorm:"column:product_name;size:100;not null" json:"product_name"`
	ProductImage   string     `gorm:"column:product_image;size:255" json:"product_image,omitempty"`
	TotalStock     *int       `gorm:"column:total_stock" json:"total_stock,omitempty"` // NULL表示不限
	RemainingStock *int       `gorm:"column:remaining_stock" json:"remaining_stock,omitempty"`
	DailyLimit     *int       `gorm:"column:daily_limit" json:"daily_limit,omitempty"`           // 每日限兑总数
	UserDailyLimit int        `gorm:"column:user_daily_limit;default:1" json:"user_daily_limit"` // 每人每日限兑
	UserTotalLimit *int       `gorm:"column:user_total_limit" json:"user_total_limit,omitempty"` // 每人总限兑
	StartTime      *time.Time `gorm:"column:start_time" json:"start_time,omitempty"`
	EndTime        *time.Time `gorm:"column:end_time" json:"end_time,omitempty"`
	Status         int8       `gorm:"column:status;default:1;index" json:"status"` // 0-下架, 1-上架
	SortOrder      int        `gorm:"column:sort_order;default:0" json:"sort_order"`
	Version        int        `gorm:"column:version;default:0" json:"version"` // 乐观锁
	CreatedAt      time.Time  `gorm:"column:created_at" json:"created_at"`
	UpdatedAt      time.Time  `gorm:"column:updated_at" json:"updated_at"`
}

ExchangeRule 积分兑换规则

func (ExchangeRule) TableName 

func (ExchangeRule) TableName() string

TableName 指定表名

type MemberPoints 

type MemberPoints struct {
	ID              int64     `gorm:"column:id;primaryKey" json:"id"`
	UserID          int64     `gorm:"column:user_id;uniqueIndex;not null" json:"user_id"`
	TotalPoints     int64     `gorm:"column:total_points;default:0" json:"total_points"`         // 累计获得积分
	AvailablePoints int64     `gorm:"column:available_points;default:0" json:"available_points"` // 可用积分
	FrozenPoints    int64     `gorm:"column:frozen_points;default:0" json:"frozen_points"`       // 冻结积分
	UsedPoints      int64     `gorm:"column:used_points;default:0" json:"used_points"`           // 已使用积分
	ExpiredPoints   int64     `gorm:"column:expired_points;default:0" json:"expired_points"`     // 已过期积分
	Version         int       `gorm:"column:version;default:0" json:"version"`                   // 乐观锁版本号
	CreatedAt       time.Time `gorm:"column:created_at" json:"created_at"`
	UpdatedAt       time.Time `gorm:"column:updated_at" json:"updated_at"`
}

MemberPoints 会员积分汇总表

func (MemberPoints) TableName 

func (MemberPoints) TableName() string

TableName 指定表名

type PointsTransaction 

type PointsTransaction struct {
	ID            int64      `gorm:"column:id;primaryKey" json:"id"`
	TransactionNo string     `gorm:"column:transaction_no;uniqueIndex;size:64;not null" json:"transaction_no"`
	UserID        int64      `gorm:"column:user_id;index;not null" json:"user_id"`
	Points        int64      `gorm:"column:points;not null" json:"points"`         // 正数增加，负数减少
	Type          int8       `gorm:"column:type;not null;index" json:"type"`       // 1-消费赠送, 2-充值赠送, 3-手动调整, 4-兑换扣减, 5-过期扣减
	Source        string     `gorm:"column:source;size:50;not null" json:"source"` // 来源
	RefID         *int64     `gorm:"column:ref_id;index" json:"ref_id,omitempty"`  // 关联ID
	Remark        string     `gorm:"column:remark;size:255" json:"remark,omitempty"`
	ExpireAt      *time.Time `gorm:"column:expire_at;index" json:"expire_at,omitempty"` // 过期时间
	Status        int8       `gorm:"column:status;default:1" json:"status"`             // 0-已撤销, 1-正常
	OperatorID    *int64     `gorm:"column:operator_id" json:"operator_id,omitempty"`
	CreatedAt     time.Time  `gorm:"column:created_at;index" json:"created_at"`
}

PointsTransaction 积分流水表

func (PointsTransaction) TableName 

func (PointsTransaction) TableName() string

TableName 指定表名

type Repository 

type Repository interface {
	// MemberPoints
	GetOrCreateMemberPoints(ctx context.Context, userID int64) (*MemberPoints, error)
	GetMemberPoints(ctx context.Context, userID int64) (*MemberPoints, error)
	UpdateMemberPoints(ctx context.Context, points *MemberPoints) error

	// PointsTransaction
	CreateTransaction(ctx context.Context, tx *PointsTransaction) error
	GetTransactionByNo(ctx context.Context, transactionNo string) (*PointsTransaction, error)
	ListTransactions(ctx context.Context, userID int64, offset, limit int) ([]*PointsTransaction, int64, error)

	// ExchangeRule
	CreateRule(ctx context.Context, rule *ExchangeRule) error
	GetRuleByID(ctx context.Context, ruleID int64) (*ExchangeRule, error)
	UpdateRule(ctx context.Context, rule *ExchangeRule) error
	ListRules(ctx context.Context, storeID *int64, status *int8, offset, limit int) ([]*ExchangeRule, int64, error)
	DecrRuleStock(ctx context.Context, ruleID int64) error // 原子减库存

	// ExchangeRecord
	CreateRecord(ctx context.Context, record *ExchangeRecord) error
	GetRecordByID(ctx context.Context, recordID int64) (*ExchangeRecord, error)
	GetRecordByNo(ctx context.Context, recordNo string) (*ExchangeRecord, error)
	GetRecordByVerifyCode(ctx context.Context, verifyCode string) (*ExchangeRecord, error)
	UpdateRecord(ctx context.Context, record *ExchangeRecord) error
	ListRecords(ctx context.Context, userID *int64, storeID *int64, status *int8, offset, limit int) ([]*ExchangeRecord, int64, error)
	CountUserExchangeToday(ctx context.Context, userID, ruleID int64) (int, error)
	CountUserExchangeTotal(ctx context.Context, userID, ruleID int64) (int, error)
}

Repository 积分仓储接口

func NewRepository 

func NewRepository() Repository

NewRepository 创建积分仓储

type Service 

type Service struct {
	// contains filtered or unexported fields
}

Service 积分领域服务

func NewService 

func NewService(repo Repository) *Service

NewService 创建积分服务

func (*Service) AddPoints 

func (s *Service) AddPoints(ctx context.Context, userID int64, points int64, pointsType int8, source string, refID *int64, remark string, expireDays int) error

AddPoints 增加积分（消费赠送、充值赠送、手动调整）

func (*Service) CancelExchange 

func (s *Service) CancelExchange(ctx context.Context, recordID int64, reason string) error

CancelExchange 取消兑换（退还积分）

func (*Service) DeductPoints 

func (s *Service) DeductPoints(ctx context.Context, userID int64, points int64, pointsType int8, source string, refID *int64, remark string) error

DeductPoints 扣减积分（兑换扣减、过期扣减）

func (*Service) ExchangePoints 

func (s *Service) ExchangePoints(ctx context.Context, userID, ruleID int64) (*ExchangeRecord, error)

ExchangePoints 积分兑换（高并发场景）

func (*Service) GetPointsTransactions 

func (s *Service) GetPointsTransactions(ctx context.Context, userID int64, page, pageSize int) ([]*PointsTransaction, int64, error)

GetPointsTransactions 获取积分流水

func (*Service) GetUserPoints 

func (s *Service) GetUserPoints(ctx context.Context, userID int64) (*MemberPoints, error)

GetUserPoints 获取用户积分

func (*Service) VerifyExchange 

func (s *Service) VerifyExchange(ctx context.Context, verifyCode string, verifierID int64) error

VerifyExchange 核销兑换

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.