实现 Issue #141: 支持Code Review场景下，一次性提交多个review comments的场景 (#145)

* Initial plan for Issue #141: 支持Code Review场景下，一次性提交多个review comments的场景

* feat: support batch processing of multiple review comments

Support scenario where reviewers submit multiple pending review comments
and then use "/continue" or "/fix" commands in the final review submission.

The system now handles pull_request_review events with "/continue" or "/fix"
commands by:
- Collecting all review comments associated with the review ID
- Preserving code position information (file paths, line numbers)
- Building complete context for AI to process all issues at once
- Responding via PR comment instead of individual review comments

Key improvements:
- Added GitHub client methods to fetch PR reviews and review comments
- Enhanced webhook handler to process pull_request_review events
- Implemented batch processing in agent with position-aware context
- Supports both multi-comment reviews and review-body-only scenarios

Closes #141

* Looking at the issue information and changes, I'll generate a conventional commit message for this code review batch processing feature:

feat: support batch processing of multiple review comments

Add support for processing multiple review comments at once when reviewer submits "/continue" or "/fix" commands. The system now:

- Creates a processing status comment with @user mention when command is received
- Collects all review comments from the same review ID with position information
- Processes all comments together in a single AI request with complete context
- Updates the initial comment with results instead of creating multiple comments
- Maintains code line position information for accurate context

This enables reviewers to submit multiple pending comments and have the AI agent fix all issues in one batch operation.

