75 lines
2.9 KiB
TypeScript
75 lines
2.9 KiB
TypeScript
|
import { Request, Response } from 'express';
|
|||
|
|
import { WorkflowTask } from '../src/pages/WorkflowOrchestrator/data';
|
|||
|
|
|
|||
|
|
// 模拟内存数据库
|
|||
|
|
let workflowData: WorkflowTask[] = [
|
|||
|
|
{
|
|||
|
|
id: 'wf-001',
|
|||
|
|
name: '自动化 UI 部署任务',
|
|||
|
|
status: 'executing',
|
|||
|
|
progress: 30,
|
|||
|
|
currentStepId: 'step-2',
|
|||
|
|
createTime: '2024-03-20 10:00:00',
|
|||
|
|
steps: [
|
|||
|
|
{ id: 'step-1', agentName: 'Planning Agent', status: 'success', startTime: '10:00', logs: '已完成架构设计与需求拆解。' },
|
|||
|
|
{ id: 'step-2', agentName: 'Frontend Agent', status: 'executing', startTime: '10:05', logs: '正在编写 ProTable 组件代码，应用 Design Tokens...' },
|
|||
|
|
{ id: 'step-3', agentName: 'QA Agent', status: 'thinking', startTime: '10:10', logs: '待执行回归测试。' },
|
|||
|
|
],
|
|||
|
|
},
|
|||
|
|
{
|
|||
|
|
id: 'wf-002',
|
|||
|
|
name: '后端 API 重构',
|
|||
|
|
status: 'success',
|
|||
|
|
progress: 100,
|
|||
|
|
currentStepId: 'step-2',
|
|||
|
|
createTime: '2024-03-20 09:30:00',
|
|||
|
|
steps: [
|
|||
|
|
{ id: 'step-1', agentName: 'Architect', status: 'success', startTime: '09:30', logs: 'API 路径规范化已通过。' },
|
|||
|
|
{ id: 'step-2', agentName: 'Backend Dev', status: 'success', startTime: '09:45', logs: '完成 Swagger 契约自动生成。' },
|
|||
|
|
],
|
|||
|
|
},
|
|||
|
|
{
|
|||
|
|
id: 'wf-003',
|
|||
|
|
name: '性能压力测试',
|
|||
|
|
status: 'failed',
|
|||
|
|
progress: 65,
|
|||
|
|
currentStepId: 'step-2',
|
|||
|
|
createTime: '2024-03-20 11:00:00',
|
|||
|
|
steps: [
|
|||
|
|
{ id: 'step-1', agentName: 'DevOps Agent', status: 'success', startTime: '11:00', logs: '环境已就绪。' },
|
|||
|
|
{ id: 'step-2', agentName: 'QA Agent', status: 'failed', startTime: '11:15', logs: '内存溢出错误：JVM heap size exceeded.' },
|
|||
|
|
],
|
|||
|
|
},
|
|||
|
|
];
|
|||
|
|
|
|||
|
|
export default {
|
|||
|
|
'GET /api/workflow/list': (req: Request, res: Response) => {
|
|||
|
|
// 动态更新逻辑：每次列表请求都模拟进度步进
|
|||
|
|
workflowData = workflowData.map((task) => {
|
|||
|
|
if (task.status === 'executing' && task.progress < 100) {
|
|||
|
|
const nextProgress = Math.min(task.progress + 5, 100);
|
|||
|
|
return {
|
|||
|
|
...task,
|
|||
|
|
progress: nextProgress,
|
|||
|
|
status: nextProgress === 100 ? 'success' : 'executing',
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
return task;
|
|||
|
|
});
|
|||
|
|
res.send({ data: workflowData, total: workflowData.length });
|
|||
|
|
},
|
|||
|
|
|
|||
|
|
'POST /api/workflow/:id/control': (req: Request, res: Response) => {
|
|||
|
|
const { id } = req.params;
|
|||
|
|
const { action } = req.body;
|
|||
|
|
workflowData = workflowData.map((task) => {
|
|||
|
|
if (task.id === id) {
|
|||
|
|
if (action === 'retry') return { ...task, status: 'executing', progress: 0 };
|
|||
|
|
if (action === 'stop') return { ...task, status: 'failed' };
|
|||
|
|
}
|
|||
|
|
return task;
|
|||
|
|
});
|
|||
|
|
res.send({ success: true });
|
|||
|
|
},
|
|||
|
|
};
|