liuwei
|
d64d11a384
|
将@关系批处理业务迁移到 value_rank 插件
- 从 MessageStorageDB 移除@抽取与社交图写入逻辑，消息层仅保留归档职责
- 从系统级任务移除 process_pending_mentions，取消 message_to_db 中对应入口
- 在 value_rank 插件新增定时动作 value_rank_mentions_extract（每10分钟）
- 在插件内实现窗口化批处理（默认10~20分钟前）、@提取、幂等写入明细/边表/日汇总及 unique_interactors 回填
- 新增插件侧可配置参数 mention_batch_size / mention_window_start_minutes / mention_window_end_minutes
|
2026-04-21 14:10:25 +08:00 |
|
liuwei
|
1ddc1dcf18
|
优化@批处理窗口：每10分钟仅处理10-20分钟前消息
- 调整待抽取@查询逻辑：默认仅扫描 timestamp 在 [NOW-20m, NOW-10m) 的消息
- 保留 mentioned_user_ids 为空才处理的条件，处理过自动跳过
- 更新 MessageStorage 与系统任务调用参数，统一使用窗口化批处理配置
- 增加窗口参数兜底修正，避免错误配置导致全量扫描
|
2026-04-21 13:54:41 +08:00 |
|
liuwei
|
906f0905df
|
将@抽取与社交图写入改为定时批处理
- 精简 archive_message 主链路：仅做消息归档，不再同步执行@解析与社交统计
- 新增 MessageStorageDB.process_pending_mentions 批处理能力，按批次回填 mentioned_user_ids 并写入社交图
- 新增系统任务 process_pending_mentions，每10分钟执行一次（every_seconds=600）
- 增加幂等保护：基于 t_message_mentions 已有记录过滤新增@关系，避免重复累加社交边和热度
- 保留详细中文注释，说明性能优化目标与批处理策略
|
2026-04-21 13:51:56 +08:00 |
|
liuwei
|
3226fabcec
|
新增定时任务重启漏执行补偿机制
变更项：1) 系统任务与插件调度重载后基于应执行时间和执行日志对账，判定是否漏执行。2) 仅在应执行时间已过且日志未覆盖时补跑一次，避免重复补偿。3) system_job_db 与 plugin_schedule_db 新增 get_latest_log_time 查询。4) 增加容差窗口与中文注释，降低误判概率。
|
2026-04-17 09:38:15 +08:00 |
|
liuwei
|
1a1306ec71
|
系统定时任务日志持久化：新增入库与后台查询
- 新增系统任务日志表 t_system_job_logs，持久化记录每次执行结果、摘要、耗时、详情JSON\n- SystemJobLoader 注册任务时增加执行包装器：成功/失败均写入数据库日志，失败后继续抛出保证运行态状态一致\n- 系统任务后台日志接口改为查询数据库日志（不再依赖仅内存的 async_job logs），解决重启后日志丢失问题\n- 保持前端日志字段兼容，接口返回映射为 time/level/message 结构
|
2026-04-16 16:27:53 +08:00 |
|
liuwei
|
3873596399
|
修复：系统任务重载日志NameError
- 修复 utils/system_jobs.py 中 logger 未定义导致的启动异常\n- 补回 loguru.logger 导入，确保无处理器任务打印 warning 时不会抛错\n- 已执行 py_compile 校验通过
|
2026-04-16 16:18:52 +08:00 |
|
liuwei
|
9652c2594e
|
系统业务任务插件化迁移：下沉7项非刚需任务并接入平滑迁移
- 系统任务保留刚需三项：登录巡检、消息计数入库、媒体补偿处理；移除新闻/Epic/排行/PDF/秀人维护等业务型系统任务定义\n- 新增 daily_news、epic_free、daily_ranking、sehuatang_push 四个插件，将原系统业务任务改为插件可调度动作\n- 扩展 xiuren_image 插件调度动作，新增秀人下载、绅士R15下载、图片缓存更新三项维护任务\n- 新增系统任务到插件任务的幂等迁移逻辑：按旧 job_key 映射到插件 action，同步 trigger_type/trigger_config/enabled，并通过 payload 标记防止反复覆盖\n- 在 Robot 启动流程中接入迁移执行与重载，并清理已迁移的历史系统任务记录，避免后台双份维护\n- 扩展插件调度数据库操作：支持按 plugin_name + action_key 精确查询，便于迁移与对账
|
2026-04-16 16:05:59 +08:00 |
|
liuwei
|
9d6609990b
|
fix(schedule): reseed default system jobs before DB reload
|
2026-04-16 14:57:51 +08:00 |
|
liuwei
|
66a9b7c4a3
|
feat(schedule): move system jobs to DB-driven config and dashboard management
|
2026-04-16 14:54:23 +08:00 |
|