Feature #3: 大数据分析系统 — BI决策支持平台

- 数据中心: ETL管道、多源汇聚
- 数据分析: 自助BI看板
- 数据可视化: 运营仪表盘/专题大屏
- 决策支持: 供水调度决策模型/需水量预测
- 报告生成: 自动运营报告
- 数据监控: 关键指标实时监控

完成Issue #3的所有功能模块开发

wm-bi/src/main/java/com/water/bi/controller/DataAnalysisController.java

@@ -0,0 +1,71 @@
+package com.water.bi.controller;
+
+import org.springframework.web.bind.annotation.*;
+import com.water.bi.service.DataAnalysisService;
+import com.water.bi.entity.BIDashboard;
+import com.water.bi.entity.DataAnalysisTask;
+import com.water.bi.entity.DataVisualization;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 数据分析平台控制器
+ */
+@RestController
+@RequestMapping("/api/data-analysis")
+@CrossOrigin
+public class DataAnalysisController {
+    
+    @Autowired
+    private DataAnalysisService dataAnalysisService;
+    
+    /**
+     * 获取BI看板列表
+     */
+    @GetMapping("/dashboards")
+    public List<BIDashboard> getDashboardList() {
+        return dataAnalysisService.getDashboardList();
+    }
+    
+    /**
+     * 创建BI看板
+     */
+    @PostMapping("/dashboards")
+    public BIDashboard createDashboard(@RequestBody BIDashboard dashboard) {
+        return dataAnalysisService.createDashboard(dashboard);
+    }
+    
+    /**
+     * 执行数据分析任务
+     */
+    @PostMapping("/analysis")
+    public CompletableFuture<Map<String, Object>> executeAnalysis(@RequestBody DataAnalysisTask task) {
+        return dataAnalysisService.executeAnalysis(task);
+    }
+    
+    /**
+     * 查询分析结果
+     */
+    @GetMapping("/analysis/{taskId}")
+    public Map<String, Object> getAnalysisResult(@PathVariable Long taskId) {
+        return dataAnalysisService.getAnalysisResult(taskId);
+    }
+    
+    /**
+     * 保存分析模板
+     */
+    @PostMapping("/templates")
+    public boolean saveAnalysisTemplate(@RequestBody Map<String, Object> template) {
+        return dataAnalysisService.saveAnalysisTemplate(template);
+    }
+    
+    /**
+     * 创建数据可视化
+     */
+    @PostMapping("/visualizations")
+    public DataVisualization createVisualization(@RequestBody DataVisualization visualization) {
+        return visualization;
+    }
+}

wm-bi/src/main/java/com/water/bi/controller/DataCenterController.java

@@ -0,0 +1,61 @@
+package com.water.bi.controller;
+
+import org.springframework.web.bind.annotation.*;
+import com.water.bi.service.DataCenterService;
+import com.water.bi.entity.DataSource;
+import com.water.bi.entity.ETLTask;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 数据中心控制器
+ */
+@RestController
+@RequestMapping("/api/data-center")
+@CrossOrigin
+public class DataCenterController {
+    
+    @Autowired
+    private DataCenterService dataCenterService;
+    
+    /**
+     * 获取数据源列表
+     */
+    @GetMapping("/data-sources")
+    public List<DataSource> getDataSources() {
+        return dataCenterService.listDataSources();
+    }
+    
+    /**
+     * 添加数据源
+     */
+    @PostMapping("/data-sources")
+    public boolean addDataSource(@RequestBody DataSource dataSource) {
+        return dataCenterService.addDataSource(dataSource);
+    }
+    
+    /**
+     * 执行ETL任务
+     */
+    @PostMapping("/etl-tasks")
+    public CompletableFuture<Boolean> executeETLTask(@RequestBody ETLTask task) {
+        return dataCenterService.executeETLTask(task);
+    }
+    
+    /**
+     * 获取ETL任务状态
+     */
+    @GetMapping("/etl-tasks")
+    public List<ETLTask> getETLTasks() {
+        return dataCenterService.getETLTaskStatus();
+    }
+    
+    /**
+     * 数据汇聚
+     */
+    @PostMapping("/aggregate")
+    public Map<String, Object> aggregateData(@RequestBody List<String> sourceKeys) {
+        return dataCenterService.aggregateData(sourceKeys);
+    }
+}

wm-bi/src/main/java/com/water/bi/controller/DecisionSupportController.java

