中心服务器三服务定时任务全量清单(main-service 7 + device-service 8 + agent-service 1,共 16)。收录边界(spec「runtime 收录边界」):仅 @Scheduled / tokio interval 形态的定时任务;JMS 内部 destination 消费与事件监听器不入本表。agent-service 任务的业务说明另见 agent-service 接口规范。
源码归纳 @ 2026-09-14(日期基线)。
本页为生成物,不可手改,重摸底刷新(重跑生成器整体覆盖)。
| 任务 | 触发 | 职责(源码归纳) |
|---|---|---|
CleanupUploadDirectoryScheduling#cleanup |
固定间隔(上次完成后)PT24H | 上传目录清理:每日清理 tus 上传锁目录(存在时触发 tusFileUploadService.cleanup) |
DataSyncMasterSchedule#executeTask |
初始延迟 PT5M,固定间隔(上次完成后)PT3S | 主节点数据同步:主节点初始化、数据导出(全量/增量)、归档清理(仅 MASTER 角色执行) |
DataSyncSecondarySchedule#executeTask |
初始延迟 PT1M,固定间隔(上次完成后)PT9S | 从节点数据同步:下载远程文件、归档清理、扫描导入 input 目录(仅 SECONDARY 角色执行) |
FirmwareFileSyncService#syncFirmwareFiles |
初始延迟 PT1M,固定间隔(上次完成后)PT15M | 固件文件同步:从节点按 15 分钟周期对账同步固件文件 |
ObfuscationCodeScheduling#generate |
固定频率 PT10M | 混淆码轮换:滚动生成并保留最近 3 个 6 位混淆码(缓存于 stringListCache) |
TranslationDirtyDataScheduling#cleanupExistingDirtyData |
初始延迟 PT5M,固定间隔(上次完成后)PT1H | 翻译脏数据清理:独立小时周期清理既有脏数据 |
TranslationScheduling#processTranslationQueue |
初始延迟 PT5M,固定间隔(上次完成后)PT6S | 翻译队列处理:用最终翻译视图过滤已发布 key,按批量阈值落库减少频繁写库 |
| 任务 | 触发 | 职责(源码归纳) |
|---|---|---|
BatteryAddDocumentsScheduling#processDocuments |
初始延迟 PT1M,固定间隔(上次完成后)PT3S | 电池遥测入 Meilisearch:批量将电池数据经 spool 缓冲写入历史索引并周期重放/清理 |
DeviceOnlineStatusSyncScheduling#scheduledSync |
cron 0 0 2 * * ? | 设备在线状态对账:每日 02:00 从 EMQX REST API 拉取在线客户端并同步 Redis 缓存(服务启动后亦立即执行一次) |
GpsAddDocumentsScheduling#processDocuments |
初始延迟 PT1M,固定间隔(上次完成后)PT3S | GPS 遥测入 Meilisearch:批量将定位数据经 spool 缓冲写入历史索引并周期重放/清理 |
MqttConnectionScheduling#processDocuments |
初始延迟 PT1M,固定间隔(上次完成后)PT3S | MQTT 连接记录入 Meilisearch:批量将连接事件经 spool 缓冲写入历史索引并周期重放/清理 |
MqttPublicAppAccountsSyncScheduling#sync |
初始延迟 PT1M,固定间隔(上次完成后)PT3S | MQTT 公共应用账号同步:从 mqtt-app-accounts 配置绑定账号并刷新缓存 |
MyLogScheduling#processDocuments |
初始延迟 PT1M,固定间隔(上次完成后)PT3S | 系统日志入 Meilisearch:批量将系统日志经 spool 缓冲写入历史索引并周期重放/清理 |
TalkGroupRoomCompensationScheduling#runPeriodicRound |
初始延迟 PT5M,固定频率 PT5M | 对讲组房间补偿:周期扫描对讲组房间状态补偿收敛(前 3 轮全量,其后分档扩大扫描窗口) |
ZfygbAddDocumentsScheduling#processDocuments |
初始延迟 PT1M,固定间隔(上次完成后)PT3S | 执法记录仪(ZFYGB)数据入 Meilisearch:批量将设备数据经 spool 缓冲写入历史索引并周期重放/清理 |
| 任务 | 触发 | 职责(源码归纳) |
|---|---|---|
scheduler#run_db_backup |
每 3600 秒(tokio::time::interval,服务启动即计时) | 每小时 PostgreSQL 自动备份:对容器 es-center-server-pg-0 内数据库 es-center-server 执行备份,产物落 {data_root}/db_backups |