mirror of
https://github.com/QuantumNous/new-api.git
synced 2026-03-30 07:57:03 +00:00
* ci: create docker automation * ✨ feat: add subscription billing system with admin management and user purchase flow Implement a new subscription-based billing model alongside existing metered/per-request billing: Backend: - Add subscription plan models (SubscriptionPlan, SubscriptionPlanItem, UserSubscription, etc.) - Implement CRUD APIs for subscription plan management (admin only) - Add user subscription queries with support for multiple active/expired subscriptions - Integrate payment gateways (Stripe, Creem, Epay) for subscription purchases - Implement pre-consume and post-consume billing logic for subscription quota tracking - Add billing preference settings (subscription_first, wallet_first, etc.) - Enhance usage logs with subscription deduction details Frontend - Admin: - Add subscription management page with table view and drawer-based edit form - Match UI/UX style with existing admin pages (redemption codes, users) - Support enabling/disabling plans, configuring payment IDs, and model quotas - Add user subscription binding modal in user management Frontend - Wallet: - Add subscription plans card with current subscription status display - Show all subscriptions (active and expired) with remaining days/usage percentage - Display purchasable plans with pricing cards following SaaS best practices - Extract purchase modal to separate component matching payment confirm modal style - Add skeleton loading states with active animation - Implement billing preference selector in card header - Handle payment gateway availability based on admin configuration Frontend - Usage Logs: - Display subscription deduction details in log entries - Show step-by-step breakdown of subscription usage (pre-consumed, delta, final, remaining) - Add subscription deduction tag for subscription-covered requests * ✨ feat(admin): add user subscription management and refine UI/pagination Add admin APIs to list/create/invalidate/delete user subscriptions Add model helpers to fetch all user subscriptions (incl. expired) and support cancel/hard-delete Wire new admin routes for user subscription operations Replace “Bind subscription plan” entry with a dedicated User Subscriptions SideSheet in Users table Use CardTable with responsive layout and working client-side pagination inside the SideSheet Improve subscription purchase modal empty-gateway state with a Banner notice * ✨ feat(admin): streamline subscription plan benefits editor with bulk actions Restore the avatar/icon header for the “Model Benefits” section Replace scattered controls with a compact toolbar-style workflow Support multi-select add with a default quota for new items Add row selection with bulk apply-to-selected / apply-to-all quota updates Enable delete-selected to manage benefits faster and reduce mistakes * ✨ fix(subscription): finalize payments, log billing, and clean up dead code Complete subscription orders by creating a matching top-up record and writing billing logs Add Epay return handler to verify and finalize browser callbacks Require Stripe/Creem webhook configuration before starting subscription payments Show subscription purchases in topup history with clearer labels/methods Remove unused subscription helper, legacy Creem webhook struct, and unused topup fields Simplify subscription self API payload to active/all lists only * 🎨 style: format all code with gofmt and lint:fix Apply consistent code formatting across the entire codebase using gofmt and lint:fix tools. This ensures adherence to Go community standards and improves code readability and maintainability. Changes include: - Run gofmt on all .go files to standardize formatting - Apply lint:fix to automatically resolve linting issues - Fix code style inconsistencies and formatting violations No functional changes were made in this commit. * ✨ feat(subscription): add quota reset periods and admin configuration - Add reset period fields on subscription plans and user items - Apply automatic quota resets during pre-consume based on plan schedule - Expose reset-period configuration in the admin plan editor - Display reset cadence in subscription cards and purchase modal - Validate custom reset seconds on plan create/update * ✨ feat(subscription): harden subscription billing with resets, idempotency, and production-grade stability Add plan-level quota reset periods and display/reset cadence in admin/UI Enforce natural reset alignment with background reset task and cleanup job Make subscription pre-consume/refund idempotent with request-scoped records and retries Use database time for consistent resets across multi-instance deployments Harden payment callbacks with locking and idempotent order completion Record subscription purchases in topup history and billing logs Optimize subscription queries and add critical composite indexes * ✨ feat(subscription): cache plan lookups and stabilize pre-consume Introduce hybrid caches for subscription plans, items, and plan info with explicit invalidation on admin updates. Streamline pre-consume transactions to reduce redundant queries while preserving idempotency and reset logic. * 🐛 fix(subscription): avoid pre-consume lookup noise Use a RowsAffected check for the idempotency lookup so missing records no longer surface as "record not found" errors while preserving behavior. * 🔧 ci: Change workflow trigger to sub branch Update the Docker image workflow to run on pushes to the sub branch instead of main. * 💸 chore: Align subscription pricing display with global currency settings Unify subscription price rendering to use the site-wide currency symbol/rate on the wallet and admin views. Make subscription plan currency read-only in the editor and force USD on create/update to avoid drift. Use global currency display type when creating Creem checkout payloads. * 🔧 chore: Unify subscription plan status toggle with PATCH endpoint Replace separate enable/disable flows with a single PATCH API that updates the enabled flag. Update frontend hooks and table actions to call the unified endpoint and keep UI behavior consistent. Introduce a minimal admin controller handler and route for the status update. * ✨ feat: Add subscription limits and UI tags consistency Add per-plan purchase limits with backend enforcement and UI disable states. Expose limit configuration in admin plan editor and show limits in plan tables/cards. Refine subscription UI tags with unified badge style and streamlined “My Subscriptions” layout. * 🎨 style: tag color to white * 🚀 refactor: Simplify subscription quota to total amount model Remove per-model subscription items and switch to a single total quota per plan and user subscription. Update billing, reset, and logging flows to operate on total quota, and refactor admin/user UI to configure and display total quota consistently. * 🚀 chore: Remove duplicate subscription usage percentage display Keep the usage percentage shown only in the total quota line to avoid redundant “已用 0%” text while preserving remaining days in the summary. * ✨ feat: Add subscription upgrade group with auto downgrade * ✨ feat: Update subscription purchase modal display Show total quota as currency with tooltip for raw quota, hide reset cycle when never, and display upgrade group when configured to match card display rules. * ✨ feat: Extract quota conversion helpers to shared utils Move quota display/conversion helpers into web/src/helpers/quota.js and update the subscription plan editor to import and use the shared utilities instead of inline functions. * ✨ chore: Add upgrade group guidance in subscription editor Add explanatory helper text under the upgrade group field to clarify automatic group upgrades, rollback conditions, and the expected delay before downgrading takes effect. * 🔧 chore: remove unused Creem settings state Drop the unused originInputs state and redundant updates to keep the Creem settings form state minimal and easier to maintain. * 🚀 chore: Remove useless action * ✨ Add full i18n coverage for subscription-related UI across locales * ✨ feat: harden subscription billing and improve UI consistency Improve subscription payment safety and data integrity by handling user/URL lookup failures, fixing Stripe subscription mode, persisting quota reset fields, and correcting subscription delta accounting and DB timestamp casting. Refine the UI with stricter custom duration validation, accurate currency rounding, conditional Epay labeling, rollback on preference update failure, and shared subscription formatting helpers plus clearer component naming. * 🔧 fix: make epay webhook and return flow subscription-aware Ensure Epay webhook acknowledges success only after order completion, returning fail on processing errors to allow retries. Redirect subscription payment returns to the subscription page instead of top-up for correct user flow. * 🚦 fix: guard epay return success on order completion Redirect subscription return flow to failure when order completion fails, preventing false success states after payment verification. * 🔧 fix: normalize epay error handling and webhook retries Standardize SubscriptionRequestEpay error responses via ApiErrorMsg for a consistent schema. Return "fail" on non-success trade statuses in the epay webhook to preserve retry behavior. * 🧾 fix: persist epay orders before purchase Create the subscription order before initiating epay payment and expire it if the provider call fails, preventing orphaned transactions and improving reconciliation. * 🔧 fix: harden epay callbacks and billing fallbacks Use POST and form parsing for epay notify/return routes, persist epay orders before provider calls with expiry on failure, and ensure notify handlers retry correctly. Restrict subscription-first fallback to insufficient-subscription errors and log refund failures after retries to avoid silent quota drift. * 🔧 fix: harden billing flow and sidebar settings Add missing strings import for subscription fallback checks, log failed subscription refunds after retries, and extend sidebar module settings with a subscription management toggle plus translations. * 🛡️ fix: fail fast on epay form parse errors Handle ParseForm errors in epay notify/return handlers by returning fail or redirecting to failure, avoiding unsafe fallback to query parameters. * ✨ fix: refine Japanese subscription status labels Adjust Japanese UI wording for active-count labels to read more naturally and consistently. * ✅ fix: standardize epay success response schema Return subscription epay pay success responses via ApiSuccess to include the consistent success field and align with error schema.
1177 lines
34 KiB
Go
1177 lines
34 KiB
Go
package model
|
||
|
||
import (
|
||
"errors"
|
||
"fmt"
|
||
"strconv"
|
||
"strings"
|
||
"sync"
|
||
"time"
|
||
|
||
"github.com/QuantumNous/new-api/common"
|
||
"github.com/QuantumNous/new-api/pkg/cachex"
|
||
"github.com/samber/hot"
|
||
"gorm.io/gorm"
|
||
)
|
||
|
||
// Subscription duration units
|
||
const (
|
||
SubscriptionDurationYear = "year"
|
||
SubscriptionDurationMonth = "month"
|
||
SubscriptionDurationDay = "day"
|
||
SubscriptionDurationHour = "hour"
|
||
SubscriptionDurationCustom = "custom"
|
||
)
|
||
|
||
// Subscription quota reset period
|
||
const (
|
||
SubscriptionResetNever = "never"
|
||
SubscriptionResetDaily = "daily"
|
||
SubscriptionResetWeekly = "weekly"
|
||
SubscriptionResetMonthly = "monthly"
|
||
SubscriptionResetCustom = "custom"
|
||
)
|
||
|
||
var (
|
||
ErrSubscriptionOrderNotFound = errors.New("subscription order not found")
|
||
ErrSubscriptionOrderStatusInvalid = errors.New("subscription order status invalid")
|
||
)
|
||
|
||
const (
|
||
subscriptionPlanCacheNamespace = "new-api:subscription_plan:v1"
|
||
subscriptionPlanInfoCacheNamespace = "new-api:subscription_plan_info:v1"
|
||
)
|
||
|
||
var (
|
||
subscriptionPlanCacheOnce sync.Once
|
||
subscriptionPlanInfoCacheOnce sync.Once
|
||
|
||
subscriptionPlanCache *cachex.HybridCache[SubscriptionPlan]
|
||
subscriptionPlanInfoCache *cachex.HybridCache[SubscriptionPlanInfo]
|
||
)
|
||
|
||
func subscriptionPlanCacheTTL() time.Duration {
|
||
ttlSeconds := common.GetEnvOrDefault("SUBSCRIPTION_PLAN_CACHE_TTL", 300)
|
||
if ttlSeconds <= 0 {
|
||
ttlSeconds = 300
|
||
}
|
||
return time.Duration(ttlSeconds) * time.Second
|
||
}
|
||
|
||
func subscriptionPlanInfoCacheTTL() time.Duration {
|
||
ttlSeconds := common.GetEnvOrDefault("SUBSCRIPTION_PLAN_INFO_CACHE_TTL", 120)
|
||
if ttlSeconds <= 0 {
|
||
ttlSeconds = 120
|
||
}
|
||
return time.Duration(ttlSeconds) * time.Second
|
||
}
|
||
|
||
func subscriptionPlanCacheCapacity() int {
|
||
capacity := common.GetEnvOrDefault("SUBSCRIPTION_PLAN_CACHE_CAP", 5000)
|
||
if capacity <= 0 {
|
||
capacity = 5000
|
||
}
|
||
return capacity
|
||
}
|
||
|
||
func subscriptionPlanInfoCacheCapacity() int {
|
||
capacity := common.GetEnvOrDefault("SUBSCRIPTION_PLAN_INFO_CACHE_CAP", 10000)
|
||
if capacity <= 0 {
|
||
capacity = 10000
|
||
}
|
||
return capacity
|
||
}
|
||
|
||
func getSubscriptionPlanCache() *cachex.HybridCache[SubscriptionPlan] {
|
||
subscriptionPlanCacheOnce.Do(func() {
|
||
ttl := subscriptionPlanCacheTTL()
|
||
subscriptionPlanCache = cachex.NewHybridCache[SubscriptionPlan](cachex.HybridCacheConfig[SubscriptionPlan]{
|
||
Namespace: cachex.Namespace(subscriptionPlanCacheNamespace),
|
||
Redis: common.RDB,
|
||
RedisEnabled: func() bool {
|
||
return common.RedisEnabled && common.RDB != nil
|
||
},
|
||
RedisCodec: cachex.JSONCodec[SubscriptionPlan]{},
|
||
Memory: func() *hot.HotCache[string, SubscriptionPlan] {
|
||
return hot.NewHotCache[string, SubscriptionPlan](hot.LRU, subscriptionPlanCacheCapacity()).
|
||
WithTTL(ttl).
|
||
WithJanitor().
|
||
Build()
|
||
},
|
||
})
|
||
})
|
||
return subscriptionPlanCache
|
||
}
|
||
|
||
func getSubscriptionPlanInfoCache() *cachex.HybridCache[SubscriptionPlanInfo] {
|
||
subscriptionPlanInfoCacheOnce.Do(func() {
|
||
ttl := subscriptionPlanInfoCacheTTL()
|
||
subscriptionPlanInfoCache = cachex.NewHybridCache[SubscriptionPlanInfo](cachex.HybridCacheConfig[SubscriptionPlanInfo]{
|
||
Namespace: cachex.Namespace(subscriptionPlanInfoCacheNamespace),
|
||
Redis: common.RDB,
|
||
RedisEnabled: func() bool {
|
||
return common.RedisEnabled && common.RDB != nil
|
||
},
|
||
RedisCodec: cachex.JSONCodec[SubscriptionPlanInfo]{},
|
||
Memory: func() *hot.HotCache[string, SubscriptionPlanInfo] {
|
||
return hot.NewHotCache[string, SubscriptionPlanInfo](hot.LRU, subscriptionPlanInfoCacheCapacity()).
|
||
WithTTL(ttl).
|
||
WithJanitor().
|
||
Build()
|
||
},
|
||
})
|
||
})
|
||
return subscriptionPlanInfoCache
|
||
}
|
||
|
||
func subscriptionPlanCacheKey(id int) string {
|
||
if id <= 0 {
|
||
return ""
|
||
}
|
||
return strconv.Itoa(id)
|
||
}
|
||
|
||
func InvalidateSubscriptionPlanCache(planId int) {
|
||
if planId <= 0 {
|
||
return
|
||
}
|
||
cache := getSubscriptionPlanCache()
|
||
_, _ = cache.DeleteMany([]string{subscriptionPlanCacheKey(planId)})
|
||
infoCache := getSubscriptionPlanInfoCache()
|
||
_ = infoCache.Purge()
|
||
}
|
||
|
||
// Subscription plan
|
||
type SubscriptionPlan struct {
|
||
Id int `json:"id"`
|
||
|
||
Title string `json:"title" gorm:"type:varchar(128);not null"`
|
||
Subtitle string `json:"subtitle" gorm:"type:varchar(255);default:''"`
|
||
|
||
// Display money amount (follow existing code style: float64 for money)
|
||
PriceAmount float64 `json:"price_amount" gorm:"type:double;not null;default:0"`
|
||
Currency string `json:"currency" gorm:"type:varchar(8);not null;default:'USD'"`
|
||
|
||
DurationUnit string `json:"duration_unit" gorm:"type:varchar(16);not null;default:'month'"`
|
||
DurationValue int `json:"duration_value" gorm:"type:int;not null;default:1"`
|
||
CustomSeconds int64 `json:"custom_seconds" gorm:"type:bigint;not null;default:0"`
|
||
|
||
Enabled bool `json:"enabled" gorm:"default:true"`
|
||
SortOrder int `json:"sort_order" gorm:"type:int;default:0"`
|
||
|
||
StripePriceId string `json:"stripe_price_id" gorm:"type:varchar(128);default:''"`
|
||
CreemProductId string `json:"creem_product_id" gorm:"type:varchar(128);default:''"`
|
||
|
||
// Max purchases per user (0 = unlimited)
|
||
MaxPurchasePerUser int `json:"max_purchase_per_user" gorm:"type:int;default:0"`
|
||
|
||
// Upgrade user group after purchase (empty = no change)
|
||
UpgradeGroup string `json:"upgrade_group" gorm:"type:varchar(64);default:''"`
|
||
|
||
// Total quota (amount in quota units, 0 = unlimited)
|
||
TotalAmount int64 `json:"total_amount" gorm:"type:bigint;not null;default:0"`
|
||
|
||
// Quota reset period for plan
|
||
QuotaResetPeriod string `json:"quota_reset_period" gorm:"type:varchar(16);default:'never'"`
|
||
QuotaResetCustomSeconds int64 `json:"quota_reset_custom_seconds" gorm:"type:bigint;default:0"`
|
||
|
||
CreatedAt int64 `json:"created_at" gorm:"bigint"`
|
||
UpdatedAt int64 `json:"updated_at" gorm:"bigint"`
|
||
}
|
||
|
||
func (p *SubscriptionPlan) BeforeCreate(tx *gorm.DB) error {
|
||
now := common.GetTimestamp()
|
||
p.CreatedAt = now
|
||
p.UpdatedAt = now
|
||
return nil
|
||
}
|
||
|
||
func (p *SubscriptionPlan) BeforeUpdate(tx *gorm.DB) error {
|
||
p.UpdatedAt = common.GetTimestamp()
|
||
return nil
|
||
}
|
||
|
||
// Subscription order (payment -> webhook -> create UserSubscription)
|
||
type SubscriptionOrder struct {
|
||
Id int `json:"id"`
|
||
UserId int `json:"user_id" gorm:"index"`
|
||
PlanId int `json:"plan_id" gorm:"index"`
|
||
Money float64 `json:"money"`
|
||
|
||
TradeNo string `json:"trade_no" gorm:"unique;type:varchar(255);index"`
|
||
PaymentMethod string `json:"payment_method" gorm:"type:varchar(50)"`
|
||
Status string `json:"status"`
|
||
CreateTime int64 `json:"create_time"`
|
||
CompleteTime int64 `json:"complete_time"`
|
||
|
||
ProviderPayload string `json:"provider_payload" gorm:"type:text"`
|
||
}
|
||
|
||
func (o *SubscriptionOrder) Insert() error {
|
||
if o.CreateTime == 0 {
|
||
o.CreateTime = common.GetTimestamp()
|
||
}
|
||
return DB.Create(o).Error
|
||
}
|
||
|
||
func (o *SubscriptionOrder) Update() error {
|
||
return DB.Save(o).Error
|
||
}
|
||
|
||
func GetSubscriptionOrderByTradeNo(tradeNo string) *SubscriptionOrder {
|
||
if tradeNo == "" {
|
||
return nil
|
||
}
|
||
var order SubscriptionOrder
|
||
if err := DB.Where("trade_no = ?", tradeNo).First(&order).Error; err != nil {
|
||
return nil
|
||
}
|
||
return &order
|
||
}
|
||
|
||
// User subscription instance
|
||
type UserSubscription struct {
|
||
Id int `json:"id"`
|
||
UserId int `json:"user_id" gorm:"index;index:idx_user_sub_active,priority:1"`
|
||
PlanId int `json:"plan_id" gorm:"index"`
|
||
|
||
AmountTotal int64 `json:"amount_total" gorm:"type:bigint;not null;default:0"`
|
||
AmountUsed int64 `json:"amount_used" gorm:"type:bigint;not null;default:0"`
|
||
|
||
StartTime int64 `json:"start_time" gorm:"bigint"`
|
||
EndTime int64 `json:"end_time" gorm:"bigint;index;index:idx_user_sub_active,priority:3"`
|
||
Status string `json:"status" gorm:"type:varchar(32);index;index:idx_user_sub_active,priority:2"` // active/expired/cancelled
|
||
|
||
Source string `json:"source" gorm:"type:varchar(32);default:'order'"` // order/admin
|
||
|
||
LastResetTime int64 `json:"last_reset_time" gorm:"type:bigint;default:0"`
|
||
NextResetTime int64 `json:"next_reset_time" gorm:"type:bigint;default:0;index"`
|
||
|
||
UpgradeGroup string `json:"upgrade_group" gorm:"type:varchar(64);default:''"`
|
||
PrevUserGroup string `json:"prev_user_group" gorm:"type:varchar(64);default:''"`
|
||
|
||
CreatedAt int64 `json:"created_at" gorm:"bigint"`
|
||
UpdatedAt int64 `json:"updated_at" gorm:"bigint"`
|
||
}
|
||
|
||
func (s *UserSubscription) BeforeCreate(tx *gorm.DB) error {
|
||
now := common.GetTimestamp()
|
||
s.CreatedAt = now
|
||
s.UpdatedAt = now
|
||
return nil
|
||
}
|
||
|
||
func (s *UserSubscription) BeforeUpdate(tx *gorm.DB) error {
|
||
s.UpdatedAt = common.GetTimestamp()
|
||
return nil
|
||
}
|
||
|
||
type SubscriptionSummary struct {
|
||
Subscription *UserSubscription `json:"subscription"`
|
||
}
|
||
|
||
func calcPlanEndTime(start time.Time, plan *SubscriptionPlan) (int64, error) {
|
||
if plan == nil {
|
||
return 0, errors.New("plan is nil")
|
||
}
|
||
if plan.DurationValue <= 0 && plan.DurationUnit != SubscriptionDurationCustom {
|
||
return 0, errors.New("duration_value must be > 0")
|
||
}
|
||
switch plan.DurationUnit {
|
||
case SubscriptionDurationYear:
|
||
return start.AddDate(plan.DurationValue, 0, 0).Unix(), nil
|
||
case SubscriptionDurationMonth:
|
||
return start.AddDate(0, plan.DurationValue, 0).Unix(), nil
|
||
case SubscriptionDurationDay:
|
||
return start.Add(time.Duration(plan.DurationValue) * 24 * time.Hour).Unix(), nil
|
||
case SubscriptionDurationHour:
|
||
return start.Add(time.Duration(plan.DurationValue) * time.Hour).Unix(), nil
|
||
case SubscriptionDurationCustom:
|
||
if plan.CustomSeconds <= 0 {
|
||
return 0, errors.New("custom_seconds must be > 0")
|
||
}
|
||
return start.Add(time.Duration(plan.CustomSeconds) * time.Second).Unix(), nil
|
||
default:
|
||
return 0, fmt.Errorf("invalid duration_unit: %s", plan.DurationUnit)
|
||
}
|
||
}
|
||
|
||
func NormalizeResetPeriod(period string) string {
|
||
switch strings.TrimSpace(period) {
|
||
case SubscriptionResetDaily, SubscriptionResetWeekly, SubscriptionResetMonthly, SubscriptionResetCustom:
|
||
return strings.TrimSpace(period)
|
||
default:
|
||
return SubscriptionResetNever
|
||
}
|
||
}
|
||
|
||
func calcNextResetTime(base time.Time, plan *SubscriptionPlan, endUnix int64) int64 {
|
||
if plan == nil {
|
||
return 0
|
||
}
|
||
period := NormalizeResetPeriod(plan.QuotaResetPeriod)
|
||
if period == SubscriptionResetNever {
|
||
return 0
|
||
}
|
||
var next time.Time
|
||
switch period {
|
||
case SubscriptionResetDaily:
|
||
next = time.Date(base.Year(), base.Month(), base.Day(), 0, 0, 0, 0, base.Location()).
|
||
AddDate(0, 0, 1)
|
||
case SubscriptionResetWeekly:
|
||
// Align to next Monday 00:00
|
||
weekday := int(base.Weekday()) // Sunday=0
|
||
// Convert to Monday=1..Sunday=7
|
||
if weekday == 0 {
|
||
weekday = 7
|
||
}
|
||
daysUntil := 8 - weekday
|
||
next = time.Date(base.Year(), base.Month(), base.Day(), 0, 0, 0, 0, base.Location()).
|
||
AddDate(0, 0, daysUntil)
|
||
case SubscriptionResetMonthly:
|
||
// Align to first day of next month 00:00
|
||
next = time.Date(base.Year(), base.Month(), 1, 0, 0, 0, 0, base.Location()).
|
||
AddDate(0, 1, 0)
|
||
case SubscriptionResetCustom:
|
||
if plan.QuotaResetCustomSeconds <= 0 {
|
||
return 0
|
||
}
|
||
next = base.Add(time.Duration(plan.QuotaResetCustomSeconds) * time.Second)
|
||
default:
|
||
return 0
|
||
}
|
||
if endUnix > 0 && next.Unix() > endUnix {
|
||
return 0
|
||
}
|
||
return next.Unix()
|
||
}
|
||
|
||
func GetSubscriptionPlanById(id int) (*SubscriptionPlan, error) {
|
||
return getSubscriptionPlanByIdTx(nil, id)
|
||
}
|
||
|
||
func getSubscriptionPlanByIdTx(tx *gorm.DB, id int) (*SubscriptionPlan, error) {
|
||
if id <= 0 {
|
||
return nil, errors.New("invalid plan id")
|
||
}
|
||
key := subscriptionPlanCacheKey(id)
|
||
if key != "" {
|
||
if cached, found, err := getSubscriptionPlanCache().Get(key); err == nil && found {
|
||
return &cached, nil
|
||
}
|
||
}
|
||
var plan SubscriptionPlan
|
||
query := DB
|
||
if tx != nil {
|
||
query = tx
|
||
}
|
||
if err := query.Where("id = ?", id).First(&plan).Error; err != nil {
|
||
return nil, err
|
||
}
|
||
_ = getSubscriptionPlanCache().SetWithTTL(key, plan, subscriptionPlanCacheTTL())
|
||
return &plan, nil
|
||
}
|
||
|
||
func CountUserSubscriptionsByPlan(userId int, planId int) (int64, error) {
|
||
if userId <= 0 || planId <= 0 {
|
||
return 0, errors.New("invalid userId or planId")
|
||
}
|
||
var count int64
|
||
if err := DB.Model(&UserSubscription{}).
|
||
Where("user_id = ? AND plan_id = ?", userId, planId).
|
||
Count(&count).Error; err != nil {
|
||
return 0, err
|
||
}
|
||
return count, nil
|
||
}
|
||
|
||
func getUserGroupByIdTx(tx *gorm.DB, userId int) (string, error) {
|
||
if userId <= 0 {
|
||
return "", errors.New("invalid userId")
|
||
}
|
||
if tx == nil {
|
||
tx = DB
|
||
}
|
||
var group string
|
||
if err := tx.Model(&User{}).Where("id = ?", userId).Select(commonGroupCol).Find(&group).Error; err != nil {
|
||
return "", err
|
||
}
|
||
return group, nil
|
||
}
|
||
|
||
func downgradeUserGroupForSubscriptionTx(tx *gorm.DB, sub *UserSubscription, now int64) (string, error) {
|
||
if tx == nil || sub == nil {
|
||
return "", errors.New("invalid downgrade args")
|
||
}
|
||
upgradeGroup := strings.TrimSpace(sub.UpgradeGroup)
|
||
if upgradeGroup == "" {
|
||
return "", nil
|
||
}
|
||
currentGroup, err := getUserGroupByIdTx(tx, sub.UserId)
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
if currentGroup != upgradeGroup {
|
||
return "", nil
|
||
}
|
||
var activeSub UserSubscription
|
||
activeQuery := tx.Where("user_id = ? AND status = ? AND end_time > ? AND id <> ? AND upgrade_group <> ''",
|
||
sub.UserId, "active", now, sub.Id).
|
||
Order("end_time desc, id desc").
|
||
Limit(1).
|
||
Find(&activeSub)
|
||
if activeQuery.Error == nil && activeQuery.RowsAffected > 0 {
|
||
return "", nil
|
||
}
|
||
prevGroup := strings.TrimSpace(sub.PrevUserGroup)
|
||
if prevGroup == "" || prevGroup == currentGroup {
|
||
return "", nil
|
||
}
|
||
if err := tx.Model(&User{}).Where("id = ?", sub.UserId).
|
||
Update("group", prevGroup).Error; err != nil {
|
||
return "", err
|
||
}
|
||
return prevGroup, nil
|
||
}
|
||
|
||
func CreateUserSubscriptionFromPlanTx(tx *gorm.DB, userId int, plan *SubscriptionPlan, source string) (*UserSubscription, error) {
|
||
if tx == nil {
|
||
return nil, errors.New("tx is nil")
|
||
}
|
||
if plan == nil || plan.Id == 0 {
|
||
return nil, errors.New("invalid plan")
|
||
}
|
||
if userId <= 0 {
|
||
return nil, errors.New("invalid user id")
|
||
}
|
||
if plan.MaxPurchasePerUser > 0 {
|
||
var count int64
|
||
if err := tx.Model(&UserSubscription{}).
|
||
Where("user_id = ? AND plan_id = ?", userId, plan.Id).
|
||
Count(&count).Error; err != nil {
|
||
return nil, err
|
||
}
|
||
if count >= int64(plan.MaxPurchasePerUser) {
|
||
return nil, errors.New("已达到该套餐购买上限")
|
||
}
|
||
}
|
||
nowUnix := GetDBTimestamp()
|
||
now := time.Unix(nowUnix, 0)
|
||
endUnix, err := calcPlanEndTime(now, plan)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
resetBase := now
|
||
nextReset := calcNextResetTime(resetBase, plan, endUnix)
|
||
lastReset := int64(0)
|
||
if nextReset > 0 {
|
||
lastReset = now.Unix()
|
||
}
|
||
upgradeGroup := strings.TrimSpace(plan.UpgradeGroup)
|
||
prevGroup := ""
|
||
if upgradeGroup != "" {
|
||
currentGroup, err := getUserGroupByIdTx(tx, userId)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
if currentGroup != upgradeGroup {
|
||
prevGroup = currentGroup
|
||
if err := tx.Model(&User{}).Where("id = ?", userId).
|
||
Update("group", upgradeGroup).Error; err != nil {
|
||
return nil, err
|
||
}
|
||
}
|
||
}
|
||
sub := &UserSubscription{
|
||
UserId: userId,
|
||
PlanId: plan.Id,
|
||
AmountTotal: plan.TotalAmount,
|
||
AmountUsed: 0,
|
||
StartTime: now.Unix(),
|
||
EndTime: endUnix,
|
||
Status: "active",
|
||
Source: source,
|
||
LastResetTime: lastReset,
|
||
NextResetTime: nextReset,
|
||
UpgradeGroup: upgradeGroup,
|
||
PrevUserGroup: prevGroup,
|
||
CreatedAt: common.GetTimestamp(),
|
||
UpdatedAt: common.GetTimestamp(),
|
||
}
|
||
if err := tx.Create(sub).Error; err != nil {
|
||
return nil, err
|
||
}
|
||
return sub, nil
|
||
}
|
||
|
||
// Complete a subscription order (idempotent). Creates a UserSubscription snapshot from the plan.
|
||
func CompleteSubscriptionOrder(tradeNo string, providerPayload string) error {
|
||
if tradeNo == "" {
|
||
return errors.New("tradeNo is empty")
|
||
}
|
||
refCol := "`trade_no`"
|
||
if common.UsingPostgreSQL {
|
||
refCol = `"trade_no"`
|
||
}
|
||
var logUserId int
|
||
var logPlanTitle string
|
||
var logMoney float64
|
||
var logPaymentMethod string
|
||
var upgradeGroup string
|
||
err := DB.Transaction(func(tx *gorm.DB) error {
|
||
var order SubscriptionOrder
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").Where(refCol+" = ?", tradeNo).First(&order).Error; err != nil {
|
||
return ErrSubscriptionOrderNotFound
|
||
}
|
||
if order.Status == common.TopUpStatusSuccess {
|
||
return nil
|
||
}
|
||
if order.Status != common.TopUpStatusPending {
|
||
return ErrSubscriptionOrderStatusInvalid
|
||
}
|
||
plan, err := GetSubscriptionPlanById(order.PlanId)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if !plan.Enabled {
|
||
// still allow completion for already purchased orders
|
||
}
|
||
upgradeGroup = strings.TrimSpace(plan.UpgradeGroup)
|
||
_, err = CreateUserSubscriptionFromPlanTx(tx, order.UserId, plan, "order")
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if err := upsertSubscriptionTopUpTx(tx, &order); err != nil {
|
||
return err
|
||
}
|
||
order.Status = common.TopUpStatusSuccess
|
||
order.CompleteTime = common.GetTimestamp()
|
||
if providerPayload != "" {
|
||
order.ProviderPayload = providerPayload
|
||
}
|
||
if err := tx.Save(&order).Error; err != nil {
|
||
return err
|
||
}
|
||
logUserId = order.UserId
|
||
logPlanTitle = plan.Title
|
||
logMoney = order.Money
|
||
logPaymentMethod = order.PaymentMethod
|
||
return nil
|
||
})
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if upgradeGroup != "" && logUserId > 0 {
|
||
_ = UpdateUserGroupCache(logUserId, upgradeGroup)
|
||
}
|
||
if logUserId > 0 {
|
||
msg := fmt.Sprintf("订阅购买成功,套餐: %s,支付金额: %.2f,支付方式: %s", logPlanTitle, logMoney, logPaymentMethod)
|
||
RecordLog(logUserId, LogTypeTopup, msg)
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func upsertSubscriptionTopUpTx(tx *gorm.DB, order *SubscriptionOrder) error {
|
||
if tx == nil || order == nil {
|
||
return errors.New("invalid subscription order")
|
||
}
|
||
now := common.GetTimestamp()
|
||
var topup TopUp
|
||
if err := tx.Where("trade_no = ?", order.TradeNo).First(&topup).Error; err != nil {
|
||
if errors.Is(err, gorm.ErrRecordNotFound) {
|
||
topup = TopUp{
|
||
UserId: order.UserId,
|
||
Amount: 0,
|
||
Money: order.Money,
|
||
TradeNo: order.TradeNo,
|
||
PaymentMethod: order.PaymentMethod,
|
||
CreateTime: order.CreateTime,
|
||
CompleteTime: now,
|
||
Status: common.TopUpStatusSuccess,
|
||
}
|
||
return tx.Create(&topup).Error
|
||
}
|
||
return err
|
||
}
|
||
topup.Money = order.Money
|
||
if topup.PaymentMethod == "" {
|
||
topup.PaymentMethod = order.PaymentMethod
|
||
}
|
||
if topup.CreateTime == 0 {
|
||
topup.CreateTime = order.CreateTime
|
||
}
|
||
topup.CompleteTime = now
|
||
topup.Status = common.TopUpStatusSuccess
|
||
return tx.Save(&topup).Error
|
||
}
|
||
|
||
func ExpireSubscriptionOrder(tradeNo string) error {
|
||
if tradeNo == "" {
|
||
return errors.New("tradeNo is empty")
|
||
}
|
||
refCol := "`trade_no`"
|
||
if common.UsingPostgreSQL {
|
||
refCol = `"trade_no"`
|
||
}
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var order SubscriptionOrder
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").Where(refCol+" = ?", tradeNo).First(&order).Error; err != nil {
|
||
return ErrSubscriptionOrderNotFound
|
||
}
|
||
if order.Status != common.TopUpStatusPending {
|
||
return nil
|
||
}
|
||
order.Status = common.TopUpStatusExpired
|
||
order.CompleteTime = common.GetTimestamp()
|
||
return tx.Save(&order).Error
|
||
})
|
||
}
|
||
|
||
// Admin bind (no payment). Creates a UserSubscription from a plan.
|
||
func AdminBindSubscription(userId int, planId int, sourceNote string) (string, error) {
|
||
if userId <= 0 || planId <= 0 {
|
||
return "", errors.New("invalid userId or planId")
|
||
}
|
||
plan, err := GetSubscriptionPlanById(planId)
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
err = DB.Transaction(func(tx *gorm.DB) error {
|
||
_, err := CreateUserSubscriptionFromPlanTx(tx, userId, plan, "admin")
|
||
return err
|
||
})
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
if strings.TrimSpace(plan.UpgradeGroup) != "" {
|
||
_ = UpdateUserGroupCache(userId, plan.UpgradeGroup)
|
||
return fmt.Sprintf("用户分组将升级到 %s", plan.UpgradeGroup), nil
|
||
}
|
||
return "", nil
|
||
}
|
||
|
||
// GetAllActiveUserSubscriptions returns all active subscriptions for a user.
|
||
func GetAllActiveUserSubscriptions(userId int) ([]SubscriptionSummary, error) {
|
||
if userId <= 0 {
|
||
return nil, errors.New("invalid userId")
|
||
}
|
||
now := common.GetTimestamp()
|
||
var subs []UserSubscription
|
||
err := DB.Where("user_id = ? AND status = ? AND end_time > ?", userId, "active", now).
|
||
Order("end_time desc, id desc").
|
||
Find(&subs).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return buildSubscriptionSummaries(subs), nil
|
||
}
|
||
|
||
// GetAllUserSubscriptions returns all subscriptions (active and expired) for a user.
|
||
func GetAllUserSubscriptions(userId int) ([]SubscriptionSummary, error) {
|
||
if userId <= 0 {
|
||
return nil, errors.New("invalid userId")
|
||
}
|
||
var subs []UserSubscription
|
||
err := DB.Where("user_id = ?", userId).
|
||
Order("end_time desc, id desc").
|
||
Find(&subs).Error
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return buildSubscriptionSummaries(subs), nil
|
||
}
|
||
|
||
func buildSubscriptionSummaries(subs []UserSubscription) []SubscriptionSummary {
|
||
if len(subs) == 0 {
|
||
return []SubscriptionSummary{}
|
||
}
|
||
result := make([]SubscriptionSummary, 0, len(subs))
|
||
for _, sub := range subs {
|
||
subCopy := sub
|
||
result = append(result, SubscriptionSummary{
|
||
Subscription: &subCopy,
|
||
})
|
||
}
|
||
return result
|
||
}
|
||
|
||
// AdminInvalidateUserSubscription marks a user subscription as cancelled and ends it immediately.
|
||
func AdminInvalidateUserSubscription(userSubscriptionId int) (string, error) {
|
||
if userSubscriptionId <= 0 {
|
||
return "", errors.New("invalid userSubscriptionId")
|
||
}
|
||
now := common.GetTimestamp()
|
||
cacheGroup := ""
|
||
downgradeGroup := ""
|
||
var userId int
|
||
err := DB.Transaction(func(tx *gorm.DB) error {
|
||
var sub UserSubscription
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").
|
||
Where("id = ?", userSubscriptionId).First(&sub).Error; err != nil {
|
||
return err
|
||
}
|
||
userId = sub.UserId
|
||
if err := tx.Model(&sub).Updates(map[string]interface{}{
|
||
"status": "cancelled",
|
||
"end_time": now,
|
||
"updated_at": now,
|
||
}).Error; err != nil {
|
||
return err
|
||
}
|
||
target, err := downgradeUserGroupForSubscriptionTx(tx, &sub, now)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if target != "" {
|
||
cacheGroup = target
|
||
downgradeGroup = target
|
||
}
|
||
return nil
|
||
})
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
if cacheGroup != "" && userId > 0 {
|
||
_ = UpdateUserGroupCache(userId, cacheGroup)
|
||
}
|
||
if downgradeGroup != "" {
|
||
return fmt.Sprintf("用户分组将回退到 %s", downgradeGroup), nil
|
||
}
|
||
return "", nil
|
||
}
|
||
|
||
// AdminDeleteUserSubscription hard-deletes a user subscription.
|
||
func AdminDeleteUserSubscription(userSubscriptionId int) (string, error) {
|
||
if userSubscriptionId <= 0 {
|
||
return "", errors.New("invalid userSubscriptionId")
|
||
}
|
||
now := common.GetTimestamp()
|
||
cacheGroup := ""
|
||
downgradeGroup := ""
|
||
var userId int
|
||
err := DB.Transaction(func(tx *gorm.DB) error {
|
||
var sub UserSubscription
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").
|
||
Where("id = ?", userSubscriptionId).First(&sub).Error; err != nil {
|
||
return err
|
||
}
|
||
userId = sub.UserId
|
||
target, err := downgradeUserGroupForSubscriptionTx(tx, &sub, now)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if target != "" {
|
||
cacheGroup = target
|
||
downgradeGroup = target
|
||
}
|
||
if err := tx.Where("id = ?", userSubscriptionId).Delete(&UserSubscription{}).Error; err != nil {
|
||
return err
|
||
}
|
||
return nil
|
||
})
|
||
if err != nil {
|
||
return "", err
|
||
}
|
||
if cacheGroup != "" && userId > 0 {
|
||
_ = UpdateUserGroupCache(userId, cacheGroup)
|
||
}
|
||
if downgradeGroup != "" {
|
||
return fmt.Sprintf("用户分组将回退到 %s", downgradeGroup), nil
|
||
}
|
||
return "", nil
|
||
}
|
||
|
||
type SubscriptionPreConsumeResult struct {
|
||
UserSubscriptionId int
|
||
PreConsumed int64
|
||
AmountTotal int64
|
||
AmountUsedBefore int64
|
||
AmountUsedAfter int64
|
||
}
|
||
|
||
// ExpireDueSubscriptions marks expired subscriptions and handles group downgrade.
|
||
func ExpireDueSubscriptions(limit int) (int, error) {
|
||
if limit <= 0 {
|
||
limit = 200
|
||
}
|
||
now := GetDBTimestamp()
|
||
var subs []UserSubscription
|
||
if err := DB.Where("status = ? AND end_time > 0 AND end_time <= ?", "active", now).
|
||
Order("end_time asc, id asc").
|
||
Limit(limit).
|
||
Find(&subs).Error; err != nil {
|
||
return 0, err
|
||
}
|
||
if len(subs) == 0 {
|
||
return 0, nil
|
||
}
|
||
expiredCount := 0
|
||
userIds := make(map[int]struct{}, len(subs))
|
||
for _, sub := range subs {
|
||
if sub.UserId > 0 {
|
||
userIds[sub.UserId] = struct{}{}
|
||
}
|
||
}
|
||
for userId := range userIds {
|
||
cacheGroup := ""
|
||
err := DB.Transaction(func(tx *gorm.DB) error {
|
||
res := tx.Model(&UserSubscription{}).
|
||
Where("user_id = ? AND status = ? AND end_time > 0 AND end_time <= ?", userId, "active", now).
|
||
Updates(map[string]interface{}{
|
||
"status": "expired",
|
||
"updated_at": common.GetTimestamp(),
|
||
})
|
||
if res.Error != nil {
|
||
return res.Error
|
||
}
|
||
expiredCount += int(res.RowsAffected)
|
||
|
||
// If there's an active upgraded subscription, keep current group.
|
||
var activeSub UserSubscription
|
||
activeQuery := tx.Where("user_id = ? AND status = ? AND end_time > ? AND upgrade_group <> ''",
|
||
userId, "active", now).
|
||
Order("end_time desc, id desc").
|
||
Limit(1).
|
||
Find(&activeSub)
|
||
if activeQuery.Error == nil && activeQuery.RowsAffected > 0 {
|
||
return nil
|
||
}
|
||
|
||
// No active upgraded subscription, downgrade to previous group if needed.
|
||
var lastExpired UserSubscription
|
||
expiredQuery := tx.Where("user_id = ? AND status = ? AND upgrade_group <> ''",
|
||
userId, "expired").
|
||
Order("end_time desc, id desc").
|
||
Limit(1).
|
||
Find(&lastExpired)
|
||
if expiredQuery.Error != nil || expiredQuery.RowsAffected == 0 {
|
||
return nil
|
||
}
|
||
upgradeGroup := strings.TrimSpace(lastExpired.UpgradeGroup)
|
||
prevGroup := strings.TrimSpace(lastExpired.PrevUserGroup)
|
||
if upgradeGroup == "" || prevGroup == "" {
|
||
return nil
|
||
}
|
||
currentGroup, err := getUserGroupByIdTx(tx, userId)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if currentGroup != upgradeGroup || currentGroup == prevGroup {
|
||
return nil
|
||
}
|
||
if err := tx.Model(&User{}).Where("id = ?", userId).
|
||
Update("group", prevGroup).Error; err != nil {
|
||
return err
|
||
}
|
||
cacheGroup = prevGroup
|
||
return nil
|
||
})
|
||
if err != nil {
|
||
return expiredCount, err
|
||
}
|
||
if cacheGroup != "" {
|
||
_ = UpdateUserGroupCache(userId, cacheGroup)
|
||
}
|
||
}
|
||
return expiredCount, nil
|
||
}
|
||
|
||
// SubscriptionPreConsumeRecord stores idempotent pre-consume operations per request.
|
||
type SubscriptionPreConsumeRecord struct {
|
||
Id int `json:"id"`
|
||
RequestId string `json:"request_id" gorm:"type:varchar(64);uniqueIndex"`
|
||
UserId int `json:"user_id" gorm:"index"`
|
||
UserSubscriptionId int `json:"user_subscription_id" gorm:"index"`
|
||
PreConsumed int64 `json:"pre_consumed" gorm:"type:bigint;not null;default:0"`
|
||
Status string `json:"status" gorm:"type:varchar(32);index"` // consumed/refunded
|
||
CreatedAt int64 `json:"created_at" gorm:"bigint"`
|
||
UpdatedAt int64 `json:"updated_at" gorm:"bigint;index"`
|
||
}
|
||
|
||
func (r *SubscriptionPreConsumeRecord) BeforeCreate(tx *gorm.DB) error {
|
||
now := common.GetTimestamp()
|
||
r.CreatedAt = now
|
||
r.UpdatedAt = now
|
||
return nil
|
||
}
|
||
|
||
func (r *SubscriptionPreConsumeRecord) BeforeUpdate(tx *gorm.DB) error {
|
||
r.UpdatedAt = common.GetTimestamp()
|
||
return nil
|
||
}
|
||
|
||
func maybeResetUserSubscriptionWithPlanTx(tx *gorm.DB, sub *UserSubscription, plan *SubscriptionPlan, now int64) error {
|
||
if tx == nil || sub == nil || plan == nil {
|
||
return errors.New("invalid reset args")
|
||
}
|
||
if sub.NextResetTime > 0 && sub.NextResetTime > now {
|
||
return nil
|
||
}
|
||
if NormalizeResetPeriod(plan.QuotaResetPeriod) == SubscriptionResetNever {
|
||
return nil
|
||
}
|
||
baseUnix := sub.LastResetTime
|
||
if baseUnix <= 0 {
|
||
baseUnix = sub.StartTime
|
||
}
|
||
base := time.Unix(baseUnix, 0)
|
||
next := calcNextResetTime(base, plan, sub.EndTime)
|
||
advanced := false
|
||
for next > 0 && next <= now {
|
||
advanced = true
|
||
base = time.Unix(next, 0)
|
||
next = calcNextResetTime(base, plan, sub.EndTime)
|
||
}
|
||
if !advanced {
|
||
if sub.NextResetTime == 0 && next > 0 {
|
||
sub.NextResetTime = next
|
||
sub.LastResetTime = base.Unix()
|
||
return tx.Save(sub).Error
|
||
}
|
||
return nil
|
||
}
|
||
sub.AmountUsed = 0
|
||
sub.LastResetTime = base.Unix()
|
||
sub.NextResetTime = next
|
||
return tx.Save(sub).Error
|
||
}
|
||
|
||
// PreConsumeUserSubscription pre-consumes from any active subscription total quota.
|
||
func PreConsumeUserSubscription(requestId string, userId int, modelName string, quotaType int, amount int64) (*SubscriptionPreConsumeResult, error) {
|
||
if userId <= 0 {
|
||
return nil, errors.New("invalid userId")
|
||
}
|
||
if strings.TrimSpace(requestId) == "" {
|
||
return nil, errors.New("requestId is empty")
|
||
}
|
||
if amount <= 0 {
|
||
return nil, errors.New("amount must be > 0")
|
||
}
|
||
now := GetDBTimestamp()
|
||
|
||
returnValue := &SubscriptionPreConsumeResult{}
|
||
|
||
err := DB.Transaction(func(tx *gorm.DB) error {
|
||
var existing SubscriptionPreConsumeRecord
|
||
query := tx.Where("request_id = ?", requestId).Limit(1).Find(&existing)
|
||
if query.Error != nil {
|
||
return query.Error
|
||
}
|
||
if query.RowsAffected > 0 {
|
||
if existing.Status == "refunded" {
|
||
return errors.New("subscription pre-consume already refunded")
|
||
}
|
||
var sub UserSubscription
|
||
if err := tx.Where("id = ?", existing.UserSubscriptionId).First(&sub).Error; err != nil {
|
||
return err
|
||
}
|
||
returnValue.UserSubscriptionId = sub.Id
|
||
returnValue.PreConsumed = existing.PreConsumed
|
||
returnValue.AmountTotal = sub.AmountTotal
|
||
returnValue.AmountUsedBefore = sub.AmountUsed
|
||
returnValue.AmountUsedAfter = sub.AmountUsed
|
||
return nil
|
||
}
|
||
|
||
var subs []UserSubscription
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").
|
||
Where("user_id = ? AND status = ? AND end_time > ?", userId, "active", now).
|
||
Order("end_time asc, id asc").
|
||
Find(&subs).Error; err != nil {
|
||
return errors.New("no active subscription")
|
||
}
|
||
if len(subs) == 0 {
|
||
return errors.New("no active subscription")
|
||
}
|
||
for _, candidate := range subs {
|
||
sub := candidate
|
||
plan, err := getSubscriptionPlanByIdTx(tx, sub.PlanId)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if err := maybeResetUserSubscriptionWithPlanTx(tx, &sub, plan, now); err != nil {
|
||
return err
|
||
}
|
||
usedBefore := sub.AmountUsed
|
||
if sub.AmountTotal > 0 {
|
||
remain := sub.AmountTotal - usedBefore
|
||
if remain < amount {
|
||
continue
|
||
}
|
||
}
|
||
record := &SubscriptionPreConsumeRecord{
|
||
RequestId: requestId,
|
||
UserId: userId,
|
||
UserSubscriptionId: sub.Id,
|
||
PreConsumed: amount,
|
||
Status: "consumed",
|
||
}
|
||
if err := tx.Create(record).Error; err != nil {
|
||
var dup SubscriptionPreConsumeRecord
|
||
if err2 := tx.Where("request_id = ?", requestId).First(&dup).Error; err2 == nil {
|
||
if dup.Status == "refunded" {
|
||
return errors.New("subscription pre-consume already refunded")
|
||
}
|
||
returnValue.UserSubscriptionId = sub.Id
|
||
returnValue.PreConsumed = dup.PreConsumed
|
||
returnValue.AmountTotal = sub.AmountTotal
|
||
returnValue.AmountUsedBefore = sub.AmountUsed
|
||
returnValue.AmountUsedAfter = sub.AmountUsed
|
||
return nil
|
||
}
|
||
return err
|
||
}
|
||
sub.AmountUsed += amount
|
||
if err := tx.Save(&sub).Error; err != nil {
|
||
return err
|
||
}
|
||
returnValue.UserSubscriptionId = sub.Id
|
||
returnValue.PreConsumed = amount
|
||
returnValue.AmountTotal = sub.AmountTotal
|
||
returnValue.AmountUsedBefore = usedBefore
|
||
returnValue.AmountUsedAfter = sub.AmountUsed
|
||
return nil
|
||
}
|
||
return fmt.Errorf("subscription quota insufficient, need=%d", amount)
|
||
})
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
return returnValue, nil
|
||
}
|
||
|
||
// RefundSubscriptionPreConsume is idempotent and refunds pre-consumed subscription quota by requestId.
|
||
func RefundSubscriptionPreConsume(requestId string) error {
|
||
if strings.TrimSpace(requestId) == "" {
|
||
return errors.New("requestId is empty")
|
||
}
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var record SubscriptionPreConsumeRecord
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").
|
||
Where("request_id = ?", requestId).First(&record).Error; err != nil {
|
||
return err
|
||
}
|
||
if record.Status == "refunded" {
|
||
return nil
|
||
}
|
||
if record.PreConsumed <= 0 {
|
||
record.Status = "refunded"
|
||
return tx.Save(&record).Error
|
||
}
|
||
if err := PostConsumeUserSubscriptionDelta(record.UserSubscriptionId, -record.PreConsumed); err != nil {
|
||
return err
|
||
}
|
||
record.Status = "refunded"
|
||
return tx.Save(&record).Error
|
||
})
|
||
}
|
||
|
||
// ResetDueSubscriptions resets subscriptions whose next_reset_time has passed.
|
||
func ResetDueSubscriptions(limit int) (int, error) {
|
||
if limit <= 0 {
|
||
limit = 200
|
||
}
|
||
now := GetDBTimestamp()
|
||
var subs []UserSubscription
|
||
if err := DB.Where("next_reset_time > 0 AND next_reset_time <= ? AND status = ?", now, "active").
|
||
Order("next_reset_time asc").
|
||
Limit(limit).
|
||
Find(&subs).Error; err != nil {
|
||
return 0, err
|
||
}
|
||
if len(subs) == 0 {
|
||
return 0, nil
|
||
}
|
||
resetCount := 0
|
||
for _, sub := range subs {
|
||
subCopy := sub
|
||
plan, err := getSubscriptionPlanByIdTx(nil, sub.PlanId)
|
||
if err != nil || plan == nil {
|
||
continue
|
||
}
|
||
err = DB.Transaction(func(tx *gorm.DB) error {
|
||
var locked UserSubscription
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").
|
||
Where("id = ? AND next_reset_time > 0 AND next_reset_time <= ?", subCopy.Id, now).
|
||
First(&locked).Error; err != nil {
|
||
return nil
|
||
}
|
||
if err := maybeResetUserSubscriptionWithPlanTx(tx, &locked, plan, now); err != nil {
|
||
return err
|
||
}
|
||
resetCount++
|
||
return nil
|
||
})
|
||
if err != nil {
|
||
return resetCount, err
|
||
}
|
||
}
|
||
return resetCount, nil
|
||
}
|
||
|
||
// CleanupSubscriptionPreConsumeRecords removes old idempotency records to keep table small.
|
||
func CleanupSubscriptionPreConsumeRecords(olderThanSeconds int64) (int64, error) {
|
||
if olderThanSeconds <= 0 {
|
||
olderThanSeconds = 7 * 24 * 3600
|
||
}
|
||
cutoff := GetDBTimestamp() - olderThanSeconds
|
||
res := DB.Where("updated_at < ?", cutoff).Delete(&SubscriptionPreConsumeRecord{})
|
||
return res.RowsAffected, res.Error
|
||
}
|
||
|
||
type SubscriptionPlanInfo struct {
|
||
PlanId int
|
||
PlanTitle string
|
||
}
|
||
|
||
func GetSubscriptionPlanInfoByUserSubscriptionId(userSubscriptionId int) (*SubscriptionPlanInfo, error) {
|
||
if userSubscriptionId <= 0 {
|
||
return nil, errors.New("invalid userSubscriptionId")
|
||
}
|
||
cacheKey := fmt.Sprintf("sub:%d", userSubscriptionId)
|
||
if cached, found, err := getSubscriptionPlanInfoCache().Get(cacheKey); err == nil && found {
|
||
return &cached, nil
|
||
}
|
||
var sub UserSubscription
|
||
if err := DB.Where("id = ?", userSubscriptionId).First(&sub).Error; err != nil {
|
||
return nil, err
|
||
}
|
||
plan, err := getSubscriptionPlanByIdTx(nil, sub.PlanId)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
info := &SubscriptionPlanInfo{
|
||
PlanId: sub.PlanId,
|
||
PlanTitle: plan.Title,
|
||
}
|
||
_ = getSubscriptionPlanInfoCache().SetWithTTL(cacheKey, *info, subscriptionPlanInfoCacheTTL())
|
||
return info, nil
|
||
}
|
||
|
||
// Update subscription used amount by delta (positive consume more, negative refund).
|
||
func PostConsumeUserSubscriptionDelta(userSubscriptionId int, delta int64) error {
|
||
if userSubscriptionId <= 0 {
|
||
return errors.New("invalid userSubscriptionId")
|
||
}
|
||
if delta == 0 {
|
||
return nil
|
||
}
|
||
return DB.Transaction(func(tx *gorm.DB) error {
|
||
var sub UserSubscription
|
||
if err := tx.Set("gorm:query_option", "FOR UPDATE").
|
||
Where("id = ?", userSubscriptionId).
|
||
First(&sub).Error; err != nil {
|
||
return err
|
||
}
|
||
newUsed := sub.AmountUsed + delta
|
||
if newUsed < 0 {
|
||
newUsed = 0
|
||
}
|
||
if sub.AmountTotal > 0 && newUsed > sub.AmountTotal {
|
||
return fmt.Errorf("subscription used exceeds total, used=%d total=%d", newUsed, sub.AmountTotal)
|
||
}
|
||
sub.AmountUsed = newUsed
|
||
return tx.Save(&sub).Error
|
||
})
|
||
}
|