修复完善笔记详情内容加载 (#301)

* feat: add like and favorite functionality for feeds - Implemented handleLikeFeed and handleFavoriteFeed methods in mcp_handlers.go to manage liking and favoriting feeds. - Added LikeFavoriteArgs struct in mcp_server.go for handling parameters. - Registered new MCP tools for liking and favoriting feeds in registerTools function. - Introduced LikeFeed and FavoriteFeed methods in XiaohongshuService to interact with the respective actions. - Created LikeFavoriteAction in a new file to encapsulate the logic for liking and favoriting feeds on the Xiaohongshu platform. * "优化评论反馈逻辑：简化回复按钮查找和点击流程 * "Fix-build-errors" * refactor: streamline like and favorite actions in LikeFavoriteAction - Introduced a generic method `performInteractAction` to handle both liking and favoriting feeds, reducing code duplication. - Updated logging to reflect the action type being performed (like or favorite). - Enhanced state verification after interaction to ensure accurate feedback on success or failure. - Removed the `clickLastMatch` function, simplifying the interaction logic. * "Add-unlike-and-unfavorite-functionality" * "Refactor-performInteractAction-function" * "Refactor-split-LikeFavoriteAction-into-separate-actions" * "Add-content-length-validation-for-publish" * refactor: improve comment posting logic with enhanced error handling and stability checks - Updated the PostComment method to include error handling for navigation and element interactions. - Replaced sleep calls with more reliable wait mechanisms to ensure page stability. - Added checks for the presence of input elements and improved logging for better debugging. * feat: add reply comment functionality for Xiaohongshu feeds - Implemented handleReplyComment method in mcp_handlers.go to manage replying to comments on feeds. - Introduced ReplyCommentArgs struct in mcp_server.go for handling parameters related to comment replies. - Registered a new MCP tool for replying to comments in the registerTools function. - Added ReplyCommentToFeed method in service.go to interact with the Xiaohongshu platform for comment replies. - Enhanced error handling for missing parameters in the reply process. * refactor: enhance reply comment functionality with improved error handling and response structure - Simplified error handling in handleReplyComment to check for both comment_id and user_id simultaneously. - Updated response message to include both Comment ID and User ID upon successful reply. - Modified ReplyCommentArgs struct to make comment_id and user_id optional. - Renamed MCP tool for replying to comments for clarity. * feat(feed): Migrate loadAllComments feature for GetFeedDetail * fix * fix * fix * fix * fix: 添加更多自定义选项操作 * fix * fix：优化代码结构 * chore: update dependencies and implement retry logic for page interactions --------- Co-authored-by: chekayo <9827969+chekayo@user.noreply.gitee.com>
2025-12-07 15:04:14 +08:00
parent 6bef535002
commit 13ac2e39c3
8 changed files with 892 additions and 42 deletions
--- a/go.mod
+++ b/go.mod
@@ -10,11 +10,12 @@ require (
 	github.com/modelcontextprotocol/go-sdk v0.7.0
 	github.com/pkg/errors v0.9.1
 	github.com/sirupsen/logrus v1.9.3
-	github.com/stretchr/testify v1.10.0
+	github.com/stretchr/testify v1.11.1
 	github.com/xpzouying/headless_browser v0.2.0
 )

 require (
+	github.com/avast/retry-go/v4 v4.7.0 // indirect
 	github.com/bytedance/sonic v1.11.6 // indirect
 	github.com/bytedance/sonic/loader v0.1.1 // indirect
 	github.com/cloudwego/base64x v0.1.4 // indirect
--- a/go.sum
+++ b/go.sum
@@ -1,3 +1,5 @@
+github.com/avast/retry-go/v4 v4.7.0 h1:yjDs35SlGvKwRNSykujfjdMxMhMQQM0TnIjJaHB+Zio=
+github.com/avast/retry-go/v4 v4.7.0/go.mod h1:ZMPDa3sY2bKgpLtap9JRUgk2yTAba7cgiFhqxY2Sg6Q=
 github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc0=
 github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4=
 github.com/bytedance/sonic/loader v0.1.1 h1:c+e5Pt1k/cy5wMveRDyk2X4B9hF4g7an8N3zCYjJFNM=
@@ -79,6 +81,8 @@ github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXl
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
 github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
 github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
+github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
 github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
 github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
 github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE=
--- a/handlers_api.go
+++ b/handlers_api.go
@@ -181,8 +181,23 @@ func (s *AppServer) getFeedDetailHandler(c *gin.Context) {
 		return
 	}

-	// 获取 Feed 详情
-	result, err := s.xiaohongshuService.GetFeedDetail(c.Request.Context(), req.FeedID, req.XsecToken)
+	var result *FeedDetailResponse
+	var err error
+
+	if req.CommentConfig != nil {
+		// 使用配置参数
+		config := xiaohongshu.CommentLoadConfig{
+			ClickMoreReplies:    req.CommentConfig.ClickMoreReplies,
+			MaxRepliesThreshold: req.CommentConfig.MaxRepliesThreshold,
+			MaxCommentItems:     req.CommentConfig.MaxCommentItems,
+			ScrollSpeed:         req.CommentConfig.ScrollSpeed,
+		}
+		result, err = s.xiaohongshuService.GetFeedDetailWithConfig(c.Request.Context(), req.FeedID, req.XsecToken, req.LoadAllComments, config)
+	} else {
+		// 使用默认配置
+		result, err = s.xiaohongshuService.GetFeedDetail(c.Request.Context(), req.FeedID, req.XsecToken, req.LoadAllComments)
+	}
+
 	if err != nil {
 		respondError(c, http.StatusInternalServerError, "GET_FEED_DETAIL_FAILED",
 			"获取Feed详情失败", err.Error())
--- a/mcp_handlers.go
+++ b/mcp_handlers.go
@@ -4,11 +4,13 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"strconv"
+	"strings"
+	"time"
+
 	"github.com/sirupsen/logrus"
 	"github.com/xpzouying/xiaohongshu-mcp/cookies"
 	"github.com/xpzouying/xiaohongshu-mcp/xiaohongshu"
-	"strings"
-	"time"
 )

 // MCP 工具处理函数
@@ -336,9 +338,67 @@ func (s *AppServer) handleGetFeedDetail(ctx context.Context, args map[string]any
 		}
 	}

-	logrus.Infof("MCP: 获取Feed详情 - Feed ID: %s", feedID)
+	loadAll := false
+	if raw, ok := args["load_all_comments"]; ok {
+		switch v := raw.(type) {
+		case bool:
+			loadAll = v
+		case string:
+			if parsed, err := strconv.ParseBool(v); err == nil {
+				loadAll = parsed
+			}
+		case float64:
+			loadAll = v != 0
+		}
+	}

-	result, err := s.xiaohongshuService.GetFeedDetail(ctx, feedID, xsecToken)
+	// 解析评论配置参数，如果未提供则使用默认值
+	config := xiaohongshu.DefaultCommentLoadConfig()
+
+	if raw, ok := args["click_more_replies"]; ok {
+		switch v := raw.(type) {
+		case bool:
+			config.ClickMoreReplies = v
+		case string:
+			if parsed, err := strconv.ParseBool(v); err == nil {
+				config.ClickMoreReplies = parsed
+			}
+		}
+	}
+
+	if raw, ok := args["max_replies_threshold"]; ok {
+		switch v := raw.(type) {
+		case float64:
+			config.MaxRepliesThreshold = int(v)
+		case string:
+			if parsed, err := strconv.Atoi(v); err == nil {
+				config.MaxRepliesThreshold = parsed
+			}
+		case int:
+			config.MaxRepliesThreshold = v
+		}
+	}
+
+	if raw, ok := args["max_comment_items"]; ok {
+		switch v := raw.(type) {
+		case float64:
+			config.MaxCommentItems = int(v)
+		case string:
+			if parsed, err := strconv.Atoi(v); err == nil {
+				config.MaxCommentItems = parsed
+			}
+		case int:
+			config.MaxCommentItems = v
+		}
+	}
+
+	if raw, ok := args["scroll_speed"].(string); ok && raw != "" {
+		config.ScrollSpeed = raw
+	}
+
+	logrus.Infof("MCP: 获取Feed详情 - Feed ID: %s, loadAllComments=%v, config=%+v", feedID, loadAll, config)
+
+	result, err := s.xiaohongshuService.GetFeedDetailWithConfig(ctx, feedID, xsecToken, loadAll, config)
 	if err != nil {
 		return &MCPToolResult{
 			Content: []MCPContent{{
--- a/mcp_server.go
+++ b/mcp_server.go
@@ -45,8 +45,13 @@ type FilterOption struct {

 // FeedDetailArgs 获取Feed详情的参数
 type FeedDetailArgs struct {
-	FeedID    string `json:"feed_id" jsonschema:"小红书笔记ID，从Feed列表获取"`
-	XsecToken string `json:"xsec_token" jsonschema:"访问令牌，从Feed列表的xsecToken字段获取"`
+	FeedID              string `json:"feed_id" jsonschema:"小红书笔记ID，从Feed列表获取"`
+	XsecToken           string `json:"xsec_token" jsonschema:"访问令牌，从Feed列表的xsecToken字段获取"`
+	LoadAllComments     bool   `json:"load_all_comments,omitempty" jsonschema:"是否加载全部评论（默认false，仅返回首批评论）"`
+	ClickMoreReplies    bool   `json:"click_more_replies,omitempty" jsonschema:"是否点击'更多回复'按钮 (默认: false)"`
+	MaxRepliesThreshold int    `json:"max_replies_threshold,omitempty" jsonschema:"回复数量阈值，超过此数量的'更多'按钮将被跳过 (0表示不跳过任何, 默认: 10)"`
+	MaxCommentItems     int    `json:"max_comment_items,omitempty" jsonschema:"最大加载评论数（0表示加载所有, 默认: 0）"`
+	ScrollSpeed         string `json:"scroll_speed,omitempty" jsonschema:"滚动速度: 'slow'|'normal'|'fast' (默认: 'normal')"`
 }

 // UserProfileArgs 获取用户主页的参数
@@ -216,8 +221,13 @@ func registerTools(server *mcp.Server, appServer *AppServer) {
 		},
 		withPanicRecovery("get_feed_detail", func(ctx context.Context, req *mcp.CallToolRequest, args FeedDetailArgs) (*mcp.CallToolResult, any, error) {
 			argsMap := map[string]interface{}{
-				"feed_id":    args.FeedID,
-				"xsec_token": args.XsecToken,
+				"feed_id":               args.FeedID,
+				"xsec_token":            args.XsecToken,
+				"load_all_comments":     args.LoadAllComments,
+				"click_more_replies":    args.ClickMoreReplies,
+				"max_replies_threshold": args.MaxRepliesThreshold,
+				"max_comment_items":     args.MaxCommentItems,
+				"scroll_speed":          args.ScrollSpeed,
 			}
 			result := appServer.handleGetFeedDetail(ctx, argsMap)
 			return convertToMCPResult(result), nil, nil
--- a/service.go
+++ b/service.go
@@ -328,7 +328,12 @@ func (s *XiaohongshuService) SearchFeeds(ctx context.Context, keyword string, fi
 }

 // GetFeedDetail 获取Feed详情
-func (s *XiaohongshuService) GetFeedDetail(ctx context.Context, feedID, xsecToken string) (*FeedDetailResponse, error) {
+func (s *XiaohongshuService) GetFeedDetail(ctx context.Context, feedID, xsecToken string, loadAllComments bool) (*FeedDetailResponse, error) {
+	return s.GetFeedDetailWithConfig(ctx, feedID, xsecToken, loadAllComments, xiaohongshu.DefaultCommentLoadConfig())
+}
+
+// GetFeedDetailWithConfig 使用配置获取Feed详情
+func (s *XiaohongshuService) GetFeedDetailWithConfig(ctx context.Context, feedID, xsecToken string, loadAllComments bool, config xiaohongshu.CommentLoadConfig) (*FeedDetailResponse, error) {
 	b := newBrowser()
 	defer b.Close()

@@ -339,7 +344,7 @@ func (s *XiaohongshuService) GetFeedDetail(ctx context.Context, feedID, xsecToke
 	action := xiaohongshu.NewFeedDetailAction(page)

 	// 获取 Feed 详情
-	result, err := action.GetFeedDetail(ctx, feedID, xsecToken)
+	result, err := action.GetFeedDetailWithConfig(ctx, feedID, xsecToken, loadAllComments, config)
 	if err != nil {
 		return nil, err
 	}
--- a/types.go
+++ b/types.go
@@ -34,10 +34,24 @@ type MCPContent struct {
 	Data     string `json:"data"`
 }

+// CommentLoadConfig 评论加载配置
+type CommentLoadConfig struct {
+	// 是否点击"更多回复"按钮
+	ClickMoreReplies bool `json:"click_more_replies,omitempty"`
+	// 回复数量阈值，超过这个数量的"更多"按钮将被跳过（0表示不跳过任何）
+	MaxRepliesThreshold int `json:"max_replies_threshold,omitempty"`
+	// 最大加载评论数（comment-item数量），0表示加载所有
+	MaxCommentItems int `json:"max_comment_items,omitempty"`
+	// 滚动速度等级: slow(慢速), normal(正常), fast(快速)
+	ScrollSpeed string `json:"scroll_speed,omitempty"`
+}
+
 // FeedDetailRequest Feed详情请求
 type FeedDetailRequest struct {
-	FeedID    string `json:"feed_id" binding:"required"`
-	XsecToken string `json:"xsec_token" binding:"required"`
+	FeedID          string             `json:"feed_id" binding:"required"`
+	XsecToken       string             `json:"xsec_token" binding:"required"`
+	LoadAllComments bool               `json:"load_all_comments,omitempty"`
+	CommentConfig   *CommentLoadConfig `json:"comment_config,omitempty"`
 }

 type SearchFeedsRequest struct {
--- a/xiaohongshu/feed_detail.go
+++ b/xiaohongshu/feed_detail.go
@@ -4,46 +4,787 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"math/rand"
+	"regexp"
+	"strconv"
 	"time"

+	"github.com/avast/retry-go/v4"
 	"github.com/go-rod/rod"
+	"github.com/go-rod/rod/lib/proto"
 	"github.com/sirupsen/logrus"
 	"github.com/xpzouying/xiaohongshu-mcp/errors"
 )

-// FeedDetailAction 表示 Feed 详情页动作
+// ========== 配置常量 ==========
+const (
+	defaultMaxAttempts      = 500
+	stagnantLimit           = 20
+	minScrollDelta          = 10
+	maxClickPerRound        = 3
+	stagnantCheckThreshold  = 2  // 达到目标后需要停滞几次才确认
+	largeScrollTrigger      = 5  // 停滞多少次后触发大滚动
+	buttonClickInterval     = 3  // 每隔多少次尝试点击一次按钮
+	finalSprintPushCount    = 15
+)
+
+// 延迟时间配置（毫秒）
+type delayConfig struct {
+	min, max int
+}
+
+var (
+	humanDelayRange    = delayConfig{300, 700}
+	reactionTimeRange  = delayConfig{300, 800}
+	hoverTimeRange     = delayConfig{100, 300}
+	readTimeRange      = delayConfig{500, 1200}
+	shortReadRange     = delayConfig{600, 1200}
+	scrollWaitRange    = delayConfig{100, 200}
+	postScrollRange    = delayConfig{300, 500}
+)
+
+// ========== 数据结构 ==========
+
+type CommentLoadConfig struct {
+	ClickMoreReplies    bool
+	MaxRepliesThreshold int
+	MaxCommentItems     int
+	ScrollSpeed         string
+}
+
+func DefaultCommentLoadConfig() CommentLoadConfig {
+	return CommentLoadConfig{
+		ClickMoreReplies:    false,
+		MaxRepliesThreshold: 10,
+		MaxCommentItems:     0,
+		ScrollSpeed:         "normal",
+	}
+}
+
 type FeedDetailAction struct {
 	page *rod.Page
 }

-// NewFeedDetailAction 创建 Feed 详情页动作
 func NewFeedDetailAction(page *rod.Page) *FeedDetailAction {
 	return &FeedDetailAction{page: page}
 }

-// GetFeedDetail 获取 Feed 详情页数据
-func (f *FeedDetailAction) GetFeedDetail(ctx context.Context, feedID, xsecToken string) (*FeedDetailResponse, error) {
-	page := f.page.Context(ctx).Timeout(60 * time.Second)
+// ========== 主要业务逻辑 ==========

-	// 构建详情页 URL
+func (f *FeedDetailAction) GetFeedDetail(ctx context.Context, feedID, xsecToken string, loadAllComments bool, config CommentLoadConfig) (*FeedDetailResponse, error) {
+	return f.GetFeedDetailWithConfig(ctx, feedID, xsecToken, loadAllComments, config)
+}
+
+func (f *FeedDetailAction) GetFeedDetailWithConfig(ctx context.Context, feedID, xsecToken string, loadAllComments bool, config CommentLoadConfig) (*FeedDetailResponse, error) {
+	page := f.page.Context(ctx).Timeout(10 * time.Minute)
 	url := makeFeedDetailURL(feedID, xsecToken)
 	
 	logrus.Infof("打开 feed 详情页: %s", url)
+	logrus.Infof("配置: 点击更多=%v, 回复阈值=%d, 最大评论数=%d, 滚动速度=%s",
+		config.ClickMoreReplies, config.MaxRepliesThreshold, config.MaxCommentItems, config.ScrollSpeed)
 	
-	// 导航到详情页
-	page.MustNavigate(url)
-	page.MustWaitDOMStable()
-	time.Sleep(1 * time.Second)
+	// 使用retry-go处理页面导航和DOM稳定等待
+	err := retry.Do(
+		func() error {
+			page.MustNavigate(url)
+			page.MustWaitDOMStable()
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(500*time.Millisecond),
+		retry.MaxJitter(1000*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("页面导航重试 #%d: %v", n, err)
+		}),
+	)
+	if err != nil {
+		logrus.Errorf("页面导航失败: %v", err)
+		return nil, err
+	}
+	sleepRandom(1000, 1000)
 	
-	result := page.MustEval(`() => {
-		if (window.__INITIAL_STATE__ &&
-		    window.__INITIAL_STATE__.note &&
-		    window.__INITIAL_STATE__.note.noteDetailMap) {
-			const noteDetailMap = window.__INITIAL_STATE__.note.noteDetailMap;
-			return JSON.stringify(noteDetailMap);
+	if err := checkPageAccessible(page); err != nil {
+		return nil, err
+	}
+	
+	if loadAllComments {
+		if err := f.loadAllCommentsWithConfig(page, config); err != nil {
+			logrus.Warnf("加载全部评论失败: %v", err)
 		}
-		return "";
-	}`).String()
+	}
+	
+	return f.extractFeedDetail(page, feedID)
+}
+
+// ========== 评论加载器 ==========
+
+type commentLoader struct {
+	page                *rod.Page
+	config              CommentLoadConfig
+	stats               *loadStats
+	state               *loadState
+}
+
+type loadStats struct {
+	totalClicked  int
+	totalSkipped  int
+	attempts      int
+}
+
+type loadState struct {
+	lastCount      int
+	lastScrollTop  int
+	stagnantChecks int
+}
+
+func (f *FeedDetailAction) loadAllCommentsWithConfig(page *rod.Page, config CommentLoadConfig) error {
+	loader := &commentLoader{
+		page:   page,
+		config: config,
+		stats:  &loadStats{},
+		state:  &loadState{},
+	}
+	
+	return loader.load()
+}
+
+func (cl *commentLoader) load() error {
+	maxAttempts := cl.calculateMaxAttempts()
+	scrollInterval := getScrollInterval(cl.config.ScrollSpeed)
+	
+	logrus.Info("开始加载评论...")
+	scrollToCommentsArea(cl.page)
+	sleepRandom(humanDelayRange.min, humanDelayRange.max)
+	
+	for cl.stats.attempts = 0; cl.stats.attempts < maxAttempts; cl.stats.attempts++ {
+		logrus.Debugf("=== 尝试 %d/%d ===", cl.stats.attempts+1, maxAttempts)
+		
+		if cl.checkComplete() {
+			return nil
+		}
+		
+		if cl.shouldClickButtons() {
+			cl.clickButtonsWithRetry()
+		}
+		
+		currentCount := getCommentCount(cl.page)
+		cl.updateState(currentCount)
+		
+		if cl.shouldStopAtTarget(currentCount) {
+			return nil
+		}
+		
+		cl.performScroll()
+		cl.handleStagnation()
+		
+		time.Sleep(scrollInterval)
+	}
+	
+	cl.performFinalSprint()
+	return nil
+}
+
+func (cl *commentLoader) calculateMaxAttempts() int {
+	if cl.config.MaxCommentItems > 0 {
+		return cl.config.MaxCommentItems * 3
+	}
+	return defaultMaxAttempts
+}
+
+func (cl *commentLoader) checkComplete() bool {
+	if checkEndContainer(cl.page) {
+		currentCount := getCommentCount(cl.page)
+		logrus.Infof("✓ 检测到 'THE END' 元素，已滑动到底部")
+		sleepRandom(humanDelayRange.min, humanDelayRange.max)
+		logrus.Infof("✓ 加载完成: %d 条评论, 尝试次数: %d, 点击: %d, 跳过: %d",
+			currentCount, cl.stats.attempts+1, cl.stats.totalClicked, cl.stats.totalSkipped)
+		return true
+	}
+	return false
+}
+
+func (cl *commentLoader) shouldClickButtons() bool {
+	return cl.config.ClickMoreReplies && cl.stats.attempts%buttonClickInterval == 0
+}
+
+func (cl *commentLoader) clickButtonsWithRetry() {
+	clicked, skipped := clickShowMoreButtonsSmart(cl.page, cl.config.MaxRepliesThreshold)
+	if clicked > 0 || skipped > 0 {
+		cl.stats.totalClicked += clicked
+		cl.stats.totalSkipped += skipped
+		logrus.Infof("点击'更多': %d 个, 跳过: %d 个, 累计点击: %d, 累计跳过: %d",
+			clicked, skipped, cl.stats.totalClicked, cl.stats.totalSkipped)
+		
+		sleepRandom(readTimeRange.min, readTimeRange.max)
+		
+		// 重试一轮
+		clicked2, skipped2 := clickShowMoreButtonsSmart(cl.page, cl.config.MaxRepliesThreshold)
+		if clicked2 > 0 || skipped2 > 0 {
+			cl.stats.totalClicked += clicked2
+			cl.stats.totalSkipped += skipped2
+			logrus.Infof("第 2 轮: 点击 %d, 跳过 %d", clicked2, skipped2)
+			sleepRandom(shortReadRange.min, shortReadRange.max)
+		}
+	}
+}
+
+func (cl *commentLoader) updateState(currentCount int) {
+	totalCount := getTotalCommentCount(cl.page)
+	logrus.Debugf("当前评论: %d, 目标: %d", currentCount, totalCount)
+	
+	if currentCount != cl.state.lastCount {
+		logrus.Infof("✓ 评论增加: %d -> %d (+%d)", 
+			cl.state.lastCount, currentCount, currentCount-cl.state.lastCount)
+		cl.state.lastCount = currentCount
+		cl.state.stagnantChecks = 0
+	} else {
+		cl.state.stagnantChecks++
+		if cl.state.stagnantChecks%5 == 0 {
+			logrus.Debugf("评论停滞 %d 次", cl.state.stagnantChecks)
+		}
+	}
+}
+
+func (cl *commentLoader) shouldStopAtTarget(currentCount int) bool {
+	if cl.config.MaxCommentItems <= 0 || currentCount < cl.config.MaxCommentItems {
+		return false
+	}
+	
+	if cl.state.stagnantChecks >= stagnantCheckThreshold {
+		logrus.Infof("✓ 已达到目标评论数: %d/%d (停滞%d次), 停止加载",
+			currentCount, cl.config.MaxCommentItems, cl.state.stagnantChecks)
+		return true
+	}
+	
+	if cl.state.stagnantChecks > 0 {
+		logrus.Debugf("已达目标数 %d/%d，再确认 %d 次...",
+			currentCount, cl.config.MaxCommentItems, stagnantCheckThreshold-cl.state.stagnantChecks)
+	}
+	
+	return false
+}
+
+func (cl *commentLoader) performScroll() {
+	currentCount := getCommentCount(cl.page)
+	if currentCount > 0 {
+		scrollToLastComment(cl.page)
+		sleepRandom(postScrollRange.min, postScrollRange.max)
+	}
+	
+	largeMode := cl.state.stagnantChecks >= largeScrollTrigger
+	pushCount := 1
+	if largeMode {
+		pushCount = 3 + rand.Intn(3)
+	}
+	
+	_, scrollDelta, currentScrollTop := humanScroll(cl.page, cl.config.ScrollSpeed, largeMode, pushCount)
+	
+	if scrollDelta < minScrollDelta || currentScrollTop == cl.state.lastScrollTop {
+		cl.state.stagnantChecks++
+		if cl.state.stagnantChecks%5 == 0 {
+			logrus.Debugf("滚动停滞 %d 次", cl.state.stagnantChecks)
+		}
+	} else {
+		cl.state.stagnantChecks = 0
+		cl.state.lastScrollTop = currentScrollTop
+	}
+}
+
+func (cl *commentLoader) handleStagnation() {
+	if cl.state.stagnantChecks >= stagnantLimit {
+		logrus.Infof("停滞过多，尝试大冲刺...")
+		humanScroll(cl.page, cl.config.ScrollSpeed, true, 10)
+		cl.state.stagnantChecks = 0
+		
+		if checkEndContainer(cl.page) {
+			currentCount := getCommentCount(cl.page)
+			logrus.Infof("✓ 到达底部，评论数: %d", currentCount)
+		}
+	}
+}
+
+func (cl *commentLoader) performFinalSprint() {
+	logrus.Infof("达到最大尝试次数，最后冲刺...")
+	humanScroll(cl.page, cl.config.ScrollSpeed, true, finalSprintPushCount)
+	
+	currentCount := getCommentCount(cl.page)
+	hasEnd := checkEndContainer(cl.page)
+	logrus.Infof("✓ 加载结束: %d 条评论, 点击: %d, 跳过: %d, 到达底部: %v",
+		currentCount, cl.stats.totalClicked, cl.stats.totalSkipped, hasEnd)
+}
+
+// ========== 工具函数 ==========
+
+func sleepRandom(minMs, maxMs int) {
+	if maxMs <= minMs {
+		time.Sleep(time.Duration(minMs) * time.Millisecond)
+		return
+	}
+	delay := time.Duration(minMs+rand.Intn(maxMs-minMs)) * time.Millisecond
+	time.Sleep(delay)
+}
+
+func getScrollInterval(speed string) time.Duration {
+	switch speed {
+	case "slow":
+		return time.Duration(1200+rand.Intn(300)) * time.Millisecond
+	case "fast":
+		return time.Duration(300+rand.Intn(100)) * time.Millisecond
+	default: // normal
+		return time.Duration(600+rand.Intn(200)) * time.Millisecond
+	}
+}
+
+// ========== 按钮点击 ==========
+
+func clickShowMoreButtonsSmart(page *rod.Page, maxRepliesThreshold int) (clicked, skipped int) {
+	elements, err := page.Elements(".show-more")
+	if err != nil {
+		return 0, 0
+	}
+	
+	replyCountRegex := regexp.MustCompile(`展开\s*(\d+)\s*条回复`)
+	maxClick := maxClickPerRound + rand.Intn(maxClickPerRound)
+	clickedInRound := 0
+	
+	for _, el := range elements {
+		if clickedInRound >= maxClick {
+			break
+		}
+		
+		if !isElementClickable(el) {
+			continue
+		}
+		
+		text, err := el.Text()
+		if err != nil {
+			continue
+		}
+		
+		if shouldSkipButton(text, maxRepliesThreshold, replyCountRegex) {
+			skipped++
+			continue
+		}
+		
+		if clickElementWithHumanBehavior(page, el, text) {
+			clicked++
+			clickedInRound++
+		}
+	}
+	
+	return clicked, skipped
+}
+
+func isElementClickable(el *rod.Element) bool {
+	visible, err := el.Visible()
+	if err != nil || !visible {
+		return false
+	}
+	
+	box, err := el.Shape()
+	return err == nil && len(box.Quads) > 0
+}
+
+func shouldSkipButton(text string, threshold int, regex *regexp.Regexp) bool {
+	if threshold <= 0 {
+		return false
+	}
+	
+	matches := regex.FindStringSubmatch(text)
+	if len(matches) > 1 {
+		if replyCount, err := strconv.Atoi(matches[1]); err == nil && replyCount > threshold {
+			logrus.Debugf("跳过'%s'（回复数 %d > 阈值 %d）", text, replyCount, threshold)
+			return true
+		}
+	}
+	return false
+}
+
+func clickElementWithHumanBehavior(page *rod.Page, el *rod.Element, text string) bool {
+	var clickSuccess bool
+	
+	// 使用retry-go进行点击操作重试
+	err := retry.Do(
+		func() error {
+			// 滚动到元素
+			el.MustEval(`() => {
+				try {
+					this.scrollIntoView({behavior: 'smooth', block: 'center'});
+				} catch (e) {}
+			}`)
+			
+			sleepRandom(reactionTimeRange.min, reactionTimeRange.max)
+			
+			// 鼠标悬停
+			if box, err := el.Shape(); err == nil && len(box.Quads) > 0 {
+				x := float64(box.Quads[0][0]+box.Quads[0][4]) / 2
+				y := float64(box.Quads[0][1]+box.Quads[0][5]) / 2
+				page.Mouse.MustMoveTo(x, y)
+				sleepRandom(hoverTimeRange.min, hoverTimeRange.max)
+			}
+			
+			// 点击
+			if err := el.Click(proto.InputMouseButtonLeft, 1); err != nil {
+				return err // 返回错误以触发重试
+			}
+			
+			// 模拟人类阅读时间
+			sleepRandom(readTimeRange.min, readTimeRange.max)
+			clickSuccess = true
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(100*time.Millisecond),
+		retry.MaxJitter(200*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("点击重试 #%d: %s, 错误: %v", n, text, err)
+		}),
+	)
+	
+	if err != nil {
+		logrus.Debugf("点击失败 '%s': %v", text, err)
+		return false
+	}
+	
+	if clickSuccess {
+		logrus.Debugf("点击了'%s'", text)
+	}
+	
+	return clickSuccess
+}
+
+// ========== 滚动相关 ==========
+
+func humanScroll(page *rod.Page, speed string, largeMode bool, pushCount int) (bool, int, int) {
+	beforeTop := getScrollTop(page)
+	viewportHeight := page.MustEval(`() => window.innerHeight`).Int()
+	
+	baseRatio := getScrollRatio(speed)
+	if largeMode {
+		baseRatio *= 2.0
+	}
+	
+	scrolled := false
+	actualDelta := 0
+	currentScrollTop := beforeTop
+	
+	for i := 0; i < max(1, pushCount); i++ {
+		scrollDelta := calculateScrollDelta(viewportHeight, baseRatio)
+		page.MustEval(`(delta) => { window.scrollBy(0, delta); }`, scrollDelta)
+		
+		sleepRandom(scrollWaitRange.min, scrollWaitRange.max)
+		
+		currentScrollTop = getScrollTop(page)
+		deltaThisTime := currentScrollTop - beforeTop
+		actualDelta += deltaThisTime
+		
+		if deltaThisTime > 5 {
+			scrolled = true
+		}
+		
+		beforeTop = currentScrollTop
+		
+		if i < pushCount-1 {
+			sleepRandom(humanDelayRange.min, humanDelayRange.max)
+		}
+	}
+	
+	if !scrolled && pushCount > 0 {
+		page.MustEval(`() => window.scrollTo(0, document.body.scrollHeight)`)
+		sleepRandom(postScrollRange.min, postScrollRange.max)
+		currentScrollTop = getScrollTop(page)
+		actualDelta = currentScrollTop - beforeTop + actualDelta
+		scrolled = actualDelta > 5
+	}
+	
+	if scrolled {
+		logrus.Debugf("滚动: %d -> %d (Δ%d, large=%v, push=%d)", 
+			beforeTop-actualDelta, currentScrollTop, actualDelta, largeMode, pushCount)
+	}
+	
+	return scrolled, actualDelta, currentScrollTop
+}
+
+func getScrollRatio(speed string) float64 {
+	switch speed {
+	case "slow":
+		return 0.5
+	case "fast":
+		return 0.9
+	default: // normal
+		return 0.7
+	}
+}
+
+func calculateScrollDelta(viewportHeight int, baseRatio float64) float64 {
+	scrollDelta := float64(viewportHeight) * (baseRatio + rand.Float64()*0.2)
+	if scrollDelta < 400 {
+		scrollDelta = 400
+	}
+	return scrollDelta + float64(rand.Intn(100)-50)
+}
+
+func scrollToCommentsArea(page *rod.Page) {
+	logrus.Info("滚动到评论区...")
+	page.MustEval(`() => {
+		const container = document.querySelector('.comments-container');
+		if (container) {
+			container.scrollIntoView({behavior: 'smooth', block: 'start'});
+		}
+	}`)
+}
+
+func scrollToLastComment(page *rod.Page) {
+	page.MustEval(`() => {
+		const container = document.querySelector('.comments-container');
+		if (!container) return;
+		const comments = container.querySelectorAll('.parent-comment');
+		if (comments.length > 0) {
+			const lastComment = comments[comments.length - 1];
+			lastComment.scrollIntoView({behavior: 'smooth', block: 'center'});
+		}
+	}`)
+}
+
+// ========== DOM 查询 ==========
+
+func getScrollTop(page *rod.Page) int {
+	var result int
+	
+	// 使用retry-go来处理可能的DOM查询失败
+	err := retry.Do(
+		func() error {
+			evalResult := page.MustEval(`() => {
+				return window.pageYOffset || document.documentElement.scrollTop || document.body.scrollTop || 0;
+			}`)
+			
+			result = evalResult.Int()
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(100*time.Millisecond),
+		retry.MaxJitter(200*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("获取滚动位置重试 #%d: %v", n, err)
+		}),
+	)
+	
+	if err != nil {
+		logrus.Warnf("获取滚动位置失败: %v", err)
+		return 0 // 失败时返回0
+	}
+	
+	return result
+}
+
+func getCommentCount(page *rod.Page) int {
+	var result int
+	
+	// 使用retry-go来处理可能的DOM查询失败
+	err := retry.Do(
+		func() error {
+			evalResult := page.MustEval(`() => {
+				const container = document.querySelector('.comments-container');
+				if (!container) return 0;
+				return container.querySelectorAll('.parent-comment').length;
+			}`)
+			
+			result = evalResult.Int()
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(100*time.Millisecond),
+		retry.MaxJitter(200*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("获取评论计数重试 #%d: %v", n, err)
+		}),
+	)
+	
+	if err != nil {
+		logrus.Warnf("获取评论计数失败: %v", err)
+		return 0 // 失败时返回0
+	}
+	
+	return result
+}
+
+func getTotalCommentCount(page *rod.Page) int {
+	var result int
+	
+	// 使用retry-go来处理可能的DOM查询失败
+	err := retry.Do(
+		func() error {
+			evalResult := page.MustEval(`() => {
+				const container = document.querySelector('.comments-container');
+				if (!container) return 0;
+				const totalEl = container.querySelector('.total');
+				if (!totalEl) return 0;
+				const text = (totalEl.textContent || '').replace(/\s+/g, '');
+				const match = text.match(/共(\d+)条评论/);
+				return match ? parseInt(match[1], 10) : 0;
+			}`)
+			
+			result = evalResult.Int()
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(100*time.Millisecond),
+		retry.MaxJitter(200*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("获取总评论计数重试 #%d: %v", n, err)
+		}),
+	)
+	
+	if err != nil {
+		logrus.Warnf("获取总评论计数失败: %v", err)
+		return 0 // 失败时返回0
+	}
+	
+	return result
+}
+
+func checkEndContainer(page *rod.Page) bool {
+	var result bool
+	
+	// 使用retry-go来处理可能的DOM查询失败
+	err := retry.Do(
+		func() error {
+			evalResult := page.MustEval(`() => {
+				const endContainer = document.querySelector('.end-container');
+				if (!endContainer) return false;
+				const text = (endContainer.textContent || '').trim().toUpperCase();
+				return text.includes('THE END') || text.includes('THEEND');
+			}`)
+			
+			result = evalResult.Bool()
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(100*time.Millisecond),
+		retry.MaxJitter(200*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("检查结束容器重试 #%d: %v", n, err)
+		}),
+	)
+	
+	if err != nil {
+		logrus.Warnf("检查结束容器失败: %v", err)
+		return false // 失败时返回false
+	}
+	
+	return result
+}
+
+// ========== 页面检查 ==========
+
+func checkPageAccessible(page *rod.Page) error {
+	time.Sleep(500 * time.Millisecond)
+	
+	// 使用retry-go来处理可能的DOM查询失败
+	err := retry.Do(
+		func() error {
+			result := page.MustEval(`() => {
+				const wrapper = document.querySelector('.access-wrapper, .error-wrapper, .not-found-wrapper, .blocked-wrapper');
+				if (!wrapper) return null;
+				
+				const text = wrapper.textContent || wrapper.innerText || '';
+				const keywords = [
+					'当前笔记暂时无法浏览',
+					'该内容因违规已被删除',
+					'该笔记已被删除',
+					'内容不存在',
+					'笔记不存在',
+					'已失效',
+					'私密笔记',
+					'仅作者可见',
+					'因用户设置，你无法查看',
+					'因违规无法查看'
+				];
+				
+				for (const kw of keywords) {
+					if (text.includes(kw)) {
+						return kw;
+					}
+				}
+				
+				if (text.trim()) {
+					return '未知错误: ' + text.trim();
+				}
+				return null;
+			}`)
+			
+			rawJSON, marshalErr := result.MarshalJSON()
+			if marshalErr != nil {
+				return fmt.Errorf("无法序列化页面状态检查结果: %w", marshalErr)
+			}
+			
+			if string(rawJSON) != "null" {
+				var reason string
+				if unmarshalErr := json.Unmarshal(rawJSON, &reason); unmarshalErr == nil {
+					logrus.Warnf("笔记不可访问: %s", reason)
+					return fmt.Errorf("笔记不可访问: %s", reason)
+				}
+				
+				rawReason := string(rawJSON)
+				logrus.Warnf("笔记不可访问，且无法解析原因: %s", rawReason)
+				return fmt.Errorf("笔记不可访问，无法解析原因: %s", rawReason)
+			}
+			
+			return nil
+		},
+		retry.Attempts(3),
+		retry.Delay(200*time.Millisecond),
+		retry.MaxJitter(300*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("页面可访问性检查重试 #%d: %v", n, err)
+		}),
+	)
+	
+	// If the error is nil, it means no access issue was found
+	if err == nil {
+		return nil // Page is accessible
+	}
+	
+	// Return the original error from the retry operation
+	return err
+}
+
+// ========== 数据提取 ==========
+
+func (f *FeedDetailAction) extractFeedDetail(page *rod.Page, feedID string) (*FeedDetailResponse, error) {
+	var result string
+	
+	// 使用retry-go来处理可能的DOM查询失败
+	err := retry.Do(
+		func() error {
+			evalResult := page.MustEval(`() => {
+				if (window.__INITIAL_STATE__ &&
+					window.__INITIAL_STATE__.note &&
+					window.__INITIAL_STATE__.note.noteDetailMap) {
+					const noteDetailMap = window.__INITIAL_STATE__.note.noteDetailMap;
+					return JSON.stringify(noteDetailMap);
+				}
+				return "";
+			}`).String()
+			
+			if evalResult != "" {
+				result = evalResult
+				return nil
+			}
+			return fmt.Errorf("无法获取初始状态数据")
+		},
+		retry.Attempts(3),
+		retry.Delay(200*time.Millisecond),
+		retry.MaxJitter(300*time.Millisecond),
+		retry.OnRetry(func(n uint, err error) {
+			logrus.Debugf("提取Feed详情重试 #%d: %v", n, err)
+		}),
+	)
+	
+	if err != nil {
+		logrus.Errorf("提取Feed详情失败: %v", err)
+		return nil, fmt.Errorf("提取Feed详情失败: %w", err)
+	}
 	
 	if result == "" {
 		return nil, errors.ErrNoFeedDetail