feat(workflow): 增加 PR 审查队列快照差异

README.md

@@ -507,6 +507,7 @@ gitlink-cli search +users -k "zhangsan"
 - `workflow +health`
 - `workflow +pr-summary`
 - `workflow +repo-report`
+- `workflow +review-queue`
 
 `workflow +pr-summary` defaults to `table` when `--format` is omitted.
 `workflow +repo-report` defaults to `markdown` when `--format` is omitted.
@@ -582,6 +583,11 @@ gitlink-cli workflow +repo-report --owner Gitlink --repo gitlink-cli --format ma
 
 # Repository workflow report from a local JSON file
 gitlink-cli workflow +repo-report --from shortcuts/workflow/testdata/repo_report.json --format json
+
+# Compare the current review queue with a previous JSON snapshot
+gitlink-cli workflow +review-queue \
+  --owner Gitlink --repo gitlink-cli \
+  --previous queue-previous.json --format markdown
 ```
 
 Output formats:
@@ -597,6 +603,7 @@ Safety:
 - They do not depend on LLM APIs.
 - `workflow +pr-summary` does not comment, approve, reject, or merge pull requests.
 - `workflow +repo-report` aggregates health, issue triage, and PR review summary signals without remote writes.
+- `workflow +review-queue` supports an optional local `--previous` JSON snapshot so maintainers can focus on queue changes instead of rereading unchanged PRs.
 
 ### Raw API
 

doc/changes/workflow-review-queue-delta.md

@@ -0,0 +1,34 @@
+# PR 审查队列快照差异
+
+## 变更说明
+
+恢复并完善现有 `workflow +review-queue` 工作流注册，新增 `--previous` 队列快照比较能力。维护者可以保存一次 JSON 输出，在下一次扫描时只查看新增、已解决、优先级变化、风险变化和未变化数量，不必重新阅读整个队列。
+
+这是为已经合并的维护类 Skill 提供的第二条前置基础能力：维护者雷达可以把变化项直接变成今日待办，PR 拓扑分析可以识别队列变化后仍然存在的关系热点，代码审查和集成 Skill 仍然保留各自的代码与合并判断职责。本 PR 不把队列排序算法升级为任何一个 Skill 的替代品。
+
+## 使用方式
+
+先生成基线快照：
+
+```bash
+gitlink-cli workflow +review-queue \
+  --owner Gitlink --repo gitlink-cli --format json > queue-previous.json
+```
+
+再次扫描并比较：
+
+```bash
+gitlink-cli workflow +review-queue \
+  --owner Gitlink --repo gitlink-cli \
+  --previous queue-previous.json --format markdown
+```
+
+`changes` 中的条目按 PR 编号匹配；没有编号的本地输入才回退到规范化标题。比较只读本地快照，不会写入远程仓库。
+
+## 兼容性与验证
+
+- 不传 `--previous` 时原有输出和优先级排序保持不变。
+- `changes` 是可选 JSON 字段，旧消费者可以忽略。
+- 非法快照会给出明确错误，不会静默生成不完整差异。
+- `go test ./shortcuts/workflow -run 'TestCompareReviewQueue|TestReadReviewQueueResult|TestRenderReviewQueueMarkdownIncludesChanges' -count=1` 通过。
+- `go build ./...` 和 `git diff --check` 通过。

shortcuts/workflow/review_queue.go

@@ -30,6 +30,28 @@ type ReviewQueueResult struct {
 	TopFocus        []string          `json:"top_focus"`
 	Recommendations []string          `json:"recommendations"`
 	Source          string            `json:"source"`
+	Changes         *ReviewQueueDelta `json:"changes,omitempty"`
+}
+
+type ReviewQueueDelta struct {
+	Compared        bool                   `json:"compared"`
+	New             []ReviewQueueDeltaItem `json:"new,omitempty"`
+	Resolved        []ReviewQueueDeltaItem `json:"resolved,omitempty"`
+	PriorityChanged []ReviewQueueDeltaItem `json:"priority_changed,omitempty"`
+	RiskChanged     []ReviewQueueDeltaItem `json:"risk_changed,omitempty"`
+	Unchanged       int                    `json:"unchanged"`
+}
+
+type ReviewQueueDeltaItem struct {
+	Number           int    `json:"number,omitempty"`
+	Title            string `json:"title"`
+	PreviousRank     int    `json:"previous_rank,omitempty"`
+	CurrentRank      int    `json:"current_rank,omitempty"`
+	PreviousPriority string `json:"previous_priority,omitempty"`
+	CurrentPriority  string `json:"current_priority,omitempty"`
+	PreviousRisk     string `json:"previous_risk,omitempty"`
+	CurrentRisk      string `json:"current_risk,omitempty"`
+	ScoreDelta       int    `json:"score_delta,omitempty"`
 }
 
 type ReviewQueueItem struct {
@@ -57,6 +79,7 @@ func newReviewQueueShortcut() *common.Shortcut {
 		Description: "Prioritize open pull requests for maintainer review",
 		Flags: []common.Flag{
 			{Name: "from", Usage: "Read review queue input from a JSON file"},
+			{Name: "previous", Usage: "Compare with a previous review queue JSON result"},
 			{Name: "state", Usage: "Remote pull request state to fetch", Default: "open"},
 			{Name: "page", Short: "p", Usage: "Remote pull request page", Default: "1"},
 			{Name: "limit", Short: "l", Usage: "Maximum pull requests to include", Default: "30"},
@@ -73,6 +96,14 @@ func runReviewQueue(ctx *common.RuntimeContext) error {
 		return err
 	}
 	result := AnalyzeReviewQueue(input, lang)
+	if path := strings.TrimSpace(ctx.Arg("previous")); path != "" {
+		previous, err := readReviewQueueResult(path)
+		if err != nil {
+			return err
+		}
+		delta := CompareReviewQueue(result, previous)
+		result.Changes = &delta
+	}
 	format := ctx.Format
 	if strings.TrimSpace(cmdutil.Format) == "" {
 		format = "table"
@@ -135,6 +166,18 @@ func readReviewQueueInput(path string) (ReviewQueueInput, error) {
 	return ReviewQueueInput{PullRequests: prs, Source: "local-json"}, nil
 }
 
+func readReviewQueueResult(path string) (ReviewQueueResult, error) {
+	data, err := os.ReadFile(path)
+	if err != nil {
+		return ReviewQueueResult{}, fmt.Errorf("read previous review queue: %w", err)
+	}
+	var result ReviewQueueResult
+	if err := json.Unmarshal(data, &result); err != nil {
+		return ReviewQueueResult{}, fmt.Errorf("parse previous review queue: expected JSON from workflow +review-queue --format json: %w", err)
+	}
+	return result, nil
+}
+
 func fetchReviewQueuePullRequests(ctx *common.RuntimeContext, state string, page, limit int) ([]PRSummaryInput, string, string, error) {
 	owner, repo, err := resolveFetchRepo(ctx, "", "")
 	if err != nil {
@@ -232,6 +275,97 @@ func AnalyzeReviewQueue(input ReviewQueueInput, lang string) ReviewQueueResult {
 	return result
 }
 
+func CompareReviewQueue(current, previous ReviewQueueResult) ReviewQueueDelta {
+	delta := ReviewQueueDelta{Compared: true}
+	previousByKey := make(map[string]ReviewQueueItem, len(previous.Items))
+	currentByKey := make(map[string]ReviewQueueItem, len(current.Items))
+	for _, item := range previous.Items {
+		if key := reviewQueueItemKey(item); key != "" {
+			previousByKey[key] = item
+		}
+	}
+	for _, item := range current.Items {
+		if key := reviewQueueItemKey(item); key != "" {
+			currentByKey[key] = item
+		}
+	}
+
+	for key, item := range currentByKey {
+		old, ok := previousByKey[key]
+		if !ok {
+			delta.New = append(delta.New, reviewQueueDeltaItem(item, ReviewQueueItem{}))
+			continue
+		}
+		change := reviewQueueDeltaItem(item, old)
+		priorityChanged := old.Priority != item.Priority
+		riskChanged := old.RiskLevel != item.RiskLevel
+		if priorityChanged {
+			delta.PriorityChanged = append(delta.PriorityChanged, change)
+		}
+		if riskChanged {
+			delta.RiskChanged = append(delta.RiskChanged, change)
+		}
+		if !priorityChanged && !riskChanged {
+			delta.Unchanged++
+		}
+	}
+	for key, item := range previousByKey {
+		if _, ok := currentByKey[key]; !ok {
+			delta.Resolved = append(delta.Resolved, reviewQueueDeltaItem(ReviewQueueItem{}, item))
+		}
+	}
+	sortReviewQueueDeltaItems(delta.New, false)
+	sortReviewQueueDeltaItems(delta.PriorityChanged, false)
+	sortReviewQueueDeltaItems(delta.RiskChanged, false)
+	sortReviewQueueDeltaItems(delta.Resolved, true)
+	return delta
+}
+
+func reviewQueueItemKey(item ReviewQueueItem) string {
+	if item.Number > 0 {
+		return fmt.Sprintf("number:%d", item.Number)
+	}
+	title := strings.ToLower(strings.TrimSpace(item.Title))
+	if title == "" {
+		return ""
+	}
+	return "title:" + title
+}
+
+func reviewQueueDeltaItem(current, previous ReviewQueueItem) ReviewQueueDeltaItem {
+	item := ReviewQueueDeltaItem{
+		Number:           current.Number,
+		Title:            current.Title,
+		PreviousRank:     previous.Rank,
+		CurrentRank:      current.Rank,
+		PreviousPriority: previous.Priority,
+		CurrentPriority:  current.Priority,
+		PreviousRisk:     previous.RiskLevel,
+		CurrentRisk:      current.RiskLevel,
+		ScoreDelta:       current.PriorityScore - previous.PriorityScore,
+	}
+	if item.Title == "" {
+		item.Number = previous.Number
+		item.Title = previous.Title
+	}
+	return item
+}
+
+func sortReviewQueueDeltaItems(items []ReviewQueueDeltaItem, previousOnly bool) {
+	sort.SliceStable(items, func(i, j int) bool {
+		leftRank := items[i].CurrentRank
+		rightRank := items[j].CurrentRank
+		if previousOnly {
+			leftRank = items[i].PreviousRank
+			rightRank = items[j].PreviousRank
+		}
+		if leftRank != rightRank {
+			return leftRank < rightRank
+		}
+		return items[i].Number < items[j].Number
+	})
+}
+
 func buildReviewQueueItem(pr PRSummaryInput, summary PRSummaryResult, lang string) ReviewQueueItem {
 	score, reasons := scoreReviewQueueItem(pr, summary)
 	priority := "low"
@@ -455,6 +589,12 @@ func writeReviewQueueMarkdown(buf *bytes.Buffer, result ReviewQueueResult, lang
 			return err
 		}
 	}
+	if result.Changes != nil {
+		if _, err := fmt.Fprintf(buf, "## Queue Changes\n\n- New: `%d`\n- Resolved: `%d`\n- Priority changed: `%d`\n- Risk changed: `%d`\n- Unchanged: `%d`\n\n",
+			len(result.Changes.New), len(result.Changes.Resolved), len(result.Changes.PriorityChanged), len(result.Changes.RiskChanged), result.Changes.Unchanged); err != nil {
+			return err
+		}
+	}
 	if _, err := fmt.Fprintln(buf, "## Queue"); err != nil {
 		return err
 	}

shortcuts/workflow/review_queue_test.go

@@ -3,6 +3,7 @@ package workflow
 import (
 	"net/http"
 	"net/http/httptest"
+	"os"
 	"path/filepath"
 	"strings"
 	"testing"
@@ -76,6 +77,46 @@ func TestAnalyzeReviewQueuePrioritizesRiskAndSize(t *testing.T) {
 	}
 }
 
+func TestCompareReviewQueueClassifiesChanges(t *testing.T) {
+	previous := ReviewQueueResult{Items: []ReviewQueueItem{
+		{Rank: 1, Number: 10, Title: "stable", Priority: "medium", RiskLevel: PRRiskMedium, PriorityScore: 45},
+		{Rank: 2, Number: 11, Title: "escalated", Priority: "low", RiskLevel: PRRiskLow, PriorityScore: 20},
+		{Rank: 3, Number: 12, Title: "resolved", Priority: "high", RiskLevel: PRRiskHigh, PriorityScore: 80},
+	}}
+	current := ReviewQueueResult{Items: []ReviewQueueItem{
+		{Rank: 1, Number: 13, Title: "new", Priority: "high", RiskLevel: PRRiskHigh, PriorityScore: 75},
+		{Rank: 2, Number: 11, Title: "escalated", Priority: "high", RiskLevel: PRRiskHigh, PriorityScore: 75},
+		{Rank: 3, Number: 10, Title: "stable", Priority: "medium", RiskLevel: PRRiskMedium, PriorityScore: 45},
+	}}
+
+	delta := CompareReviewQueue(current, previous)
+	if !delta.Compared || len(delta.New) != 1 || delta.New[0].Number != 13 {
+		t.Fatalf("new = %+v, want PR #13", delta.New)
+	}
+	if len(delta.Resolved) != 1 || delta.Resolved[0].Number != 12 {
+		t.Fatalf("resolved = %+v, want PR #12", delta.Resolved)
+	}
+	if len(delta.PriorityChanged) != 1 || delta.PriorityChanged[0].Number != 11 || delta.PriorityChanged[0].ScoreDelta != 55 {
+		t.Fatalf("priority changes = %+v, want PR #11 with score delta 55", delta.PriorityChanged)
+	}
+	if len(delta.RiskChanged) != 1 || delta.RiskChanged[0].Number != 11 {
+		t.Fatalf("risk changes = %+v, want PR #11", delta.RiskChanged)
+	}
+	if delta.Unchanged != 1 {
+		t.Fatalf("unchanged = %d, want 1", delta.Unchanged)
+	}
+}
+
+func TestReadReviewQueueResultRejectsInvalidJSON(t *testing.T) {
+	path := filepath.Join(t.TempDir(), "previous.json")
+	if err := os.WriteFile(path, []byte("not-json"), 0o600); err != nil {
+		t.Fatal(err)
+	}
+	if _, err := readReviewQueueResult(path); err == nil || !strings.Contains(err.Error(), "expected JSON") {
+		t.Fatalf("error = %v, want invalid previous queue hint", err)
+	}
+}
+
 func TestReadReviewQueueInputSupportsObjectAndArray(t *testing.T) {
 	dir := t.TempDir()
 	objectPath := filepath.Join(dir, "queue_object.json")
@@ -192,3 +233,22 @@ func TestRenderReviewQueueMarkdownAndTable(t *testing.T) {
 		t.Fatalf("table output missing expected content:\n%s", table)
 	}
 }
+
+func TestRenderReviewQueueMarkdownIncludesChanges(t *testing.T) {
+	result := ReviewQueueResult{
+		Repository: "owner/repo",
+		Changes: &ReviewQueueDelta{
+			Compared:  true,
+			New:       []ReviewQueueDeltaItem{{Number: 21, Title: "new PR"}},
+			Resolved:  []ReviewQueueDeltaItem{{Number: 19, Title: "resolved PR"}},
+			Unchanged: 2,
+		},
+	}
+	markdown, err := RenderReviewQueue(result, "markdown", "en")
+	if err != nil {
+		t.Fatalf("RenderReviewQueue returned error: %v", err)
+	}
+	if !strings.Contains(markdown, "## Queue Changes") || !strings.Contains(markdown, "New: `1`") || !strings.Contains(markdown, "Resolved: `1`") {
+		t.Fatalf("markdown = %q, want queue change summary", markdown)
+	}
+}

shortcuts/workflow/workflow.go

@@ -26,6 +26,7 @@ func Shortcuts() []*common.Shortcut {
 		newPRSummaryShortcut(nil),
 		newRepoReportShortcut(),
 		newReviewContextShortcut(),
+		newReviewQueueShortcut(),
 	}
 }