# 智源AI 数据架构设计文档 v2.0

> 📅 创建时间：2026年1月11日
> 🔄 升级自：v1.2（2026年1月10日）
> 🎯 设计原则：先跑通，再完善
> 📦 数据来源：远程mydb(192.168.1.160) + 本地zyoperations
> 🔧 技术栈：PostgreSQL + Prisma + Node.js (Fastify) + Next.js + React
> 📁 配套文档：业务框架文档v2.2、数字化基础设施架构方案v1.2、产品服务信息库

---

> ## ⚠️ 实际实现说明（2026-01-12更新）
>
> **本文档为设计参考文档**，实际实现与设计有以下差异：
>
> | 设计方案 | 实际实现 |
> |----------|----------|
> | 原始SQL建表 | **Prisma schema** 统一管理（packages/database/prisma/schema.prisma） |
> | 客户编号 customer_code (C0001) | UUID主键 + 简化字段 |
> | 订单编号 ORD-类别-客户-时间-SKU | 简化为 ZY + 时间戳 + 随机码 |
> | 双数据库（mydb + zyoperations） | **统一数据库**，mydb表结构已整合到Prisma schema |
> | service_deliveries 表 | 使用现有 deliveries 表扩展 |
>
> **实际数据模型请参考**：`packages/database/prisma/schema.prisma`

---

## 一、文档定位与升级说明

### 1.1 v2.0 主要升级内容

| 升级项 | v1.2 | v2.0 | 升级原因 |
|--------|------|------|----------|
| **数据来源** | 仅规划Notion迁移 | 整合远程mydb（206条订阅订单） | 对接已有成熟业务数据 |
| **三层业务标识** | 概念存在，标识不清晰 | ACC/API/SOL分类体系 | 支撑三层业务数据隔离与统计 |
| **客户编号** | UUID主键 | BIGSERIAL + customer_code（C0001） | 便于人工操作和沟通 |
| **订单编号** | 未明确规则 | ORD-[类别]-[客户]-[时间]-[SKU]-[序号] | 可读性强，支撑业务追溯 |
| **第二三层交付** | deliveries表（简单） | service_deliveries表（完整流程） | 支撑配置服务和Agent服务交付管理 |
| **商品目录** | products表（基础） | product_info表（含service_tier） | 支撑三层业务商品分类 |

### 1.2 现状分析

| 数据源 | 服务层级 | 业务状态 | 数据成熟度 |
|--------|----------|----------|------------|
| 远程mydb | 第一层（接入服务） | ✅ 已成熟运营 | 高（206条订阅订单） |
| 本地zyoperations | 第二/三层 | 🔄 待跑通 | 低（种子数据） |

### 1.3 设计目标

1. **整合第一层**：将mydb成熟表结构和数据进行结合业务逻辑进行优化后补充到目前数据库有关数据库表
2. **补充第二/三层**：基于官网业务场景设计配套表结构
3. **统一管理**：一套数据库支撑全部三层业务
4. **快速落地**：优先跑通核心流程，逐步完善

---

## 二、三层业务数据模型

### 2.1 业务分层架构

┌─────────────────────────────────────────────────────────────────────────────┐ │ 第三层：调用能力层 (SOL) │ │ Agent定制 / 工作流自动化 │ │ │ │ 产品SKU: AGENT-CUSTOM / AGENT-WORKFLOW / AGENT-PROTOTYPE │ │ 订单类型: ORD-SOL-* │ ├─────────────────────────────────────────────────────────────────────────────┤ │ 第二层：管理知识层 (API) │ │ Project配置 / 提示词优化 / 知识库搭建 │ │ │ │ 产品SKU: CONFIG-PROJECT / CONFIG-PROMPT / CONFIG-KB / CONFIG-WORKFLOW │ │ 订单类型: ORD-API-* │ ├─────────────────────────────────────────────────────────────────────────────┤ │ 第一层：接入工具层 (ACC) │ │ Claude / ChatGPT / Gemini 订阅账号 │ │ │ │ 产品SKU: CLD-PRO-* / CLD-MAX5-* / CLD-MAX20-* / GPT-PLUS-* │ │ 订单类型: ORD-ACC-* │ └─────────────────────────────────────────────────────────────────────────────┘

