mirror of
https://github.com/whyour/qinglong.git
synced 2025-11-10 00:26:09 +08:00
353 lines
11 KiB
Markdown
353 lines
11 KiB
Markdown
# 场景模式实现总结 (Scenario Mode Implementation Summary)
|
||
|
||
## 📊 实现统计 (Implementation Statistics)
|
||
|
||
- **新增文件**: 8 个 (8 new files)
|
||
- **修改文件**: 6 个 (6 modified files)
|
||
- **代码行数**: ~2,100 行新增代码 (~2,100 lines of new code)
|
||
- **功能数量**: 5 种触发器 + 4 种动作 (5 triggers + 4 actions)
|
||
- **语言支持**: 中文 + 英文 (Chinese + English)
|
||
|
||
## 🎯 核心功能实现 (Core Features Implemented)
|
||
|
||
### 1. 数据模型 (Data Models)
|
||
```
|
||
back/data/scenario.ts - 场景数据模型 (117 lines)
|
||
back/data/scenarioLog.ts - 日志数据模型 (58 lines)
|
||
```
|
||
|
||
**特性**:
|
||
- 完整的场景配置存储
|
||
- 触发器、条件、动作的灵活配置
|
||
- 执行统计和状态跟踪
|
||
- 详细的日志记录
|
||
|
||
### 2. 后端服务 (Backend Service)
|
||
```
|
||
back/services/scenario.ts - 场景服务 (501 lines)
|
||
```
|
||
|
||
**核心功能**:
|
||
- ✅ 场景生命周期管理(创建、更新、删除)
|
||
- ✅ 5 种触发器实现
|
||
- ✅ 条件评估引擎
|
||
- ✅ 动作执行引擎
|
||
- ✅ 失败熔断机制
|
||
- ✅ 自适应重试策略
|
||
- ✅ 完整的日志系统
|
||
|
||
### 3. API 接口 (API Endpoints)
|
||
```
|
||
back/api/scenario.ts - REST API (214 lines)
|
||
```
|
||
|
||
**端点列表**:
|
||
- `GET /api/scenarios` - 获取场景列表
|
||
- `POST /api/scenarios` - 创建场景
|
||
- `PUT /api/scenarios` - 更新场景
|
||
- `DELETE /api/scenarios` - 删除场景
|
||
- `POST /api/scenarios/:id/trigger` - 手动触发
|
||
- `GET /api/scenarios/:id/webhook` - 获取 Webhook URL
|
||
- `GET /api/scenarios/logs` - 查询日志
|
||
- `POST /api/scenarios/webhook/:token` - Webhook 触发
|
||
|
||
### 4. 前端界面 (Frontend UI)
|
||
```
|
||
src/pages/scenario/index.tsx - 主页面 (318 lines)
|
||
src/pages/scenario/modal.tsx - 编辑器 (443 lines)
|
||
src/pages/scenario/logModal.tsx - 日志查看 (130 lines)
|
||
```
|
||
|
||
**界面功能**:
|
||
- 📋 场景列表管理
|
||
- ✏️ 可视化场景编辑器
|
||
- 🔧 动态触发器配置
|
||
- 🧩 条件构建器 (AND/OR)
|
||
- ⚡ 动作配置器
|
||
- 📊 执行统计展示
|
||
- 📝 日志查看器
|
||
- 🔗 Webhook 管理
|
||
|
||
### 5. 国际化支持 (i18n)
|
||
```
|
||
src/locales/zh-CN.json - 中文翻译 (+72 entries)
|
||
src/locales/en-US.json - 英文翻译 (+72 entries)
|
||
```
|
||
|
||
## 🔧 技术架构 (Technical Architecture)
|
||
|
||
```
|
||
┌─────────────────────────────────────────────────────────┐
|
||
│ 前端层 (Frontend) │
|
||
├─────────────────────────────────────────────────────────┤
|
||
│ 场景列表 │ 场景编辑器 │ 日志查看器 │
|
||
│ (List) │ (Editor) │ (Log Viewer) │
|
||
└─────────────────────────────────────────────────────────┘
|
||
↕ HTTP API
|
||
┌─────────────────────────────────────────────────────────┐
|
||
│ API 层 (API Layer) │
|
||
├─────────────────────────────────────────────────────────┤
|
||
│ 场景管理 │ 手动触发 │ Webhook │ 日志 │
|
||
│ (CRUD) │ (Trigger) │ (External) │ (Logs) │
|
||
└─────────────────────────────────────────────────────────┘
|
||
↕ Service Layer
|
||
┌─────────────────────────────────────────────────────────┐
|
||
│ 服务层 (Service Layer) │
|
||
├─────────────────────────────────────────────────────────┤
|
||
│ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ │
|
||
│ │ 触发器管理 │ │ 条件评估引擎 │ │ 动作执行引擎 │ │
|
||
│ │ (Triggers) │ │ (Conditions) │ │ (Actions) │ │
|
||
│ └──────────────┘ └──────────────┘ └──────────────┘ │
|
||
│ ┌──────────────┐ ┌──────────────┐ ┌──────────────┐ │
|
||
│ │ 失败熔断 │ │ 重试策略 │ │ 日志记录 │ │
|
||
│ │ (Breaker) │ │ (Retry) │ │ (Logging) │ │
|
||
│ └──────────────┘ └──────────────┘ └──────────────┘ │
|
||
└─────────────────────────────────────────────────────────┘
|
||
↕ Data Layer
|
||
┌─────────────────────────────────────────────────────────┐
|
||
│ 数据层 (Data Layer) │
|
||
├─────────────────────────────────────────────────────────┤
|
||
│ Scenario 表 │ ScenarioLog 表 │
|
||
│ (场景配置) │ (执行日志) │
|
||
└─────────────────────────────────────────────────────────┘
|
||
```
|
||
|
||
## 🎨 触发器详解 (Trigger Details)
|
||
|
||
### 1. Variable Monitor (变量监听)
|
||
```javascript
|
||
{
|
||
triggerType: 'variable',
|
||
triggerConfig: {
|
||
watchPath: '/path/to/watch'
|
||
}
|
||
}
|
||
```
|
||
**工作原理**: 使用 chokidar 监控文件系统变化
|
||
|
||
### 2. Webhook Trigger (Webhook 触发)
|
||
```javascript
|
||
{
|
||
triggerType: 'webhook',
|
||
triggerConfig: {
|
||
token: 'auto-generated-or-custom'
|
||
}
|
||
}
|
||
```
|
||
**工作原理**: 生成唯一 Token,通过 HTTP POST 接收触发
|
||
|
||
### 3. Task Status Trigger (任务状态)
|
||
```javascript
|
||
{
|
||
triggerType: 'task_status',
|
||
triggerConfig: {
|
||
cronId: 123,
|
||
status: 'success' // or 'failure'
|
||
}
|
||
}
|
||
```
|
||
**工作原理**: 监听定时任务执行结果
|
||
|
||
### 4. Time Trigger (时间触发)
|
||
```javascript
|
||
{
|
||
triggerType: 'time',
|
||
triggerConfig: {
|
||
schedule: '0 0 * * *' // Cron expression
|
||
}
|
||
}
|
||
```
|
||
**工作原理**: 使用 Cron 表达式定时触发
|
||
|
||
### 5. System Event Trigger (系统事件)
|
||
```javascript
|
||
{
|
||
triggerType: 'system_event',
|
||
triggerConfig: {
|
||
eventType: 'disk_space', // or 'memory'
|
||
threshold: 80, // percentage
|
||
checkInterval: 60000 // milliseconds
|
||
}
|
||
}
|
||
```
|
||
**工作原理**: 定期检查系统资源使用率
|
||
|
||
## 🧩 条件逻辑示例 (Condition Logic Examples)
|
||
|
||
### AND 逻辑(全部满足)
|
||
```json
|
||
{
|
||
"conditionLogic": "AND",
|
||
"conditions": [
|
||
{ "field": "status", "operator": "equals", "value": "success" },
|
||
{ "field": "branch", "operator": "equals", "value": "main" }
|
||
]
|
||
}
|
||
```
|
||
|
||
### OR 逻辑(任一满足)
|
||
```json
|
||
{
|
||
"conditionLogic": "OR",
|
||
"conditions": [
|
||
{ "field": "branch", "operator": "equals", "value": "main" },
|
||
{ "field": "branch", "operator": "equals", "value": "develop" }
|
||
]
|
||
}
|
||
```
|
||
|
||
### 支持的操作符
|
||
- `equals` - 等于
|
||
- `not_equals` - 不等于
|
||
- `greater_than` - 大于
|
||
- `less_than` - 小于
|
||
- `contains` - 包含
|
||
- `not_contains` - 不包含
|
||
|
||
## ⚡ 动作类型详解 (Action Types)
|
||
|
||
### 1. Run Task (运行任务)
|
||
```json
|
||
{
|
||
"type": "run_task",
|
||
"cronId": 123
|
||
}
|
||
```
|
||
|
||
### 2. Set Variable (设置变量)
|
||
```json
|
||
{
|
||
"type": "set_variable",
|
||
"name": "DEPLOY_STATUS",
|
||
"value": "completed"
|
||
}
|
||
```
|
||
|
||
### 3. Execute Command (执行命令)
|
||
```json
|
||
{
|
||
"type": "execute_command",
|
||
"command": "rm -rf /tmp/cache/*"
|
||
}
|
||
```
|
||
|
||
### 4. Send Notification (发送通知)
|
||
```json
|
||
{
|
||
"type": "send_notification",
|
||
"message": "Deployment completed successfully"
|
||
}
|
||
```
|
||
|
||
## 🛡️ 可靠性机制 (Reliability Mechanisms)
|
||
|
||
### 失败熔断 (Circuit Breaker)
|
||
```javascript
|
||
{
|
||
failureThreshold: 3, // 连续失败 3 次后自动禁用
|
||
consecutiveFailures: 0 // 当前连续失败次数
|
||
}
|
||
```
|
||
|
||
### 自适应重试 (Adaptive Retry)
|
||
```javascript
|
||
{
|
||
retryStrategy: {
|
||
maxRetries: 3, // 最多重试 3 次
|
||
retryDelay: 5, // 基础延迟 5 秒
|
||
backoffMultiplier: 2 // 每次延迟翻倍
|
||
}
|
||
}
|
||
// 重试延迟: 5s, 10s, 20s
|
||
```
|
||
|
||
### 延迟执行 (Delayed Execution)
|
||
```javascript
|
||
{
|
||
delayExecution: 30 // 触发后延迟 30 秒执行
|
||
}
|
||
```
|
||
|
||
## 📈 统计信息 (Statistics)
|
||
|
||
每个场景实时跟踪:
|
||
- `executionCount` - 总执行次数
|
||
- `successCount` - 成功次数
|
||
- `failureCount` - 失败次数
|
||
- `consecutiveFailures` - 连续失败次数
|
||
- `lastTriggeredAt` - 最后触发时间
|
||
- `lastExecutedAt` - 最后执行时间
|
||
|
||
## 🔍 日志系统 (Logging System)
|
||
|
||
每次执行记录:
|
||
- 触发数据 (`triggerData`)
|
||
- 条件匹配结果 (`conditionsMatched`)
|
||
- 执行状态 (`executionStatus`: success/failure/partial)
|
||
- 执行详情 (`executionDetails`)
|
||
- 错误信息 (`errorMessage`)
|
||
- 执行耗时 (`executionTime`)
|
||
- 重试次数 (`retriesAttempted`)
|
||
- 创建时间 (`createdAt`)
|
||
|
||
## 🎯 使用场景示例 (Use Case Examples)
|
||
|
||
### 场景 1: 配置文件自动重载
|
||
```
|
||
触发器: Variable Monitor
|
||
- 监听: /config/app.json
|
||
条件: 无
|
||
动作:
|
||
1. Execute Command - "pm2 reload app"
|
||
2. Send Notification - "配置已更新并重载"
|
||
```
|
||
|
||
### 场景 2: CI/CD 集成
|
||
```
|
||
触发器: Webhook
|
||
条件:
|
||
- event = "deployment" AND
|
||
- status = "success" AND
|
||
- branch = "main"
|
||
动作:
|
||
1. Run Task - 执行部署后清理任务
|
||
2. Set Variable - LAST_DEPLOY_TIME = ${timestamp}
|
||
```
|
||
|
||
### 场景 3: 磁盘空间告警
|
||
```
|
||
触发器: System Event
|
||
- 事件类型: disk_space
|
||
- 阈值: 85%
|
||
条件: 无
|
||
动作:
|
||
1. Execute Command - "清理临时文件"
|
||
2. Send Notification - "磁盘空间不足,已自动清理"
|
||
```
|
||
|
||
### 场景 4: 任务失败自动重试
|
||
```
|
||
触发器: Task Status
|
||
- 任务 ID: 123
|
||
- 状态: failure
|
||
条件: 无
|
||
动作:
|
||
1. Run Task - 重新执行任务 123
|
||
高级设置:
|
||
- 延迟执行: 300 秒
|
||
- 失败熔断: 3 次
|
||
```
|
||
|
||
## 📝 总结 (Summary)
|
||
|
||
场景模式功能为青龙面板提供了强大的自动化能力:
|
||
|
||
✅ **完整实现** - 从数据模型到前端界面全栈实现
|
||
✅ **灵活配置** - 5 种触发器和 4 种动作满足各种需求
|
||
✅ **可靠稳定** - 失败熔断、重试机制确保系统稳定
|
||
✅ **易于使用** - 可视化配置,无需编写代码
|
||
✅ **完善文档** - 详细的使用指南和 API 文档
|
||
✅ **国际化** - 完整的中英文支持
|
||
|
||
这个功能将青龙面板从简单的定时任务管理工具升级为智能的自动化运维中枢!
|