01 · 系统技术架构业务能力、服务编排与运行治理
CHANNEL INTAKE · 多源接入X / Facebook / Excel / 销售反馈 / OpenAPI
ACCESS GATEWAY · 接入网关Nginx + HTTPS · REST / OpenAPI · 批量导入
IDENTITY & ACCESS · 身份与权限JWT / bcrypt · RBAC + ABAC · 字段 / 行级范围
EXPERIENCE · 体验与管理端React 18 + TypeScript · 销售 / 管理员 / 看板
01多源采集
02批次解析
03数据治理
04Lead 主数据
05组织分配
06销售跟进
07转化 / 回收
DATA GOVERNANCE · 数据治理服务
Validate字段与格式校验
Normalize标准化
Deduplicate跨平台去重
Reconcile匹配 / 合并
Rollback批次回滚
Quality血缘与质量评分
SLA · Retry · DLQ · 错误日志 · 异常检测 · 人工干预
DOMAIN SERVICES · FastAPI / Python 3.11
Lead Service主数据与状态
Import Pipeline导入与治理
Assignment Engine分配与回收
Follow-up Engine跟进与提醒
Tag / Profile Graph标签与画像
Reporting Query报表与查询
依赖注入 · 中间件 · 限流 / 熔断 · OpenAPI · 版本与 Schema 校验
AI Runtime 与策略决策
CopilotKitSales Copilot 运行时
LiteLLM统一模型接口
可替换模型效果 / 成本 / 地区策略
Policy Engine权限与分配规则
Idempotency防止重复写入
Optimistic Lock并发状态保护
模型只提供建议；授权、状态转换和数据写入仍由业务服务控制
EVENT AUTOMATION · ACID Write Path → Transactional Outbox → Async Consumers主数据写入、分配与任务在事务内提交；Outbox 使用 INSERT-ONLY Ledger、Idempotency-Key 和顺序保证，异步驱动通知、Todos / Tasks 与 Audit Trail。
任务调度APScheduler / Worker · SLA、提醒、回收
缓存与迁移Redis Cache · Alembic
可观测性Metrics · Logs · Traces · Alerts · Dashboards
部署运行Docker Compose · 灰度 · 回退 · 对账
安全边界TLS 1.2+ · 最小权限 · 脱敏 · 审计
同步 API异步事件RBAC + ABACDefault DenyAt-least-onceRetry / Backoff / DLQAI 模型解耦
02 · 数据库技术架构数据模型、关系、约束与查询治理
DATA & INSIGHT · PostgreSQL 16 · Lead 统一数据底座SQLAlchemy Async / Alembic · Encryption at Rest · UTC Timezone
lead_accountsaccount_no
platform / platform_account_id
import_batch_id
stage / scoreLead 主实体
import_batchessource
status
created_at
rollback_ref导入批次
teamsname
region
parent_id
closure_path组织树
system_usersuser_name / email
role_id
team_id
status身份主体
lead_assignmentslead_account_id
assignee_user_id
due_at
is_current唯一有效归属
progress_eventslead_account_id
event_type
content JSONB
event_atINSERT-ONLY
lead_taskslead_account_id
owner_user_id
status
due_atSLA 任务
audit_logsactor_user_id
resource / action
status_code
created_atINSERT-ONLY
user_notificationsrecipient_user_id
severity
payload JSONB
read_at通知投递
outbox_eventsaggregate_id / type
payload JSONB
status / retry_count
occurred_at事务事件
import_batches 1:N lead_accounts · teams 1:N system_users · lead_accounts 1:N assignments / progress / tasks · system_users 1:N assignments / tasks / audit / notifications
完整性与并发PK / FK · Partial Unique Index · 乐观锁 · 单一有效归属
索引与检索JSONB · GIN Index · 全文检索 · 分区 / 时间索引
数据安全RLS · 最小权限 · 静态加密 · 敏感字段脱敏
历史与恢复Append Only · 审计账本 · 在线对账 · 备份 / 回滚
PostgreSQL 16JSONB / GINClosure TableRow-Level SecurityPartial UniqueAppend Only审计可追溯