Merge pull request #1747 from A-Dawn/dev

增加人物画像证据纠错功能，并提高检索表现

Author: A-Dawn

dashboard/src/components/memory/MemoryProfileManager.tsx

@@ -762,6 +762,49 @@ export interface MemoryProfileQueryPayload extends Record<string, unknown> {
   error?: string
 }
 
+export interface MemoryProfileEvidenceItemPayload extends Record<string, unknown> {
+  evidence_key?: string
+  evidence_type?: string
+  hash?: string
+  content?: string
+  source?: string
+  source_type?: string
+  metadata?: Record<string, unknown>
+  score?: number | null
+  confidence?: number | null
+  correction_mode?: string
+  deletable?: boolean
+  not_deletable_reason?: string
+}
+
+export interface MemoryProfileEvidencePayload extends Record<string, unknown> {
+  success: boolean
+  person_id?: string
+  person_name?: string
+  profile_text?: string
+  auto_profile_text?: string
+  profile_version?: number
+  updated_at?: number | null
+  expires_at?: number | null
+  profile_source?: string
+  has_manual_override?: boolean
+  manual_override_text?: string
+  evidence?: MemoryProfileEvidenceItemPayload[]
+  evidence_count?: number
+  error?: string
+}
+
+export interface MemoryProfileEvidenceCorrectPayload extends Record<string, unknown> {
+  success: boolean
+  person_id?: string
+  evidence?: MemoryProfileEvidenceItemPayload
+  delete_result?: Record<string, unknown>
+  operation_id?: string
+  refreshed_profile?: Record<string, unknown>
+  refreshed_evidence?: MemoryProfileEvidencePayload
+  error?: string
+}
+
 export interface MemoryProfileOverridePayload extends Record<string, unknown> {
   success: boolean
   override?: Record<string, unknown>
@@ -1059,6 +1102,41 @@ export async function deleteMemoryProfileOverride(personId: string): Promise<Mem
   })
 }
 
+export async function getMemoryProfileEvidence(options: {
+  personId: string
+  limit?: number
+  forceRefresh?: boolean
+}): Promise<MemoryProfileEvidencePayload> {
+  const params = new URLSearchParams({
+    limit: String(options.limit ?? 12),
+    force_refresh: options.forceRefresh ? 'true' : 'false',
+  })
+  return requestJson<MemoryProfileEvidencePayload>(`/profiles/${encodeURIComponent(options.personId)}/evidence?${params.toString()}`)
+}
+
+export async function correctMemoryProfileEvidence(payload: {
+  person_id: string
+  evidence_type: string
+  hash: string
+  requested_by?: string
+  reason?: string
+  refresh?: boolean
+  limit?: number
+}): Promise<MemoryProfileEvidenceCorrectPayload> {
+  return requestJson<MemoryProfileEvidenceCorrectPayload>(`/profiles/${encodeURIComponent(payload.person_id)}/evidence/correct`, {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify({
+      evidence_type: payload.evidence_type,
+      hash: payload.hash,
+      requested_by: payload.requested_by ?? 'knowledge_base',
+      reason: payload.reason ?? 'profile_evidence_correction',
+      refresh: payload.refresh ?? true,
+      limit: payload.limit ?? 12,
+    }),
+  })
+}
+
 export async function getMemoryRecycleBin(limit: number = 50): Promise<MemoryRecycleBinPayload> {
   return requestJson<MemoryRecycleBinPayload>(`/maintenance/recycle-bin?limit=${limit}`)
 }

dashboard/src/lib/memory-api.ts

@@ -88,6 +88,8 @@ vi.mock('@/lib/memory-api', () => ({
   getMemoryDeleteOperation: vi.fn(),
   getMemoryFeedbackCorrections: vi.fn(),
   getMemoryFeedbackCorrection: vi.fn(),
+  getMemoryProfileEvidence: vi.fn(),
+  correctMemoryProfileEvidence: vi.fn(),
   previewMemoryDelete: vi.fn(),
   executeMemoryDelete: vi.fn(),
   restoreMemoryDelete: vi.fn(),

dashboard/src/routes/resource/__tests__/knowledge-base.test.tsx

@@ -220,6 +220,61 @@ async def fake_profile_admin(*, action: str, **kwargs):
     assert response.json()["person_id"] == "resolved-person-id"
 
 
+def test_webui_memory_profile_evidence_route(client: TestClient, monkeypatch):
+    async def fake_profile_admin(*, action: str, **kwargs):
+        assert action == "evidence"
+        assert kwargs["person_id"] == "person-1"
+        assert kwargs["limit"] == 7
+        assert kwargs["force_refresh"] is True
+        return {
+            "success": True,
+            "person_id": "person-1",
+            "evidence": [{"evidence_type": "person_fact", "hash": "p-1"}],
+        }
+
+    monkeypatch.setattr(memory_router_module.memory_service, "profile_admin", fake_profile_admin)
+
+    response = client.get(
+        "/api/webui/memory/profiles/person-1/evidence",
+        params={"limit": 7, "force_refresh": True},
+    )
+
+    assert response.status_code == 200
+    assert response.json()["success"] is True
+    assert response.json()["evidence"][0]["hash"] == "p-1"
+
+
+def test_webui_memory_profile_evidence_correct_route(client: TestClient, monkeypatch):
+    async def fake_profile_admin(*, action: str, **kwargs):
+        assert action == "correct_evidence"
+        assert kwargs["person_id"] == "person-1"
+        assert kwargs["evidence_type"] == "relation"
+        assert kwargs["hash"] == "rel-1"
+        assert kwargs["requested_by"] == "tester"
+        assert kwargs["reason"] == "wrong_relation"
+        assert kwargs["refresh"] is True
+        assert kwargs["limit"] == 6
+        return {"success": True, "operation_id": "delete-1"}
+
+    monkeypatch.setattr(memory_router_module.memory_service, "profile_admin", fake_profile_admin)
+
+    response = client.post(
+        "/api/webui/memory/profiles/person-1/evidence/correct",
+        json={
+            "evidence_type": "relation",
+            "hash": "rel-1",
+            "requested_by": "tester",
+            "reason": "wrong_relation",
+            "refresh": True,
+            "limit": 6,
+        },
+    )
+
+    assert response.status_code == 200
+    assert response.json()["success"] is True
+    assert response.json()["operation_id"] == "delete-1"
+
+
 def test_webui_memory_profile_query_prefers_explicit_person_id(client: TestClient, monkeypatch):
     def fake_resolve_person_id_for_memory(**kwargs):
         raise AssertionError(f"不应解析平台账号: {kwargs}")