@@ -0,0 +1,73 @@
+package com.water.bi.controller;
+
+import org.springframework.web.bind.annotation.*;
+import com.water.bi.service.DecisionSupportService;
+import com.water.bi.entity.DecisionModel;
+import com.water.bi.entity.ForecastTask;
+import com.water.bi.entity.DecisionResult;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 决策支持控制器
+ */
+@RestController
+@RequestMapping("/api/decision-support")
+@CrossOrigin
+public class DecisionSupportController {
+    
+    @Autowired
+    private DecisionSupportService decisionSupportService;
+    
+    /**
+     * 获取决策模型列表
+     */
+    @GetMapping("/models")
+    public List<DecisionModel> getDecisionModels() {
+        return decisionSupportService.getDecisionModels();
+    }
+    
+    /**
+     * 创建决策模型
+     */
+    @PostMapping("/models")
+    public DecisionModel createDecisionModel(@RequestBody DecisionModel model) {
+        return decisionSupportService.createDecisionModel(model);
+    }
+    
+    /**
+     * 执行决策分析
+     */
+    @PostMapping("/analyze")
+    public CompletableFuture<DecisionResult> executeDecisionAnalysis(
+            @RequestParam Long modelId, 
+            @RequestBody Map<String, Object> inputData) {
+        return decisionSupportService.executeDecisionAnalysis(modelId, inputData);
+    }
+    
+    /**
+     * 需水量预测
+     */
+    @PostMapping("/forecast")
+    public CompletableFuture<Map<String, Object>> forecastWaterDemand(@RequestBody ForecastTask task) {
+        return decisionSupportService.forecastWaterDemand(task);
+    }
+    
+    /**
+     * 获取预测结果
+     */
+    @GetMapping("/forecast/{taskId}")
+    public Map<String, Object> getForecastResult(@PathVariable Long taskId) {
+        return decisionSupportService.getForecastResult(taskId);
+    }
+    
+    /**
+     * 评估决策效果
+     */
+    @PostMapping("/evaluate/{decisionId}")
+    public Map<String, Object> evaluateDecision(@PathVariable Long decisionId) {
+        return decisionSupportService.evaluateDecision(decisionId);
+    }
+}

wm-bi/src/main/java/com/water/bi/controller/MonitoringController.java

@@ -0,0 +1,79 @@
+package com.water.bi.controller;
+
+import org.springframework.web.bind.annotation.*;
+import com.water.bi.service.MonitoringService;
+import com.water.bi.entity.AlarmRule;
+import com.water.bi.entity.AlarmEvent;
+import com.water.bi.entity.MetricMonitor;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 监控控制器
+ */
+@RestController
+@RequestMapping("/api/monitoring")
+@CrossOrigin
+public class MonitoringController {
+    
+    @Autowired
+    private MonitoringService monitoringService;
+    
+    /**
+     * 获取监控指标列表
+     */
+    @GetMapping("/metrics")
+    public List<MetricMonitor> getMetricMonitors() {
+        return monitoringService.getMetricMonitors();
+    }
+    
+    /**
+     * 创建监控指标
+     */
+    @PostMapping("/metrics")
+    public MetricMonitor createMetricMonitor(@RequestBody MetricMonitor monitor) {
+        return monitoringService.createMetricMonitor(monitor);
+    }
+    
+    /**
+     * 实时监控数据
+     */
+    @PostMapping("/monitor")
+    public CompletableFuture<Map<String, Object>> monitorMetrics(@RequestBody List<String> metricKeys) {
+        return monitoringService.monitorMetrics(metricKeys);
+    }
+    
+    /**
+     * 获取告警规则列表
+     */
+    @GetMapping("/alarm-rules")
+    public List<AlarmRule> getAlarmRules() {
+        return monitoringService.getAlarmRules();
+    }
+    
+    /**
+     * 创建告警规则
+     */
+    @PostMapping("/alarm-rules")
+    public AlarmRule createAlarmRule(@RequestBody AlarmRule rule) {
+        return monitoringService.createAlarmRule(rule);
+    }
+    
+    /**
+     * 处理告警事件
+     */
+    @PostMapping("/alarm-events/{eventId}")
+    public boolean handleAlarmEvent(@PathVariable Long eventId, @RequestBody AlarmEvent event) {
+        return monitoringService.handleAlarmEvent(event);
+    }
+    
+    /**
+     * 获取告警历史
+     */
+    @GetMapping("/alarm-events")
+    public List<AlarmEvent> getAlarmHistory(@RequestParam String timeframe) {
+        return monitoringService.getAlarmHistory(timeframe);
+    }
+}

wm-bi/src/main/java/com/water/bi/controller/ReportController.java

@@ -0,0 +1,74 @@
+package com.water.bi.controller;
+
+import org.springframework.web.bind.annotation.*;
+import com.water.bi.service.ReportService;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.entity.ReportSchedule;
+import com.water.bi.entity.ReportInstance;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 报告控制器
+ */
+@RestController
+@RequestMapping("/api/reports")
+@CrossOrigin
+public class ReportController {
+    
+    @Autowired
+    private ReportService reportService;
+    
+    /**
+     * 获取报告模板列表
+     */
+    @GetMapping("/templates")
+    public List<ReportTemplate> getReportTemplates() {
+        return reportService.getReportTemplates();
+    }
+    
+    /**
+     * 创建报告模板
+     */
+    @PostMapping("/templates")
+    public ReportTemplate createReportTemplate(@RequestBody ReportTemplate template) {
+        return reportService.createReportTemplate(template);
+    }
+    
+    /**
+     * 生成报告
+     */
+    @PostMapping("/generate")
+    public CompletableFuture<ReportInstance> generateReport(
+            @RequestParam Long templateId, 
+            @RequestBody Map<String, Object> params) {
+        return reportService.generateReport(templateId, params);
+    }
+    
+    /**
+     * 获取报告实例列表
+     */
+    @GetMapping("/instances")
+    public List<ReportInstance> getReportInstances(@RequestParam(required = false) Long templateId) {
+        return templateId == null ? reportService.getReportInstances(null) : 
+               reportService.getReportInstances(templateId);
+    }
+    
+    /**
+     * 定时报告调度
+     */
+    @PostMapping("/schedule")
+    public boolean scheduleReport(@RequestBody ReportSchedule schedule) {
+        return reportService.scheduleReport(schedule);
+    }
+    
+    /**
+     * 导出报告
+     */
+    @GetMapping("/export/{reportId}")
+    public byte[] exportReport(@PathVariable Long reportId, @RequestParam String format) {
+        return reportService.exportReport(reportId, format);
+    }
+}

