Function SyncSubscriptions

internal/payment/sync.go:17–103

SyncSubscriptions checks all active subscription orders against Stripe to catch any missed webhook events (cancellations, failures, etc.). sg 用于动态读取 Stripe 密钥；若未配置则静默跳过。

(ctx context.Context, sg SettingsGetter, envSecretKey string, orderStore orders.Store, userStore users.Store)

// to catch any missed webhook events (cancellations, failures, etc.).
// sg 用于动态读取 Stripe 密钥；若未配置则静默跳过。
func SyncSubscriptions(ctx context.Context, sg SettingsGetter, envSecretKey string, orderStore orders.Store, userStore users.Store) error {
	liveKey, hasLive := ResolveSecretKeyByMode(sg, "live", envSecretKey)
	testKey, hasTest := ResolveSecretKeyByMode(sg, "test", "")
	if !hasLive && !hasTest {
		return nil
	}

	allOrders, err := orderStore.ListOrders()
	if err != nil {
		return err
	}

	for _, order := range allOrders {
		if order.StripeSubscriptionID == "" || order.Status != orders.StatusPaid {
			continue
		}

		select {
		case <-ctx.Done():
			return ctx.Err()
		default:
		}

		var sub *stripe.Subscription
		if hasLive {
			sub, err = GetSubscription(liveKey, order.StripeSubscriptionID)
		}
		if err != nil && hasTest {
			sub, err = GetSubscription(testKey, order.StripeSubscriptionID)
		}
		if err != nil {
			log.Printf("sync-stripe: get subscription %s: %v", order.StripeSubscriptionID, err)
			continue
		}

		switch sub.Status {
		case stripe.SubscriptionStatusCanceled,
			stripe.SubscriptionStatusUnpaid,
			stripe.SubscriptionStatusIncompleteExpired:
			// 不覆盖已退款订单的终态
			if order.Status == orders.StatusRefunded {
				continue
			}
			order.Status = orders.StatusFailed
			if _, err := orderStore.UpsertOrder(order); err != nil {
				log.Printf("sync-stripe: update order %s: %v", order.ID, err)
			}
			if order.UserID != "" {
				user, err := userStore.GetUser(order.UserID)
				if err == nil && user.Status == users.StatusActive {
					user.Status = users.StatusDisabled
					user.CurrentPlanID = ""
					if _, err := userStore.UpsertUser(user); err != nil {
						log.Printf("sync-stripe: disable user %s: %v", user.ID, err)
					} else {
						log.Printf("sync-stripe: disabled user %s (subscription %s cancelled)", user.Username, order.StripeSubscriptionID)
					}
				}