Open-Bank 开放银行平台

第1章 代码基线分析

1.1 全平台规模概览

1.2 系统级边界评估

1.3 ABCD 评级分布

pie title ABCD 评级分布
"A级 必须重构" : 12
"B级 建议重构" : 28
"C级 可选重构" : 65
"D级 维持现状" : 545

1.4 A 级关键类 TOP 10

1.5 核心包结构

cn/bank/gateway/
├── config/
│   ├── GatewayConfig.java          # 网关核心配置
│   ├── SecurityConfig.java         # 安全配置(OAuth2+Shiro)
│   ├── SentinelConfig.java         # 限流熔断配置
│   └── CorsConfig.java             # 跨域配置
├── filter/
│   ├── AuthFilter.java             # 认证过滤链 [A]
│   ├── RateLimitFilter.java        # 限流过滤器 [A]
│   ├── LogFilter.java              # 日志记录过滤器 [B]
│   └── TraceIdFilter.java          # 链路追踪ID [D]
├── controller/
│   ├── AppInfoController.java      # 应用管理 [A]
│   ├── ApiApplyController.java     # API申请管理 [A]
│   ├── DevAccountController.java   # 开发者账户 [B]
│   └── StatController.java         # 统计报表 [C]
├── service/
│   ├── DubboConsumerService.java   # Dubbo消费端 [B]
│   ├── RouteCacheService.java      # 路由缓存 [C]
│   └── TokenService.java           # Token服务 [B]
├── handler/
│   ├── GlobalExceptionHandler.java # 全局异常处理 [B]
│   └── SentinelFallbackHandler.java # 降级处理器 [A]
└── util/
    ├── SignUtil.java               # 签名验证 [C]
    └── IpUtil.java                 # IP工具 [D]

cn/bank/fop/
├── common/                         # 公共模块
│   ├── po/                         # 持久化对象
│   │   ├── AppInfoPO.java          # 应用信息实体
│   │   ├── DeveloperPO.java        # 开发者实体
│   │   ├── ApiInfoPO.java          # API信息实体
│   │   └── ApplyRecordPO.java      # 申请记录实体
│   ├── dto/                         # 数据传输对象
│   │   ├── AppInfoDTO.java
│   │   ├── ApiDTO.java
│   │   └── ResultDTO.java          # 统一返回DTO
│   ├── enum/                        # 枚举定义
│   │   ├── AppStatusEnum.java      # 应用状态枚举
│   │   ├── ApplyTypeEnum.java      # 申请类型枚举
│   │   └── ApiStatusEnum.java      # API状态枚举
│   ├── exception/                   # 自定义异常
│   │   └── FopBusinessException.java
│   └── util/                        # 工具类
│       ├── DateUtil.java
│       ├── EncryptUtil.java         # 加解密工具 [安全关注]
│       └── ValidatorUtil.java
├── platform-service/               # 平台服务
│   ├── service/                     # 业务服务层 [A/B级集中]
│   │   ├── FopAuthService.java     # 认证服务 [A]
│   │   ├── FopPlatformService.java # 平台核心服务 [A]
│   │   ├── AppManageService.java   # 应用管理 [B]
│   │   ├── ApiManageService.java   # API管理 [B]
│   │   └── DevAccountService.java  # 开发者服务 [B]
│   ├── dao/                         # 数据访问层
│   │   ├── AppInfoDao.java
│   │   ├── ApiInfoDao.java
│   │   └── DeveloperDao.java
│   └── dubbo/                       # Dubbo Provider
│       ├── FopAuthProvider.java    # 认证提供者
│       └── FopPlatformProvider.java # 平台服务提供者

第2章 业务/功能定位分析

2.1 功能分组矩阵

2.2 核心业务流程：API 调用全链路

flowchart TD
    A["第三方应用发起HTTP请求"] --> B{"网关入口\nGatewayRouteLocator"}
    B --> C["TraceIdFilter\n生成链路追踪ID"]
    C --> D{"AuthFilter\n认证检查"}
    D -->|未认证| E["返回401未授权"]
    D -->|已认证| F{"RateLimitFilter\n限流检查"}
    F -->|超限| G["返回429限流"]
    F -->|通过| H["LogFilter\n记录请求日志"]
    H --> I{"Sentinel\n熔断检查"}
    I -->|熔断开启| J["SentinelFallback\n降级响应"]
    I -->|正常| K["LoadBalancerClient\n路由到目标服务"]
    K --> L{"目标服务类型"}
    L -->|Dubbo RPC| M["DubboConsumerService\n远程调用平台服务"]
    L -->|HTTP REST| N["HttpClient\n转发至FOP微服务"]
    M --> O["FopPlatformServiceImpl\n执行业务逻辑"]
    N --> P[FopController\n处理REST请求]
    O --> Q[MyBatis DAO\n数据库读写]
    P --> Q
    Q --> R["组装响应结果"]
    R --> S["AOP切面\n记录响应日志/审计"]
    S --> T["返回JSON响应"]

    style A fill:#eff6ff,stroke:#2563eb
    style E fill:#fef2f2,stroke:#dc2626
    style G fill:#fffbeb,stroke:#d97706
    style J fill:#fffbeb,stroke:#d97706
    style T fill:#ecfdf5,stroke:#059669

