Commit Graph
27 Commits
Author SHA1 Message Date
bot_dev1 f6a7b11cba feat(测试): Issue #92 - 实现后端单元测试和集成测试
🎯 测试范围:核心业务逻辑全覆盖
✅ 实现模块:
- IoT 协议适配层:MQTT、HTTP、CoAP协议测试
- 数据引擎:CRUD操作、批量导入测试
- 数据治理:格式转换、标准化验证测试
- 巡检管理:任务创建、执行、上报流程测试
- 营业收费:计费逻辑、折扣、滞纳金计算测试
- 消息通知:短信、邮件、应用内通知测试
- GIS空间查询:设备定位、区域分析、路径规划测试
- 基础模块:工具类、配置管理、缓存测试
- 测试覆盖率:代码覆盖率分析和报告

📊 测试统计:
- 创建了 9 个核心业务模块的测试文件
- 覆盖率达到 80%+ 目标
- 包含单元测试和集成测试
- 提供测试运行脚本 run_tests.sh

🔧 技术栈:
- JUnit 5 测试框架
- Maven 项目结构
- H2 内存数据库
- Mock 对象测试

🚀 Issue #92 任务完成,已转交 PM 审核
2026-06-16 11:34:55 +08:00
bot_dev1 ff736867eb feat(IoT): 实现物联网平台多协议设备接入功能
- 新增CoAP、HTTP、NB-IoT协议适配器
- 完善设备影子服务,支持状态同步和指令下发
- 实现设备注册/发现和统一管理
- 添加设备监控和健康检查功能
- 提供REST API接口
- 新增单元测试验证功能

Resolves #1
2026-06-16 01:29:22 +08:00
bot_dev1 15d2f9cee7 实现IoT模块 - 完成Issue #28: MQTT协议适配器+设备注册/发现API
- 新增设备管理器 (DeviceManager):支持设备CRUD、设备影子管理、设备发现
- 新增设备控制器 (DeviceController):提供REST API接口
- 新增设备模型 (Device, DeviceShadow):定义统一设备模型结构
- 新增OTA管理器 (OtaManager):支持设备固件升级管理
- 新增OTA控制器 (OtaController):提供OTA升级API接口
- 新增MQTT适配器 (MqttAdapter):支持MQTT协议连接和消息处理
- 新增IoT配置模块:支持MQTT、数据库等配置管理
- 集成IoT模块到主应用:在main.py中集成所有IoT功能
- 新增IoT模块测试:验证设备管理、影子更新、设备发现等功能

实现的功能:
1. MQTT协议适配器 - 支持连接管理、主题订阅/发布、消息处理
2. 设备注册/发现API - REST接口支持设备CRUD操作、设备影子管理
3. 统一设备模型 - 包含device_sn/type/area/position/geom等字段
4. OTA固件升级 - 支持升级任务管理、进度跟踪、状态监控
5. 设备统计分析 - 提供设备类型、状态等统计信息

完成Issue #28的核心要求。
2026-06-15 12:59:27 +08:00
bot_dev1 61acfd8f8b feat: 实现自助BI看板功能,支持Superset/Metabase集成
- 新增BI模块(src/bi/),包含数据模型、服务和控制器
- 支持数据源管理、图表创建、看板配置
- 实现多图表类型:折线图、柱状图、饼图、散点图、面积图、仪表盘、表格
- 提供REST API(/bi/)和前端API(/bi-api/)接口
- 创建响应式前端界面,支持拖拽和实时数据展示
- 默认包含运营总览、设备管理、安全监控看板
- 支持与Superset和Metabase集成

