feat(people): 身份画像后台构建改为有界并发协调器

新增 identityProfileCoordinator，将原先每轮串行构建单个人物的 buildOneDirtyPerson
升级为“有界并发构建 + 串行写入提交 + 批末 ANN 合并调度”，提升 dirty 画像吞吐：

- coordinator（identity_profile_coordinator.go）：worker 并发执行只读+纯计算
  （ListProfileFaces + builder.Build），写入仍经 WriteQueue 串行提交，单 person
  失败只 MarkFailed 不阻断同批；批末统一决定 ANN activate 还是 full rebuild。
- 前台让路：service.go 注入 SetForegroundBusyFn，复用 clusteringCoordinator
  的 foregroundWaiterCount，前台有 merge/split/move 写操作时跳过新批次，已开始
  的小批次允许完成，避免与前台争抢资源。
- 高/低优先级 dirty 分批：新增 repo.ListDirtyByReasons，前台操作产生的
  dirty_reason 优先构建，避免被低优先级按 person_id 挤出。
- 时间预算：slice budget（默认 5s）软上限，超时不再派发新 worker。
- 新增配置项 build_workers(1-4)/dirty_batch_size/slice_budget_ms/
  ann_rebuild_delta_threshold，含默认值与 Validate 校验。
- NewBackgroundDB 连接池 1→8，WAL 模式支持并发只读 worker 不互锁。
- 运行状态接口新增 IdentityCoordinatorStats（脱敏），定位瓶颈在
  build/write/ANN rebuild 哪一阶段。
- 测试桩补齐 ListDirtyByReasons，SliceBuildsAtMostOnePerson 改为
  SliceBuildsBoundedDirtyBatch。

Author: davidhoo

backend/config.dev.yaml.example

@@ -58,3 +58,7 @@ people:
   identity_profile_rescue_threshold: 0.65
   identity_profile_batch_size: 25
   identity_profile_cooldown_ms: 500
+  identity_profile_build_workers: 2          # 后台画像构建并发 worker 数（1-4），写入仍串行
+  identity_profile_dirty_batch_size: 10      # 单轮调度最多构建的 dirty 人物数
+  identity_profile_slice_budget_ms: 5000     # 单轮调度时间预算（软上限）
+  identity_profile_ann_rebuild_delta_threshold: 0.75  # delta 占用比例达阈值时批末触发 ANN full rebuild

backend/config.prod.yaml.example

@@ -93,6 +93,10 @@ people:
   identity_profile_rescue_threshold: 0.65
   identity_profile_batch_size: 25
   identity_profile_cooldown_ms: 500
+  identity_profile_build_workers: 2
+  identity_profile_dirty_batch_size: 10
+  identity_profile_slice_budget_ms: 5000
+  identity_profile_ann_rebuild_delta_threshold: 0.75
 
 # 地理编码配置（启动默认值，运行时通过管理后台配置后以数据库为准）
 geocode:

backend/internal/model/dto.go

