项目预警中心
- {total}
+ {formatBadgeCount(total)}
-
@@ -108,3 +92,31 @@ export function SSTCRiskFloatPanel({ risks, onJump }: SSTCRiskFloatPanelProps) {
);
}
+
+export function SSTCRiskTopbarEntry({ risks, onJump }: SSTCRiskPanelProps) {
+ const total = useMemo(() => computeRiskTotal(risks), [risks]);
+
+ return (
+
+
+
+
+
+
+
+
+ );
+}
diff --git a/frontend/src/pages/InboxPage.tsx b/frontend/src/pages/InboxPage.tsx
index 6a52307b..e922f8f3 100644
--- a/frontend/src/pages/InboxPage.tsx
+++ b/frontend/src/pages/InboxPage.tsx
@@ -1,264 +1,56 @@
import { useMemo, useState } from "react";
import { useNavigate, useSearchParams } from "react-router-dom";
import { useQuery, useQueryClient } from "@tanstack/react-query";
-import {
- BellRing,
- CheckCircle2,
- Filter,
- LoaderCircle,
- ShieldAlert,
- SlidersHorizontal,
- Sparkles,
-} from "lucide-react";
+import { BellRing } from "lucide-react";
import { aiPmoApi } from "@/api/aiPmo";
import { notificationsApi } from "@/api/notifications";
-import { Badge } from "@/components/ui/badge";
+import InboxListItem, { buildInboxActionKey } from "@/components/inbox/InboxListItem";
import { Button } from "@/components/ui/button";
-import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "@/components/ui/card";
-import {
- Dialog,
- DialogContent,
- DialogDescription,
- DialogFooter,
- DialogHeader,
- DialogTitle,
-} from "@/components/ui/dialog";
import { Input } from "@/components/ui/input";
-import { Switch } from "@/components/ui/switch";
-import { Tabs, TabsList, TabsTrigger } from "@/components/ui/tabs";
import { useToast } from "@/components/ui/toast";
-import { buildInboxView, getInboxSectionLabel } from "@/lib/inbox";
import { getApiErrorMessage } from "@/lib/apiError";
-import { cn } from "@/lib/utils";
-import { toZhPriority } from "@/lib/display";
import { parseBackendDate } from "@/lib/datetime";
-import type { InboxActionDescriptor, InboxDisplayKind, InboxItemViewModel, InboxSectionKey } from "@/types/inbox";
+import { buildInboxView } from "@/lib/inbox";
+import { cn } from "@/lib/utils";
+import type { InboxActionDescriptor, InboxDisplayKind, InboxItemViewModel } from "@/types/inbox";
const POLL_INTERVAL_MS = 15000;
-const STATUS_LABELS: Record
= {
- action_required: "需你决策",
- auto_running: "AI 已接手",
- auto_done: "AI 执行完成",
- info: "仅通知",
+type InboxTabKey = "all" | "needs_action" | "in_progress" | "done";
+
+const TAB_LABELS: Record = {
+ all: "全部",
+ needs_action: "待处理",
+ in_progress: "进行中",
+ done: "已完成",
};
-const STATUS_STYLES: Record = {
- action_required: "border-amber-500/40 bg-amber-500/10 text-amber-700 dark:text-amber-300",
- auto_running: "border-sky-500/40 bg-sky-500/10 text-sky-700 dark:text-sky-300",
- auto_done: "border-emerald-500/40 bg-emerald-500/10 text-emerald-700 dark:text-emerald-300",
- info: "border-slate-400/40 bg-slate-500/10 text-slate-700 dark:text-slate-300",
+const TAB_TO_DISPLAY_KIND: Partial> = {
+ needs_action: "action_required",
+ in_progress: "auto_running",
+ done: "auto_done",
};
-const METRIC_CARD_STYLES = [
- "bg-blue-50 text-blue-700",
- "bg-sky-50 text-sky-700",
- "bg-emerald-50 text-emerald-700",
- "bg-amber-50 text-amber-700",
- "bg-violet-50 text-violet-700",
-];
-
-const PRIORITY_OPTIONS = [
- { value: "all", label: "全部优先级" },
- { value: "high", label: "高优先级" },
- { value: "medium", label: "中优先级" },
- { value: "low", label: "低优先级" },
-];
-
-function matchesPriority(item: InboxItemViewModel, priorityFilter: string): boolean {
- if (priorityFilter === "all") return true;
- if (priorityFilter === "high") return item.priority_rank >= 3;
- if (priorityFilter === "medium") return item.priority_rank === 2;
- return item.priority_rank <= 1;
+function normalizeTabKey(raw?: string | null): InboxTabKey {
+ const value = String(raw || "").trim();
+ if (value === "action_required" || value === "needs_action") return "needs_action";
+ if (value === "auto_running" || value === "in_progress") return "in_progress";
+ if (value === "auto_done" || value === "done") return "done";
+ return "all";
}
-function buildScopedSections(items: InboxItemViewModel[]) {
- const sectionKeys: InboxSectionKey[] = ["all", "action_required", "auto_running", "auto_done", "info"];
- return sectionKeys.map((key) => ({
- key,
- label: getInboxSectionLabel(key),
- count: key === "all" ? items.length : items.filter((item) => item.display_kind === key).length,
- }));
+function sortByLatest(items: InboxItemViewModel[]): InboxItemViewModel[] {
+ const toTimestamp = (item: InboxItemViewModel): number => {
+ const date = parseBackendDate(item.updated_at || item.created_at);
+ return date ? date.getTime() : -1;
+ };
+
+ return [...items].sort((a, b) => toTimestamp(b) - toTimestamp(a));
}
-function isToday(value?: string | null) {
- const date = parseBackendDate(value);
- if (!date) return false;
- const now = new Date();
- return (
- date.getFullYear() === now.getFullYear() &&
- date.getMonth() === now.getMonth() &&
- date.getDate() === now.getDate()
- );
-}
-
-function formatDetailTime(value?: string | null) {
- const date = parseBackendDate(value);
- if (!date) return value || "-";
- return date.toLocaleString("zh-CN", { hour12: false });
-}
-
-function formatJsonBlock(value: unknown): string {
- if (!value) return "暂无";
- try {
- return JSON.stringify(value, null, 2);
- } catch {
- return String(value);
- }
-}
-
-function buildActionKey(item: InboxItemViewModel, action: InboxActionDescriptor): string {
- return `${item.id}:${action.kind}:${action.label}`;
-}
-
-function renderMiniList(title: string, description: string, items: InboxItemViewModel[], onOpen: (item: InboxItemViewModel) => void) {
- return (
-
-
- {title}
- {description}
-
-
- {items.length === 0 ? (
-
- 当前为空
-
- ) : (
- items.map((item) => (
-
- ))
- )}
-
-
- );
-}
-
-function InboxCard({
- item,
- onAction,
- pendingActionKey,
-}: {
- item: InboxItemViewModel;
- onAction: (item: InboxItemViewModel, action: InboxActionDescriptor) => void;
- pendingActionKey: string | null;
-}) {
- const stageCards = [
- { label: "当前阶段", value: item.stage_text || STATUS_LABELS[item.display_kind] },
- { label: "预计下一步", value: item.next_step_text || item.ai_plan || "-" },
- { label: "撤销状态", value: item.can_undo ? `可撤销，截止 ${item.undo_deadline || "-"}` : "不可撤销" },
- ];
- const primaryActionKey = buildActionKey(item, item.primary_action);
- const secondaryActionKey = buildActionKey(item, item.secondary_action);
- const weakActionKey = buildActionKey(item, item.weak_action);
- const primaryPending = pendingActionKey === primaryActionKey;
- const secondaryPending = pendingActionKey === secondaryActionKey;
- const weakPending = pendingActionKey === weakActionKey;
-
- return (
-
-
-
-
-
- {STATUS_LABELS[item.display_kind]}
-
-
- {toZhPriority(item.priority)}
-
- {item.project_id && (
-
- {item.project_name || `项目 #${item.project_id}`}
-
- )}
- {item.dedupe_count > 1 && (
-
- 重复 {item.dedupe_count} 次
-
- )}
-
-
-
{item.updated_at || item.created_at || "-"}
-
-
-
- {item.title}
- {item.summary}
-
-
-
-
AI 已做/将做什么
-
{item.ai_plan}
-
-
为什么需要你
-
{item.blocking_reason}
-
- {stageCards.map((stage) => (
-
-
{stage.label}
-
{stage.value}
-
- ))}
-
-
-
- {item.weak_action.kind === "none" ? (
- {item.weak_action.label}
- ) : (
-
- )}
-
-
-
- );
+function matchesTab(item: InboxItemViewModel, tab: InboxTabKey): boolean {
+ if (tab === "all") return true;
+ return item.display_kind === TAB_TO_DISPLAY_KIND[tab];
}
export default function InboxPage() {
@@ -266,34 +58,25 @@ export default function InboxPage() {
const queryClient = useQueryClient();
const { toast } = useToast();
const [searchParams, setSearchParams] = useSearchParams();
- const [notificationDetailItem, setNotificationDetailItem] = useState(null);
- const [workItemDetailItem, setWorkItemDetailItem] = useState(null);
const [pendingActionKey, setPendingActionKey] = useState(null);
- const [priorityFilter, setPriorityFilter] = useState("all");
- const [onlyDecision, setOnlyDecision] = useState(false);
- const [onlyUnread, setOnlyUnread] = useState(false);
- const activeSection = (searchParams.get("section") as InboxSectionKey) || "all";
+ const [expandedItemId, setExpandedItemId] = useState(null);
+
+ const activeTab = normalizeTabKey(searchParams.get("section"));
const projectFilter = searchParams.get("project_id") || "all";
const searchValue = searchParams.get("q") || "";
const notificationsQuery = useQuery({
queryKey: ["notifications", "inbox"],
- queryFn: () => notificationsApi.list({ limit: 60 }),
+ queryFn: () => notificationsApi.list({ limit: 80 }),
refetchInterval: POLL_INTERVAL_MS,
});
const workItemsQuery = useQuery({
queryKey: ["ai-pmo-work-items", "inbox"],
- queryFn: () => aiPmoApi.listWorkItems({ limit: 60 }),
+ queryFn: () => aiPmoApi.listWorkItems({ limit: 80 }),
refetchInterval: POLL_INTERVAL_MS,
});
- const workItemDetailQuery = useQuery({
- queryKey: ["ai-pmo-work-item-detail", workItemDetailItem?.source_work_item?.id || null],
- queryFn: () => aiPmoApi.getWorkItem(Number(workItemDetailItem?.source_work_item?.id)),
- enabled: Boolean(workItemDetailItem?.source_work_item?.id),
- });
-
const inboxData = useMemo(() => {
return buildInboxView({
notifications: notificationsQuery.data || { items: [], unread_count: 0 },
@@ -317,42 +100,35 @@ export default function InboxPage() {
});
}, [inboxData.items, projectFilter]);
- const filteredItems = useMemo(() => {
- const query = searchValue.trim().toLowerCase();
- return projectScopedItems.filter((item) => {
- if (activeSection !== "all" && item.display_kind !== activeSection) return false;
- if (onlyDecision && item.display_kind !== "action_required") return false;
- if (onlyUnread && item.is_read) return false;
- if (!matchesPriority(item, priorityFilter)) return false;
- if (!query) return true;
- return `${item.title} ${item.summary} ${item.ai_plan || ""} ${item.project_name || ""}`.toLowerCase().includes(query);
- });
- }, [activeSection, onlyDecision, onlyUnread, priorityFilter, projectScopedItems, searchValue]);
-
- const scopedSections = useMemo(() => buildScopedSections(projectScopedItems), [projectScopedItems]);
- const scopedLeaderSummary = useMemo(() => {
+ const tabCounts = useMemo(() => {
return {
- decision_count: projectScopedItems.filter((item) => item.display_kind === "action_required").length,
- auto_running_count: projectScopedItems.filter((item) => item.display_kind === "auto_running").length,
- auto_done_today: projectScopedItems.filter(
- (item) => item.display_kind === "auto_done" && isToday(item.updated_at || item.created_at)
- ).length,
- high_priority_blocked_count: projectScopedItems.filter(
- (item) => item.display_kind === "action_required" && item.priority_rank >= 3 && Boolean(item.blocking_reason)
- ).length,
- external_authorization_count: projectScopedItems.filter(
- (item) =>
- item.display_kind === "action_required" &&
- /(github|gitlab|jira|接入|授权|跨系统|外部系统)/i.test(`${item.title} ${item.summary} ${item.blocking_reason || ""}`)
- ).length,
- top_decisions: projectScopedItems.filter((item) => item.display_kind === "action_required").slice(0, 3),
- recent_completions: projectScopedItems.filter((item) => item.display_kind === "auto_done").slice(0, 3),
- };
+ all: projectScopedItems.length,
+ needs_action: projectScopedItems.filter((item) => item.display_kind === "action_required").length,
+ in_progress: projectScopedItems.filter((item) => item.display_kind === "auto_running").length,
+ done: projectScopedItems.filter((item) => item.display_kind === "auto_done").length,
+ } satisfies Record;
}, [projectScopedItems]);
- const setSection = (section: string) => {
+ const searchedItems = useMemo(() => {
+ const query = searchValue.trim().toLowerCase();
+ if (!query) return projectScopedItems;
+
+ return projectScopedItems.filter((item) => {
+ return `${item.title} ${item.summary} ${item.project_name || ""} ${item.stage_text || ""}`
+ .toLowerCase()
+ .includes(query);
+ });
+ }, [projectScopedItems, searchValue]);
+
+ const feedItems = useMemo(() => {
+ const tabItems = searchedItems.filter((item) => matchesTab(item, activeTab));
+ return sortByLatest(tabItems);
+ }, [searchedItems, activeTab]);
+
+ const setTab = (tab: string) => {
+ const normalized = normalizeTabKey(tab);
const next = new URLSearchParams(searchParams);
- next.set("section", section);
+ next.set("section", normalized);
setSearchParams(next);
};
@@ -370,6 +146,10 @@ export default function InboxPage() {
setSearchParams(next);
};
+ const toggleExpand = (itemId: string) => {
+ setExpandedItemId((current) => (current === itemId ? null : itemId));
+ };
+
const refreshAll = async () => {
await Promise.all([
queryClient.invalidateQueries({ queryKey: ["notifications", "inbox"] }),
@@ -382,28 +162,12 @@ export default function InboxPage() {
try {
await notificationsApi.markRead(Number(item.source_notification.id));
} catch {
- // 不阻断后续跳转。
+ // 不阻断后续操作。
}
}
};
- const openNotificationDetail = async (item: InboxItemViewModel) => {
- await markNotificationRead(item);
- setNotificationDetailItem(item);
- await refreshAll();
- };
-
- const openWorkItemDetail = async (item: InboxItemViewModel) => {
- setWorkItemDetailItem(item);
- await refreshAll();
- };
-
- const openTarget = async (item: InboxItemViewModel, options?: { forceDirect?: boolean }) => {
- if (!options?.forceDirect && item.source_kind === "notification" && item.display_kind === "info") {
- await openNotificationDetail(item);
- return;
- }
-
+ const openTarget = async (item: InboxItemViewModel) => {
await markNotificationRead(item);
if (item.target_url) {
@@ -412,60 +176,46 @@ export default function InboxPage() {
await refreshAll();
return;
}
- if (item.source_kind === "ai_pmo_work_item") {
- await openWorkItemDetail(item);
- return;
- }
- toast({ title: "当前卡片暂无可打开的详情入口", variant: "error" });
+
+ toast({ title: "当前消息暂无可打开的目标入口", variant: "default" });
};
const handleAction = async (item: InboxItemViewModel, action: InboxActionDescriptor) => {
- const actionKey = buildActionKey(item, action);
+ const actionKey = buildInboxActionKey(item, action);
setPendingActionKey(actionKey);
+
try {
- if (item.source_kind === "notification" && action.label === "查看详情") {
- await openNotificationDetail(item);
- return;
- }
if (action.kind === "open_target") {
await openTarget(item);
return;
}
+
if (action.kind === "open_detail") {
- if (item.source_kind === "notification") {
- await openNotificationDetail(item);
- return;
- }
- await openWorkItemDetail(item);
+ await markNotificationRead(item);
+ toggleExpand(item.id);
+ await refreshAll();
return;
}
+
if (action.kind === "confirm" && item.source_kind === "ai_pmo_work_item" && item.source_work_item) {
const result = await aiPmoApi.decideWorkItem(item.source_work_item.id, {
action: "approve",
project_id: item.project_id ?? undefined,
});
await refreshAll();
+
const followupReply = String(result.followup_reply || "").trim();
if (result.status === "succeeded") {
- toast({ title: followupReply || "AI PMO 已继续执行并完成该工作项", variant: "success" });
+ toast({ title: followupReply || "已继续执行并完成", variant: "success" });
} else if (result.status === "pending_manual") {
- toast({ title: followupReply || "继续执行后仍需补充信息或人工确认", variant: "default" });
+ toast({ title: followupReply || "继续执行后仍需人工确认", variant: "default" });
} else {
toast({ title: followupReply || "继续执行失败，请查看详情", variant: "error" });
}
- setWorkItemDetailItem({
- ...item,
- display_kind:
- result.status === "succeeded"
- ? "auto_done"
- : result.status === "pending_manual"
- ? "action_required"
- : "info",
- stage_text: String(result.target_state || item.stage_text || "").trim() || item.stage_text,
- next_step_text: String(result.followup_reply || item.next_step_text || "").trim() || item.next_step_text,
- });
+ setExpandedItemId(item.id);
return;
}
+
if (action.kind === "reject" && item.source_kind === "ai_pmo_work_item" && item.source_work_item) {
const result = await aiPmoApi.decideWorkItem(item.source_work_item.id, {
action: "reject",
@@ -474,22 +224,17 @@ export default function InboxPage() {
await refreshAll();
const followupReply = String(result.followup_reply || "").trim();
toast({ title: followupReply || "已标记失效，不再继续执行", variant: "default" });
- if (workItemDetailItem?.id === item.id) {
- setWorkItemDetailItem(null);
- }
return;
}
+
if (action.kind === "mark_read" && item.source_kind === "notification" && item.source_notification) {
await notificationsApi.markRead(item.source_notification.id);
await refreshAll();
return;
}
+
if (action.kind === "none") {
- if (item.source_kind === "ai_pmo_work_item") {
- await openWorkItemDetail(item);
- return;
- }
- toast({ title: action.label, variant: "default" });
+ toggleExpand(item.id);
}
} catch (error) {
toast({ title: getApiErrorMessage(error), variant: "error" });
@@ -501,8 +246,8 @@ export default function InboxPage() {
const markAllRead = async () => {
try {
await notificationsApi.markAllRead();
- toast({ title: "站内通知已全部设为已读", variant: "success" });
await refreshAll();
+ toast({ title: "站内通知已全部设为已读", variant: "success" });
} catch (error) {
toast({ title: getApiErrorMessage(error, "全部已读失败"), variant: "error" });
}
@@ -511,403 +256,102 @@ export default function InboxPage() {
const isLoading = notificationsQuery.isLoading || workItemsQuery.isLoading;
return (
- <>
-
-
-
-
-
消息台
-
AI 决策收件箱 · 先看摘要，再处理真正需要你拍板的事项
-
- 当前结果：{filteredItems.length} 条
- {projectFilter !== "all" ? `（已筛选项目 #${projectFilter}）` : "（全租户汇总）"}
-
-
-
-
-
-
+
+
+
+
+
消息台
+
列表 Feed · 最新在上 · 支持移动端
+
当前结果：{feedItems.length} 条
-
-
-
- AI 决策收件箱
-
-
铃铛只看摘要，完整工作流统一沉到 Inbox
-
-
- 只保留真正可执行的事项；查询、闲聊、健康提示默认不进入消息台。
-
-
- {[
- { icon: ShieldAlert, label: "需你决策", value: scopedLeaderSummary.decision_count },
- { icon: LoaderCircle, label: "AI处理中", value: scopedLeaderSummary.auto_running_count },
- { icon: CheckCircle2, label: "今日自动完成", value: scopedLeaderSummary.auto_done_today },
- { icon: Sparkles, label: "高优先级阻塞", value: scopedLeaderSummary.high_priority_blocked_count },
- { icon: Filter, label: "待授权外部接入", value: scopedLeaderSummary.external_authorization_count },
- ].map(({ icon: Icon, label, value }, index) => (
-
- ))}
-
+
+
+
+
+ setSearch(event.target.value)}
+ onKeyDown={(event) => {
+ if (event.key === "Enter") setSearch((event.target as HTMLInputElement).value);
+ }}
+ />
+
+
+
+
+
+
信息流筛选（单列时间流，不分栏）
+
+ {(Object.keys(TAB_LABELS) as InboxTabKey[]).map((tabKey) => (
+
+ ))}
-
- {renderMiniList("最需要你拍板的 3 件事", "优先看高风险、上下文不完整或需要授权的事项。", scopedLeaderSummary.top_decisions, (item) =>
- void handleAction(item, item.primary_action)
- )}
- {renderMiniList("AI 刚完成的 3 件事", "自动结果会优先给出产物和影响范围。", scopedLeaderSummary.recent_completions, (item) =>
- void handleAction(item, item.primary_action)
- )}
+
+
+
+ {isLoading ? (
+
-
-
-
-
-
- setSearch(event.target.value)}
- onKeyDown={(event) => {
- if (event.key === "Enter") setSearch((event.target as HTMLInputElement).value);
- }}
- />
-
-
-
-
-
-
-
-
-
- {scopedSections.map((section) => (
-
- {section.label} {section.count}
-
- ))}
-
-
+ ) : feedItems.length === 0 ? (
+
+
+
+
当前没有匹配收件项
+
请调整筛选条件后重试
-
- {isLoading ? (
-
- ) : filteredItems.length === 0 ? (
-
-
-
-
- 当前没有匹配收件项
- 请调整筛选条件后重试
-
-
-
- ) : (
-
-
- {filteredItems.map((item) => (
- void handleAction(target, action)}
- />
- ))}
-
-
- )}
-
);
}
diff --git a/frontend/src/pages/ProjectBoardPage.tsx b/frontend/src/pages/ProjectBoardPage.tsx
index ab7af829..6d42c375 100644
--- a/frontend/src/pages/ProjectBoardPage.tsx
+++ b/frontend/src/pages/ProjectBoardPage.tsx
@@ -2,7 +2,7 @@ import { useDeferredValue, useEffect, useMemo, useState } from "react";
import { useParams, Link, useNavigate } from "react-router-dom";
import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query";
import { AlertTriangle, ArrowLeft, ChevronDown, ChevronRight, Plus } from "lucide-react";
-import { aiPmoApi } from "@/api/aiPmo";
+import { aiPmoApi, type AIPMOWorkItem } from "@/api/aiPmo";
import { sstcApi, type AIRoutingConfig, type SSTCSignal, type StageKey } from "@/api/sstc";
import { Card, CardContent } from "@/components/ui/card";
import { Button } from "@/components/ui/button";
@@ -23,7 +23,6 @@ import { BudgetControlPanel } from "@/components/budget/BudgetControlPanel";
import { SSTCGlobalHeader } from "@/components/sstc/SSTCGlobalHeader";
import { SSTCStageNav } from "@/components/sstc/SSTCStageNav";
import { SSTCWorkspace } from "@/components/sstc/SSTCWorkspace";
-import { SSTCRiskFloatPanel } from "@/components/sstc/SSTCRiskFloatPanel";
import { useToast } from "@/components/ui/toast";
import { formatProjectNameWithId, toZhPriority } from "@/lib/display";
import { getApiErrorMessage } from "@/lib/apiError";
@@ -47,6 +46,70 @@ const DEFAULT_SIGNAL_FILTERS: SignalFilterState = {
created_from: "",
created_to: "",
};
+const REGISTRY_REPAIR_SOURCE_MESSAGE_ID_RE = /^om_registry_repair_(\d+)_(\d+)_(base|explicit)$/i;
+const REGISTRY_REPAIR_TEXT_RE = /补录历史接入记录\s*registry#(\d+)(?:（([^）]+)）)?/i;
+
+function normalizeTechText(value?: string | null): string {
+ const raw = String(value || "").trim();
+ if (!raw) return "";
+ return raw
+ .replace(/补录历史接入记录/g, "补全历史接入信息")
+ .replace(/registry#(\d+)/gi, "记录#$1")
+ .replace(/请仅执行入库，不需要二次处理。?/g, "请确认后继续，系统会自动完成补录。");
+}
+
+function dedupeWorkItemsBySemanticKey(items: AIPMOWorkItem[]): AIPMOWorkItem[] {
+ const seen = new Set
();
+ const deduped: AIPMOWorkItem[] = [];
+ for (const item of items) {
+ const sourceMessageId = String(item.source_message_id || "").trim();
+ const sourceMatch = sourceMessageId.match(REGISTRY_REPAIR_SOURCE_MESSAGE_ID_RE);
+ let key = `work_item:${item.id}`;
+ if (sourceMatch) {
+ key = `registry_repair:${sourceMatch[1]}:${sourceMatch[2]}`;
+ } else {
+ const merged = [item.title, item.summary, item.next_step_text].filter(Boolean).join(" ");
+ const textMatch = merged.match(REGISTRY_REPAIR_TEXT_RE);
+ if (textMatch) {
+ key = `registry_repair:${item.project_id || "na"}:${textMatch[1]}`;
+ }
+ }
+ if (seen.has(key)) continue;
+ seen.add(key);
+ deduped.push(item);
+ }
+ return deduped;
+}
+
+function toReadableWorkItemTitle(item: AIPMOWorkItem): string {
+ const sourceMessageId = String(item.source_message_id || "").trim();
+ const sourceMatch = sourceMessageId.match(REGISTRY_REPAIR_SOURCE_MESSAGE_ID_RE);
+ if (sourceMatch) {
+ return `补全历史接入记录（#${sourceMatch[2]}）`;
+ }
+ const titleMatch = String(item.title || "").match(REGISTRY_REPAIR_TEXT_RE);
+ if (titleMatch) {
+ return `补全历史接入记录（#${titleMatch[1]}）`;
+ }
+ return normalizeTechText(item.title) || `工作项#${item.id}`;
+}
+
+function toReadableWorkItemSummary(item: AIPMOWorkItem): string {
+ const merged = [item.title, item.summary, item.next_step_text].filter(Boolean).join(" ");
+ const textMatch = merged.match(REGISTRY_REPAIR_TEXT_RE);
+ if (textMatch) {
+ const sourceName = String(textMatch[2] || "").trim();
+ if (sourceName) {
+ return `检测到「${sourceName}」存在历史接入信息缺失，请确认后继续，系统将自动入库并回填关联。`;
+ }
+ return "检测到历史接入信息缺失，请确认后继续，系统将自动入库并回填关联。";
+ }
+ return (
+ normalizeTechText(item.next_step_text)
+ || normalizeTechText(item.summary)
+ || "请进入收件箱查看详情并选择下一步处理。"
+ );
+}
export default function ProjectBoardPage() {
const SIGNAL_PAGE_SIZE = 10;
@@ -322,7 +385,14 @@ export default function ProjectBoardPage() {
}),
24
);
- const pmoWorkItems = pmoWorkItemsPayload?.items || [];
+ const pmoWorkItems = useMemo(
+ () => dedupeWorkItemsBySemanticKey(pmoWorkItemsPayload?.items || []),
+ [pmoWorkItemsPayload?.items]
+ );
+ const pendingManualWorkItemCount = useMemo(
+ () => pmoWorkItems.filter((item) => item.state === "waiting_manual").length,
+ [pmoWorkItems]
+ );
const riskSummary = (pmoRiskSnapshot?.summary || {}) as Record;
const dailyPayload = (pmoDailySnapshot?.payload || {}) as Record;
const riskActions = Array.isArray(dailyPayload.focus_actions)
@@ -525,14 +595,14 @@ export default function ProjectBoardPage() {
- {[
- { label: "Blocked Tasks", value: Number(riskSummary.blocked_task_count || 0) },
- { label: "待确认信号源", value: Number(riskSummary.pending_signal_source_count || 0) },
- { label: "风险通知", value: Number(riskSummary.unread_risk_notification_count || 0) },
- { label: "待确认工作项", value: pmoWorkItems.filter((item) => item.state === "waiting_manual").length },
- ].map((metric) => (
-
-
{metric.label}
+ {[
+ { label: "Blocked Tasks", value: Number(riskSummary.blocked_task_count || 0) },
+ { label: "待确认信号源", value: Number(riskSummary.pending_signal_source_count || 0) },
+ { label: "风险通知", value: Number(riskSummary.unread_risk_notification_count || 0) },
+ { label: "待确认工作项", value: pendingManualWorkItemCount },
+ ].map((metric) => (
+
+
{metric.label}
{metric.value}
))}
@@ -563,8 +633,19 @@ export default function ProjectBoardPage() {
{pmoWorkItems.length === 0 ? (
-
- 当前项目暂无 PMO 工作项。
+
+
当前项目暂无 PMO 工作项。
+
+ 建议下一步：先在任务阶段创建首批任务，或前往消息台确认待处理信号。
+
+
+
+
+
) : (
pmoWorkItems.map((item) => (
@@ -575,11 +656,11 @@ export default function ProjectBoardPage() {
onClick={() => navigate(`/inbox?project_id=${id}&q=${encodeURIComponent(item.title)}`)}
>
-
{item.title}
+
{toReadableWorkItemTitle(item)}
{item.state === "waiting_manual" &&
}
{item.stage_text || item.state}
-
{item.next_step_text || item.summary}
+
{toReadableWorkItemSummary(item)}
))
)}
@@ -642,8 +723,6 @@ export default function ProjectBoardPage() {
- {risks &&
}
-