Method renewExistingUser

internal/payment/webhook.go:196–260

(order orders.Order, plan plans.Plan, now time.Time)

}

func (d *WebhookDeps) renewExistingUser(order orders.Order, plan plans.Plan, now time.Time) error {
	user, err := d.UserStore.GetUser(order.UserID)
	if err != nil {
		return fmt.Errorf("get user %s: %w", order.UserID, err)
	}

	// 到期时间：未过期则从当前到期时间延长，已过期则从现在起算
	notExpired := user.ExpireAt != nil && user.ExpireAt.After(now)
	base := now
	if notExpired {
		base = *user.ExpireAt
	}
	expireAt := base.Add(time.Duration(plan.DurationDays) * 24 * time.Hour)
	user.ExpireAt = &expireAt

	// 流量：剩余量叠加到新套餐额度，清零计数器以保证 SyncUsage delta 正确
	user.PlanTrafficLimit = plan.TrafficLimit
	if plan.TrafficLimit == 0 {
		user.TrafficLimit = 0 // 新套餐无限流量
	} else {
		remaining := user.TrafficLimit - user.UsedBytes
		if remaining < 0 {
			remaining = 0
		}
		user.TrafficLimit = remaining + plan.TrafficLimit
	}
	user.UploadBytes = 0
	user.DownloadBytes = 0
	user.UsedBytes = 0
	user.RawUploadBytes = 0
	user.RawDownloadBytes = 0
	// 未过期续费时以旧 ExpireAt 为锚点，确保下次定时重置与套餐周期对齐
	if notExpired {
		user.LastTrafficResetAt = user.ExpireAt
	} else {
		user.LastTrafficResetAt = &now
	}
	user.DataLimitResetStrategy = plan.DataLimitResetStrategy
	user.CurrentPlanID = plan.ID
	user.Status = users.StatusActive

	if _, err := d.UserStore.UpsertUser(user); err != nil {
		return fmt.Errorf("update user %s: %w", user.ID, err)
	}
	if err := d.UserStore.ClearUserNodeDailyUsage(user.ID); err != nil {
		log.Printf("payment: renew clear daily usage user %s: %v", user.ID, err)
	}

	// 加入套餐绑定的用户组
	if plan.UserGroupIDs != "" {
		gIDs := strings.Split(plan.UserGroupIDs, ",")
		for i := range gIDs {
			gIDs[i] = strings.TrimSpace(gIDs[i])
		}
		if err := d.AddUserToGroups(user.ID, gIDs); err != nil {
			log.Printf("payment: renew add user to groups: %v", err)
		}
	}