定时任务

中心服务器三服务定时任务全量清单(main-service 7 + device-service 8 + agent-service 1,共 16)。收录边界(spec「runtime 收录边界」):仅 @Scheduled / tokio interval 形态的定时任务;JMS 内部 destination 消费与事件监听器不入本表。agent-service 任务的业务说明另见 agent-service 接口规范

源码归纳 @ 2026-09-14(日期基线)。

本页为生成物,不可手改,重摸底刷新(重跑生成器整体覆盖)。

main-service

任务 触发 职责(源码归纳)
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,按批量阈值落库减少频繁写库

device-service

任务 触发 职责(源码归纳)
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 缓冲写入历史索引并周期重放/清理

agent-service

任务 触发 职责(源码归纳)
scheduler#run_db_backup 每 3600 秒(tokio::time::interval,服务启动即计时) 每小时 PostgreSQL 自动备份:对容器 es-center-server-pg-0 内数据库 es-center-server 执行备份,产物落 {data_root}/db_backups