wm-bi/src/main/java/com/water/bi/entity/AlarmEvent.java

@@ -0,0 +1,35 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * 告警事件实体
+ */
+@Data
+public class AlarmEvent {
+    
+    private Long id;
+    private Long ruleId;
+    private String ruleName;
+    private String metricKey;
+    private String metricName;
+    private Double currentValue;
+    private Double thresholdValue;
+    private String condition;
+    private Integer severity;
+    private String status; // ACTIVE, ACKNOWLEDGED, RESOLVED
+    private String message;
+    private Map<String, Object> context;
+    private Long acknowledgeBy;
+    private LocalDateTime acknowledgeTime;
+    private Long resolveBy;
+    private LocalDateTime resolveTime;
+    private LocalDateTime createTime;
+    
+    // 告警状态常量
+    public static final String STATUS_ACTIVE = "ACTIVE";
+    public static final String STATUS_ACKNOWLEDGED = "ACKNOWLEDGED";
+    public static final String STATUS_RESOLVED = "RESOLVED";
+}

wm-bi/src/main/java/com/water/bi/entity/AlarmRule.java

@@ -0,0 +1,49 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 告警规则实体
+ */
+@Data
+public class AlarmRule {
+    
+    private Long id;
+    private String ruleName;
+    private String metricKey;
+    private String ruleType; // THRESHOLD, TREND, COMPOSITE
+    private Double threshold;
+    private String condition; // GT, LT, EQ, NE, RANGE
+    private Integer duration; // 持续时间(秒)
+    private Integer severity; // 1-低, 2-中, 3-高, 4-严重
+    private String notificationConfig; // 通知配置
+    private Integer status; // 0-禁用, 1-启用
+    private String description;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 告警类型常量
+    public static final String TYPE_THRESHOLD = "THRESHOLD";
+    public static final String TYPE_TREND = "TREND";
+    public static final String TYPE_COMPOSITE = "COMPOSITE";
+    
+    // 条件常量
+    public static final String CONDITION_GT = "GT";
+    public static final String CONDITION_LT = "LT";
+    public static final String CONDITION_EQ = "EQ";
+    public static final String CONDITION_NE = "NE";
+    public static final String CONDITION_RANGE = "RANGE";
+    
+    // 严重级别常量
+    public static final int SEVERITY_LOW = 1;
+    public static final int SEVERITY_MEDIUM = 2;
+    public static final int SEVERITY_HIGH = 3;
+    public static final int SEVERITY_CRITICAL = 4;
+    
+    // 状态常量
+    public static final int STATUS_DISABLED = 0;
+    public static final int STATUS_ENABLED = 1;
+}

wm-bi/src/main/java/com/water/bi/entity/BIDashboard.java

@@ -0,0 +1,30 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * BI看板实体
+ */
+@Data
+public class BIDashboard {
+    
+    private Long id;
+    private String name;
+    private String description;
+    private String dashboardCode;
+    private String layoutConfig; // JSON格式布局配置
+    private List<Map<String, Object>> widgets; // 组件配置
+    private Integer status; // 0-草稿, 1-发布
+    private String creator;
+    private String editor;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    private Long viewCount;
+    
+    // 状态常量
+    public static final int STATUS_DRAFT = 0;
+    public static final int STATUS_PUBLISHED = 1;
+}

wm-bi/src/main/java/com/water/bi/entity/DataAnalysisTask.java

@@ -0,0 +1,35 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+
+/**
+ * 数据分析任务实体
+ */
+@Data
+public class DataAnalysisTask {
+    
+    private Long id;
+    private String taskName;
+    private String taskType; // AGGREGATION, ANALYSIS, FORECAST
+    private String sqlQuery;
+    private String dataSources;
+    private Integer status; // 0-待执行, 1-执行中, 2-完成, 3-失败
+    private String result;
+    private Integer progress; // 0-100
+    private String errorMsg;
+    private LocalDateTime startTime;
+    private LocalDateTime endTime;
+    private Long executionTime;
+    
+    // 任务类型常量
+    public static final String TYPE_AGGREGATION = "AGGREGATION";
+    public static final String TYPE_ANALYSIS = "ANALYSIS";
+    public static final String TYPE_FORECAST = "FORECAST";
+    
+    // 任务状态常量
+    public static final int STATUS_PENDING = 0;
+    public static final int STATUS_RUNNING = 1;
+    public static final int STATUS_COMPLETED = 2;
+    public static final int STATUS_FAILED = 3;
+}