### 2.2 产品类别代码

| 代码 | 服务层级 | 说明 | 数据表关联 |
|------|----------|------|------------|
| **ACC** | 第一层 | Account - 账号接入服务 | accounts, subscription_orders |
| **API** | 第二层 | API/Config - 配置服务 | service_deliveries |
| **SOL** | 第三层 | Solution - 解决方案/Agent服务 | service_deliveries |

---

## 三、统一表结构设计

### 3.1 表清单总览

| 序号 | 表名 | 说明 | 来源 | 服务层级 |
|:----:|------|------|------|----------|
| 1 | **customers** | 客户管理表 | 新建 | 全部 |
| 2 | **product_info** | 商品信息表 | mydb优化 | 全部 |
| 3 | **orders** | 统一订单表 | mydb优化 | 全部 |
| 4 | **accounts** | 成品账号表 | mydb | 第一层 |
| 5 | **subscription_orders** | 订阅记录表 | mydb | 第一层 |
| 6 | **service_deliveries** | 服务交付表 | 新建 | 第二/三层 |
| 7 | **after_sales_records** | 售后记录表 | mydb | 全部 |
| 8 | **inquiries** | 官网咨询表 | 本地优化 | 第二/三层 |
| 9 | **contacts** | 沟通记录表 | 本地 | 全部 |
| 10 | **inventory** | 库存物料表 | mydb整合 | 第一层 |
| 11 | **gift_cards** | 礼品卡表 | mydb | 第一层 |

### 3.2 实体关系图

┌─────────────────────────────────────────────────────────────────────────────┐ │ 智源AI 业务实体关系图 v2.0 │ ├─────────────────────────────────────────────────────────────────────────────┤ │ │ │ ┌──────────┐ ┌──────────┐ ┌──────────────────┐ │ │ │ 客户 │ 1:N │ 订单 │ 1:1 │ 账号交付(第一层) │ │ │ │ Customer │──────▶│ Order │──────▶│ subscription │ │ │ │ │ │ │ │ _orders │ │ │ └────┬─────┘ └────┬─────┘ └──────────────────┘ │ │ │ │ │ │ │ 1:N │ 1:1 ┌──────────────────┐ │ │ │ └────────────▶│ 服务交付(二三层) │ │ │ │ │ service │ │ │ │ │ _deliveries │ │ │ ▼ └──────────────────┘ │ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │ │ 沟通记录 │ │ 商品信息 │ │ 售后记录 │ │ │ │ contacts │ │ product │ │ after │ │ │ │ │ │ _info │ │ _sales │ │ │ └──────────┘ └──────────┘ └──────────┘ │ │ │ │ ┌──────────┐ ┌──────────┐ │ │ │ 官网咨询 │ │ 库存物料 │ │ │ │ inquiries│ │ inventory│ │ │ └──────────┘ └──────────┘ │ │ │ └─────────────────────────────────────────────────────────────────────────────┘

---

## 四、核心表结构详解

### 4.1 customers - 客户管理表（新建）

> 统一管理所有客户，包含官网注册用户和淘宝客户

