财务分析与报告

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;
}