154 lines
4.3 KiB
Go
154 lines
4.3 KiB
Go
package user
|
||
|
||
import (
|
||
"context"
|
||
"fmt"
|
||
"time"
|
||
|
||
"bindbox-game/internal/repository/mysql/model"
|
||
|
||
"gorm.io/gorm/clause"
|
||
)
|
||
|
||
// StartOrderTimeoutTask 启动订单超时清理任务（每分钟执行）
|
||
func (s *service) StartOrderTimeoutTask(ctx context.Context) {
|
||
ticker := time.NewTicker(1 * time.Minute)
|
||
defer ticker.Stop()
|
||
|
||
for {
|
||
select {
|
||
case <-ctx.Done():
|
||
return
|
||
case <-ticker.C:
|
||
s.cleanupExpiredOrders()
|
||
}
|
||
}
|
||
}
|
||
|
||
// cleanupExpiredOrders 清理超时未支付的订单
|
||
// 规则：待支付订单超过30分钟自动取消，并恢复已预扣的优惠券
|
||
func (s *service) cleanupExpiredOrders() {
|
||
ctx := context.Background()
|
||
cutoff := time.Now().Add(-30 * time.Minute)
|
||
|
||
// 查找所有超时的待支付订单（排除一番赏订单，因为有专门的清理任务）
|
||
var expiredOrders []struct {
|
||
ID int64
|
||
UserID int64
|
||
CouponID int64
|
||
OrderNo string
|
||
PointsAmount int64
|
||
}
|
||
|
||
err := s.readDB.Orders.WithContext(ctx).UnderlyingDB().Raw(`
|
||
SELECT id, user_id, coupon_id, order_no, points_amount
|
||
FROM orders
|
||
WHERE status = 1 AND created_at < ? AND source_type != 3
|
||
LIMIT 100
|
||
`, cutoff).Scan(&expiredOrders).Error
|
||
|
||
if err != nil {
|
||
fmt.Printf("OrderTimeoutTask: 查询超时订单失败: %v\n", err)
|
||
return
|
||
}
|
||
|
||
for _, order := range expiredOrders {
|
||
s.cancelExpiredOrder(ctx, order.ID, order.UserID, order.CouponID, order.PointsAmount)
|
||
}
|
||
|
||
if len(expiredOrders) > 0 {
|
||
fmt.Printf("OrderTimeoutTask: 已处理 %d 个超时订单\n", len(expiredOrders))
|
||
}
|
||
}
|
||
|
||
// cancelExpiredOrder 取消超时订单并恢复优惠券
|
||
func (s *service) cancelExpiredOrder(ctx context.Context, orderID int64, userID int64, couponID int64, pointsAmount int64) {
|
||
// 1. 恢复优惠券
|
||
if couponID > 0 {
|
||
type couponRow struct {
|
||
AppliedAmount int64
|
||
DiscountType int32
|
||
}
|
||
var cr couponRow
|
||
s.readDB.OrderCoupons.WithContext(ctx).UnderlyingDB().Raw(`
|
||
SELECT oc.applied_amount, sc.discount_type
|
||
FROM order_coupons oc
|
||
JOIN user_coupons uc ON uc.id = oc.user_coupon_id
|
||
JOIN system_coupons sc ON sc.id = uc.coupon_id
|
||
WHERE oc.order_id = ? AND oc.user_coupon_id = ?
|
||
`, orderID, couponID).Scan(&cr)
|
||
|
||
if cr.AppliedAmount > 0 {
|
||
if cr.DiscountType == 1 {
|
||
// 金额券：恢复余额
|
||
// 此时 coupon 可能 status=1 (Active) 或 2 (Used/Exhausted)
|
||
// 不需要 status=4 限制，因为下单时已直接扣减
|
||
res := s.writeDB.UserCoupons.WithContext(ctx).UnderlyingDB().Exec(`
|
||
UPDATE user_coupons
|
||
SET balance_amount = balance_amount + ?,
|
||
status = 1,
|
||
used_order_id = NULL,
|
||
used_at = NULL
|
||
WHERE id = ?
|
||
`, cr.AppliedAmount, couponID)
|
||
|
||
if res.RowsAffected > 0 {
|
||
// 记录流水
|
||
s.writeDB.UserCouponLedger.WithContext(ctx).Create(&model.UserCouponLedger{
|
||
UserID: userID,
|
||
UserCouponID: couponID,
|
||
ChangeAmount: cr.AppliedAmount,
|
||
OrderID: orderID,
|
||
Action: "timeout_refund",
|
||
CreatedAt: time.Now(),
|
||
})
|
||
}
|
||
} else {
|
||
// 满减/折扣券：恢复状态
|
||
s.writeDB.UserCoupons.WithContext(ctx).UnderlyingDB().Exec(`
|
||
UPDATE user_coupons
|
||
SET status = 1,
|
||
used_order_id = NULL,
|
||
used_at = NULL
|
||
WHERE id = ? AND status = 4
|
||
`, couponID)
|
||
}
|
||
}
|
||
}
|
||
|
||
// 2. 退还积分（如有）
|
||
if pointsAmount > 0 {
|
||
existing, _ := s.writeDB.UserPoints.WithContext(ctx).
|
||
Clauses(clause.Locking{Strength: "UPDATE"}).
|
||
Where(s.writeDB.UserPoints.UserID.Eq(userID)).First()
|
||
|
||
if existing != nil {
|
||
s.writeDB.UserPoints.WithContext(ctx).
|
||
Where(s.writeDB.UserPoints.ID.Eq(existing.ID)).
|
||
Updates(map[string]any{"points": existing.Points + pointsAmount})
|
||
} else {
|
||
s.writeDB.UserPoints.WithContext(ctx).
|
||
Omit(s.writeDB.UserPoints.ValidEnd).
|
||
Create(&model.UserPoints{UserID: userID, Points: pointsAmount})
|
||
}
|
||
|
||
s.writeDB.UserPointsLedger.WithContext(ctx).Create(&model.UserPointsLedger{
|
||
UserID: userID,
|
||
Action: "timeout_refund",
|
||
Points: pointsAmount,
|
||
RefTable: "orders",
|
||
RefID: fmt.Sprintf("%d", orderID),
|
||
Remark: "order_timeout",
|
||
})
|
||
}
|
||
|
||
// 3. 更新订单状态为已取消
|
||
res := s.writeDB.Orders.WithContext(ctx).UnderlyingDB().Exec(`
|
||
UPDATE orders SET status = 3, cancelled_at = NOW() WHERE id = ? AND status = 1
|
||
`, orderID)
|
||
|
||
if res.RowsAffected > 0 {
|
||
fmt.Printf("OrderTimeoutTask: 订单 %d 已超时取消\n", orderID)
|
||
}
|
||
}
|