gdxz/hepa-calc-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加了发放优惠卷

Browse Source
This commit is contained in:
wucongxing8150 2024-08-13 08:51:24 +08:00
parent ca2f2c4421
commit 978dadf14e
8 changed files with 197 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/amqp/consumer/CouponExpire.go
View File

@ -71,7 +71,7 @@ func CouponExpire(msg amqp091.Delivery) {
// 检测优惠卷过期时间
now := time.Now()
validEndTime := time.Time(coupon.ValidEndTime)
validEndTime := time.Time(*coupon.ValidEndTime)
diffTime := validEndTime.Sub(now)
if diffTime >= 60*time.Second {
// 重新添加入队列

2
api/crontab/SystemCouponExpire.go
View File

@ -19,7 +19,7 @@ func SystemCouponExpire() {
for _, coupon := range coupons {
// 计算过期时间
validEndTime := time.Time(coupon.ValidEndTime)
validEndTime := time.Time(*coupon.ValidEndTime)
delay := validEndTime.Sub(time.Now())
if delay < 5*time.Second {

18
api/dao/Coupon.go
View File

@ -115,3 +115,21 @@ func (r *CouponDao) GetCouponListByValidTime(maps interface{}, startTime, endTim
}
return m, nil
}
// Inc 自增
func (r *CouponDao) Inc(tx *gorm.DB, couponId int64, field string, numeral int) error {
err := tx.Model(&model.Coupon{}).Where("coupon_id = ?", couponId).UpdateColumn(field, gorm.Expr(field+" + ?", numeral)).Error
if err != nil {
return err
}
return nil
}
// Dec 自减
func (r *CouponDao) Dec(tx *gorm.DB, couponId int64, field string, numeral int) error {
err := tx.Model(&model.Coupon{}).Where("coupon_id = ?", couponId).UpdateColumn(field, gorm.Expr(field+" - ?", numeral)).Error
if err != nil {
return err
}
return nil
}

38
api/dto/Coupon.go
View File

@ -7,25 +7,25 @@ import (
)
type CouponDto struct {
CouponId string `json:"coupon_id"` // 主键id
CouponName string `json:"coupon_name"` // 优惠券名称
CouponType int `json:"coupon_type"` // 优惠券类型（1:无门槛 2:满减）
CouponStatus int `json:"coupon_status"` // 状态（1:正常 2:强制失效 3:结束 4:删除）
ApplicationScope int `json:"application_scope"` // 适用范围（1:全场通用）
IsMutex int `json:"is_mutex"` // 是否互斥（0:否 1:是）
CouponCount int `json:"coupon_count"` // 发放数量
CouponTakeCount int `json:"coupon_take_count"` // 已领取数量
CouponUsedCount int `json:"coupon_used_count"` // 已使用数量
CouponPrice float64 `json:"coupon_price"` // 优惠券金额
WithAmount float64 `json:"with_amount"` // 符合满减标准金额（优惠券类型为满减时使用）
ValidType int `json:"valid_type"` // 有效类型（1:绝对时效，xxx-xxx时间段有效 2:相对时效 n天内有效）
ValidDays int `json:"valid_days"` // 自领取之日起有效天数
ValidStartTime model.LocalTime `json:"valid_start_time"` // 开始使用时间
ValidEndTime model.LocalTime `json:"valid_end_time"` // 结束使用时间
SystemMemberIds []*string `json:"system_member_ids"` // 会员id（适用范围为会员时生效，如果此项为null，则表示所有会员通用）
CouponDesc string `json:"coupon_desc"` // 优惠券描述
CreatedAt model.LocalTime `json:"created_at"` // 创建时间
UpdatedAt model.LocalTime `json:"updated_at"` // 更新时间
CouponId string `json:"coupon_id"` // 主键id
CouponName string `json:"coupon_name"` // 优惠券名称
CouponType int `json:"coupon_type"` // 优惠券类型（1:无门槛 2:满减）
CouponStatus int `json:"coupon_status"` // 状态（1:正常 2:强制失效 3:结束 4:删除）
ApplicationScope int `json:"application_scope"` // 适用范围（1:全场通用）
IsMutex int `json:"is_mutex"` // 是否互斥（0:否 1:是）
CouponCount int `json:"coupon_count"` // 发放数量
CouponTakeCount int `json:"coupon_take_count"` // 已领取数量
CouponUsedCount int `json:"coupon_used_count"` // 已使用数量
CouponPrice float64 `json:"coupon_price"` // 优惠券金额
WithAmount float64 `json:"with_amount"` // 符合满减标准金额（优惠券类型为满减时使用）
ValidType int `json:"valid_type"` // 有效类型（1:绝对时效，xxx-xxx时间段有效 2:相对时效 n天内有效）
ValidDays int `json:"valid_days"` // 自领取之日起有效天数
ValidStartTime *model.LocalTime `json:"valid_start_time"` // 开始使用时间
ValidEndTime *model.LocalTime `json:"valid_end_time"` // 结束使用时间
SystemMemberIds []*string `json:"system_member_ids"` // 会员id（适用范围为会员时生效，如果此项为null，则表示所有会员通用）
CouponDesc string `json:"coupon_desc"` // 优惠券描述
CreatedAt model.LocalTime `json:"created_at"` // 创建时间
UpdatedAt model.LocalTime `json:"updated_at"` // 更新时间
}
// GetCouponDto 优惠卷详情

34
api/model/Coupon.go
View File

@ -7,23 +7,23 @@ import (
)
type Coupon struct {
CouponId int64 `gorm:"column:coupon_id;type:bigint(19);primary_key;comment:主键id" json:"coupon_id"`
CouponName string `gorm:"column:coupon_name;type:varchar(255);comment:优惠卷名称" json:"coupon_name"`
CouponType int `gorm:"column:coupon_type;type:varchar(255);comment:优惠卷类型（1:无门槛 2:满减）" json:"coupon_type"`
CouponStatus int `gorm:"column:coupon_status;type:tinyint(1);default:1;comment:状态（1:正常 2:强制失效 3:结束 4:删除）" json:"coupon_status"`
ApplicationScope int `gorm:"column:application_scope;type:tinyint(1);default:1;comment:适用范围（1:全场通用 2:单项 3:会员）" json:"application_scope"`
IsMutex int `gorm:"column:is_mutex;type:tinyint(1);default:1;comment:是否互斥（0:否 1:是）互斥情况下无法和其他优惠卷同时使用" json:"is_mutex"`
CouponCount int `gorm:"column:coupon_count;type:int(10);default:1;comment:发放数量;NOT NULL" json:"coupon_count"`
CouponTakeCount int `gorm:"column:coupon_take_count;type:int(10);comment:已领取数量" json:"coupon_take_count"`
CouponUsedCount int `gorm:"column:coupon_used_count;type:int(10);default:0;comment:已使用数量" json:"coupon_used_count"`
CouponPrice float64 `gorm:"column:coupon_price;type:decimal(10,2) unsigned;default:0.00;comment:优惠卷金额" json:"coupon_price"`
WithAmount float64 `gorm:"column:with_amount;type:decimal(10,2);comment:符合满减标准金额（优惠卷类型为满减时使用）" json:"with_amount"`
ValidType int `gorm:"column:valid_type;type:tinyint(1);comment:有效类型（1:绝对时效，xxx-xxx时间段有效 2:相对时效 n天内有效）;NOT NULL" json:"valid_type"`
ValidDays int `gorm:"column:valid_days;type:int(3);comment:自领取之日起有效天数" json:"valid_days"`
ValidStartTime LocalTime `gorm:"column:valid_start_time;type:datetime;comment:开始使用时间" json:"valid_start_time"`
ValidEndTime LocalTime `gorm:"column:valid_end_time;type:datetime;comment:结束使用时间" json:"valid_end_time"`
SystemMemberIds string `gorm:"column:system_member_ids;type:bigint(19);comment:会员id（适用范围为会员时生效，如果此项为null，则表示所有会员通用）" json:"system_member_ids"`
CouponDesc string `gorm:"column:coupon_desc;type:varchar(200);comment:优惠卷描述" json:"coupon_desc"`
CouponId int64 `gorm:"column:coupon_id;type:bigint(19);primary_key;comment:主键id" json:"coupon_id"`
CouponName string `gorm:"column:coupon_name;type:varchar(255);comment:优惠卷名称" json:"coupon_name"`
CouponType int `gorm:"column:coupon_type;type:varchar(255);comment:优惠卷类型（1:无门槛 2:满减）" json:"coupon_type"`
CouponStatus int `gorm:"column:coupon_status;type:tinyint(1);default:1;comment:状态（1:正常 2:强制失效 3:结束 4:删除）" json:"coupon_status"`
ApplicationScope int `gorm:"column:application_scope;type:tinyint(1);default:1;comment:适用范围（1:全场通用 2:单项 3:会员）" json:"application_scope"`
IsMutex int `gorm:"column:is_mutex;type:tinyint(1);default:1;comment:是否互斥（0:否 1:是）互斥情况下无法和其他优惠卷同时使用" json:"is_mutex"`
CouponCount int `gorm:"column:coupon_count;type:int(10);default:1;comment:发放数量;NOT NULL" json:"coupon_count"`
CouponTakeCount int `gorm:"column:coupon_take_count;type:int(10);comment:已领取数量" json:"coupon_take_count"`
CouponUsedCount int `gorm:"column:coupon_used_count;type:int(10);default:0;comment:已使用数量" json:"coupon_used_count"`
CouponPrice float64 `gorm:"column:coupon_price;type:decimal(10,2) unsigned;default:0.00;comment:优惠卷金额" json:"coupon_price"`
WithAmount float64 `gorm:"column:with_amount;type:decimal(10,2);comment:符合满减标准金额（优惠卷类型为满减时使用）" json:"with_amount"`
ValidType int `gorm:"column:valid_type;type:tinyint(1);comment:有效类型（1:绝对时效，xxx-xxx时间段有效 2:相对时效 n天内有效）;NOT NULL" json:"valid_type"`
ValidDays int `gorm:"column:valid_days;type:int(3);comment:自领取之日起有效天数" json:"valid_days"`
ValidStartTime *LocalTime `gorm:"column:valid_start_time;type:datetime;comment:开始使用时间" json:"valid_start_time"`
ValidEndTime *LocalTime `gorm:"column:valid_end_time;type:datetime;comment:结束使用时间" json:"valid_end_time"`
SystemMemberIds string `gorm:"column:system_member_ids;type:bigint(19);comment:会员id（适用范围为会员时生效，如果此项为null，则表示所有会员通用）" json:"system_member_ids"`
CouponDesc string `gorm:"column:coupon_desc;type:varchar(200);comment:优惠卷描述" json:"coupon_desc"`
Model
}

116
api/service/Coupon.go Normal file
View File

@ -0,0 +1,116 @@
package service
import (
"fmt"
"gorm.io/gorm"
"hepa-calc-api/api/dao"
"hepa-calc-api/api/model"
"hepa-calc-api/extend/rabbitMq"
"time"
)
type CouponService struct {
}
// GrantUserCoupon 发放优惠卷
func (r *CouponService) GrantUserCoupon(tx *gorm.DB, userId, couponId int64, grantQuantity int) bool {
// 获取优惠卷数据
couponDao := dao.CouponDao{}
coupon, err := couponDao.GetCouponById(couponId)
if err != nil {
return false
}
// 判断优惠卷状态
if coupon.CouponStatus != 1 {
return true
}
// 判断优惠卷过期时间
if coupon.ValidType == 1 {
now := time.Now().Add(10 * 60 * time.Second)
validEndTime := time.Time(*coupon.ValidEndTime)
if validEndTime.Before(now) {
return false
}
}
// 判断优惠卷数量是否充足
if coupon.CouponCount <= coupon.CouponTakeCount {
return false
}
// 检测剩余数量
remainingQuantity := coupon.CouponCount - coupon.CouponTakeCount
if remainingQuantity <= grantQuantity {
return false
}
// 添加用户优惠卷表
userCoupon := &model.UserCoupon{
UserId: userId,
CouponId: couponId,
UserCouponStatus: 0,
IsWindows: 0,
CouponUseDate: nil,
}
if coupon.ValidType == 1 {
// 有效类型（1:绝对时效，xxx-xxx时间段有效 2:相对时效 n天内有效）
userCoupon.ValidStartTime = coupon.ValidStartTime
userCoupon.ValidEndTime = coupon.ValidEndTime
} else {
validStartTime := model.LocalTime(time.Now())
userCoupon.ValidStartTime = &validStartTime
validEndTime := model.LocalTime(time.Now().Add(time.Duration(coupon.ValidDays) * 24 * time.Hour))
userCoupon.ValidEndTime = &validEndTime
}
userCouponDao := dao.UserCouponDao{}
userCoupon, err = userCouponDao.AddUserCoupon(tx, userCoupon)
if err != nil {
return false
}
// 增加优惠卷发放数量
err = couponDao.Inc(tx, couponId, "coupon_take_count", grantQuantity)
if err != nil {
return false
}
// 增加过期队列
if coupon.ValidType == 1 {
validEndTime := time.Time(*userCoupon.ValidEndTime)
// 计算当天的结束时间
now := time.Now()
year, month, day := now.Date()
location := now.Location()
endOfDay := time.Date(year, month, day, 23, 59, 59, 0, location)
if validEndTime.Before(endOfDay) {
delay := validEndTime.Sub(time.Now())
if delay < 5*time.Second {
delay = 5 * time.Second
}
// 添加处理优惠卷过期队列
data := make(map[string]interface{})
data["coupon_id"] = fmt.Sprintf("%d", coupon.CouponId)
p := rabbitMq.PublishS{
QueueName: "user.coupon.expired.delay.queue",
ExchangeName: "amqp.delay.direct",
RoutingKey: "UserCouponExpired",
Message: data,
Delay: delay,
}
err := p.PublishWithDelay()
if err != nil {
return false
}
}
}
return true
}

2
api/service/UserCoupon.go
View File

@ -77,7 +77,7 @@ func (r *UserCouponService) CheckUserCoupon(m *model.UserCoupon, id int64, order
// 检测优惠劵过期时间
if m.Coupon.ValidType == 1 {
validEndTime = time.Time(m.Coupon.ValidEndTime)
validEndTime = time.Time(*m.Coupon.ValidEndTime)
if validEndTime.Before(now) {
return false, errors.New("优惠卷已过期，无法使用")
}

24
utils/tz.go Normal file
View File

@ -0,0 +1,24 @@
package utils
import (
"hepa-calc-api/api/model"
"time"
)
// StrToLocalTime 字符串时间转localtime
func StrToLocalTime(s string) (*model.LocalTime, error) {
// 获取本地时区
location, err := time.LoadLocation("Local")
if err != nil {
return nil, err
}
timeParse, err := time.ParseInLocation("2006-01-02 15:04:05", s, location)
if err != nil {
return nil, err
}
t := model.LocalTime(timeParse)
return &t, nil
}