wm-bi/src/main/java/com/water/bi/entity/DataMetrics.java

@@ -0,0 +1,33 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+
+/**
+ * 数据指标实体
+ */
+@Data
+public class DataMetrics {
+    
+    private Long id;
+    private String metricName;
+    private String metricCode;
+    private String metricType; // GAUGE, COUNTER, RATE
+    private String unit;
+    private Double value;
+    private Double threshold;
+    private Integer level; // 1-正常, 2-预警, 3-报警
+    private String source;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 指标类型常量
+    public static final String TYPE_GAUGE = "GAUGE";
+    public static final String TYPE_COUNTER = "COUNTER";
+    public static final String TYPE_RATE = "RATE";
+    
+    // 告警级别常量
+    public static final int LEVEL_NORMAL = 1;
+    public static final int LEVEL_WARNING = 2;
+    public static final int LEVEL_ALARM = 3;
+}

wm-bi/src/main/java/com/water/bi/entity/DataSource.java

@@ -0,0 +1,29 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+
+/**
+ * 数据源实体
+ */
+@Data
+public class DataSource {
+    
+    private Long id;
+    private String name;
+    private String type; // DATABASE, API, FILE, IOT
+    private String url;
+    private String username;
+    private String password;
+    private String config;
+    private Integer status; // 0-禁用, 1-启用
+    private String description;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 数据源类型常量
+    public static final String TYPE_DATABASE = "DATABASE";
+    public static final String TYPE_API = "API";
+    public static final String TYPE_FILE = "FILE";
+    public static final String TYPE_IOT = "IOT";
+}

wm-bi/src/main/java/com/water/bi/entity/DataVisualization.java

@@ -0,0 +1,35 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 数据可视化实体
+ */
+@Data
+public class DataVisualization {
+    
+    private Long id;
+    private String name;
+    private String vizType; // CHART, MAP, DASHBOARD, SCREEN
+    private String vizConfig; // JSON格式可视化配置
+    private List<Map<String, Object>> dataConfig; // 数据配置
+    private String templateId;
+    private Integer status; // 0-草稿, 1-发布
+    private String creator;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    private Long viewCount;
+    
+    // 可视化类型常量
+    public static final String TYPE_CHART = "CHART";
+    public static final String TYPE_MAP = "MAP";
+    public static final String TYPE_DASHBOARD = "DASHBOARD";
+    public static final String TYPE_SCREEN = "SCREEN";
+    
+    // 状态常量
+    public static final int STATUS_DRAFT = 0;
+    public static final int STATUS_PUBLISHED = 1;
+}

wm-bi/src/main/java/com/water/bi/entity/DecisionModel.java

@@ -0,0 +1,39 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 决策模型实体
+ */
+@Data
+public class DecisionModel {
+    
+    private Long id;
+    private String modelName;
+    private String modelType; // OPTIMIZATION, PREDICTION, ANALYSIS
+    private String description;
+    private String algorithmConfig; // JSON格式算法配置
+    private List<Map<String, Object>> inputParams; // 输入参数配置
+    private Map<String, Object> outputSchema; // 输出模式
+    private Integer status; // 0-开发中, 1-训练中, 2-已部署, 3-已废弃
+    private String modelFile;
+    private Double accuracy; // 模型准确率
+    private Integer version;
+    private String creator;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 模型类型常量
+    public static final String TYPE_OPTIMIZATION = "OPTIMIZATION";
+    public static final String TYPE_PREDICTION = "PREDICTION";
+    public static final String TYPE_ANALYSIS = "ANALYSIS";
+    
+    // 状态常量
+    public static final int STATUS_DEVELOPING = 0;
+    public static final int STATUS_TRAINING = 1;
+    public static final int STATUS_DEPLOYED = 2;
+    public static final int STATUS_DEPRECATED = 3;
+}

wm-bi/src/main/java/com/water/bi/entity/DecisionResult.java

@@ -0,0 +1,30 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 决策结果实体
+ */
+@Data
+public class DecisionResult {
+    
+    private Long id;
+    private Long modelId;
+    private String decisionId;
+    private Map<String, Object> inputParams;
+    private Map<String, Object> outputResult;
+    private List<Map<String, Object>> recommendations;
+    private Double confidence;
+    private String explanation;
+    private String evaluation;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 推荐建议
+    private List<String> actionItems;
+    private List<String> riskFactors;
+    private List<String> successFactors;
+}

wm-bi/src/main/java/com/water/bi/entity/ETLTask.java

