cyhzzz FICC经营分析报告主协调器
概述
本协调器作为FICC经营分析报告生成的主控模块，负责：
- 工作流编排：定义和管理6个Phase的执行顺序
- 阶段路由：根据用户输入和数据状态决定执行路径
- 状态管理：跟踪报告生成过程中的状态和数据
- 子技能协调：调用数据收集、指标计算、报告生成等子技能
工作流程
用户请求
│
▼
┌─────────────────────────────────────────────────────────────┐
│ Phase 0: 需求解析与初始化 │
│ - 识别业务团队和业务线 │
│ - 确定分析周期 │
│ - 初始化状态管理器 │
│ - 选择数据收集模式（A:引导式/B:数据库） │
└─────────────────────────────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────┐
│ Phase 1: 数据收集（调用data-collection子技能） │
│ 模式A: 引导式数据收集 │
│ - 交互式对话收集必需字段 │
│ - 按优先级引导用户输入 │
│ 模式B: 数据库采集 │
│ - 连接企业数据库 │
│ - 执行预定义SQL查询 │
│ - 数据格式转换 │
└─────────────────────────────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────┐
│ Phase 2: 数据验证（调用validation子技能） │
│ - 完整性检查：必需字段是否齐全 │
│ - 一致性检查：数值逻辑是否合理 │
│ - 业务规则验证：收入分解是否等于总收入 │
└─────────────────────────────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────┐
│ Phase 3: 指标计算（调用metrics-calculation子技能） │
│ - RAROC计算（风险调整资本回报率） │
│ - EVA计算（经济增加值） │
│ - 损益归因计算（债券5维模型） │
│ - 对冲有效性计算 │
└─────────────────────────────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────┐
│ Phase 4: 报告生成（调用report-generation子技能） │
│ - 根据业务线选择对应模板 │
│ - 填充数据与撰写内容（LLM驱动） │
│ - 生成Markdown格式报告 │
│ - 交互式确认：展示报告并询问用户满意度 │
│ ├─ 满意 → 进入Phase 5 │
│ └─ 需调整 → 循环修改直到满意 │
└─────────────────────────────────────────────────────────────┘
│
▼
┌─────────────────────────────────────────────────────────────┐
│ Phase 5: H5可视化（调用h5-visualization子技能） │
│ - 基于确认的Markdown报告生成H5页面 │
│ - 使用招商银行品牌设计系统 │
│ - 响应式设计，支持手机和PC访问 │
│ - 纯CSS/SVG图表，无外部依赖 │
└─────────────────────────────────────────────────────────────┘
│
▼
输出：完整的Markdown报告 + H5可视化页面
状态管理
状态定义
class WorkflowState:
"""工作流状态"""
# 基础信息
business_line: str # 业务线（如：贵金属）
team: str # 团队（如：商品交易团队）
period: str # 分析周期（如：2025年Q1）
# 数据收集模式
collection_mode: str # A: 引导式, B: 数据库
# 数据状态
raw_data: dict # 原始收集数据
validated_data: dict # 验证后数据
calculated_metrics: dict # 计算后指标
# 报告状态
markdown_report: str # Markdown报告内容
user_confirmed: bool # 用户是否确认
h5_page: str # H5页面HTML
# 阶段状态
current_phase: int # 当前阶段 (0-5)
phase_status: dict # 各阶段状态
状态转换图
┌─────────┐ 用户请求 ┌─────────┐
│ IDLE │ ────────────→ │ PHASE_0 │
└─────────┘ └────┬────┘
│
┌─────────────────────┼─────────────────────┐
│ │ │
▼ ▼ ▼
┌─────────┐ ┌─────────┐ ┌─────────┐
│ PHASE_1 │ ────────→│ PHASE_2 │ ────────→│ PHASE_3 │
│数据收集 │ │数据验证 │ │指标计算 │
└────┬────┘ └────┬────┘ └────┬────┘
│ │ │
└─────────────────────┼─────────────────────┘
│
▼
┌─────────┐
│ PHASE_4 │
│报告生成 │
└────┬────┘
│
┌─────────────────┼─────────────────┐
│ │ │
▼ │ ▼
┌─────────┐ │ ┌─────────┐
│用户不满意 │ ←──────────┘ │ 用户确认 │
│ 需调整 │ └────┬────┘
└─────────┘ │
▼
┌─────────┐
│ PHASE_5 │
│H5可视化 │
└────┬────┘
│
▼
┌─────────┐
│ COMPLETE│
└─────────┘
子技能调用接口
数据收集子技能 (data-collection)
# 模式A: 引导式数据收集
result = invoke_skill(
skill="data-collection/guided_mode",
params={
"business_line": "贵金属",
"period": "2025年Q1",
"required_fields": [
"total_revenue",
"yoy_growth",
"budget_completion_rate",
"revenue_breakdown",
"trading_strategies",
"risk_metrics"
]
}
)
# 模式B: 数据库采集
result = invoke_skill(
skill="data-collection/database_mode",
params={
"db_type": "oracle",
"business_line": "贵金属",
"period": "2025年Q1",
"connection_config": {
"host": "10.10.10.100",
"port": 1521,
"service_name": "FICCDB"
}
}
)
指标计算子技能 (metrics-calculation)
result = invoke_skill(
skill="metrics-calculation",
params={
"calculations": [
{"type": "raroc", "params": {...}},
{"type": "eva", "params": {...}},
{"type": "pnl_attribution", "params": {...}},
{"type": "hedge_effectiveness", "params": {...}}
],
"input_data": validated_data
}
)
报告生成子技能 (report-generation)
result = invoke_skill(
skill="report-generation",
params={
"business_line": "贵金属",
"template_type": "commodities/precious_metal",
"data": calculated_data,
"output_format": "markdown"
}
)
H5可视化子技能 (h5-visualization)
result = invoke_skill(
skill="h5-visualization",
params={
"markdown_report": markdown_content,
"theme": "cmb", # 招商银行主题
"responsive": True,
"charts": [
{"type": "bar", "data": ...},
{"type": "line", "data": ...},
{"type": "pie", "data": ...}
]
}
)
错误处理与恢复
错误类型
class WorkflowError(Exception):
"""工作流错误基类"""
pass
class PhaseError(WorkflowError):
"""阶段执行错误"""
def __init__(self, phase: int, message: str):
self.phase = phase
self.message = message
class DataValidationError(WorkflowError):
"""数据验证错误"""
pass
class UserInterruptError(WorkflowError):
"""用户中断错误"""
pass
恢复策略
def handle_error(error: WorkflowError, state: WorkflowState):
"""错误处理与恢复"""
if isinstance(error, PhaseError):
# 阶段错误：重试或跳过
if can_retry(state):
return retry_phase(state)
else:
return skip_to_next_phase(state)
elif isinstance(error, DataValidationError):
# 数据验证错误：返回数据收集阶段
return rollback_to_phase(state, phase=1)
elif isinstance(error, UserInterruptError):
# 用户中断：保存状态，等待恢复
save_checkpoint(state)
return pause_workflow(state)
文档版本
- Version: 1.0
- Last Updated: 2026-03-01
- Author: OpenClaw