177 lines
4.9 KiB
Markdown
177 lines
4.9 KiB
Markdown
# task_status_${snCode} 主题推送位置分析
|
||
|
||
## 一、推送位置（服务端）
|
||
|
||
### 1. 任务状态变更推送 (`task_status_update`)
|
||
|
||
**位置**: `autoAiWorkSys/api/middleware/schedule/taskQueue.js`
|
||
|
||
**方法**: `notifyTaskStatusChange(sn_code, taskData)`
|
||
|
||
**推送时机**:
|
||
- ✅ **任务开始执行时** (第586行)
|
||
- 状态: `running`
|
||
- 进度: `0`
|
||
- 触发位置: `executeTask` 方法中，任务开始执行时
|
||
|
||
- ✅ **任务完成时** (第631行)
|
||
- 状态: `completed`
|
||
- 进度: `100`
|
||
- 触发位置: `executeTask` 方法中，任务成功完成后
|
||
|
||
- ✅ **任务失败时** (第675行)
|
||
- 状态: `failed`
|
||
- 进度: `0`
|
||
- 错误信息: `errorMessage`
|
||
- 触发位置: `executeTask` 方法中，任务执行失败时
|
||
|
||
**推送内容**:
|
||
```javascript
|
||
{
|
||
action: 'task_status_update',
|
||
data: {
|
||
taskId: task.id,
|
||
taskName: task.taskName,
|
||
taskType: task.taskType,
|
||
status: 'running' | 'completed' | 'failed',
|
||
progress: 0 | 100,
|
||
errorMessage?: string,
|
||
endTime?: Date
|
||
},
|
||
timestamp: string
|
||
}
|
||
```
|
||
|
||
### 2. 任务状态摘要推送 (`task_status_summary`)
|
||
|
||
**位置**: `autoAiWorkSys/api/middleware/schedule/taskQueue.js`
|
||
|
||
**方法**: `sendTaskStatusSummary(sn_code)`
|
||
|
||
**推送时机**:
|
||
- ✅ **定时推送** (每10秒一次)
|
||
- 位置: `autoAiWorkSys/api/middleware/schedule/scheduledJobs.js`
|
||
- 方法: `syncTaskStatusSummary()`
|
||
- 条件: 只向在线设备推送（最后心跳时间 < 3分钟）
|
||
|
||
**推送内容**:
|
||
```javascript
|
||
{
|
||
action: 'task_status_summary',
|
||
data: {
|
||
sn_code: string,
|
||
currentTask: {
|
||
taskId: number,
|
||
taskName: string,
|
||
taskType: string,
|
||
status: 'running',
|
||
progress: number,
|
||
currentStep: string,
|
||
startTime: Date,
|
||
jobTitle?: string, // 新增：职位名称
|
||
companyName?: string // 新增：公司名称
|
||
} | null,
|
||
pendingTasks: Array<{
|
||
taskId: number,
|
||
taskName: string,
|
||
taskType: string,
|
||
status: 'pending',
|
||
scheduledTime: Date,
|
||
priority: number
|
||
}>,
|
||
nextTaskTime: Date | null,
|
||
pendingCount: number, // 队列中的任务数
|
||
totalPendingCount: number, // 总待执行数（包括当前任务的剩余步骤）
|
||
mqttTopic: string,
|
||
timestamp: string
|
||
},
|
||
timestamp: string
|
||
}
|
||
```
|
||
|
||
## 二、接收位置（客户端）
|
||
|
||
### 1. MQTT 订阅
|
||
|
||
**位置**: `boss-automation-nodejs/src/services/mqttService.js`
|
||
|
||
**订阅时机**: MQTT 连接成功后 (第360行)
|
||
|
||
**订阅代码**:
|
||
```javascript
|
||
const taskStatusTopic = `task_status_${this.config.snCode}`;
|
||
this.client.subscribe(taskStatusTopic, { qos: 1 });
|
||
```
|
||
|
||
### 2. 消息处理
|
||
|
||
**位置**: `boss-automation-nodejs/src/services/mqttService.js`
|
||
|
||
**处理方法**: `handleMessage` (第292行)
|
||
|
||
**处理逻辑**:
|
||
- 如果 `action === 'task_status_update'`:
|
||
- 发送到渲染进程: `task:status-update`
|
||
|
||
- 如果 `action === 'task_status_summary'`:
|
||
- 发送到渲染进程: `task:status-summary`
|
||
|
||
### 3. 渲染进程接收
|
||
|
||
**位置**: `boss-automation-nodejs/app/mixins/taskMixin.js`
|
||
|
||
**方法**:
|
||
- `onTaskStatusUpdate(taskData)` - 处理任务状态变更
|
||
- `onTaskStatusSummary(summary)` - 处理任务状态摘要
|
||
|
||
**事件监听**: `boss-automation-nodejs/app/mixins/eventListenerMixin.js`
|
||
|
||
## 三、当前推送策略分析
|
||
|
||
### ✅ 优点
|
||
1. **实时性**: 任务状态变更立即推送
|
||
2. **完整性**: 定时推送完整的状态摘要
|
||
3. **可靠性**: 只向在线设备推送，避免资源浪费
|
||
|
||
### ⚠️ 潜在问题
|
||
1. **推送频率**: 定时任务每10秒推送一次，可能过于频繁
|
||
2. **重复推送**: 任务状态变更和定时摘要可能推送重复信息
|
||
3. **推送时机**: 某些关键状态变更可能没有及时推送（如进度更新）
|
||
|
||
## 四、建议的优化方案
|
||
|
||
### 方案1: 减少定时推送频率
|
||
- 当前: 每10秒推送一次
|
||
- 建议: 改为每30秒或60秒推送一次
|
||
- 理由: 任务状态变更已实时推送，定时推送主要用于同步完整状态
|
||
|
||
### 方案2: 只在关键时机推送摘要
|
||
- 任务队列变化时推送（新增/删除任务）
|
||
- 当前任务完成/失败时推送
|
||
- 定时推送作为兜底（频率降低）
|
||
|
||
### 方案3: 合并推送
|
||
- 将任务状态变更和摘要合并为一个消息
|
||
- 减少消息数量，提高效率
|
||
|
||
### 方案4: 添加进度更新推送
|
||
- 任务执行过程中，定期推送进度更新
|
||
- 例如：每完成10%进度推送一次
|
||
|
||
## 五、需要推送的场景建议
|
||
|
||
### ✅ 必须推送的场景
|
||
1. **任务开始执行** - 立即推送状态变更
|
||
2. **任务完成** - 立即推送状态变更 + 状态摘要
|
||
3. **任务失败** - 立即推送状态变更 + 状态摘要
|
||
4. **任务队列变化** - 新增/删除任务时推送摘要
|
||
|
||
### ⚠️ 可选推送的场景
|
||
1. **进度更新** - 每10%或每完成一个步骤推送一次
|
||
2. **定时同步** - 作为兜底，频率降低到30-60秒
|
||
|
||
### ❌ 不需要推送的场景
|
||
1. **任务状态未变化** - 避免重复推送相同状态
|
||
2. **设备离线** - 不向离线设备推送
|
||
|