XuJiacheng
cf61e8dac6
- 新增 RoomStatusManager 类，负责管理房间状态快照表的数据库连接池及批量 Upsert 操作。 - 新增 StatusBatchProcessor 类，负责收集和合并房间状态更新，并定期将其写入数据库。 - 新增状态提取器 statusExtractor.js，从 Kafka 消息中提取并构建房间状态更新对象。 - 修改 index.js，初始化 RoomStatusManager 和 StatusBatchProcessor，并在 Kafka 消息处理流程中并行推送状态更新。 - 修改 processor/index.js，更新 processKafkaMessage 函数以支持状态提取和处理。 - 更新 kafkaPayload.js，修正 control_list 的提取逻辑，兼容 Kafka 实际传输中的 loop 字段。 - 添加状态批处理器和状态提取器的单元测试，确保功能的正确性。 - 更新文档 plan-room-status-sync.md，详细描述房间状态同步方案及字段映射。
748 B
748 B
移除 online_status 字段处理
背景
room_status_moment 表中的 online_status 字段不由本项目（RCU Action Server）管理。
本项目不应从 fault_list 中推导 online_status，该字段由其他服务负责写入。
变更范围
src/processor/statusExtractor.js— 移除online_status推导逻辑src/db/roomStatusManager.js— Upsert SQL 移除online_status列src/db/statusBatchProcessor.js— 合并逻辑移除online_statustests/status_extractor.test.js— 删除online_status相关测试用例tests/status_batch_processor.test.js— 删除online_status相关测试用例docs/plan-room-status-sync.md— 移除字段映射行和 SQL 中的online_status