85 lines
2.8 KiB
JavaScript
85 lines
2.8 KiB
JavaScript
|
/**
|
|||
|
|
* 执行状态查询路由 · L2 API 层
|
|||
|
|
*
|
|||
|
|
* GET /api/execution/:executionId/status — 前端轮询执行状态
|
|||
|
|
* POST /api/execution/:executionId/cancel — 明确拒绝取消（403）
|
|||
|
|
* DELETE /api/execution/:executionId — 明确拒绝删除（403）
|
|||
|
|
*
|
|||
|
|
* 注意：没有取消接口。这不是遗漏，是设计。
|
|||
|
|
* 版权：国作登字-2026-A-00037559
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
'use strict';
|
|||
|
|
|
|||
|
|
var express = require('express');
|
|||
|
|
var router = express.Router();
|
|||
|
|
var executionLock = require('../middleware/execution-lock');
|
|||
|
|
var authMiddleware = require('../middleware/auth');
|
|||
|
|
|
|||
|
|
router.use(authMiddleware.requireAuth);
|
|||
|
|
|
|||
|
|
// 查询执行状态（前端轮询用）
|
|||
|
|
router.get('/:executionId/status', function(req, res) {
|
|||
|
|
var status = executionLock.getExecutionStatus(req.params.executionId);
|
|||
|
|
|
|||
|
|
if (!status) {
|
|||
|
|
return res.json({
|
|||
|
|
state: 'not_found',
|
|||
|
|
reply: '未找到该执行记录。可能已经完成。'
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 计算进度百分比
|
|||
|
|
var progress = 5;
|
|||
|
|
if (status.totalSteps > 0) {
|
|||
|
|
progress = Math.min(95, Math.round((status.completedSteps / status.totalSteps) * 100));
|
|||
|
|
} else if (status.steps.length > 0) {
|
|||
|
|
progress = Math.min(95, status.steps.length * 15);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var afterIdx = parseInt(req.query.after, 10) || 0;
|
|||
|
|
|
|||
|
|
res.json({
|
|||
|
|
executionId: status.executionId,
|
|||
|
|
state: status.state,
|
|||
|
|
operation: status.operation,
|
|||
|
|
progress: progress,
|
|||
|
|
currentStep: status.steps.length > 0
|
|||
|
|
? status.steps[status.steps.length - 1].message
|
|||
|
|
: '初始化执行环境…',
|
|||
|
|
completedSteps: status.steps.filter(function(s) { return s.success; }).map(function(s) {
|
|||
|
|
return { message: s.message, timestamp: s.timestamp };
|
|||
|
|
}),
|
|||
|
|
newLogs: status.steps.slice(afterIdx),
|
|||
|
|
startTime: new Date(status.startTime).toISOString(),
|
|||
|
|
elapsed: Date.now() - status.startTime,
|
|||
|
|
result: status.state === 'completed' ? status.result : undefined,
|
|||
|
|
error: status.state === 'failed' ? status.error : undefined
|
|||
|
|
});
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 明确拒绝取消执行的请求
|
|||
|
|
router.post('/:executionId/cancel', function(_req, res) {
|
|||
|
|
res.status(403).json({
|
|||
|
|
error: true,
|
|||
|
|
code: 'CANCEL_FORBIDDEN',
|
|||
|
|
reply: '🔒 执行中的操作不可取消。\n\n' +
|
|||
|
|
'系统已开始执行，多个自动化流程正在联动。' +
|
|||
|
|
'中途中断会导致数据不一致和级联故障。\n\n' +
|
|||
|
|
'请等待执行完成。如果结果不理想，你可以说：\n' +
|
|||
|
|
'「前面的我没想好，我们重新来」\n' +
|
|||
|
|
'系统会在已有基础上重新迭代。'
|
|||
|
|
});
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 明确拒绝删除执行记录
|
|||
|
|
router.delete('/:executionId', function(_req, res) {
|
|||
|
|
res.status(403).json({
|
|||
|
|
error: true,
|
|||
|
|
code: 'DELETE_FORBIDDEN',
|
|||
|
|
reply: '🔒 不可删除执行记录。所有执行都是永久记录。'
|
|||
|
|
});
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
module.exports = router;
|