```sql
CREATE TABLE customers (
    id BIGSERIAL PRIMARY KEY,

    -- 客户编号（自动生成：C0001, C0002...）
    customer_code VARCHAR(20) NOT NULL UNIQUE,

    -- 基本信息
    nickname VARCHAR(100),               -- 昵称/旺旺ID
    wechat_id VARCHAR(100),              -- 微信号
    phone VARCHAR(20),                   -- 手机号
    email VARCHAR(255),                  -- 邮箱
    company VARCHAR(200),                -- 公司名称

    -- 来源渠道
    source VARCHAR(50) NOT NULL DEFAULT 'website',  -- taobao/wechat/website/referral
    source_detail VARCHAR(255),          -- 来源详情
    referrer_code VARCHAR(20),           -- 推荐人客户编号

    -- 客户分层
    level VARCHAR(20) NOT NULL DEFAULT 'normal',    -- normal/vip/svip/enterprise
    tags TEXT[],                         -- 标签数组

    -- 统计字段
    total_orders INT NOT NULL DEFAULT 0,
    total_amount NUMERIC(12, 2) NOT NULL DEFAULT 0,
    first_order_at TIMESTAMP,
    last_order_at TIMESTAMP,

    -- 认证字段（官网注册用户）
    password VARCHAR(255),               -- 密码哈希
    is_registered BOOLEAN NOT NULL DEFAULT FALSE,
    last_login_at TIMESTAMP,

    -- 状态
    status VARCHAR(20) NOT NULL DEFAULT 'active',   -- active/inactive/blocked
    notes TEXT,

    -- 审计字段
    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);

-- 索引
CREATE INDEX idx_customers_code ON customers(customer_code);
CREATE INDEX idx_customers_source ON customers(source);
CREATE INDEX idx_customers_level ON customers(level);
CREATE INDEX idx_customers_email ON customers(email);
CREATE INDEX idx_customers_phone ON customers(phone);

字段枚举值：

4.2 product_info - 商品信息表（来自mydb优化）

支撑三层业务的统一商品目录

CREATE TABLE product_info (
    id BIGSERIAL PRIMARY KEY,

    -- 商品基础信息
    product_sku VARCHAR(100) NOT NULL UNIQUE,    -- SKU编码
    product_name VARCHAR(200) NOT NULL,          -- 商品名称
    product_type VARCHAR(50) NOT NULL,           -- 商品类型
    product_type_code VARCHAR(20) NOT NULL,      -- 类型代码

    -- 服务层级（核心字段）
    service_tier VARCHAR(20) NOT NULL,           -- tier1_access / tier2_config / tier3_agent

    -- 产品类别（订单用）
    product_category VARCHAR(10) NOT NULL,       -- ACC / API / SOL

    -- 渠道和付费信息
    channel_management VARCHAR(100),             -- 渠道管理
    payment_cycle VARCHAR(50),                   -- 付费周期
    payment_cycle_code VARCHAR(20),              -- 付费周期代码
    service_type VARCHAR(50),                    -- 服务类型（成品号/定制化/护航版）
    service_type_code VARCHAR(20),               -- 服务类型代码

    -- 自动生成字段
    sku_family_code VARCHAR(50) GENERATED ALWAYS AS (
        CASE
            WHEN product_sku LIKE '%-%-%' THEN
                SUBSTRING(product_sku FROM 1 FOR
                    LENGTH(product_sku) - LENGTH(SUBSTRING(product_sku FROM '[^-]*$')) - 1
                )
            ELSE product_sku
        END
    ) STORED,

    -- 价格信息
    base_price NUMERIC(24, 6),                   -- 基础价格
    cost_price NUMERIC(24, 6),                   -- 成本价格
    profit_rate NUMERIC(24, 6),                  -- 利润率

    -- 质保信息
    warranty_days INT DEFAULT 0,
    warranty_scope TEXT,

    -- 商品状态
    product_status VARCHAR(32) NOT NULL DEFAULT 'ON_SALE',
    features TEXT,                               -- 功能特性
    remarks TEXT,

    -- 多租户
    tenant_id VARCHAR(32),
    revision INT NOT NULL DEFAULT 0,

    -- 审计字段
    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);

-- 索引
CREATE INDEX idx_product_info_sku ON product_info(product_sku);
CREATE INDEX idx_product_info_tier ON product_info(service_tier);
CREATE INDEX idx_product_info_category ON product_info(product_category);
CREATE INDEX idx_product_info_status ON product_info(product_status);

service_tier 枚举值：

4.3 orders - 统一订单表（来自mydb优化）

支撑三层业务的统一订单管理

CREATE TABLE orders (
    id BIGSERIAL PRIMARY KEY,

    -- 订单编号（格式: ORD-[类别]-[客户]-[时间]-[SKU]-[序号]）
    order_number VARCHAR(60) NOT NULL UNIQUE,

    -- 产品类别（核心分层字段）
    product_category VARCHAR(10) NOT NULL CHECK (product_category IN ('ACC', 'API', 'SOL')),

    -- 关联客户
    customer_code VARCHAR(20) NOT NULL,

    -- 下单时间
    order_time_code VARCHAR(10) NOT NULL,        -- 格式: YYMMDDHH
    order_datetime TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,

    -- 商品信息
    product_sku VARCHAR(100) NOT NULL,
    product_name VARCHAR(200),

    -- 付费周期
    billing_cycle VARCHAR(20) NOT NULL CHECK (billing_cycle IN ('月付', '季付', '半年付', '年付', '一次性', '自定义')),

    -- 数量和价格
    quantity INT NOT NULL DEFAULT 1,
    unit_price NUMERIC(10, 2) NOT NULL,
    has_discount BOOLEAN NOT NULL DEFAULT FALSE,
    discount_rate NUMERIC(3, 2) DEFAULT 1.00,
    total_amount NUMERIC(12, 2) NOT NULL,        -- 自动计算

    -- 订单状态
    order_status VARCHAR(20) NOT NULL DEFAULT '未支付'
        CHECK (order_status IN ('未支付', '已支付', '处理中', '交付中', '已交付', '已完成', '已取消', '退款中', '已退款')),

    -- 来源渠道
    order_channel VARCHAR(20),                   -- taobao / wechat / website
    channel_order_no VARCHAR(100),               -- 渠道订单号

    -- 物料分配（第一层专用）
    allocated_material VARCHAR(50),

    -- 服务有效期
    service_start_time TIMESTAMP,
    service_end_time TIMESTAMP,

    -- 支付信息
    payment_method VARCHAR(50),
    payment_time TIMESTAMP,
    trade_no VARCHAR(100),

    -- 完成信息
    completion_time TIMESTAMP,
    cancellation_time TIMESTAMP,
    cancellation_reason TEXT,

    -- 备注
    customer_remark TEXT,
    admin_remark TEXT,

    -- 软删除
    is_deleted BOOLEAN NOT NULL DEFAULT FALSE,
    deleted_at TIMESTAMP,

    -- 乐观锁
    version INT NOT NULL DEFAULT 0,

    -- 审计字段
    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    created_by VARCHAR(50),
    updated_by VARCHAR(50)
);

-- 索引
CREATE INDEX idx_orders_number ON orders(order_number);
CREATE INDEX idx_orders_category ON orders(product_category) WHERE is_deleted = FALSE;
CREATE INDEX idx_orders_customer ON orders(customer_code) WHERE is_deleted = FALSE;
CREATE INDEX idx_orders_status ON orders(order_status) WHERE is_deleted = FALSE;
CREATE INDEX idx_orders_datetime ON orders(order_datetime DESC) WHERE is_deleted = FALSE;
CREATE INDEX idx_orders_sku ON orders(product_sku) WHERE is_deleted = FALSE;

-- 触发器：自动计算总金额
CREATE OR REPLACE FUNCTION calculate_order_total_amount()
RETURNS TRIGGER AS $$
BEGIN
    NEW.total_amount = NEW.unit_price * NEW.quantity * COALESCE(NEW.discount_rate, 1.00);
    IF NEW.discount_rate < 1.00 THEN
        NEW.has_discount = TRUE;
    ELSE
        NEW.has_discount = FALSE;
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trigger_calculate_order_total
    BEFORE INSERT OR UPDATE OF unit_price, quantity, discount_rate ON orders
    FOR EACH ROW
    EXECUTE FUNCTION calculate_order_total_amount();

4.4 service_deliveries - 服务交付表（新建，第二/三层专用）

管理第二/三层服务的交付过程和成果

CREATE TABLE service_deliveries (
    id BIGSERIAL PRIMARY KEY,

    -- 交付编号
    delivery_no VARCHAR(50) NOT NULL UNIQUE,     -- 格式: DEL-API-C0001-20260111-01

    -- 关联订单
    order_number VARCHAR(60) NOT NULL,
    customer_code VARCHAR(20) NOT NULL,
    product_sku VARCHAR(100) NOT NULL,

    -- 服务层级
    service_tier VARCHAR(20) NOT NULL,           -- tier2_config / tier3_agent

    -- 服务类型细分
    service_subtype VARCHAR(50) NOT NULL,        
    -- project_config / prompt_optimize / knowledge_base / workflow_design 
    -- agent_custom / agent_workflow / agent_prototype

    -- 交付状态
    delivery_status VARCHAR(30) NOT NULL DEFAULT 'pending'
        CHECK (delivery_status IN ('pending', 'requirement_confirmed', 'in_progress', 'reviewing', 'delivered', 'revision', 'completed', 'cancelled')),

    -- 需求信息
    requirement_summary TEXT,                    -- 需求摘要
    requirement_doc_url VARCHAR(500),            -- 需求文档链接
    confirmed_at TIMESTAMP,                      -- 需求确认时间

    -- 交付信息
    deliverable_summary TEXT,                    -- 交付物摘要
    deliverable_doc_url VARCHAR(500),            -- 交付文档链接
    delivered_at TIMESTAMP,                      -- 交付时间

    -- 验收信息
    accepted_at TIMESTAMP,                       -- 验收时间
    acceptance_notes TEXT,                       -- 验收备注

    -- 服务有效期
    warranty_start TIMESTAMP,                    -- 质保开始
    warranty_end TIMESTAMP,                      -- 质保结束

    -- 进度跟踪
    progress_percent INT DEFAULT 0,              -- 进度百分比 0-100
    current_phase VARCHAR(50),                   -- 当前阶段
    phase_notes TEXT,                            -- 阶段备注

    -- 负责人
    assigned_to VARCHAR(100),                    -- 负责人

    -- 评价
    rating INT,                                  -- 评分 1-5
    feedback TEXT,                               -- 客户反馈

    -- 审计字段
    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    created_by VARCHAR(50),
    updated_by VARCHAR(50)
);

-- 索引
CREATE INDEX idx_service_deliveries_order ON service_deliveries(order_number);
CREATE INDEX idx_service_deliveries_customer ON service_deliveries(customer_code);
CREATE INDEX idx_service_deliveries_status ON service_deliveries(delivery_status);
CREATE INDEX idx_service_deliveries_tier ON service_deliveries(service_tier);
CREATE INDEX idx_service_deliveries_subtype ON service_deliveries(service_subtype);

delivery_status 状态机：

pending → requirement_confirmed → in_progress → reviewing → delivered → completed
                                      ↓              ↓
                                   revision ←───────┘
                                      ↓
                                  cancelled

service_subtype 枚举值：

4.5 inquiries - 官网咨询表（优化）

管理官网表单提交的咨询请求

CREATE TABLE inquiries (
    id BIGSERIAL PRIMARY KEY,

    -- 咨询编号
    inquiry_no VARCHAR(50) NOT NULL UNIQUE,      -- 格式: INQ-20260111-0001

    -- 咨询人信息
    name VARCHAR(100),
    company VARCHAR(200),
    email VARCHAR(255),
    phone VARCHAR(20),
    wechat_id VARCHAR(100),

    -- 咨询内容
    service_type VARCHAR(50) NOT NULL,           -- ai_configuration / agent_development / general
    service_subtype VARCHAR(50),                 -- 具体服务子类型
    scenario VARCHAR(255),                       -- 使用场景
    requirement TEXT,                            -- 需求描述
    budget_range VARCHAR(20),                    -- under_1k / range_1k_5k / range_5k_10k / above_10k / negotiable

    -- 来源追踪
    source_page VARCHAR(255),                    -- 来源页面
    utm_source VARCHAR(100),
    utm_medium VARCHAR(100),
    utm_campaign VARCHAR(100),

    -- 处理状态
    status VARCHAR(20) NOT NULL DEFAULT 'pending'
        CHECK (status IN ('pending', 'contacted', 'following', 'quoted', 'converted', 'closed', 'lost')),

    -- 跟进信息
    assigned_to VARCHAR(100),                    -- 分配给
    first_contact_at TIMESTAMP,                  -- 首次联系时间
    follow_up_notes TEXT,                        -- 跟进备注
    next_follow_at TIMESTAMP,                    -- 下次跟进时间

    -- 转化信息
    customer_code VARCHAR(20),                   -- 转化后关联客户
    converted_order VARCHAR(60),                 -- 转化订单号
    converted_at TIMESTAMP,

    -- 关闭信息
    closed_at TIMESTAMP,
    close_reason TEXT,

    -- 审计字段
    created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);

-- 索引
CREATE INDEX idx_inquiries_no ON inquiries(inquiry_no);
CREATE INDEX idx_inquiries_status ON inquiries(status);
CREATE INDEX idx_inquiries_service_type ON inquiries(service_type);
CREATE INDEX idx_inquiries_created ON inquiries(created_at DESC);
CREATE INDEX idx_inquiries_customer ON inquiries(customer_code);

4.6 保留mydb原有表

以下表结构直接从mydb迁移，保留原有设计：

五、商品数据设计

5.1 第一层商品（接入服务）

来自mydb，保持原有SKU体系

5.2 第二层商品（配置服务）

基于官网 /services/ai-configuration 页面

5.3 第三层商品（Agent服务）

基于官网 /services/agent-development 页面

六、订单编号规则

6.1 统一编号格式

ORD-[类别]-[客户编号]-[时间码]-[SKU简码]-[序号]

示例：

6.2 其他编号规则

七、API接口规划

7.1 按服务层级划分

7.2 核心接口清单

八、数据迁移计划

8.1 迁移阶段

# 第一阶段：表结构迁移
# 1. 创建新的统一数据库
createdb zyoperations_unified

# 2. 执行建表脚本（按顺序）
psql -d zyoperations_unified -f 01_customers.sql
psql -d zyoperations_unified -f 02_product_info.sql
psql -d zyoperations_unified -f 03_orders.sql
psql -d zyoperations_unified -f 04_accounts.sql        # 从mydb迁移
psql -d zyoperations_unified -f 05_subscription_orders.sql  # 从mydb迁移
psql -d zyoperations_unified -f 06_service_deliveries.sql
psql -d zyoperations_unified -f 07_after_sales_records.sql  # 从mydb迁移
psql -d zyoperations_unified -f 08_inquiries.sql
psql -d zyoperations_unified -f 09_contacts.sql
psql -d zyoperations_unified -f 10_inventory.sql

8.2 数据迁移

# 第二阶段：数据迁移
# 1. 从mydb导出数据
PGPASSWORD=mydb123456 pg_dump -h 192.168.1.160 -U mydb_user -d mydb \\
    -t subscription_orders \\
    -t accounts \\
    -t after_sales_records \\
    -t gift_cards \\
    -t orders \\
    --data-only > mydb_data.sql

# 2. 导入到统一数据库
psql -d zyoperations_unified < mydb_data.sql

# 3. 填充商品目录（种子数据）
psql -d zyoperations_unified < seed_product_info.sql

8.3 验证

-- 第三阶段：验证数据迁移
SELECT 'subscription_orders' as table_name, COUNT(*) as count FROM subscription_orders
UNION ALL SELECT 'accounts', COUNT(*) FROM accounts
UNION ALL SELECT 'orders', COUNT(*) FROM orders
UNION ALL SELECT 'product_info', COUNT(*) FROM product_info;

九、待确认事项

9.1 已确认的设计决策

9.2 后续优化方向

• [ ] 添加客户自动升级触发器（根据消费金额）
• [ ] 添加订单编号自动生成函数
• [ ] 添加到期提醒视图
• [ ] 添加数据分析视图
• [ ] 添加审计日志表
• [ ] Prisma schema同步更新

附录

A. 相关文档索引

B. 版本记录

文档维护：开发团队 最后更新：2025年1月12日 实际数据模型：packages/database/prisma/schema.prisma