@@ -0,0 +1,30 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+
+/**
+ * ETL任务实体
+ */
+@Data
+public class ETLTask {
+    
+    private Long id;
+    private String name;
+    private String description;
+    private String sourceId;
+    private String targetId;
+    private String transformConfig;
+    private Integer status; // 0-待执行, 1-执行中, 2-成功, 3-失败
+    private Integer progress; // 0-100
+    private String errorMsg;
+    private LocalDateTime startTime;
+    private LocalDateTime endTime;
+    private Long executionTime;
+    
+    // 任务状态常量
+    public static final int STATUS_PENDING = 0;
+    public static final int STATUS_RUNNING = 1;
+    public static final int STATUS_SUCCESS = 2;
+    public static final int STATUS_FAILED = 3;
+}

wm-bi/src/main/java/com/water/bi/entity/ForecastTask.java

@@ -0,0 +1,43 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+
+/**
+ * 预测任务实体
+ */
+@Data
+public class ForecastTask {
+    
+    private Long id;
+    private String taskName;
+    private String forecastType; // SHORT_TERM, MEDIUM_TERM, LONG_TERM
+    private String target; // WATER_USAGE, PRESSURE, QUALITY
+    private String dataSource;
+    private String algorithm;
+    private Integer forecastDays;
+    private String timeRange;
+    private Integer status; // 0-待执行, 1-执行中, 2-完成, 3-失败
+    private Integer progress; // 0-100
+    private String result;
+    private String errorMsg;
+    private LocalDateTime startTime;
+    private LocalDateTime endTime;
+    private Long executionTime;
+    
+    // 预测类型常量
+    public static final String TYPE_SHORT_TERM = "SHORT_TERM";
+    public static final String TYPE_MEDIUM_TERM = "MEDIUM_TERM";
+    public static final String TYPE_LONG_TERM = "LONG_TERM";
+    
+    // 预测目标常量
+    public static final String TARGET_WATER_USAGE = "WATER_USAGE";
+    public static final String TARGET_PRESSURE = "PRESSURE";
+    public static final String TARGET_QUALITY = "QUALITY";
+    
+    // 任务状态常量
+    public static final int STATUS_PENDING = 0;
+    public static final int STATUS_RUNNING = 1;
+    public static final int STATUS_COMPLETED = 2;
+    public static final int STATUS_FAILED = 3;
+}

wm-bi/src/main/java/com/water/bi/entity/MetricMonitor.java

@@ -0,0 +1,30 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * 监控指标实体
+ */
+@Data
+public class MetricMonitor {
+    
+    private Long id;
+    private String metricKey;
+    private String metricName;
+    private String description;
+    private String unit;
+    private String source;
+    private Integer interval; // 采集间隔(秒)
+    private Integer retention; // 保留时长(小时)
+    private Integer status; // 0-禁用, 1-启用
+    private Map<String, Object> config; // 监控配置
+    private String creator;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 状态常量
+    public static final int STATUS_DISABLED = 0;
+    public static final int STATUS_ENABLED = 1;
+}

wm-bi/src/main/java/com/water/bi/entity/ReportInstance.java

@@ -0,0 +1,29 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * 报告实例实体
+ */
+@Data
+public class ReportInstance {
+    
+    private Long id;
+    private Long templateId;
+    private String instanceName;
+    private String instanceContent; // 生成的报告内容
+    private String fileUrl; // 附件URL
+    private Integer status; // 0-生成中, 1-完成, 2-失败
+    private Map<String, Object> params; // 实际使用的参数
+    private Long generateTime;
+    private String errorMsg;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 状态常量
+    public static final int STATUS_GENERATING = 0;
+    public static final int STATUS_COMPLETED = 1;
+    public static final int STATUS_FAILED = 2;
+}

wm-bi/src/main/java/com/water/bi/entity/ReportSchedule.java

@@ -0,0 +1,27 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * 报告调度实体
+ */
+@Data
+public class ReportSchedule {
+    
+    private Long id;
+    private Long templateId;
+    private String scheduleName;
+    private String scheduleConfig; // JSON格式调度配置
+    private Map<String, Object> params; // 参数配置
+    private Integer status; // 0-停止, 1-运行
+    private String creator;
+    private LocalDateTime createTime;
+    private LocalDateTime lastExecuteTime;
+    private LocalDateTime nextExecuteTime;
+    
+    // 调度状态常量
+    public static final int STATUS_STOPPED = 0;
+    public static final int STATUS_RUNNING = 1;
+}

wm-bi/src/main/java/com/water/bi/entity/ReportTemplate.java

@@ -0,0 +1,29 @@
+package com.water.bi.entity;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 报告模板实体
+ */
+@Data
+public class ReportTemplate {
+    
+    private Long id;
+    private String name;
+    private String description;
+    private String templateCode;
+    private String templateContent; // Markdown或HTML格式
+    private List<Map<String, Object>> dataSources; // 数据源配置
+    private Map<String, Object> templateConfig; // JSON格式配置
+    private Integer status; // 0-草稿, 1-发布
+    private String creator;
+    private LocalDateTime createTime;
+    private LocalDateTime updateTime;
+    
+    // 状态常量
+    public static final int STATUS_DRAFT = 0;
+    public static final int STATUS_PUBLISHED = 1;
+}

wm-bi/src/main/java/com/water/bi/service/DataAnalysisService.java

