2. 智能成本估算系统架构：微服务架构设计、估算引擎核心模块、数据流与接口设计

智能成本估算系统并非单一巨石应用，而是采用微服务架构将估算能力拆解为独立、可伸缩的服务单元。这种架构允许团队独立部署、独立扩展估算引擎、参数管理、历史数据检索等模块，同时通过明确定义的 API 网关与数据总线实现高效协作。本节将深入剖析微服务划分原则、估算引擎的核心计算模块，以及贯穿系统的数据流与接口契约。

2.1 微服务架构设计

系统按业务边界拆分为以下核心微服务，每个服务拥有独立的数据库实例（Database per Service 模式），避免紧耦合。

2.2 估算引擎核心模块

估算引擎是系统的“大脑”，内部由四个子模块构成，按管道（Pipeline）模式串联执行。

1. 参数解析器（Parameter Parser）：接收来自 API 网关的估算请求 JSON，校验必填字段（如规模、复杂度、语言类型），加载对应的参数化模型定义（如 COCOMO II 的后架构模型）。
2. 计算核心（Calculation Core）：执行参数化公式，例如 COCOMO II 的人月计算公式：PM = A × (Size)^B × ∏(EM_i)。支持确定性计算与概率性计算（蒙特卡洛模拟，默认 1000 次迭代）。
3. 类比调整器（Analogy Adjuster）：调用类比估算服务获取相似项目列表，计算加权调整系数，对参数化结果进行修正。修正公式：Adjusted_PM = PM × (1 + α × Deviation_Rate)，其中 α 为置信权重。
4. 结果聚合器（Result Aggregator）：汇总确定性结果、概率分布（P50/P80/P90）、敏感度分析（Top-5 敏感因子），生成统一的结果结构体返回给 API 网关。

2.3 数据流与接口设计

数据流分为同步估算流与异步历史数据同步流。同步流用于实时估算请求，异步流用于后台更新历史项目特征库。

2.3.1 同步估算数据流

用户通过客户端发起估算请求，数据流经过以下步骤：

1. 客户端 → API 网关：POST /api/v1/estimate，请求体包含项目特征 JSON。
2. API 网关 → 估算引擎服务：转发请求，附加认证上下文。
3. 估算引擎服务 → 参数管理服务：GET /api/v1/parameters?model=COCOMO_II，获取模型定义与因子表。
4. 估算引擎服务 → 类比估算服务：POST /api/v1/analogy，传入项目特征向量，返回相似项目列表及调整系数。
5. 估算引擎服务内部执行计算核心与结果聚合，返回估算结果。
6. 估算引擎服务 → 结果管理服务：POST /api/v1/results，持久化估算报告。
7. API 网关 → 客户端：返回估算结果 JSON，包含 PM、工期、成本、置信区间。

2.3.2 接口契约示例

以下为估算请求与响应的核心接口定义（简化版）：

// 请求体：POST /api/v1/estimate
{
  "projectId": "PRJ-2025-001",
  "model": "COCOMO_II",
  "parameters": {
    "size": 125.5,           // 单位：千行代码（KSLOC）
    "sizeType": "KSLOC",
    "complexity": "HIGH",
    "language": "Java",
    "teamExperience": 0.85,  // 团队经验因子
    "useAnalogy": true       // 是否启用类比调整
  },
  "simulation": {
    "enabled": true,
    "iterations": 1000,
    "confidenceLevels": [50, 80, 90]
  }
}

// 响应体：200 OK
{
  "estimateId": "EST-2025-001-001",
  "status": "COMPLETED",
  "deterministic": {
    "personMonths": 425.3,
    "durationMonths": 14.2,
    "costUSD": 510360.0
  },
  "probabilistic": {
    "p50": { "personMonths": 410.0, "durationMonths": 13.8 },
    "p80": { "personMonths": 480.5, "durationMonths": 15.1 },
    "p90": { "personMonths": 520.0, "durationMonths": 16.0 }
  },
  "sensitivity": [
    { "factor": "size", "impact": 0.45 },
    { "factor": "teamExperience", "impact": 0.22 }
  ],
  "analogyAdjustment": {
    "applied": true,
    "similarProjects": 3,
    "adjustmentFactor": 1.08
  }
}

2.3.3 异步历史数据同步流

历史项目数据通过消息队列（Kafka）异步同步，避免阻塞估算主流程。

• 生产者：结果管理服务在估算报告审批通过后，发送 ProjectCompletedEvent 到 Kafka Topic history.sync。
• 消费者：历史项目服务消费事件，提取项目特征、实际成本、偏差数据，更新 Elasticsearch 索引与特征向量缓存。
• 数据一致性：采用“至少一次”投递语义，消费者侧做幂等去重（基于 projectId + 版本号）。

2.4 系统架构总览

下图展示了智能成本估算系统的微服务架构、核心模块及数据流关系。图中使用深色节点表示主要微服务，箭头表示同步/异步调用方向。

2.5 接口设计原则与版本管理

所有微服务接口遵循 RESTful 风格，使用 OpenAPI 3.0 规范定义。关键设计原则如下：

• 版本前缀：所有接口路径以 /api/v{major_version} 开头，例如 /api/v1/estimate。主版本号变更表示不兼容的接口变更。
• 幂等性：估算请求支持幂等键（Idempotency-Key），客户端重试时不会产生重复估算记录。
• 超时与熔断：估算引擎服务对外部依赖（参数管理、类比估算）设置 2s 超时，超时后触发熔断，返回降级结果（仅使用参数化结果，不进行类比调整）。
• 错误码规范：统一使用 EST-{服务代码}-{错误序号} 格式，例如 EST-ENG-001 表示估算引擎服务参数校验失败。