经营数据驾驶舱

type WorkflowInput = { request: string; userId: string };
type StageAdapter = (context: unknown) => Promise<unknown>;

const stages = [
  "接入财务、销售、产品和运营数据",
  "统一指标口径并执行质量校验",
  "计算趋势、同比环比和异常信号",
  "生成原因解释、影响范围和行动提示",
  "按角色分发日报、周报和预警"
];
const selectedTools = [];

export async function runWorkflow(input: WorkflowInput, adapters: Record<string, StageAdapter>) {
  let context: unknown = { ...input, selectedTools };

  for (const stage of stages) {
    const adapter = adapters[stage];
    if (!adapter) throw new Error(`Missing adapter: ${stage}`);
    context = await adapter(context);
  }

  return context;
}