Method handleInvoicePaid

internal/payment/webhook.go:262–349

(event stripe.Event)

}

func (d *WebhookDeps) handleInvoicePaid(event stripe.Event) {
	var invoice struct {
		ID            string `json:"id"`
		Subscription  string `json:"subscription"`
		Customer      string `json:"customer"`
		BillingReason string `json:"billing_reason"`
	}
	if err := json.Unmarshal(event.Data.Raw, &invoice); err != nil {
		log.Printf("payment: unmarshal invoice: %v", err)
		return
	}
	if invoice.Subscription == "" {
		return
	}
	// 首次订阅已由 checkout.session.completed 处理，跳过避免双倍延期
	if invoice.BillingReason == "subscription_create" {
		return
	}

	order, err := d.OrderStore.GetOrderByStripeSubscription(invoice.Subscription)
	if err != nil {
		log.Printf("payment: get order by subscription %s: %v", invoice.Subscription, err)
		return
	}
	if order.UserID == "" {
		return
	}

	// 幂等性：原子地认领 invoice，防止并发重试导致双倍续费（Stripe 保证至少一次投递）。
	if invoice.ID != "" {
		claimed, err := d.OrderStore.ClaimInvoice(order.ID, invoice.ID)
		if err != nil {
			log.Printf("payment: claim invoice %s for order %s: %v", invoice.ID, order.ID, err)
			return
		}
		if !claimed {
			log.Printf("payment: invoice %s already processed for order %s, skipping", invoice.ID, order.ID)
			return
		}
	}

	plan, err := d.PlanStore.GetPlan(order.PlanID)
	if err != nil {
		log.Printf("payment: get plan %s for invoice: %v", order.PlanID, err)
		return
	}

	user, err := d.UserStore.GetUser(order.UserID)
	if err != nil {
		log.Printf("payment: get user %s for invoice: %v", order.UserID, err)
		return
	}

	now := time.Now().UTC()
	base := now
	if user.ExpireAt != nil && user.ExpireAt.After(now) {
		base = *user.ExpireAt
	}