Home Esplora Aiuto
Accedi
user5
/
forge_admin
1
0
Forka 0
File Problemi 0 Pull Requests 0 Wiki
Ramo (Branch): master
Rami (Branch) Tag
forge_admin
/
code-copilot
/
changes
/
定时任务可靠性加固
/
tasks.md

tasks.md 4.1 KB
Permalink Cronologia Originale

定时任务可靠性加固 Implementation Plan

status: complete scope: V1 only

进度总览

Task 状态 完成情况
Task 1 最小数据库迁移 complete 3/3
Task 2 DTO、VO、校验和 Mapper XML complete 3/3
Task 3 Quartz 异常和幂等同步 complete 3/3
Task 4 启动恢复和注解登记 complete 3/3
Task 5 日志筛选和安全裁剪 complete 3/3
Task 6 Controller 和前端同步状态 complete 3/3
Task 7 回归验证 complete 4/4

Task 1: 最小数据库迁移

  • 目标: 增加同步可见性、乐观版本和日志关联字段。
  • 涉及文件:
    • Create: forge-server/db/migration/V__harden_job_scheduler_reliability.sql
    • Test: forge-server/forge-framework/forge-plugin-parent/forge-plugin-job/src/test/java/com/mdframe/forge/plugin/job/migration/JobReliabilityMigrationContractTest.java
  • 先写迁移契约测试并确认失败。
  • 编写幂等 Flyway，保持历史状态值。
  • 运行迁移契约测试并确认通过。

    • Task 2: DTO、VO、校验和 Mapper XML

    • 目标: 隔离 Entity 协议并修复查询规范。
    • 涉及文件:
      • Create: dto/JobConfigQuery.java、dto/JobConfigSaveRequest.java
      • Create: vo/JobConfigVO.java、support/JobConfigValidator.java
      • Modify: mapper/SysJobConfigMapper.java、mapper/SysJobLogMapper.java
      • Create/Modify: resources/mapper/SysJobConfigMapper.xml、SysJobLogMapper.xml
    • 关键签名:
      • void validateCreate(JobConfigSaveRequest request)
      • void validateUpdate(JobConfigSaveRequest request, SysJobConfig current)
      • Page selectJobPage(Page page, JobConfigQuery query)
      • 先写校验和 XML 契约失败测试。
      • 实现最小协议与 XML 查询。
      • 扫描 Service，确认分页查询不再使用 LambdaQueryWrapper。

      Task 3: Quartz 异常和幂等同步

      • 目标: 用明确异常和统一同步替代 boolean 静默失败。
      • 涉及文件:
        • Modify: scheduler/JobScheduler.java
        • Create: manager/JobScheduleCoordinator.java
        • Modify: service/impl/SysJobConfigServiceImpl.java
      • 关键签名:
        • void synchronize(Long jobConfigId)
        • void retrySynchronization(Long jobConfigId)
        • void reconcileOnStartup()
      • 写新增、更新、暂停、删除和调度失败测试。
      • 实现同步状态流转 PENDING、SYNCED、FAILED、DELETE_PENDING。
      • 确认失败对调用方可见且可重试。

      Task 4: 统一启动恢复和注解登记

      • 目标: 只保留一个数据库到 Quartz 的调度入口。
      • 涉及文件:
        • Modify: registry/JobAutoRegistrar.java
        • Replace/Delete: loader/JobConfigLoader.java
        • Create: scheduler/JobStartupReconciler.java
      • 注解任务仅按 job_name + job_group 登记期望配置。
      • 启动后执行一次幂等恢复。
      • 测试缺失任务恢复、暂停状态保持和非 Forge Job 不受影响。

      Task 5: 日志筛选和安全裁剪

      • 目标: 修复时间筛选并降低敏感数据泄露风险。
      • 涉及文件:
        • Modify: entity/SysJobLog.java、monitor/JobMonitor.java、scheduler/QuartzJobExecutor.java
        • Create: support/JobLogSanitizer.java
        • Modify: service/impl/SysJobLogServiceImpl.java
      • 测试 Token、手机号、Authorization 等字段脱敏。
      • 实现参数、结果、异常的长度上限。
      • 验证 startTime/endTime 查询真实进入 XML SQL。

      Task 6: Controller 和前端同步状态

      • 目标: 接入新协议并提供同步失败重试入口。
      • 涉及文件:
        • Modify: controller/JobConfigController.java、controller/JobLogController.java
        • Modify: forge-admin-ui/src/views/system/job-config.vue
        • Modify: forge-admin-ui/src/views/system/job-log-list.vue
      • Controller 使用 DTO/VO 并保留现有路径兼容。
      • 列表展示同步状态和错误摘要。
      • 同步失败任务提供重试操作。

      Task 7: 回归验证

      • 读取 automated-testing-standard.md 并创建 test-spec.md、execution-log.md。
      • 运行 job 模块全部测试和 admin 聚合构建。
      • 运行前端定向检查、Lint 和生产构建。
      • 回填 Spec、Tasks 和执行日志。