|
|
680bf6a957
|
feat: 增加批量处理和数据库离线恢复机制以提升可靠性
- 新增 BatchProcessor 类实现消息批量插入，提高数据库写入性能
- 在 consumer 中禁用 autoCommit 并实现手动提交，确保数据一致性
- 添加数据库健康检查机制，在数据库离线时暂停消费并自动恢复
- 支持 0x0E 命令字处理，扩展消息类型识别范围
- 增加数据库连接重试逻辑，解决 Windows 环境端口冲突问题
- 更新环境变量配置，优化 Kafka 消费者参数
- 添加相关单元测试验证批量处理和可靠性功能
|
2026-02-04 20:36:33 +08:00 |
|
|
|
339db6f95f
|
feat(processor): 添加循环名称自动生成的配置开关
新增环境变量 ENABLE_LOOP_NAME_AUTO_GENERATION 用于控制当缓存未命中时是否自动生成循环名称。当设置为 false 时，系统将不再生成 [类型-地址-回路] 格式的备用名称，而是直接返回 null。更新了配置文件、处理器逻辑并添加了相应的单元测试。
|
2026-02-03 09:26:01 +08:00 |
|
|
|
4e0f5213db
|
feat: 添加回路名称字段并实现元数据缓存查询
在 RCU 事件处理中新增回路名称（loop_name）字段，用于标识具体设备回路。
- 在 rcu_action_events 表中添加 loop_name 字段
- 新增项目元数据缓存模块，每日从 temporary_project 表刷新房间与回路信息
- 处理消息时，根据 device_id、dev_addr 等字段查询缓存获取回路名称
- 若缓存未命中，则根据设备类型规则生成兜底名称
- 更新环境变量、文档及测试用例以适配新功能
|
2026-02-02 19:43:49 +08:00 |
|
|
|
0e6c5c3cc3
|
feat: 增强Kafka消费者配置并完善action_type分类逻辑
- 支持多实例Kafka消费者，增加并发处理能力
- 新增Kafka配置参数：最大飞行中消息数、获取字节数、等待时间等
- 完善action_type分类逻辑，根据dev_type映射为"用户操作"或"设备回路状态"
- 临时支持hex格式udp_raw自动转换为base64存储
- 增加extra字段支持上游扩展数据传递
- 优化数据库初始化脚本查找路径
- 更新PM2配置，修改应用名称和端口
- 清理开发环境日志文件，将dist目录加入.gitignore
- 更新相关文档说明
|
2026-01-30 20:09:46 +08:00 |
|
|
|
e0c3728b42
|
chore: 移除不再需要的 .gitkeep 文件
该文件用于确保空目录被 Git 追踪。现在 `dist` 目录已包含实际构建产物，不再需要占位文件。
|
2026-01-30 20:03:57 +08:00 |
|
|
|
86a1e79153
|
feat: 初始化后端服务基础架构与核心组件
- 添加项目基础结构，包括 .gitignore、package.json、Docker 配置和环境变量示例
- 实现核心模块：Kafka 消费者、PostgreSQL 数据库管理器、Redis 客户端与错误队列
- 添加工具类：日志记录器、指标收集器、UUID 生成器
- 实现数据处理器，支持 0x36 上报和 0x0F 命令的解析与存储
- 添加数据库初始化脚本和分区管理，支持按时间范围分区
- 引入 Zod 数据验证和 Vitest 单元测试框架
- 提供完整的项目文档，包括数据库设计、Kafka 格式规范和 Redis 集成协议
|
2026-01-30 11:05:00 +08:00 |
|
|
|
ec2b44b165
|
build: 添加 Vite 配置文件用于后端构建
配置 Vite 以构建 Node.js 后端应用，指定入口文件、输出目录、Node 版本，并将关键依赖标记为外部模块以避免打包。
|
2026-01-30 11:04:30 +08:00 |
|
