-- jinrong_core 表结构 · 对齐客户资料（用户信息示例 / 适当性指南 / AML 规则） USE jinrong_core; -- 风险等级字典（客户 C1~C5 · 产品 R1~R5） CREATE TABLE core_risk_grade ( code VARCHAR(4) NOT NULL PRIMARY KEY COMMENT 'C1~C5 或 R1~R5', grade_type ENUM('customer','product') NOT NULL, display_name VARCHAR(32) NOT NULL, sort_order TINYINT UNSIGNED NOT NULL ) ENGINE=InnoDB COMMENT='风险等级字典'; CREATE TABLE core_industry ( industry_code VARCHAR(16) NOT NULL PRIMARY KEY, industry_name VARCHAR(64) NOT NULL ) ENGINE=InnoDB COMMENT='行业分类'; -- C×R 适当性匹配矩阵（《个人投资者适当性管理指南》第十二条） CREATE TABLE core_suitability_rule ( id TINYINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, customer_risk_code CHAR(2) NOT NULL COMMENT 'C1~C5', product_risk_code CHAR(2) NOT NULL COMMENT 'R1~R5', match_result ENUM('allowed','allowed_with_disclosure','forbidden') NOT NULL, rule_ref VARCHAR(32) NOT NULL DEFAULT 'JR-AST-012', UNIQUE KEY uk_cx_r (customer_risk_code, product_risk_code), CONSTRAINT fk_suit_cust_risk FOREIGN KEY (customer_risk_code) REFERENCES core_risk_grade(code), CONSTRAINT fk_suit_prod_risk FOREIGN KEY (product_risk_code) REFERENCES core_risk_grade(code) ) ENGINE=InnoDB COMMENT='适当性匹配规则（L0 权威）'; -- 内部员工（含 RBAC 角色种子，供 JWT/鉴权联调对照） CREATE TABLE core_staff ( staff_id VARCHAR(64) NOT NULL PRIMARY KEY, display_name VARCHAR(64) NOT NULL, staff_type ENUM('advisor','analyst','risk_officer','compliance','ops') NOT NULL, roles JSON NOT NULL COMMENT 'JWT roles 数组，如 ["advisor"]', tenant_id VARCHAR(32) NOT NULL DEFAULT 'TENANT-001', is_active TINYINT(1) NOT NULL DEFAULT 1, created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ) ENGINE=InnoDB COMMENT='内部员工主档（模拟 IdP 账号源）'; -- 客户主档 L0（KYC + 财务概况 · 对齐用户信息数据示例） CREATE TABLE core_customer ( customer_id VARCHAR(64) NOT NULL PRIMARY KEY, display_name VARCHAR(64) NOT NULL COMMENT '脱敏展示名', gender ENUM('M','F','U') NOT NULL DEFAULT 'U', birth_date DATE NULL, age TINYINT UNSIGNED NULL, id_no_mask VARCHAR(32) NULL COMMENT '310101199903XXXXXX', occupation VARCHAR(64) NULL, employer VARCHAR(128) NULL, education ENUM('high_school','associate','bachelor','master','doctor','other') NULL, marital_status ENUM('single','married','widowed','divorced','other') NULL, city VARCHAR(64) NULL, address_mask VARCHAR(256) NULL, phone_mask VARCHAR(16) NULL, email_mask VARCHAR(64) NULL, annual_income DECIMAL(18,2) NULL COMMENT '家庭年收入（元）', financial_asset DECIMAL(18,2) NULL COMMENT '金融资产规模（不含房产）', monthly_investable DECIMAL(18,2) NULL COMMENT '月可投资金额', is_hnw TINYINT(1) NOT NULL DEFAULT 0 COMMENT '高净值客户', service_tier ENUM('normal','vip','diamond') NOT NULL DEFAULT 'normal', is_pep TINYINT(1) NOT NULL DEFAULT 0 COMMENT '政治公众人物', aml_risk_level ENUM('low','medium','high') NOT NULL DEFAULT 'low', invest_experience_years TINYINT UNSIGNED NULL, first_invest_date DATE NULL, tenant_id VARCHAR(32) NOT NULL DEFAULT 'TENANT-001', open_date DATE NOT NULL, is_active TINYINT(1) NOT NULL DEFAULT 1, created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3), KEY idx_service_tier (service_tier), KEY idx_hnw (is_hnw), KEY idx_aml (aml_risk_level) ) ENGINE=InnoDB COMMENT='客户主档 L0 · KYC'; -- 正式风险测评 L0（对齐适当性指南 16 题问卷 + FM-03 风评过期） CREATE TABLE core_customer_risk ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, customer_id VARCHAR(64) NOT NULL, risk_code CHAR(2) NOT NULL COMMENT 'C1~C5', questionnaire_score SMALLINT UNSIGNED NULL COMMENT '问卷总分 20-100', max_loss_tolerance_pct DECIMAL(5,2) NULL COMMENT '最大可承受亏损比例', investment_goal VARCHAR(128) NULL, investment_horizon ENUM('short','medium','long','flexible') NULL, investor_category ENUM('ordinary','professional','professional_pending') NOT NULL DEFAULT 'ordinary', professional_approved_at DATE NULL, is_authoritative TINYINT(1) NOT NULL DEFAULT 1, evaluated_at DATE NOT NULL, expires_at DATE NOT NULL COMMENT '风评有效期（通常 evaluated_at+12 月）', source VARCHAR(32) NOT NULL DEFAULT 'risk_questionnaire', UNIQUE KEY uk_customer_current (customer_id), KEY idx_risk (risk_code), KEY idx_expires (expires_at), KEY idx_investor_cat (investor_category), CONSTRAINT fk_cust_risk_customer FOREIGN KEY (customer_id) REFERENCES core_customer(customer_id), CONSTRAINT fk_cust_risk_code FOREIGN KEY (risk_code) REFERENCES core_risk_grade(code) ) ENGINE=InnoDB COMMENT='客户正式风险测评 L0'; CREATE TABLE core_customer_advisor ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, customer_id VARCHAR(64) NOT NULL, advisor_id VARCHAR(64) NOT NULL COMMENT '对应 core_staff.staff_id', rel_status ENUM('active','transferred','closed') NOT NULL DEFAULT 'active', effective_from DATE NOT NULL, effective_to DATE NULL, UNIQUE KEY uk_cust_advisor_from (customer_id, advisor_id, effective_from), KEY idx_advisor (advisor_id, rel_status), CONSTRAINT fk_ca_customer FOREIGN KEY (customer_id) REFERENCES core_customer(customer_id), CONSTRAINT fk_ca_advisor FOREIGN KEY (advisor_id) REFERENCES core_staff(staff_id) ) ENGINE=InnoDB COMMENT='客户-代理人归属'; -- 产品主档（对齐 C-11：风险等级 + 期限 + 起购金额） CREATE TABLE core_product ( product_id VARCHAR(64) NOT NULL PRIMARY KEY, product_name VARCHAR(128) NOT NULL, product_type ENUM( 'money','bond','mixed','stock','index', 'wealth_mgmt','private_fund','insurance','structured' ) NOT NULL, min_risk_code CHAR(2) NOT NULL COMMENT 'R1~R5 最低适配', min_subscribe_amount DECIMAL(18,2) NOT NULL DEFAULT 1.00 COMMENT '起购金额（元）', term_days INT UNSIGNED NULL COMMENT '产品期限（天），NULL=灵活开放', requires_disclosure TINYINT(1) NOT NULL DEFAULT 0 COMMENT '购买前需签署风险揭示书', industry_code VARCHAR(16) NULL, fee_rate DECIMAL(6,4) NULL, is_open TINYINT(1) NOT NULL DEFAULT 1, created_at DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3), KEY idx_min_risk (min_risk_code), KEY idx_product_type (product_type), CONSTRAINT fk_product_risk FOREIGN KEY (min_risk_code) REFERENCES core_risk_grade(code), CONSTRAINT fk_product_industry FOREIGN KEY (industry_code) REFERENCES core_industry(industry_code) ) ENGINE=InnoDB COMMENT='产品主档'; CREATE TABLE core_holding ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, customer_id VARCHAR(64) NOT NULL, product_id VARCHAR(64) NOT NULL, qty DECIMAL(18,4) NOT NULL, cost_amount DECIMAL(18,2) NOT NULL, market_value DECIMAL(18,2) NOT NULL, pnl_pct DECIMAL(8,4) NOT NULL COMMENT '盈亏比例', as_of DATE NOT NULL, UNIQUE KEY uk_cust_product (customer_id, product_id), KEY idx_customer (customer_id), CONSTRAINT fk_hold_customer FOREIGN KEY (customer_id) REFERENCES core_customer(customer_id), CONSTRAINT fk_hold_product FOREIGN KEY (product_id) REFERENCES core_product(product_id) ) ENGINE=InnoDB COMMENT='持仓快照'; -- 交易流水（扩展 AML 字段 · 对齐反洗钱规则 RW-001~020） CREATE TABLE core_trade ( trade_id VARCHAR(64) NOT NULL PRIMARY KEY, customer_id VARCHAR(64) NOT NULL, product_id VARCHAR(64) NOT NULL, trade_type ENUM('subscribe','redeem','convert') NOT NULL, amount DECIMAL(18,2) NOT NULL, qty DECIMAL(18,4) NULL, channel ENUM('online','mobile','counter','other') NOT NULL DEFAULT 'online', counterparty_account_mask VARCHAR(32) NULL, counterparty_name VARCHAR(64) NULL, is_cash TINYINT(1) NOT NULL DEFAULT 0, payer_name VARCHAR(64) NULL COMMENT '代付人（RW-014）', is_third_party_pay TINYINT(1) NOT NULL DEFAULT 0, trade_status ENUM('confirmed','pending','cancelled') NOT NULL DEFAULT 'confirmed', traded_at DATETIME(3) NOT NULL, KEY idx_customer_time (customer_id, traded_at), KEY idx_amount (amount, traded_at), KEY idx_channel_time (channel, traded_at), CONSTRAINT fk_trade_customer FOREIGN KEY (customer_id) REFERENCES core_customer(customer_id), CONSTRAINT fk_trade_product FOREIGN KEY (product_id) REFERENCES core_product(product_id) ) ENGINE=InnoDB COMMENT='交易流水'; CREATE TABLE core_cash_flow ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, customer_id VARCHAR(64) NOT NULL, flow_type ENUM('in','out') NOT NULL, flow_subtype ENUM('deposit','withdraw','transfer_in','transfer_out','subscribe','redeem','other') NOT NULL DEFAULT 'other', amount DECIMAL(18,2) NOT NULL, channel ENUM('online','mobile','counter','other') NOT NULL DEFAULT 'online', counterparty_account_mask VARCHAR(32) NULL, counterparty_name VARCHAR(64) NULL, remark VARCHAR(128) NULL, occurred_at DATETIME(3) NOT NULL, KEY idx_customer (customer_id, occurred_at), KEY idx_flow_subtype (flow_subtype, occurred_at), CONSTRAINT fk_cf_customer FOREIGN KEY (customer_id) REFERENCES core_customer(customer_id) ) ENGINE=InnoDB COMMENT='资金进出'; CREATE TABLE core_product_nav ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, product_id VARCHAR(64) NOT NULL, nav DECIMAL(10,4) NOT NULL, daily_chg_pct DECIMAL(8,4) NOT NULL, nav_date DATE NOT NULL, UNIQUE KEY uk_product_date (product_id, nav_date), CONSTRAINT fk_nav_product FOREIGN KEY (product_id) REFERENCES core_product(product_id) ) ENGINE=InnoDB COMMENT='产品净值';