opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: 上传相关日志改用结构化输出并统一错误信息

Browse source
This commit is contained in:
boydzheng 2026-03-08 17:42:31 +08:00
parent 9d65af13e4
commit 2334ba5efa
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
pkg/channels/qq/media.go
View file

@ -15,6 +15,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/sipeed/picoclaw/pkg/logger"
"github.com/tencent-connect/botgo/dto" "github.com/tencent-connect/botgo/dto"
"github.com/tencent-connect/botgo/openapi" "github.com/tencent-connect/botgo/openapi"
"golang.org/x/oauth2" "golang.org/x/oauth2"
@ -160,14 +161,18 @@ func (c *Client) apiRequestWithRetry(ctx context.Context, accessToken, method, p
// Fast-fail on non-retriable errors // Fast-fail on non-retriable errors
if strings.Contains(errMsg, "400") || strings.Contains(errMsg, "401") || if strings.Contains(errMsg, "400") || strings.Contains(errMsg, "401") ||
strings.Contains(errMsg, "Invalid") || strings.Contains(errMsg, "上传超时") || strings.Contains(errMsg, "Invalid") || strings.Contains(errMsg, "upload timeout") ||
strings.Contains(errMsg, "timeout") || strings.Contains(errMsg, "Timeout") { strings.Contains(errMsg, "timeout") || strings.Contains(errMsg, "Timeout") {
return nil, lastErr return nil, lastErr
} }
if attempt < uploadMaxRetries { if attempt < uploadMaxRetries {
delay := time.Duration(uploadBaseDelayMs*pow(2, attempt)) * time.Millisecond delay := time.Duration(uploadBaseDelayMs*pow(2, attempt)) * time.Millisecond
fmt.Printf("[qqbot-api] Upload attempt %d failed, retrying in %v: %s\n", attempt+1, delay, truncate(errMsg, 100)) logger.WarnCF("qq", "Upload attempt failed, retrying", map[string]any{
"attempt": attempt + 1,
"delay": delay.String(),
"error": truncate(errMsg, 100),
})
select { select {
case <-time.After(delay): case <-time.After(delay):
@ -235,7 +240,7 @@ func (c *Client) uploadC2CMedia(
if fileData != "" { if fileData != "" {
contentHash := computeFileHash(fileData) contentHash := computeFileHash(fileData)
if cached, ok := c.getCachedFileInfo(contentHash, "c2c", openid, fileType); ok { if cached, ok := c.getCachedFileInfo(contentHash, "c2c", openid, fileType); ok {
fmt.Println("[qqbot-api] uploadC2CMedia: using cached file_info (skip upload)") logger.InfoC("qq", "uploadC2CMedia: using cached file_info (skip upload)")
return &UploadMediaResponse{FileInfo: cached}, nil return &UploadMediaResponse{FileInfo: cached}, nil
} }
} }