收到合法 finish callback 后，task 立即进入 uploading，后续 Recorder 断连不再回退。
+ Task
+
+
+ Keystone task state design
+Task uploading 状态方案
+
+ 本方案为 task 新增 uploading 状态，用于表达“录制已结束，任务进入上传后处理阶段”。核心目标是让 Recorder 断连、ping timeout 或重连状态同步不再把已完成录制的任务回退到 pending，同时允许订单和批次的生产侧先收敛。
+
目标与边界
+
+
+ 目标
+ 保护已结束录制的任务
+
+
+ 非目标
+ 不设计上传调度器
+
+
+ 约束
+ 区分生产与后处理
+
+
+ 第一版不做自动重试、不做上传超时、不持久化上传进度、不新增 pending_upload 或 upload_stalled。
completed_at 仍只表示 task 到达终态；order/batch completed 可以早于部分 uploading 后处理完成。
状态语义
+
+
+
+ pending
+
+ 未下发，等待配置或执行。
+
+ ready
+
+ Recorder 已配置，等待开始录制。
+
+ in_progress
+
+ Recorder 正在录制，仍属于 Recorder 阶段。
+
+ uploading
+
+ 录制已结束，上传后处理已接管或待接管。
+
+ completed
+
+ S3 验证、episode 写入、upload_ack 已完成。
+
+ 关键定义：
+
+ uploading 不严格表示“字节已经开始上传”，而表示“Recorder 不再拥有该 task，任务进入上传后处理阶段”。它不计入 in_progress，也不占用工位生产状态。
+ | 状态 | +是否终态 | +是否允许回退到 pending | +主要拥有方 | +
|---|---|---|---|
pending |
+ 否 | +不适用 | +Keystone | +
ready |
+ 否 | +允许，来自 clear、cancel、断连恢复 | +Recorder | +
in_progress |
+ 否 | +允许，来自 cancel、断连恢复 | +Recorder | +
uploading |
+ 否 | +禁止 | +Transfer / Keystone | +
completed / failed / cancelled |
+ 是 | +禁止 | +Keystone | +
设备归属校验
+所有来自 Recorder 或 Transfer 的设备事件，在修改 task 状态、写 error_message、写 episode 或发送 ACK 前，都必须确认事件来自拥有该 task 的设备。
tasks.task_id = message.task_id
+tasks.workstation_id = workstations.id
+workstations.robot_id = robots.id
+robots.device_id = callback.device_id 或当前 Transfer WebSocket 的 device_id| 入口 | +校验失败时 | +
|---|---|
| finish callback / Recorder state reconcile | +不改状态，只记录 warning/error；finish callback 返回可说明 task/device 不匹配。 | +
upload_started / upload_failed / upload_not_found |
+ 不改状态，不写错误到该 task，只记录来源设备和 task_id。 | +
upload_complete |
+ 不写 episode，不改 task，不发 upload_ack。 |
+
事件规则
+| 事件 | +状态变更 | +字段与响应 | +
|---|---|---|
| 合法 finish callback | +pending/ready/in_progress/uploading -> uploading |
+ 归属校验通过后立即更新状态；不写 completed_at；之后尝试发送 upload_request。 |
+
upload_request 发送成功 |
+ 保持 uploading |
+ 清空 upload 相关 error_message；finish callback 返回 200，并带 upload_request_sent: true。 |
+
upload_request 发送失败 |
+ 保持 uploading |
+ 写入 error_message；合法 finish callback 仍返回 200，并带 upload_request_sent: false。 |
+
upload_started |
+ pending/ready/in_progress/uploading -> uploading |
+ 归属校验通过后幂等确认上传阶段；清空 upload 相关 error_message；不碰终态。 |
+
upload_complete 且 ACK 成功 |
+ pending/ready/in_progress/uploading -> completed |
+ 归属校验通过后写 episode；发送 upload_ack；写 completed_at 并清空 error_message。 |
+
重复 upload_complete 且 task 已 completed |
+ 保持 completed |
+ 允许幂等发送 upload_ack；不重复写 episode、不改 completed_at、不重复推进 batch/order。 |
+
upload_failed |
+ in_progress/uploading -> failed |
+ 归属校验通过后写 completed_at 和 error_message；不回滚已 completed 的 order/batch。 |
+
upload_not_found |
+ 保持 uploading |
+ 归属校验通过后只写 error_message；不自动失败；不触发 batch/order 推进。 |
+
| 重复 finish callback | +保持 uploading |
+ 幂等处理；不写 completed_at；重新尝试 upload_request；根据发送结果清空或更新错误。 |
+
| 终态收到迟到事件 | +failed/cancelled 不恢复 |
+ failed/cancelled 收到 upload_complete 时不改状态、不发 ACK；只记录日志。 |
+
状态机约束
+pending -> ready -> in_progress -> uploading -> completed
+ | |
+ | -> failed
+ -> failed
+
+ready/in_progress -> pending 仅限 Recorder 阶段回退
+uploading -> pending 禁止
+failed -> uploading/completed 第一版禁止自动恢复
+ 第一版允许 task 长期停留在
+ uploading。该状态表示上传后处理残留，不阻塞 order/batch 的生产侧完成；后续如需收敛，由自动超时方案处理。
+ 断连与回退规则
+| 触发源 | +允许回退 | +禁止影响 | +
|---|---|---|
| Recorder 普通 disconnect | +ready/in_progress -> pending |
+ uploading、终态 |
+
| Recorder ping timeout | +ready/in_progress -> pending |
+ uploading、终态 |
+
| Transfer disconnect | +ready/in_progress -> pending，并可通知 Recorder clear/cancel |
+ uploading、终态 |
+
| Recorder state reconcile | +pending -> ready 或 pending/ready -> in_progress |
+ 不能把 uploading 拉回 ready 或 in_progress |
+
| Recorder clear/cancel RPC | +ready/in_progress -> pending |
+ uploading、终态 |
+
接口调整
+-
+
- 移除普通任务状态更新接口
PUT /tasks/:id；task 状态由系统事件和 batch cancel/recall 驱动。
+ - 移除手动 ACK 接口
POST /transfer/{device_id}/upload_ack；ACK 只由upload_complete验证路径自动发送。
+ - 手动
/transfer/{device_id}/upload_request不负责把非uploading的任务推进到uploading。
+ - 如果 task 已是
uploading，手动 upload_request 发送成功后清空error_message。
+ - 第一版不做
uploading自动超时，不自动把卡住的上传改为failed。
+ - 第一版不新增管理员手动失败接口；
uploading -> failed只来自 Transfer 的upload_failed。
+
批次与订单
+| 规则 | +结论 | +
|---|---|
uploading 是否终态 |
+ 不是终态，但不永久阻塞 order/batch 的生产侧收敛。 | +
正常 batch active -> completed |
+ 仍要求所有 task 进入 completed/failed/cancelled。 |
+
| order 达标收尾 | +order 可以 completed；open batch 可 completed；保留 uploading task 继续后处理。 |
+
| batch cancel / recall | +只取消 pending/ready/in_progress；不取消 uploading。 |
+
| completed order/batch 下的后处理 | +uploading -> completed/failed 只更新 task、episode 和统计；不回滚 order/batch。 |
+
| 自动准备下一条任务 | +uploading 不阻塞同工位准备下一条；但需要 Recorder fresh idle 且 Transfer 在线。 |
+
| 工位占用 | +uploading 不改变工位生产占用语义，工位可用性仍看 Recorder 状态和设备连接。 |
+
数据库与迁移
+-
+
tasks.status增加枚举值uploading。
+ - 只做 schema 迁移，不批量回填历史
in_progress任务。
+ - 不新增
upload_started_at字段。
+ - finish callback 进入
uploading时不写completed_at。
+ upload_complete + upload_ack或upload_failed到达终态时写completed_at。
+ GET /tasks和GET /tasks/:id返回error_message，用于展示上传调度异常。
+ uploading和completedtask 禁止删除；长期uploading后续由自动超时方案收敛。
+
前端与大屏
+| 位置 | +调整 | +
|---|---|
| 任务列表 / 详情 | +uploading 显示为“上传中”，颜色复用进行中或同步中的蓝色系；详情和列表可展示 error_message。 |
+
| 生产大屏生命周期轨 | +改为 5 节点：pending -> ready -> in_progress -> uploading -> completed。 |
+
| 大屏后端统计 | +dashboardTaskCounts、summary、trend、batch task summary、status distribution 都单独处理 uploading。 |
+
| 趋势与统计卡 | +uploading 不计入 pending 或 in_progress，避免双算或误读。 |
+
| recent tasks | +status_text 对 uploading 返回“上传中”。 |
+
| 生产语义 | +order/batch completed 下仍可显示 uploading task；这是允许的上传后处理状态。 |
+
测试清单
+| 类别 | +必须覆盖的行为 | +
|---|---|
| finish callback | +归属校验通过的合法 callback 立即把 pending/ready/in_progress/uploading 改为或保持 uploading，并返回 200。 |
+
| 上传请求失败 | +Transfer 不在线或写失败时保持 uploading，写 error_message，响应 upload_request_sent: false。 |
+
| 设备归属 | +callback、upload_started、upload_complete、upload_failed、upload_not_found 的 device mismatch 都不能改 task。 |
+
| 断连恢复 | +Recorder disconnect、Recorder ping timeout、Transfer disconnect 都不能把 uploading 回退到 pending。 |
+
| 上传完成 | +upload_complete + upload_ack 把 uploading 改为 completed；已 completed 的重复 complete 可幂等 ACK。 |
+
| 上传失败 | +upload_failed 把 uploading 改为 failed，并写终态时间和错误；迟到 complete 不恢复 failed。 |
+
| 未找到上传 | +upload_not_found 保持 uploading，只更新 error_message。 |
+
| 接口移除 | +PUT /tasks/:id 和 POST /transfer/{device_id}/upload_ack 不再可用。 |
+
| 删除与 API 展示 | +uploading 禁止删除；任务 API 返回 error_message。 |
+
| 批次与订单 | +order 达标可 completed；open batch 可 completed；uploading 保留后处理且不影响工位占用。 |
+
| 大屏统计 | +状态分布、summary、trend、batch summary、recent tasks、5 节点生命周期轨都能正确展示 uploading。 |
+
| 长期上传中 | +第一版允许 task 长期停留 uploading，不阻塞 order/batch 生产侧完成。 |
+