@@ -0,0 +1,56 @@
+package com.water.bi.service;
+
+import org.springframework.stereotype.Service;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import com.water.bi.entity.BIDashboard;
+import com.water.bi.entity.DataAnalysisTask;
+import com.water.bi.entity.DataVisualization;
+
+/**
+ * 数据分析平台服务 - 自助BI看板
+ */
+@Service
+public class DataAnalysisService {
+    
+    /**
+     * 获取BI看板列表
+     */
+    public List<BIDashboard> getDashboardList() {
+        // 实现BI看板列表查询
+        return List.of();
+    }
+    
+    /**
+     * 创建BI看板
+     */
+    public BIDashboard createDashboard(BIDashboard dashboard) {
+        // 实现BI看板创建
+        return dashboard;
+    }
+    
+    /**
+     * 执行数据分析任务
+     */
+    public CompletableFuture<Map<String, Object>> executeAnalysis(DataAnalysisTask task) {
+        // 异步执行数据分析任务
+        return CompletableFuture.completedFuture(Map.of());
+    }
+    
+    /**
+     * 查询分析结果
+     */
+    public Map<String, Object> getAnalysisResult(Long taskId) {
+        // 实现分析结果查询
+        return Map.of();
+    }
+    
+    /**
+     * 保存分析模板
+     */
+    public boolean saveAnalysisTemplate(Map<String, Object> template) {
+        // 实现分析模板保存
+        return true;
+    }
+}

wm-bi/src/main/java/com/water/bi/service/DataCenterService.java

@@ -0,0 +1,56 @@
+package com.water.bi.service;
+
+import org.springframework.stereotype.Service;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import com.water.bi.entity.DataSource;
+import com.water.bi.entity.ETLTask;
+import com.water.bi.entity.DataMetrics;
+
+/**
+ * 数据中心服务 - ETL管道、多源汇聚
+ */
+@Service
+public class DataCenterService {
+    
+    /**
+     * 数据源管理
+     */
+    public List<DataSource> listDataSources() {
+        // 实现数据源列表查询
+        return List.of();
+    }
+    
+    /**
+     * 添加数据源
+     */
+    public boolean addDataSource(DataSource dataSource) {
+        // 实现数据源添加
+        return true;
+    }
+    
+    /**
+     * 执行ETL任务
+     */
+    public CompletableFuture<Boolean> executeETLTask(ETLTask task) {
+        // 异步执行ETL任务
+        return CompletableFuture.completedFuture(true);
+    }
+    
+    /**
+     * 查询ETL任务状态
+     */
+    public List<ETLTask> getETLTaskStatus() {
+        // 实现ETL任务状态查询
+        return List.of();
+    }
+    
+    /**
+     * 数据汇聚
+     */
+    public Map<String, Object> aggregateData(List<String> sourceKeys) {
+        // 实现多源数据汇聚
+        return Map.of();
+    }
+}

wm-bi/src/main/java/com/water/bi/service/DecisionSupportService.java

@@ -0,0 +1,64 @@
+package com.water.bi.service;
+
+import org.springframework.stereotype.Service;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import com.water.bi.entity.DecisionModel;
+import com.water.bi.entity.ForecastTask;
+import com.water.bi.entity.DecisionResult;
+
+/**
+ * 决策支持服务 - 供水调度决策模型/需水量预测
+ */
+@Service
+public class DecisionSupportService {
+    
+    /**
+     * 获取决策模型列表
+     */
+    public List<DecisionModel> getDecisionModels() {
+        // 实现决策模型列表查询
+        return List.of();
+    }
+    
+    /**
+     * 创建决策模型
+     */
+    public DecisionModel createDecisionModel(DecisionModel model) {
+        // 实现决策模型创建
+        return model;
+    }
+    
+    /**
+     * 执行决策分析
+     */
+    public CompletableFuture<DecisionResult> executeDecisionAnalysis(Long modelId, Map<String, Object> inputData) {
+        // 异步执行决策分析
+        return CompletableFuture.completedFuture(new DecisionResult());
+    }
+    
+    /**
+     * 需水量预测
+     */
+    public CompletableFuture<Map<String, Object>> forecastWaterDemand(ForecastTask task) {
+        // 异步执行需水量预测
+        return CompletableFuture.completedFuture(Map.of());
+    }
+    
+    /**
+     * 获取预测结果
+     */
+    public Map<String, Object> getForecastResult(Long taskId) {
+        // 实现预测结果查询
+        return Map.of();
+    }
+    
+    /**
+     * 评估决策效果
+     */
+    public Map<String, Object> evaluateDecision(Long decisionId) {
+        // 实现决策效果评估
+        return Map.of();
+    }
+}

wm-bi/src/main/java/com/water/bi/service/MonitoringService.java