2.3 角色操作矩阵

第3章 包/类关联关系分析

3.1 模块间调用关系 (SVG)

3.2 核心调用时序：应用创建与审核

sequenceDiagram
    participant Dev as 开发者(门户)
    participant Portal as PortalController
    participant GW as API网关
    participant Platform as FopPlatformService
    participant DB as MySQL
    participant OA as OA审批系统
    participant MQ as RabbitMQ

    Dev->>Portal: 1.提交应用注册表单
    Portal->>GW: 2.DubboRPC: createApp()
    GW->>Platform: 3.转发Dubbo调用
    Platform->>DB: 4.INSERT app_info (待审核)
    Platform->>MQ: 5.发送审核事件消息
    MQ-->>OA: 6.OA消费者接收审核任务
    Note over OA: 管理员在OA系统中审核
    OA->>MQ: 7.审核结果消息
    MQ-->>Platform: 8.消费审核结果
    Platform->>DB: 9.UPDATE app_status
    Platform-->>GW: 10.返回审核结果
    GW-->>Portal: 11.Dubbo响应
    Portal-->>Dev: 12.展示审核结果通知

3.3 类间耦合热点

第4章 数据模型与状态流转分析

4.1 核心 ER 关系图

erDiagram
    DEVELOPER {
        bigint developer_id PK "开发者主键"
        varchar username "登录用户名"
        varchar real_name "真实姓名"
        varchar email "电子邮箱"
        varchar phone "手机号码"
        varchar company "所属企业"
        int cert_status "认证状态 0未1已"
        datetime create_time "注册时间"
        datetime update_time "更新时间"
    }

    APP_INFO {
        bigint app_id PK "应用主键"
        bigint developer_id FK "所属开发者"
        varchar app_name "应用名称"
        varchar app_code "应用编码(唯一)"
        varchar app_key "API调用密钥"
        varchar app_secret "加密后的Secret"
        int app_type "应用类型 1自建2第三方"
        int status "状态 0草稿1待审2已审3冻结4注销"
        datetime create_time "创建时间"
        datetime update_time "更新时间"
    }

    API_INFO {
        bigint api_id PK "API主键"
        varchar api_name "API名称"
        varchar api_path "API路径(如/api/v1/user)"
        varchar http_method "HTTP方法 GET/POST等"
        int api_category "分类 1查询2写入3支付"
        int status "状态 0 draft 1 published 2 deprecated"
        varchar description "API描述"
        datetime publish_time "发布时间"
    }

    APPLY_RECORD {
        bigint apply_id PK "申请主键"
        bigint app_id FK "关联应用"
        bigint api_id FK "关联API(可为空)"
        bigint applicant_id FK "申请人"
        int apply_type "申请类型 1api订阅2app创建3密钥重置"
        int apply_status "状态 0待审1通过2驳回"
        varchar audit_opinion "审核意见"
        datetime apply_time "申请时间"
        datetime audit_time "审核时间"
        bigint auditor_id FK "审核人"
    }

    API_SUBSCRIPTION {
        bigint sub_id PK "订阅主键"
        bigint app_id FK "应用ID"
        bigint api_id FK "API ID"
        datetime subscribe_time "订阅时间"
        int qps_limit "QPS限制"
        int daily_limit "日调用量限制"
        int status "0生效1暂停2过期"
    }

    CALL_LOG {
        bigint log_id PK "日志主键"
        bigint app_id FK "调用应用"
        bigint api_id FK "调用API"
        varchar request_id "请求唯一标识"
        int http_status "HTTP状态码"
        int response_time_ms "响应耗时ms"
        datetime call_time "调用时间"
        varchar client_ip "客户端IP"
    }

    DEVELOPER ||--o{ APP_INFO : "拥有(1:N)"
    APP_INFO ||--o{ APPLY_RECORD : "产生申请(1:N)"
    API_INFO ||--o{ APPLY_RECORD : "关联申请(1:N)"
    APP_INFO ||--o{ API_SUBSCRIPTION : "订阅API(1:N)"
    API_INFO ||--o{ API_SUBSCRIPTION : "被订阅(1:N)"
    APP_INFO ||--o{ CALL_LOG : "产生调用日志(1:N)"
    API_INFO ||--o{ CALL_LOG : "产生调用日志(1:N)"
    DEVELOPER ||--o{ APPLY_RECORD : "提交申请(1:N)"

4.2 应用状态机

stateDiagram-v2
    [*] --> 草稿 : 开发者创建应用
    草稿 --> 待审核 : 提交审核
    待审核 --> 已上线 : 管理员审批通过
    待审核 --> 已驳回 : 管理员驳回(含意见)
    已驳回 --> 草稿 : 开发者修改后重新提交
    草稿 --> 已注销 : 开发者主动注销
    已上线 --> 已冻结 : 管理员违规冻结
    已冻结 --> 已上线 : 管理员解冻
    已上线 --> 已注销 : 开发者主动注销
    已注销 --> [*]

    note right of 草稿 : 可编辑所有信息\n不可调用API
    note right of 待审核 : 只读状态\n等待管理员审批
    note right of 已上线 : 正常运行态\n可调用已订阅API
    note right of 已冻结 : API调用被拦截\n需人工介入恢复

4.3 API 申请状态机

stateDiagram-v2
    [*] --> 待提交 : 创建申请单
    待提交 --> 已提交 : 提交申请
    已提交 --> 待审批 : 系统预检通过
    已提交 --> 预检不通过 : 系统预检失败
    预检不通过 --> 待提交 : 修正后重新提交
    待审批 --> 审批中 : 进入OA工作流
    审批中 --> 已通过 : OA审批通过
    审批中 --> 已驳回 : OA审批驳回
    已通过 --> 已生效 : 配置自动下发
    已驳回 --> 待提交 : 修改后重新提交
    已生效 --> [*] : 流程结束

    note right of 审批中 : 涉及BPM工作流引擎\n多级审批节点

4.4 实体字段追踪：敏感数据字段

4.5 级联事务边界

第5章 全量接口分析

5.1 接口统计概览

5.2 核心接口清单 (按优先级排列)

第6章 外部依赖边界分析

6.1 外部系统依赖全景

pie title 框架耦合占比(按代码行)
"Spring Framework" : 30
"MyBatis" : 18
"Dubbo" : 15
"Shiro" : 12
"Spring Cloud Gateway" : 10
"Sentinel" : 5
"Fastjson" : 5
"其他" : 5

flowchart TD
    subgraph Phase1["Phase 1: 安全加固 (P0)"]
        A1["1.1 敏感配置加密迁移"] --> A2["1.2 Fastjson安全模式配置"]
        A2 --> A3["1.3 SQL注入修复(全部${}→#{})"]
        A3 --> A4["1.4 加密工具升级(KMS+BCrypt)"]
    end

    subgraph Phase2["Phase 2: 认证统一 (P0-P1)"]
        B1["2.1 新建JwtAuthService(并行开发)"]
        B2["2.2 拆分GatewayAuthFilter为责任链"]
        B1 --> B3["2.3 双轨运行(新旧并存)"]
        A4 --> B1
        A2 --> B1
        B3 --> B4["2.4 废除Shiro, 切换至Spring Security"]
        B2 --> B4
    end

    subgraph Phase3["Phase 3: 服务拆分 (P1-P2)"]
        C1["3.1 FopPlatformService纵向拆分"]
        C2["3.2 Controller瘦身(业务逻辑下沉)"]
        C3["3.3 DAO层公共提取(BaseMapper)"]
        B4 --> C1
        C1 --> C2
        C2 --> C3
    end

    subgraph Phase4["Phase 4: 治理完善 (P2-P3)"]
        D1["4.1 路由/限流规则动态化"]
        D2["4.2 测试覆盖率达标(60%)"]
        D3["4.3 框架版本升级(Spring Boot 2.7+)"]
        C3 --> D1
        D1 --> D2
        D2 --> D3
    end

    Phase1 --> Phase2 --> Phase3 --> Phase4

    style Phase1 fill:#fef2f2,stroke:#dc2626
    style Phase2 fill:#fffbeb,stroke:#d97706
    style Phase3 fill:#eff6ff,stroke:#2563eb
    style Phase4 fill:#ecfdf5,stroke:#059669