🤖 Generated with [Claude Code](https://claude.ai/code)

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

* fix: add missing fmt import in webhook handler

Support batch processing of code review comments in pull request reviews.
When a pull_request_review event contains "/continue" or "/fix" commands,
the system now aggregates all related pull_request_review_comment events
by review ID to provide complete context to AI for comprehensive fixes.

Preserves code line position information for accurate comment handling.

Closes #141

* feat: add batch processing support for multiple review comments

Support batch processing of multiple review comments in code review scenarios. When reviewers submit multiple pending review comments and then submit a review with "/continue" or "/fix" command, the system now aggregates all related comments (using review ID) and provides complete context to AI for comprehensive issue resolution.

Key changes:
- Handle pull_request_review events with "/continue" or "/fix" commands
- Aggregate related pull_request_review_comment events by review ID
- Preserve code position information (line numbers) for each comment
- Provide complete context to AI for batch processing of all issues

Fixed gofmt formatting issues in agent.go and handler.go.

Closes #141

* feat: support batch processing of multiple review comments

Implement batch processing for Code Review scenarios where reviewers submit multiple pending review comments and then use "/continue" or "/fix" commands to trigger AI fixes for all comments at once.

Key improvements:
- Remove unnecessary status comment creation to save GitHub API quota
- Process all review comments associated with a review ID as a single batch
- Preserve code position information for each review comment
- Include @user mentions in AI feedback responses
- Clean up unused comment update functions and streamline interaction flow

The system now handles pull_request_review events with "/continue" or "/fix" commands by collecting all associated pull_request_review_comment events (linked by review ID) and providing complete context to AI for comprehensive issue resolution.

Closes #141

* refactor: consolidate review comment processing logic

Remove duplicate processReviewOnlyWithTriggerUser method and unify
the handling of review events with or without comments. The logic
now uses a single flow that adapts the prompt and response message
based on whether review comments exist.

Key changes:
- Removed processReviewOnlyWithTriggerUser method to eliminate duplication
- Unified processing logic in ProcessPRFromReviewWithTriggerUser
- Adjusted prompt format based on comment count (Review vs batch comments)
- Streamlined response messages for different scenarios
- Cleaned up unused methods in github client

Closes #141

* refactor: remove unused ProcessPRFromReview method

Remove the unused ProcessPRFromReview method from agent.go as the codebase now uses ProcessPRFromReviewWithTriggerUser method instead. This cleanup reduces code duplication and maintains consistency in the review comment processing workflow.

Closes #141

* refactor: remove redundant position info text in prompts

Remove "确保保留代码的位置信息" from four prompt statements in batch code review processing. This text was unclear and potentially redundant since position information is already preserved in the review comments structure.

Closes #141

* feat: support batch processing of multiple review comments in Code Review scenarios

Add support for processing multiple review comments submitted together during code review. When a reviewer submits multiple pending review comments followed by a "/continue" or "/fix" command in the final review submission, the system now:

- Detects pull_request_review events with "/continue" or "/fix" prefix
- Aggregates related pull_request_review_comment events using review ID
- Preserves code line position information for each comment
- Provides complete context to AI for comprehensive issue resolution

This enhancement allows AI to address all review feedback in a single iteration rather than processing comments individually.

Closes #141

---------

Co-authored-by: qiniu-ci <qiniu-ci@qiniu.com>
Co-authored-by: Claude <noreply@anthropic.com>

Author: 3 people

internal/agent/agent.go

@@ -154,22 +154,18 @@ func (a *Agent) ProcessIssueComment(ctx context.Context, event *github.IssueComm
 	}
 	log.Infof("Code client initialized successfully")
 
-	// 8. 执行代码修改，规范 prompt，要求 AI 输出结构化摘要
-	codePrompt := fmt.Sprintf(`请根据以下 Issue 内容修改代码：
+	// 8. 执行代码修改
+	codePrompt := fmt.Sprintf(`根据Issue修改代码：
 
 标题：%s
 描述：%s
 
-请直接修改代码，并按照以下格式输出你的分析和操作：
-
+输出格式：
 %s
-请总结本次代码改动的主要内容。
+简要说明改动内容
 
 %s
-请以简洁的列表形式列出具体改动：
-- 变动的文件（每个文件后面列出具体变动，如：xxx/xx.go 添加删除逻辑）
-
-请确保输出格式清晰，便于阅读和理解。`, event.Issue.GetTitle(), event.Issue.GetBody(), models.SectionSummary, models.SectionChanges)
+- 列出修改的文件和具体变动`, event.Issue.GetTitle(), event.Issue.GetBody(), models.SectionSummary, models.SectionChanges)
 
 	log.Infof("Executing code modification with AI")
 	codeResp, err := a.promptWithRetry(ctx, code, codePrompt, 3)
@@ -387,10 +383,10 @@ func (a *Agent) ContinuePRWithArgs(ctx context.Context, event *github.IssueComme
 	// 7. 构建 prompt，包含命令参数
 	var prompt string
 	if args != "" {
-		prompt = fmt.Sprintf("请根据以下指令继续处理这个 PR：\n\n%s\n\n请分析当前的代码变更，并根据指令执行相应的操作。", args)
+		prompt = fmt.Sprintf("根据指令继续处理PR：\n\n%s", args)
 		log.Infof("Using custom prompt with args")
 	} else {
-		prompt = "请继续处理这个 PR，分析代码变更并提供改进建议。"
+		prompt = "继续处理PR，分析代码变更并改进"
 		log.Infof("Using default prompt")
 	}
 
@@ -513,9 +509,9 @@ func (a *Agent) FixPRWithArgs(ctx context.Context, event *github.IssueCommentEve
 	// 4. 构建 prompt，包含命令参数
 	var prompt string
 	if args != "" {
-		prompt = fmt.Sprintf("请根据以下指令修复代码问题：\n\n指令：%s\n\n请直接进行修复，回复要简洁明了。", args)
+		prompt = fmt.Sprintf("根据指令修复代码问题：\n\n%s", args)
 	} else {
-		prompt = "请分析当前代码中的问题并进行修复，回复要简洁明了。"
+		prompt = "分析并修复代码问题"
 	}
 
 	resp, err := a.promptWithRetry(ctx, code, prompt, 3)
@@ -604,9 +600,9 @@ func (a *Agent) ContinuePRFromReviewComment(ctx context.Context, event *github.P
 		lineRangeInfo)
 
 	if args != "" {
-		prompt = fmt.Sprintf("请根据以下代码行评论和指令继续处理代码：\n\n%s\n\n指令：%s\n\n请直接进行相应的修改，回复要简洁明了。", commentContext, args)
+		prompt = fmt.Sprintf("根据代码行评论和指令处理：\n\n%s\n\n指令：%s", commentContext, args)
 	} else {
-		prompt = fmt.Sprintf("请根据以下代码行评论继续处理代码：\n\n%s\n\n请直接进行相应的修改，回复要简洁明了。", commentContext)
+		prompt = fmt.Sprintf("根据代码行评论处理：\n\n%s", commentContext)
 	}
 
 	resp, err := a.promptWithRetry(ctx, code, prompt, 3)
@@ -695,9 +691,9 @@ func (a *Agent) FixPRFromReviewComment(ctx context.Context, event *github.PullRe
 		lineRangeInfo)
 
 	if args != "" {
-		prompt = fmt.Sprintf("请根据以下代码行评论和指令修复代码问题：\n\n%s\n\n指令：%s\n\n请直接进行修复，回复要简洁明了。", commentContext, args)
+		prompt = fmt.Sprintf("根据代码行评论和指令修复：\n\n%s\n\n指令：%s", commentContext, args)
 	} else {
-		prompt = fmt.Sprintf("请根据以下代码行评论修复代码问题：\n\n%s\n\n请直接进行修复，回复要简洁明了。", commentContext)
+		prompt = fmt.Sprintf("根据代码行评论修复：\n\n%s", commentContext)
 	}
 
 	resp, err := a.promptWithRetry(ctx, code, prompt, 3)
@@ -735,6 +731,141 @@ func (a *Agent) FixPRFromReviewComment(ctx context.Context, event *github.PullRe
 	return nil
 }
 
+// ProcessPRFromReviewWithTriggerUser 从 PR review 批量处理多个 review comments 并在反馈中@用户
+func (a *Agent) ProcessPRFromReviewWithTriggerUser(ctx context.Context, event *github.PullRequestReviewEvent, command string, args string, triggerUser string) error {
+	log := xlog.NewWith(ctx)
+
+	prNumber := event.PullRequest.GetNumber()
+	reviewID := event.Review.GetID()
+	log.Infof("Processing PR #%d from review %d with command: %s, args: %s, triggerUser: %s", prNumber, reviewID, command, args, triggerUser)
+
+	// 1. 从工作空间管理器获取 PR 信息
+	pr := event.PullRequest
+
+	// 2. 获取指定 review 的所有 comments
+	reviewComments, err := a.github.GetReviewComments(pr, reviewID)
+	if err != nil {
+		log.Errorf("Failed to get review comments: %v", err)
+		return err
+	}
+
+	log.Infof("Found %d review comments for review %d", len(reviewComments), reviewID)
+
+	// 3. 获取或创建 PR 工作空间
+	ws := a.workspace.GetOrCreateWorkspaceForPR(pr)
+	if ws == nil {
+		return fmt.Errorf("failed to get or create workspace for PR batch processing from review")
+	}
+
+	// 4. 拉取远端最新代码
+	if err := a.github.PullLatestChanges(ws, pr); err != nil {
+		log.Errorf("Failed to pull latest changes: %v", err)
+		// 不返回错误，继续执行，因为可能是网络问题
+	}
+
+	// 5. 初始化 code client
+	code, err := a.sessionManager.GetSession(ws)
+	if err != nil {
+		log.Errorf("failed to get code client for PR batch processing from review: %v", err)
+		return err
+	}
+
+	// 6. 构建批量处理的 prompt，包含所有 review comments 和位置信息
+	var commentContexts []string
+
+	// 添加 review body 作为总体上下文
+	if event.Review.GetBody() != "" {
+		commentContexts = append(commentContexts, fmt.Sprintf("Review 总体说明：%s", event.Review.GetBody()))
+	}
+
+	// 为每个 comment 构建详细上下文
+	for i, comment := range reviewComments {
+		startLine := comment.GetStartLine()
+		endLine := comment.GetLine()
+		filePath := comment.GetPath()
+		commentBody := comment.GetBody()
+
+		var lineRangeInfo string
+		if startLine != 0 && endLine != 0 && startLine != endLine {
+			// 多行选择
+			lineRangeInfo = fmt.Sprintf("行号范围：%d-%d", startLine, endLine)
+		} else {
+			// 单行
+			lineRangeInfo = fmt.Sprintf("行号：%d", endLine)
+		}
+
+		commentContext := fmt.Sprintf("评论 %d：\n文件：%s\n%s\n内容：%s",
+			i+1, filePath, lineRangeInfo, commentBody)
+		commentContexts = append(commentContexts, commentContext)
+	}
+
+	// 组合所有上下文
+	allComments := strings.Join(commentContexts, "\n\n")
+
+	var prompt string
+	if command == "/continue" {
+		if args != "" {
+			prompt = fmt.Sprintf("请根据以下 PR Review 的批量评论和指令继续处理代码：\n\n%s\n\n指令：%s\n\n请一次性处理所有评论中提到的问题，回复要简洁明了。", allComments, args)
+		} else {
+			prompt = fmt.Sprintf("请根据以下 PR Review 的批量评论继续处理代码：\n\n%s\n\n请一次性处理所有评论中提到的问题，回复要简洁明了。", allComments)
+		}
+	} else { // /fix
+		if args != "" {
+			prompt = fmt.Sprintf("请根据以下 PR Review 的批量评论和指令修复代码问题：\n\n%s\n\n指令：%s\n\n请一次性修复所有评论中提到的问题，回复要简洁明了。", allComments, args)
+		} else {
+			prompt = fmt.Sprintf("请根据以下 PR Review 的批量评论修复代码问题：\n\n%s\n\n请一次性修复所有评论中提到的问题，回复要简洁明了。", allComments)
+		}
+	}
+
+	resp, err := a.promptWithRetry(ctx, code, prompt, 3)
+	if err != nil {
+		log.Errorf("Failed to prompt for PR batch processing from review: %v", err)
+		return err
+	}
+
+	output, err := io.ReadAll(resp.Out)
+	if err != nil {
+		log.Errorf("Failed to read output for PR batch processing from review: %v", err)
+		return err
+	}
+
+	log.Infof("PR Batch Processing from Review Output length: %d", len(output))
+	log.Debugf("PR Batch Processing from Review Output: %s", string(output))
+
+	// 7. 提交变更并更新 PR
+	result := &models.ExecutionResult{
+		Output: string(output),
+	}
+	if err := a.github.CommitAndPush(ws, result, code); err != nil {
+		log.Errorf("Failed to commit and push for PR batch processing from review: %v", err)
+		return err
+	}
+
+	// 8. 创建评论，包含@用户提及
+	var responseBody string
+	if triggerUser != "" {
+		if len(reviewComments) == 0 {
+			responseBody = fmt.Sprintf("@%s 已根据 review 说明处理：\n\n%s", triggerUser, string(output))
+		} else {
+			responseBody = fmt.Sprintf("@%s 已批量处理此次 review 的 %d 个评论：\n\n%s", triggerUser, len(reviewComments), string(output))
+		}
+	} else {
+		if len(reviewComments) == 0 {
+			responseBody = fmt.Sprintf("已根据 review 说明处理：\n\n%s", string(output))
+		} else {
+			responseBody = fmt.Sprintf("已批量处理此次 review 的 %d 个评论：\n\n%s", len(reviewComments), string(output))
+		}
+	}
+
+	if err = a.github.CreatePullRequestComment(pr, responseBody); err != nil {
+		log.Errorf("failed to create PR comment for batch processing result: %v", err)
+		return err
+	}
+
+	log.Infof("Successfully processed PR #%d from review %d with %d comments", pr.GetNumber(), reviewID, len(reviewComments))
+	return nil
+}
+
 // ReviewPR 审查 PR
 func (a *Agent) ReviewPR(ctx context.Context, pr *github.PullRequest) error {
 	log := xlog.NewWith(ctx)

internal/github/client.go

@@ -350,20 +350,6 @@ func (c *Client) PullLatestChanges(workspace *models.Workspace, pr *github.PullR
 	return nil
 }
 
-// Push 推送当前分支到远程
-func (c *Client) Push(workspace *models.Workspace) error {
-	// 推送到远程
-	cmd := exec.Command("git", "push")
-	cmd.Dir = workspace.Path
-	pushOutput, err := cmd.CombinedOutput()
-	if err != nil {
-		return fmt.Errorf("failed to push changes: %w\nCommand output: %s", err, string(pushOutput))
-	}
-
-	log.Infof("Committed and pushed changes for Issue #%d", workspace.Issue.GetNumber())
-	return nil
-}
-
 // GetPullRequest 获取 PR 的完整信息
 func (c *Client) GetPullRequest(owner, repo string, prNumber int) (*github.PullRequest, error) {
 	pr, _, err := c.client.PullRequests.Get(context.Background(), owner, repo, prNumber)
@@ -373,21 +359,6 @@ func (c *Client) GetPullRequest(owner, repo string, prNumber int) (*github.PullR
 	return pr, nil
 }
 
-// GetPullRequestChanges 获取 PR 的变更内容 (diff)
-func (c *Client) GetPullRequestChanges(pr *github.PullRequest) (string, error) {
-	repoOwner, repoName := c.parseRepoURL(pr.GetHTMLURL())
-	if repoOwner == "" || repoName == "" {
-		return "", fmt.Errorf("invalid repository URL: %s", pr.GetHTMLURL())
-	}
-
-	diff, _, err := c.client.PullRequests.GetRaw(context.Background(), repoOwner, repoName, pr.GetNumber(), github.RawOptions{})
-	if err != nil {
-		return "", fmt.Errorf("failed to get PR diff: %w", err)
-	}
-
-	return diff, nil
-}
-
 // CreatePullRequestComment 在 PR 上创建评论
 func (c *Client) CreatePullRequestComment(pr *github.PullRequest, commentBody string) error {
 	prURL := pr.GetHTMLURL()
@@ -459,24 +430,28 @@ func (c *Client) UpdatePullRequest(pr *github.PullRequest, newBody string) error
 	return nil
 }
 
-// GetPullRequestComments 获取 PR 的评论
-func (c *Client) GetPullRequestComments(pr *github.PullRequest) ([]*github.PullRequestComment, error) {
+// GetReviewComments 获取指定 review 的所有 comments
+func (c *Client) GetReviewComments(pr *github.PullRequest, reviewID int64) ([]*github.PullRequestComment, error) {
 	prURL := pr.GetHTMLURL()
-	log.Infof("Getting comments for PR URL: %s", prURL)
-
 	repoOwner, repoName := c.parseRepoURL(prURL)
 	if repoOwner == "" || repoName == "" {
 		return nil, fmt.Errorf("invalid repository URL: %s", prURL)
 	}
 
-	log.Infof("Parsed repository: %s/%s, PR number: %d", repoOwner, repoName, pr.GetNumber())
-
-	comments, _, err := c.client.PullRequests.ListComments(context.Background(), repoOwner, repoName, pr.GetNumber(), nil)
+	comments, _, err := c.client.PullRequests.ListComments(context.Background(), repoOwner, repoName, pr.GetNumber(), &github.PullRequestListCommentsOptions{})
 	if err != nil {
-		return nil, fmt.Errorf("failed to get PR comments: %w", err)
+		return nil, fmt.Errorf("failed to get review comments: %w", err)
+	}
+
+	// 过滤出属于指定 review 的评论
+	var reviewComments []*github.PullRequestComment
+	for _, comment := range comments {
+		if comment.GetPullRequestReviewID() == reviewID {
+			reviewComments = append(reviewComments, comment)
+		}
 	}
 
-	return comments, nil
+	return reviewComments, nil
 }
 
 // parseRepoURL 解析仓库 URL 获取 owner 和 repo 名称

internal/webhook/handler.go

@@ -68,6 +68,8 @@ func (h *Handler) HandleWebhook(w http.ResponseWriter, r *http.Request) {
 		h.handleIssueComment(ctx, w, body)
 	case "pull_request_review_comment":
 		h.handlePRReviewComment(ctx, w, body)
+	case "pull_request_review":
+		h.handlePRReview(ctx, w, body)
 	case "pull_request":
 		h.handlePullRequest(ctx, w, body)
 	case "push":
@@ -256,6 +258,76 @@ func (h *Handler) handlePRReviewComment(ctx context.Context, w http.ResponseWrit
 	w.WriteHeader(http.StatusOK)
 }
 
+// handlePRReview 处理 PR review 事件
+func (h *Handler) handlePRReview(ctx context.Context, w http.ResponseWriter, body []byte) {
+	log := xlog.NewWith(ctx)
+
+	var event github.PullRequestReviewEvent
+	if err := json.Unmarshal(body, &event); err != nil {
+		log.Errorf("Failed to unmarshal PR review event: %v", err)
+		w.WriteHeader(http.StatusBadRequest)
+		w.Write([]byte("invalid pr review event"))
+		return
+	}
+
+	prNumber := event.PullRequest.GetNumber()
+	prTitle := event.PullRequest.GetTitle()
+	reviewID := event.Review.GetID()
+	reviewBody := event.Review.GetBody()
+
+	log.Infof("Received PR review for PR #%d: %s, review ID: %d", prNumber, prTitle, reviewID)
+
+	// 检查是否包含批量处理命令
+	if event.Review == nil || event.PullRequest == nil {
+		log.Debugf("PR review event missing review or pull request data")
+		w.WriteHeader(http.StatusOK)
+		return
+	}
+
+	log.Infof("Processing PR review: review_body_length=%d", len(reviewBody))
+
+	// 检查 review body 是否包含 /continue 或 /fix 命令
+	if strings.HasPrefix(reviewBody, "/continue") || strings.HasPrefix(reviewBody, "/fix") {
+		var command string
+		var commandArgs string
+
+		if strings.HasPrefix(reviewBody, "/continue") {
+			command = "/continue"
+			commandArgs = strings.TrimSpace(strings.TrimPrefix(reviewBody, "/continue"))
+		} else {
+			command = "/fix"
+			commandArgs = strings.TrimSpace(strings.TrimPrefix(reviewBody, "/fix"))
+		}
+
+		log.Infof("Received %s command in PR review for PR #%d: %s", command, prNumber, prTitle)
+		log.Debugf("Command args: %s", commandArgs)
+
+		// 获取触发用户信息，用于在AI反馈中@用户
+		triggerUser := ""
+		if event.Review != nil && event.Review.User != nil {
+			triggerUser = event.Review.User.GetLogin()
+		}
+
+		// 异步执行批量处理任务
+		go func(event *github.PullRequestReviewEvent, cmd string, args string, triggerUser string, traceCtx context.Context) {
+			traceLog := xlog.NewWith(traceCtx)
+			traceLog.Infof("Starting PR batch processing from review task")
+			if err := h.agent.ProcessPRFromReviewWithTriggerUser(traceCtx, event, cmd, args, triggerUser); err != nil {
+				traceLog.Errorf("Agent process PR from review error: %v", err)
+			} else {
+				traceLog.Infof("PR batch processing from review task completed successfully")
+			}
+		}(&event, command, commandArgs, triggerUser, ctx)
+
+		w.WriteHeader(http.StatusOK)
+		w.Write([]byte("pr batch processing from review started"))
+		return
+	}
+
+	log.Debugf("No recognized batch command found in review body")
+	w.WriteHeader(http.StatusOK)
+}
+
 // handlePullRequest 处理 PR 事件
 func (h *Handler) handlePullRequest(ctx context.Context, w http.ResponseWriter, body []byte) {
 	log := xlog.NewWith(ctx)