面向金融投研团队的报告批量生产与运营管理场景。随着 AI 报告生成能力接入，单份报告可以通过接口生成，但按股票标的、报告类型和业务日期组织批量生产时，仍需要统一解决计划调度、长任务跟踪、异常恢复、报告归档和运营排障等问题。
项目建设独立的报告批处理与管理平台，通过可视化控制台统一管理跑批计划、批次、任务和报告资产，支持定时生产、人工触发、失败任务受控重试和操作审计。
平台通过接口复用外部 AI 报告生成服务，重点建设任务控制与资产管理能力，使报告生产过程可查询、异常可定位、操作可追溯，为后续扩展更多报告服务和统一存储提供基础。
面向金融投研场景的 AI 报告批量生产平台，覆盖计划调度、异步任务执行、报告资产管理、权限审计与运行监控。
1. 计划与批次管理：支持跑批计划创建、编辑、启停、Cron 调度预览和人工触发，按标的、报告类型与业务日期生成批次和任务，查询执行进度与结果摘要。
2. 异步任务与异常恢复：通过持久化 Outbox、后台 Worker、异步回调与补偿轮询推进长任务，记录执行尝试与失败原因，支持符合重试条件的任务重新执行及重跑来源追踪。
3. 报告资产管理：集中管理报告元数据、产物索引与 OSS 文件访问，支持在线查看和下载；对不完整报告保留部分产物并隔离展示，避免作为正式报告交付。
4. 可视化运行中心：提供批次、任务、报告资产列表与详情，联查回调、补偿轮询、分发记录和外部接口调用，辅助定位任务阻塞与状态异常。
5. 权限与操作审计：实现登录会话、角色权限、环境与数据范围控制；写操作结合幂等校验、版本校验和必要的二次确认，并保留操作审计记录。
6. 监控与治理：提供治理驾驶舱、告警中心、数据一致性检查、调用用量与估算成本分析，覆盖回调与分发积压、补偿异常、Worker 心跳过期等监测场景。
以全栈研发负责人角色推进项目，覆盖需求梳理、架构与数据模型设计、前后端开发、外部服务集成、自动化测试及云端部署。
前端采用 React、TypeScript、Vite、Ant Design、TanStack Query、React Router 与 ECharts，实现管理控制台、计划表单、任务链路详情、权限交互和治理分析页面。后端采用Python、FastAPI、SQLAlchemy、Alembic 与 PostgreSQL，建设管理 API、业务状态控制、数据持久化及数据库迁移体系。
系统按 API、调度器、任务分发、回调消费和补偿跟进拆分进程角色，通过持久化 Outbox、幂等校验与补偿机制协调外部 AI 服务调用及结果落库。针对长任务回调与轮询并存的情况，处理重复事件、状态竞争和终态一致性；针对报告不完整的情况，实现部分产物保存、正式资产隔离及受控重试。
安全与运维方面，实现管理端 RBAC、外部回调 HMAC 验签与防重放校验、操作审计及 trace_id 链路追踪，采用 JSON Lines 分类日志辅助排障。通过 Docker、Nginx、GitHub Actions 和阿里云 ECS 建立 staging 自动部署与发布后健康检查。
技术栈包含：Python、FastAPI、SQLAlchemy、Alembic、PostgreSQL、React、TypeScript、Vite、Ant Design、TanStack Query、React Router、ECharts、Docker、Nginx、GitHub Actions、阿里云ECS、阿里云 OSS。
评论