@@ -718,13 +718,14 @@ type BatchRotateRequest struct {
 // IdentityProfileOperationalStatsResponse 是身份画像运行状态的顶层响应。
 // legacy 模式仅返回 mode 与零值运行状态，不查询 profile/center/member/ANN/backfill/decision。
 type IdentityProfileOperationalStatsResponse struct {
-	Mode      string                    `json:"mode"`
-	Profiles  IdentityProfileCountStats `json:"profiles"`
-	Centers   IdentityCenterStats       `json:"centers"`
-	Members   IdentityMemberStats       `json:"members"`
-	Backfill  IdentityBackfillStats     `json:"backfill"`
-	ANN       IdentityANNStats          `json:"ann"`
-	Decisions IdentityDecisionStats     `json:"decisions"`
+	Mode        string                    `json:"mode"`
+	Profiles    IdentityProfileCountStats `json:"profiles"`
+	Centers     IdentityCenterStats       `json:"centers"`
+	Members     IdentityMemberStats       `json:"members"`
+	Backfill    IdentityBackfillStats     `json:"backfill"`
+	ANN         IdentityANNStats          `json:"ann"`
+	Coordinator IdentityCoordinatorStats  `json:"coordinator"`
+	Decisions   IdentityDecisionStats     `json:"decisions"`
 }
 
 // IdentityProfileCountStats 汇总 profile 各 status 计数。
@@ -799,6 +800,31 @@ type IdentityDecisionStats struct {
 	RescueApplied         int64 `json:"rescue_applied"`
 }
 
+// IdentityCoordinatorStats 汇总身份画像后台构建协调器的运行状态。
+// 用于判断瓶颈在 backfill / build / write / ANN rebuild 哪一阶段。
+// 不含 person ID、embedding、路径或原始 SQL 错误。
+type IdentityCoordinatorStats struct {
+	Running bool `json:"running"`
+
+	LastSliceStartedAt *time.Time `json:"last_slice_started_at,omitempty"`
+	LastSliceEndedAt   *time.Time `json:"last_slice_ended_at,omitempty"`
+
+	LastDirtySelected int `json:"last_dirty_selected"`
+	LastBuiltSuccess  int `json:"last_built_success"`
+	LastBuiltFailed   int `json:"last_built_failed"`
+	LastSkipped       int `json:"last_skipped"`
+
+	Workers int `json:"workers"`
+
+	LastBuildDurationMs int64 `json:"last_build_duration_ms"`
+	MaxBuildDurationMs  int64 `json:"max_build_duration_ms"`
+	LastWriteDurationMs int64 `json:"last_write_duration_ms"`
+
+	LastAnnActivated   int    `json:"last_ann_activated"`
+	LastAnnRebuild     bool   `json:"last_ann_rebuild"`
+	LastAnnRebuildReason string `json:"last_ann_rebuild_reason,omitempty"`
+}
+
 // IdentityDecisionResponse 是单条决策遥测的只读响应。
 // 明确不返回 ComponentFaceIDs、ComponentHash、DecisionKey、embedding、路径、人物名称。
 // CenterIDs 从数据库逗号字符串安全解析（过滤非法/0/重复、升序、最多 32 个）。

backend/internal/repository/person_identity_profile_repo.go

@@ -71,6 +71,10 @@ type PersonIdentityProfileRepository interface {
 	// ListDirty 返回 status=dirty 且 person_id > cursor 的 profile，按 person_id ASC，
 	// 严格应用 limit，游标分页避免全量加载。
 	ListDirty(cursor uint, limit int) ([]*model.PersonIdentityProfile, error)
+	// ListDirtyByReasons 返回 status=dirty、person_id > cursor 且 dirty_reason IN reasons
+	// 的 profile，按 person_id ASC，严格应用 limit。reasons 为空时不按 reason 过滤
+	// （等价于 ListDirty）。用于协调器高/低优先级分批拉取，避免全量加载后内存排序。
+	ListDirtyByReasons(reasons []string, cursor uint, limit int) ([]*model.PersonIdentityProfile, error)
 	// GetActive 加载人物活动 generation 的完整构建（profile + centers + members）。
 	// profile 不存在或 active_generation=0 时返回 (nil, nil)。
 	GetActive(personID uint) (*model.PersonIdentityProfileBuild, error)
@@ -189,6 +193,25 @@ func (r *personIdentityProfileRepository) ListDirty(cursor uint, limit int) ([]*
 	return profiles, nil
 }
 
+// ListDirtyByReasons 返回 status=dirty、person_id > cursor 且 dirty_reason IN reasons 的 profile。
+// reasons 为空时不按 reason 过滤（等价于 ListDirty），避免空 IN 子句语义歧义。
+// 按 person_id ASC，严格应用 limit，游标分页避免全量加载。
+func (r *personIdentityProfileRepository) ListDirtyByReasons(reasons []string, cursor uint, limit int) ([]*model.PersonIdentityProfile, error) {
+	var profiles []*model.PersonIdentityProfile
+	q := r.db.Where("status = ? AND person_id > ?", model.PersonIdentityProfileStatusDirty, cursor)
+	if len(reasons) > 0 {
+		q = q.Where("dirty_reason IN ?", reasons)
+	}
+	q = q.Order("person_id ASC")
+	if limit > 0 {
+		q = q.Limit(limit)
+	}
+	if err := q.Find(&profiles).Error; err != nil {
+		return nil, err
+	}
+	return profiles, nil
+}
+
 func (r *personIdentityProfileRepository) GetActive(personID uint) (*model.PersonIdentityProfileBuild, error) {
 	var profile model.PersonIdentityProfile
 	err := r.db.Where("person_id = ?", personID).First(&profile).Error