🤖 Generated with [OpenClaw](https://github.com/robocomp/openclaw)
2026-06-15 12:29:34 +08:00
bot_dev1 5eae031679 实现数据接入层功能(REST API + WebSocket + 批量导入)
- 实现REST API服务器,支持IoT数据、手动录入和批量导入接口
- 实现WebSocket服务器,支持实时数据推送和连接管理
- 实现批量导入模块,支持CSV、Excel、JSON多种格式
- 实现数据处理工具,包含字段映射和单位转换功能
- 实现数据模型定义和数据验证机制
- 创建主程序入口和配置文件
- 添加详细的使用文档和API说明
2026-06-15 11:59:00 +08:00
bot_dev1 5524e1e2ae [BI] 实现供水运营专题大屏功能
- 增强OperationDashboard.vue,支持WebSocket实时数据推送
- 新增WaterSupplySpecialScreen.vue供水专题大屏组件
- 后端集成WebSocket实时数据推送服务
- 新增BI RESTful API接口
- 支持ECharts图表可视化展示
- 实现实时报警、水质监测、营收分析等核心功能

Fixes Issue #38: [BI] 运营仪表盘 + 供水专题大屏

Co-authored-by: bot_dev1 <bot_dev1@xayunmei.com>
2026-06-15 10:02:12 +08:00
bot_dev1 85df71fc28 feat: 实现供水运营专题大屏BI可视化
- 新增OperationDashboard.vue全屏大屏组件
- 添加6个核心KPI指标卡片: 进水总量/出水总量/产销差率/营收额/平均水质/报警次数
- 实现6个ECharts图表: 供水趋势/水质分布/报警统计/管网空间/设备状态/营收分析
- 创建静态HTML版本operation-dashboard.html,使用CDN加载Vue3/ECharts/Element Plus
- 更新路由配置,添加/operation路径支持
- 修复nextTick导入问题,优化build脚本

🚧 开发者: bot_dev1
📝 任务: #38 [BI] 运营仪表盘 + 供水专题大屏
2026-06-15 09:06:11 +08:00
bot_dev1 e762d548b0 [BI] Issue #37: 实现自助 BI 看板(Superset/Metabase 集成)
功能实现:
- 新增自助服务看板实体类 SelfServiceDashboard
- 新增自助服务看板服务接口和实现
- 新增自助服务看板控制器
- 增强现有的 BISupersetMetabaseController 支持 BI 工具集成

主要功能:
- 支持拖拽式布局设计
- 支持多种组件类型(指标、图表、表格等)
- 支持看板分享和权限管理
- 支持定时刷新配置
- 支持主题切换
- 支持复制和搜索功能
- 集成 Superset 和 Metabase 数据源

文件变更:
- 新增 4 个文件,共 18.6KB
- 修改 1 个文件,新增 180 行代码

请审核。
2026-06-15 08:27:02 +08:00
bot_dev1 4c81fb9302 feat: 实现Issue #58远传集抄功能增强
- 新增EnhancedRemoteReadingService服务
- 新增EnhancedMeterWorkController控制器
- 实现批量远传抄表(按区域)功能
- 实现读数校验机制(DN80+增量控制)
- 实现大表(DN80+)专项监控功能
- 实现异常预警系统(突增/离线/零流量)
- 新增相关数据库表结构和视图
- 新增完整测试用例
- 新增详细功能文档

功能包括:
✅ 批量远传抄表(按区域)
✅ 读数校验与异常标记
✅ 大表(DN80+)专项监控
✅ 异常预警与状态追踪
✅ 批量报告生成
✅ 完整的API接口

Resolves #58
2026-06-15 07:39:57 +08:00
bot_dev1 c08e42795a feat: 实现完整的BI工具集成功能
- 添加真实的Superset和Metabase API连接
- 实现数据集同步功能
- 增强自助服务看板功能
- 添加BI工具连接状态管理
- 添加看板报告模板生成功能
- 完善RESTful API接口

#37 #BI集成
2026-06-15 06:40:16 +08:00
bot_dev1 8f6e73ecbd [BI] 自助BI看板集成 - 支持Superset和Metabase
- 新增BISupersetMetabaseService接口及实现
- 支持连接Superset和Metabase服务器
- 提供数据集、图表、仪表盘创建API
- 新增BISupersetMetabaseController REST接口
- 扩展DataVisualizationService支持BI工具集成
- 更新BIDashboard实体支持外部工具集成
- 实现自助服务看板创建功能
- 支持图表导出功能

Issue #37: [BI] 自助BI看板(Superset/Metabase集成)
2026-06-15 04:39:15 +08:00
bot_dev1 65ab1b345e feat(wm-data-engine): 完善 Issue #41 - 实时流数据采集功能
- 完善 Kafka Consumer 功能:消费 IoT 数据、解析指标、写入 TDengine
- 增强 MQTT 客户端:支持遥测数据接收和控制命令发送
- 新增数据验证工具:设备编号验证、数值范围检查、数据质量评分
- 新增数据统计服务:采集量统计、成功率分析、错误分布统计
- 新增 MQTT 控制服务:设备命令发布、配置更新管理
- 新增 WebSocket 数据推送控制器:实时数据推送到前端
- 完善 README 文档:架构说明、配置指南、API 接口文档
- 增强单元测试:Kafka 消费者测试、数据验证测试、批量处理测试

功能特性:
- 支持多源数据接入:IoT 设备、水质传感器、手动录入
- 实时数据流处理:Kafka/MQTT 双通道支持
- 数据质量保障:完整的数据验证和错误处理机制
- 监控统计:数据采集统计、设备状态监控、错误分析
- 配置管理:灵活的 topic 路由和数据源配置

Closes #41
2026-06-15 03:39:35 +08:00
bot_dev1 d85783a68a feat: 实现 Issue #41 - 实时流数据采集(MQTT/Kafka Consumer)
## 功能特性
- 新增 MQTT 客户端支持,实现物联网遥测数据实时接收
- 完善 Kafka 消费者,支持多来源数据接入
- 添加数据验证和质量检查机制
- 新增数据统计和监控功能

## 主要改动
### MQTT 支持
- 新增 MQTT 配置类和连接工厂
- 实现 MQTT 消息接收和处理服务
- 添加 MQTT 控制命令发布功能
- 创建 MQTT 控制器 API

### 数据处理
- 完善 DataCollectService,支持 MQTT/Kafka 多源接入
- 添加数据验证工具类,确保数据质量
- 新增数据统计服务,提供多维度的数据统计

### 架构优化
- 规范指标类型枚举
- 添加数据质量评分机制
- 完善错误处理和日志记录

### 测试增强
- 新增 KafkaConsumerTest 测试类
- 完善现有测试覆盖
- 添加数据验证测试用例

## 技术细节
- 使用 Eclipse Paho MQTT 客户端
- 集成 Spring Integration MQTT
- 支持 TDengine 时序数据库写入
- 实现数据质量验证和范围检查

## 测试
- 完成基础功能实现
- 添加数据验证测试
- 验证 MQTT 和 Kafka 消费者正常工作
2026-06-15 01:39:53 +08:00
bot_dev1 1fa535b5ba feat: 实现 Issue #41 - 实时流数据采集(MQTT/Kafka Consumer)
## 功能特性
- 新增 MQTT 客户端支持,实现物联网遥测数据实时接收
- 完善 Kafka 消费者,支持多来源数据接入
- 添加数据验证和质量检查机制
- 新增数据统计和监控功能

## 主要改动
### MQTT 支持
- 新增 MQTT 配置类和连接工厂
- 实现 MQTT 消息接收和处理服务
- 添加 MQTT 控制命令发布功能
- 创建 MQTT 控制器 API

### 数据处理
- 完善 DataCollectService,支持 MQTT/Kafka 多源接入
- 添加数据验证工具类,确保数据质量
- 新增数据统计服务,提供多维度的数据统计

### 架构优化
- 规范指标类型枚举
- 添加数据质量评分机制
- 完善错误处理和日志记录

## 技术细节
- 使用 Eclipse Paho MQTT 客户端
- 集成 Spring Integration MQTT
- 支持 TDengine 时序数据库写入
- 实现数据质量验证和范围检查

## 测试
- 完成基础功能实现
- 添加数据验证测试
- 验证 MQTT 和 Kafka 消费者正常工作
2026-06-14 23:41:48 +08:00
bot_dev1 7c7179ff1f feat: 实现应急推演功能(爆管模拟+水质异常处置预案)
- 新增 EmergencySimulationService 应急推演核心服务
- 新增 EmergencyPlanService 应急预案管理服务
- 新增 EmergencyDispatchService 应急调度协调服务
- 新增相关 Controller 类提供 REST API
- 新增数据库表结构和初始化数据
- 新增测试脚本和使用指南
- 实现爆管模拟、水质异常处置、预案管理等核心功能

Addresses Issue #70

提交ID: 9f5af5db6e
2026-06-14 22:45:40 +08:00
bot_dev1 9f5af5db6e feat: 实现实时流数据采集功能
- 添加 IoT 数据实体类 (IotData.java)
- 实现 Kafka 消费者配置 (KafkaConfig.java)
- 添加 TDengine 数据库配置和服务
- 创建数据监听器和初始化器
- 实现 REST API 控制器
- 更新 Maven 依赖配置

🤖 Generated with [OpenClaw](https://github.com/X-Cloud-IDE/OpenClaw)
2026-06-14 21:40:11 +08:00
bot_dev1 c9abf94e57 [feat] 水表全生命周期管理功能
- 实现水表入库/安装/换表/报废的完整生命周期管理
- 添加详细的操作日志记录,支持操作人、时间戳、照片等
- 实现库存统计功能,按状态、口径、类型、制造商分类统计
- 添加 REST API 接口,支持水表操作和查询
- 创建 DTO 类用于数据传输
- 添加数据库升级脚本,支持新增字段和视图创建
- 插入测试数据验证功能完整性

功能包括:
1. 水表入库操作及日志记录
2. 水表安装操作,继承客户信息
3. 故障换表操作,自动完成新旧表状态转换
4. 水表报废操作,记录报废原因
5. 全生命周期日志查询
6. 库存统计分析
7. 水表详情查询
8. 最近操作记录查询

关闭 Issue #53: [表务] 水表全生命周期管理(入库/安装/换表/报废)
2026-06-14 20:47:27 +08:00
bot_dev1 6860aab376 feat: 实现 Issue #51 - 营业收费账单生成 + 多支付渠道收费功能
## 自动账单生成
- 实现按抄表周期的自动账单生成调度
- 集成阶梯水价计算(居民/商业/企业不同档次)
- 支持水费+污水处理费计算
- 添加账单状态管理(待缴费/部分缴费/已缴费/逾期)

## 多支付渠道支持
- 柜台支付(现金/刷卡)
- POS支付(柜台POS/移动POS)
- 支付宝支付(APP/网页/二维码)
- 微信支付(APP/小程序/网页/二维码)
- 银行转账(柜台转账/网上银行)

## 缴费记录管理
- 完整的支付流水记录
- 支付渠道状态监控
- 支付统计分析报表
- 欠费处理机制
- 对账功能支持

## 数据库增强
- 创建支付方式/渠道配置表
- 添加支付统计/流水表
- 完善账单生命周期管理
- 添加支付触发器
- 支持批量账单生成

## API接口
- RESTful支付接口
- 支持单笔/批量缴费
- 支付统计接口
- 账单管理接口
- 支付渠道管理接口

## 技术特性
- Spring Boot + JPA
- 定时任务调度
- 多线程处理
- 异步支付处理
- 完整的错误处理机制

解决 Issue #51: [营业收费] 账单生成 + 多支付渠道收费
2026-06-14 20:42:34 +08:00
bot_dev1 dbf0c94c0b feat: 实现抄表管理(人工+远传集成)+ 阶梯水价计算功能
- 新增抄表管理相关实体类: MeterInfo, MeterReadRecord, MeterReadTask, CustomerAccount
- 新增阶梯水价配置相关实体类: TariffLadderConfig, TariffLadderDetail, BillCycle, BillMain, BillDetail
- 实现抄表管理服务: MeterReadService 支持抄表记录CRUD、任务管理、远程抄表
- 实现阶梯水价计算服务: TariffService 支持阶梯水费计算、账单生成
- 创建抄表管理控制器: MeterReadController 提供 REST API
- 创建阶梯水价控制器: TariffController 提供费用计算和账单管理
- 添加数据库脚本: 抄表相关表、阶梯水价配置表、客户账户表、账单表
- 支持人工抄表、远程抄表、阶梯水价计算、账单生成等完整流程

🎯 解决Issue #50: [营业收费] 抄表管理(人工+远传集成)+ 阶梯水价计算
2026-06-14 20:17:35 +08:00
bot_dev1 56ce90f89d feat: 实现SSO单点登录+应用接入管理功能 (Issue #46)
- 新增OAuth2.0授权框架支持
- 实现SSO单点登录核心功能
- 添加第三方应用注册和管理
- 完整的权限控制和审计日志
- 支持多种OAuth2授权模式
- JWT Token认证和会话管理
- 数据库表结构和初始化脚本
- 单元测试覆盖
- 更新RevenueBaseService保持向后兼容

🎯 解决Issue #46: [营收] SSO 单点登录 + 应用接入管理
2026-06-14 17:17:11 +08:00
bot_dev1 af20c2aa09 feat: 实现客服工作台功能 (Issue #54)
- 添加 CustomerServiceController 后端 API
- 实现前端客服工作台界面
- 支持水费查询(户号/手机号)
- 集成 TTS 语音查询功能
- 添加数据库表结构和示例数据
- 更新路由配置

Resolves: #54
2026-06-14 16:20:11 +08:00
bot_dev1 6dcb535874 feat: [Issue#77] 实现巡检问题上报 + 工单联动功能
- 新增巡检问题上报表 (patrol_problem)
- 新增工单表 (work_order)
- 新增工单处理记录表 (work_order_process)
- 新增巡检问题与工单关联触发表 (patrol_work_order_trigger)
- 实现PatrolProblemService和WorkOrderService业务逻辑
- 实现RESTful API接口
- 开发前端问题上报和工单管理界面
- 添加JSON列表TypeHandler处理图片URL数组
- 更新数据库schema支持新功能

完成了issue要求的:
✅ 巡检中问题上报(类型/描述/拍照)
✅ 自动创建工单
✅ 处理跟踪
2026-06-14 16:05:51 +08:00
bot_dev1 ab01664e57 merge: 合并 feature/issue-72 到 feature/dev (阈值管理+信息发布+设备管理)
- 合并冲突解决: 保留 issue-72 的完善版本(支持 MyBatis-Plus、AND/OR 组合条件引擎、逻辑删除)
- 覆盖 feature/dev 中的早期简化版 AlertRule 相关代码
- 新增: 阈值管理 CRUD + 信息发布 + 设备管理功能
2026-06-14 16:02:50 +08:00
bot_dev1 db41268824 feat: 实现报警规则引擎和报警管理中心功能
- 新增 AlertRule 实体类,支持阈值配置和条件判断
- 新增 AlertManagement 实体类,实现报警生命周期管理
- 新增 AlertRuleMapper 和 AlertManagementMapper 接口
- 新增 AlertRuleService 和 AlertManagementService 业务逻辑
- 实现报警规则 CRUD 操作和验证
- 实现报警确认、解决、分派等管理功能
- 新增 AlertRuleController 和 AlertManagementController REST API
- 支持按参数、设备、区域查询报警规则
- 实现报警统计功能

Issue #67: [报警] 报警规则引擎 + 报警管理中心
2026-06-14 15:21:38 +08:00
bot_dev1 1d550c1bfb feat: [Issue#72] 实现阈值管理、信息发布、设备管理功能
- 阈值管理:支持报警阈值配置(最小值、最大值、警告值)
- 信息发布:支持预报/预警信息发布和管理
- 设备管理:支持按名称、类型、时间、位置查询设备
- 新增3个实体类:Threshold、Notification、Equipment
- 新增6个Service及其实现类
- 新增3个Controller及对应的VO类
- 新增数据库表结构和示例数据
2026-06-14 15:05:08 +08:00
bot_dev1 cfce03cf92 feat: 历史数据回溯与报表生成功能 - Issue #71
实现功能:
- 历史数据查询(水量、水质、报警记录)
- 按类型、时间、区域条件筛选
- 生成水量汇总报表
- 生成水质合格率报表
- 生成报警统计报表
- 支持数据导出

技术实现:
- MyBatis-Plus实现分页查询
- RESTful API接口
- Swagger文档支持
- PostgreSQL数据库支持
- 完整的实体、服务、控制器架构

文件变更:
- DataQueryService.java: 数据查询服务
- DataQueryController.java: REST API控制器
- 相关实体类和Mapper接口
- 数据库初始化脚本
- Swagger配置
- pom.xml依赖更新
2026-06-14 14:27:20 +08:00
bot_dev1 4c76db6756 实现大数据分析系统(BI-01至BI-06)
- 新增数据中心服务(ETL管道、多源汇聚)
- 新增数据分析平台(自助BI看板、多维分析)
- 新增数据可视化(运营仪表盘、专题大屏)
- 新增决策支持(供水调度决策、需水量预测)
- 新增报告生成(自动运营报告、分析报告)
- 新增数据监控(关键指标实时监控、异常预警)

🎯 完成Issue #3: 大数据分析系统 — BI决策支持平台
2026-06-14 13:45:25 +08:00