feat: 为 topup 流程添加详细的 debug 日志

- 添加请求 URL、请求体、请求头的 debug 日志
- 添加响应状态码、响应体长度的 debug 日志
- 添加账号下载过程的详细日志
- 添加 auth_json 和 download_url 的处理日志
- 便于排查 topup 返回 0 个账号的问题

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: Devocy

internal/topup/client.go

@@ -91,6 +91,10 @@ func (c *Client) sendRequest(url string, req *TopupRequest) (*TopupResponse, err
 		return nil, fmt.Errorf("failed to marshal request: %w", err)
 	}
 
+	logger.Debug("Topup 请求 URL: %s", url)
+	logger.Debug("Topup 请求体: target_pool_size=%d, reports=%d, account_ids=%d",
+		req.TargetPoolSize, len(req.Reports), len(req.AccountIDs))
+
 	// Create HTTP request
 	httpReq, err := http.NewRequest("POST", url, bytes.NewReader(data))
 	if err != nil {
@@ -100,6 +104,7 @@ func (c *Client) sendRequest(url string, req *TopupRequest) (*TopupResponse, err
 	// Set headers
 	httpReq.Header.Set("Content-Type", "application/json")
 	httpReq.Header.Set("X-User-Key", c.userKey)
+	logger.Debug("Topup 请求头: X-User-Key=%s...%s", c.userKey[:8], c.userKey[len(c.userKey)-4:])
 
 	// Send request
 	httpResp, err := c.httpClient.Do(httpReq)
@@ -108,23 +113,32 @@ func (c *Client) sendRequest(url string, req *TopupRequest) (*TopupResponse, err
 	}
 	defer httpResp.Body.Close()
 
+	logger.Debug("Topup 响应状态码: %d", httpResp.StatusCode)
+
 	// Read response
 	body, err := io.ReadAll(httpResp.Body)
 	if err != nil {
 		return nil, fmt.Errorf("failed to read response: %w", err)
 	}
 
+	logger.Debug("Topup 响应体长度: %d bytes", len(body))
+
 	// Check status code
 	if httpResp.StatusCode != http.StatusOK {
+		logger.Debug("Topup 错误响应: %s", string(body))
 		return nil, fmt.Errorf("server returned status %d: %s", httpResp.StatusCode, string(body))
 	}
 
 	// Parse response
 	var resp TopupResponse
 	if err := json.Unmarshal(body, &resp); err != nil {
+		logger.Debug("Topup 响应解析失败: %s", string(body))
 		return nil, fmt.Errorf("failed to parse response: %w", err)
 	}
 
+	logger.Debug("Topup 响应: ok=%v, accounts=%d, auto_disabled=%v, abuse_auto_banned=%v, total_hold_limit=%d",
+		resp.OK, len(resp.Accounts), resp.AutoDisabled, resp.AbuseAutoBanned, resp.TotalHoldLimit)
+
 	return &resp, nil
 }
 

internal/topup/response.go

@@ -16,32 +16,42 @@ import (
 func DownloadAccounts(resp *TopupResponse, accountsDir string, httpClient *http.Client) ([]account.Account, error) {
 	var newAccounts []account.Account
 
-	for _, accInfo := range resp.Accounts {
-		logger.Info("处理账号：%s", accInfo.FileName)
+	logger.Debug("开始下载账号：总数=%d", len(resp.Accounts))
+
+	for i, accInfo := range resp.Accounts {
+		logger.Info("处理账号 %d/%d：%s", i+1, len(resp.Accounts), accInfo.FileName)
+		logger.Debug("账号信息: download_url=%s, auth_json_len=%d",
+			accInfo.DownloadURL, len(accInfo.AuthJSON))
 
 		var acc account.Account
 
 		// Try to use auth_json first
 		if len(accInfo.AuthJSON) > 0 {
+			logger.Debug("使用 auth_json 解析账号")
 			if err := json.Unmarshal(accInfo.AuthJSON, &acc); err != nil {
 				logger.Warn("解析 %s 的 auth_json 失败：%v", accInfo.FileName, err)
+				logger.Debug("auth_json 内容: %s", string(accInfo.AuthJSON))
 				continue
 			}
+			logger.Debug("auth_json 解析成功: account_id=%s, email=%s", acc.AccountID, acc.Email)
 		} else if accInfo.DownloadURL != "" {
 			// Download from URL
+			logger.Debug("从 URL 下载账号: %s", accInfo.DownloadURL)
 			var err error
 			acc, err = downloadFromURL(accInfo.DownloadURL, httpClient)
 			if err != nil {
 				logger.Warn("从 %s 下载账号失败：%v", accInfo.DownloadURL, err)
 				continue
 			}
+			logger.Debug("URL 下载成功: account_id=%s, email=%s", acc.AccountID, acc.Email)
 		} else {
 			logger.Warn("%s 没有 auth_json 或 download_url", accInfo.FileName)
 			continue
 		}
 
 		// Set file path
 		acc.FilePath = filepath.Join(accountsDir, accInfo.FileName)
+		logger.Debug("设置文件路径: %s", acc.FilePath)
 
 		// Save account
 		storage := account.NewStorage(accountsDir)
@@ -54,18 +64,24 @@ func DownloadAccounts(resp *TopupResponse, accountsDir string, httpClient *http.
 		newAccounts = append(newAccounts, acc)
 	}
 
+	logger.Debug("下载完成：成功=%d, 失败=%d", len(newAccounts), len(resp.Accounts)-len(newAccounts))
+
 	return newAccounts, nil
 }
 
 func downloadFromURL(url string, httpClient *http.Client) (account.Account, error) {
 	var acc account.Account
 
+	logger.Debug("开始从 URL 下载: %s", url)
+
 	resp, err := httpClient.Get(url)
 	if err != nil {
 		return acc, fmt.Errorf("failed to download: %w", err)
 	}
 	defer resp.Body.Close()
 
+	logger.Debug("下载响应状态码: %d", resp.StatusCode)
+
 	if resp.StatusCode != http.StatusOK {
 		return acc, fmt.Errorf("download failed with status %d", resp.StatusCode)
 	}
@@ -75,7 +91,10 @@ func downloadFromURL(url string, httpClient *http.Client) (account.Account, erro
 		return acc, fmt.Errorf("failed to read response: %w", err)
 	}
 
+	logger.Debug("下载响应体长度: %d bytes", len(body))
+
 	if err := json.Unmarshal(body, &acc); err != nil {
+		logger.Debug("解析失败的 JSON: %s", string(body))
 		return acc, fmt.Errorf("failed to parse account JSON: %w", err)
 	}