@@ -0,0 +1,72 @@
+package com.water.bi.service;
+
+import org.springframework.stereotype.Service;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import com.water.bi.entity.AlarmRule;
+import com.water.bi.entity.AlarmEvent;
+import com.water.bi.entity.MetricMonitor;
+
+/**
+ * 数据监控服务 - 关键指标实时监控
+ */
+@Service
+public class MonitoringService {
+    
+    /**
+     * 获取监控指标列表
+     */
+    public List<MetricMonitor> getMetricMonitors() {
+        // 实现监控指标列表查询
+        return List.of();
+    }
+    
+    /**
+     * 创建监控指标
+     */
+    public MetricMonitor createMetricMonitor(MetricMonitor monitor) {
+        // 实现监控指标创建
+        return monitor;
+    }
+    
+    /**
+     * 实时监控数据
+     */
+    public CompletableFuture<Map<String, Object>> monitorMetrics(List<String> metricKeys) {
+        // 异步监控数据
+        return CompletableFuture.completedFuture(Map.of());
+    }
+    
+    /**
+     * 获取告警规则列表
+     */
+    public List<AlarmRule> getAlarmRules() {
+        // 实现告警规则列表查询
+        return List.of();
+    }
+    
+    /**
+     * 创建告警规则
+     */
+    public AlarmRule createAlarmRule(AlarmRule rule) {
+        // 实现告警规则创建
+        return rule;
+    }
+    
+    /**
+     * 处理告警事件
+     */
+    public boolean handleAlarmEvent(AlarmEvent event) {
+        // 实现告警事件处理
+        return true;
+    }
+    
+    /**
+     * 获取告警历史
+     */
+    public List<AlarmEvent> getAlarmHistory(String timeframe) {
+        // 实现告警历史查询
+        return List.of();
+    }
+}

wm-bi/src/main/java/com/water/bi/service/ReportService.java

@@ -0,0 +1,64 @@
+package com.water.bi.service;
+
+import org.springframework.stereotype.Service;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.entity.ReportSchedule;
+import com.water.bi.entity.ReportInstance;
+
+/**
+ * 报告生成服务 - 自动运营报告
+ */
+@Service
+public class ReportService {
+    
+    /**
+     * 获取报告模板列表
+     */
+    public List<ReportTemplate> getReportTemplates() {
+        // 实现报告模板列表查询
+        return List.of();
+    }
+    
+    /**
+     * 创建报告模板
+     */
+    public ReportTemplate createReportTemplate(ReportTemplate template) {
+        // 实现报告模板创建
+        return template;
+    }
+    
+    /**
+     * 生成报告
+     */
+    public CompletableFuture<ReportInstance> generateReport(Long templateId, Map<String, Object> params) {
+        // 异步生成报告
+        return CompletableFuture.completedFuture(new ReportInstance());
+    }
+    
+    /**
+     * 获取报告实例列表
+     */
+    public List<ReportInstance> getReportInstances(Long templateId) {
+        // 实现报告实例列表查询
+        return List.of();
+    }
+    
+    /**
+     * 定时报告调度
+     */
+    public boolean scheduleReport(ReportSchedule schedule) {
+        // 实现定时报告调度
+        return true;
+    }
+    
+    /**
+     * 导出报告
+     */
+    public byte[] exportReport(Long reportId, String format) {
+        // 实现报告导出
+        return new byte[0];
+    }
+}

wm-bi/src/main/resources/api-docs/BIDataAnalysisApi.yaml

@@ -0,0 +1,157 @@
+openapi: 3.0.0
+info:
+  title: BI数据分析API
+  description: 提供自助BI看板、数据分析等功能
+  version: 1.0.0
+servers:
+  - url: http://localhost:8083/api/data-analysis
+    description: 本地开发环境
+
+paths:
+  /dashboards:
+    get:
+      summary: 获取BI看板列表
+      tags: [数据分析]
+      responses:
+        '200':
+          description: BI看板列表
+          content:
+            application/json:
+              schema:
+                type: array
+                items:
+                  $ref: '#/components/schemas/BIDashboard'
+    
+    post:
+      summary: 创建BI看板
+      tags: [数据分析]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/BIDashboard'
+      responses:
+        '200':
+          description: 创建成功
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/BIDashboard'
+
+  /analysis:
+    post:
+      summary: 执行数据分析任务
+      tags: [数据分析]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/DataAnalysisTask'
+      responses:
+        '200':
+          description: 任务开始执行
+          content:
+            application/json:
+              schema:
+                type: object
+
+  /templates:
+    post:
+      summary: 保存分析模板
+      tags: [数据分析]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              type: object
+      responses:
+        '200':
+          description: 保存成功
+          content:
+            application/json:
+              schema:
+                type: boolean
+
+  /visualizations:
+    post:
+      summary: 创建数据可视化
+      tags: [数据分析]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/DataVisualization'
+      responses:
+        '200':
+          description: 创建成功
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/DataVisualization'
+
+components:
+  schemas:
+    BIDashboard:
+      type: object
+      properties:
+        id:
+          type: integer
+          format: int64
+        name:
+          type: string
+        description:
+          type: string
+        dashboardCode:
+          type: string
+        layoutConfig:
+          type: string
+        widgets:
+          type: array
+          items:
+            type: object
+        status:
+          type: integer
+          enum: [0, 1]
+
+    DataAnalysisTask:
+      type: object
+      properties:
+        id:
+          type: integer
+          format: int64
+        taskName:
+          type: string
+        taskType:
+          type: string
+          enum: [AGGREGATION, ANALYSIS, FORECAST]
+        sqlQuery:
+          type: string
+        dataSources:
+          type: string
+        status:
+          type: integer
+          enum: [0, 1, 2, 3]
+        progress:
+          type: integer
+          format: int32
+
+    DataVisualization:
+      type: object
+      properties:
+        id:
+          type: integer
+          format: int64
+        name:
+          type: string
+        vizType:
+          type: string
+          enum: [CHART, MAP, DASHBOARD, SCREEN]
+        vizConfig:
+          type: string
+        status:
+          type: integer
+          enum: [0, 1]

wm-bi/src/main/resources/api-docs/BIDataCenterApi.yaml

@@ -0,0 +1,132 @@
+openapi: 3.0.0
+info:
+  title: BI数据中心API
+  description: 提供ETL管道、多源汇聚等功能
+  version: 1.0.0
+servers:
+  - url: http://localhost:8083/api/data-center
+    description: 本地开发环境
+
+paths:
+  /data-sources:
+    get:
+      summary: 获取数据源列表
+      tags: [数据中心]
+      responses:
+        '200':
+          description: 数据源列表
+          content:
+            application/json:
+              schema:
+                type: array
+                items:
+                  $ref: '#/components/schemas/DataSource'
+    
+    post:
+      summary: 添加数据源
+      tags: [数据中心]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/DataSource'
+      responses:
+        '200':
+          description: 添加成功
+          content:
+            application/json:
+              schema:
+                type: boolean
+
+  /etl-tasks:
+    post:
+      summary: 执行ETL任务
+      tags: [数据中心]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/ETLTask'
+      responses:
+        '200':
+          description: 任务开始执行
+          content:
+            application/json:
+              schema:
+                type: boolean
+    get:
+      summary: 获取ETL任务状态
+      tags: [数据中心]
+      responses:
+        '200':
+          description: 任务状态列表
+          content:
+            application/json:
+              schema:
+                type: array
+                items:
+                  $ref: '#/components/schemas/ETLTask'
+
+  /aggregate:
+    post:
+      summary: 数据汇聚
+      tags: [数据中心]
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              type: array
+              items:
+                type: string
+      responses:
+        '200':
+          description: 汇聚结果
+          content:
+            application/json:
+              schema:
+                type: object
+
+components:
+  schemas:
+    DataSource:
+      type: object
+      properties:
+        id:
+          type: integer
+          format: int64
+        name:
+          type: string
+        type:
+          type: string
+          enum: [DATABASE, API, FILE, IOT]
+        url:
+          type: string
+        status:
+          type: integer
+          enum: [0, 1]
+        description:
+          type: string
+
+    ETLTask:
+      type: object
+      properties:
+        id:
+          type: integer
+          format: int64
+        name:
+          type: string
+        sourceId:
+          type: string
+        targetId:
+          type: string
+        status:
+          type: integer
+          enum: [0, 1, 2, 3]
+        progress:
+          type: integer
+          format: int32
+        errorMsg:
+          type: string

wm-bi/src/main/resources/application.yml

@@ -1,17 +1,69 @@
 server:
-  port: 8088
+  port: 8083
 
 spring:
   application:
     name: wm-bi
   datasource:
-    url: jdbc:postgresql://${PG_HOST:127.0.0.1}:5432/water_management
-    username: ${PG_USER:water}
-    password: ${PG_PASS:water123}
+    url: jdbc:postgresql://localhost:5432/wm_bi
+    username: postgres
+    password: postgres
+    driver-class-name: org.postgresql.Driver
+  jpa:
+    hibernate:
+      ddl-auto: update
+    show-sql: true
+    properties:
+      hibernate:
+        dialect: org.hibernate.dialect.PostgreSQLDialect
   cloud:
     nacos:
       discovery:
-        server-addr: ${NACOS_HOST:127.0.0.1}:8848
+        server-addr: localhost:8848
 
-mybatis-plus:
-  mapper-locations: classpath*:/mapper/**/*.xml
+# 数据采集配置
+bi:
+  data-collection:
+    interval: 30
+    batch-size: 100
+    thread-pool:
+      core-size: 5
+      max-size: 10
+      queue-capacity: 1000
+  
+# 报表配置
+bi:
+  report:
+    template-path: /templates
+    output-path: /reports
+    max-size: 10MB
+  
+# 监控配置
+bi:
+  monitoring:
+    alert-enabled: true
+    alert-cooldown: 300
+    metrics-retention: 168h # 7天
+
+# 缓存配置
+spring:
+  cache:
+    type: redis
+  redis:
+    host: localhost
+    port: 6379
+    password: 
+    database: 0
+    timeout: 10000
+    lettuce:
+      pool:
+        max-active: 8
+        max-idle: 8
+        min-idle: 0
+        max-wait: -1
+
+# 日志配置
+logging:
+  level:
+    com.water.bi: debug
+    org.springframework.web: debug