feat(wm-bi+frontend): #40 自动运营报告生成完整实现

- 后端: ReportTemplate/GeneratedReport 实体+CRUD+分页
- 服务: ReportTemplateService(模板管理/变量解析/渲染引擎)
- 服务: ReportGeneratorService(数据采集聚合/HTML生成/推送调度)
- 定时: ReportScheduler(日报08:00/周报周一/月报1号)
- 推送: 邮件(SimpleMailMessage) + 企微webhook(HTTP POST)
- 前端: ReportTemplateView.vue(模板管理+预览)
- 前端: GeneratedReportView.vue(报告列表+详情+推送记录)
- SQL: V_bi_report.sql + 3套默认模板
- 测试: ReportTemplateServiceTest + ReportGeneratorServiceTest
- 路由: /bi/template + /bi/report

frontend/src/api/reportApi.ts

@@ -0,0 +1,80 @@
+import request from './request'
+
+// ==================== 报告模板 API ====================
+
+/** 分页查询模板 */
+export function getReportTemplates(params: {
+  pageNum?: number; pageSize?: number; reportType?: string; status?: string
+}) {
+  return request.get('/bi/report-template/page', { params })
+}
+
+/** 获取模板详情 */
+export function getReportTemplate(id: number) {
+  return request.get(`/bi/report-template/${id}`)
+}
+
+/** 创建模板 */
+export function createReportTemplate(data: any) {
+  return request.post('/bi/report-template', data)
+}
+
+/** 更新模板 */
+export function updateReportTemplate(id: number, data: any) {
+  return request.put(`/bi/report-template/${id}`, data)
+}
+
+/** 删除模板 */
+export function deleteReportTemplate(id: number) {
+  return request.delete(`/bi/report-template/${id}`)
+}
+
+/** 启用/停用模板 */
+export function toggleTemplateStatus(id: number, status: string) {
+  return request.patch(`/bi/report-template/${id}/status`, null, { params: { status } })
+}
+
+/** 复制模板 */
+export function copyReportTemplate(id: number) {
+  return request.post(`/bi/report-template/${id}/copy`)
+}
+
+/** 预览模板变量 */
+export function previewTemplate(id: number) {
+  return request.get(`/bi/report-template/${id}/preview`)
+}
+
+// ==================== 生成报告 API ====================
+
+/** 分页查询报告 */
+export function getGeneratedReports(params: {
+  pageNum?: number; pageSize?: number; reportType?: string;
+  pushStatus?: string; startTime?: string; endTime?: string
+}) {
+  return request.get('/bi/report/page', { params })
+}
+
+/** 获取报告详情 */
+export function getGeneratedReport(id: number) {
+  return request.get(`/bi/report/${id}`)
+}
+
+/** 删除报告 */
+export function deleteGeneratedReport(id: number) {
+  return request.delete(`/bi/report/${id}`)
+}
+
+/** 重新生成报告 */
+export function regenerateReport(id: number) {
+  return request.post(`/bi/report/${id}/regenerate`)
+}
+
+/** 手动推送报告 */
+export function manualPushReport(id: number) {
+  return request.post(`/bi/report/${id}/push`)
+}
+
+/** 手动触发生成报告 */
+export function generateReport(reportType: string) {
+  return request.post('/bi/report/generate', null, { params: { reportType } })
+}

frontend/src/router/index.ts

@@ -16,6 +16,8 @@ const routes = [
       { path: 'cs/knowledge', name: 'csKnowledge', component: () => import('@/views/cs/KnowledgeBaseView.vue') },
       { path: 'cs/announcement', name: 'csAnnouncement', component: () => import('@/views/cs/AnnouncementView.vue') },
       { path: 'cs/kpi', name: 'csKpi', component: () => import('@/views/cs/KpiDashboardView.vue') },
+      { path: 'bi/template', name: 'biTemplate', component: () => import('@/views/bi/ReportTemplateView.vue') },
+      { path: 'bi/report', name: 'biReport', component: () => import('@/views/bi/GeneratedReportView.vue') },
     ]
   },
   { path: '/:pathMatch(.*)*', redirect: '/dashboard' }

frontend/src/views/bi/GeneratedReportView.vue

@@ -0,0 +1,263 @@
+<template>
+  <div class="generated-report-mgmt">
+    <!-- 搜索区 -->
+    <el-card shadow="never">
+      <el-form :inline="true" :model="filterForm">
+        <el-form-item label="报告类型">
+          <el-select v-model="filterForm.reportType" placeholder="全部" clearable @change="handleSearch">
+            <el-option label="日报" value="daily" />
+            <el-option label="周报" value="weekly" />
+            <el-option label="月报" value="monthly" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="推送状态">
+          <el-select v-model="filterForm.pushStatus" placeholder="全部" clearable @change="handleSearch">
+            <el-option label="待推送" value="pending" />
+            <el-option label="推送中" value="pushing" />
+            <el-option label="成功" value="success" />
+            <el-option label="部分失败" value="partial_fail" />
+            <el-option label="失败" value="fail" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="生成时间">
+          <el-date-picker v-model="timeRange" type="daterange"
+            range-separator="至" start-placeholder="开始日期" end-placeholder="结束日期"
+            value-format="YYYY-MM-DD HH:mm:ss" @change="handleTimeChange" />
+        </el-form-item>
+        <el-form-item>
+          <el-button type="primary" @click="handleSearch"><el-icon><Search /></el-icon> 查询</el-button>
+          <el-button @click="handleReset">重置</el-button>
+        </el-form-item>
+      </el-form>
+    </el-card>
+
+    <!-- 操作栏 -->
+    <div style="margin-top: 16px">
+      <el-dropdown @command="handleGenerate" style="margin-right: 12px">
+        <el-button type="primary">
+          <el-icon><Plus /></el-icon> 手动生成 <el-icon class="el-icon--right"><ArrowDown /></el-icon>
+        </el-button>
+        <template #dropdown>
+          <el-dropdown-menu>
+            <el-dropdown-item command="daily">生成日报</el-dropdown-item>
+            <el-dropdown-item command="weekly">生成周报</el-dropdown-item>
+            <el-dropdown-item command="monthly">生成月报</el-dropdown-item>
+          </el-dropdown-menu>
+        </template>
+      </el-dropdown>
+    </div>
+
+    <!-- 列表 -->
+    <el-table :data="tableData" border style="margin-top: 12px" v-loading="loading">
+      <el-table-column prop="id" label="ID" width="70" />
+      <el-table-column prop="reportTitle" label="报告标题" min-width="280" show-overflow-tooltip />
+      <el-table-column prop="reportType" label="类型" width="90">
+        <template #default="{ row }">
+          <el-tag :type="typeTag(row.reportType)" size="small">{{ typeLabel(row.reportType) }}</el-tag>
+        </template>
+      </el-table-column>
+      <el-table-column prop="pushStatus" label="推送状态" width="110">
+        <template #default="{ row }">
+          <el-tag :type="pushStatusTag(row.pushStatus)" size="small">{{ pushStatusLabel(row.pushStatus) }}</el-tag>
+        </template>
+      </el-table-column>
+      <el-table-column prop="generatedAt" label="生成时间" width="170" />
+      <el-table-column prop="periodStart" label="报告周期" width="200">
+        <template #default="{ row }">
+          <span style="font-size: 12px">{{ formatPeriod(row) }}</span>
+        </template>
+      </el-table-column>
+      <el-table-column label="操作" width="280" fixed="right">
+        <template #default="{ row }">
+          <el-button link type="primary" @click="viewDetail(row)">查看</el-button>
+          <el-button link type="warning" @click="handleRegenerate(row)">重新生成</el-button>
+          <el-button link type="success" @click="handlePush(row)">推送</el-button>
+          <el-button link type="info" @click="viewPushLog(row)">推送记录</el-button>
+          <el-button link type="danger" @click="handleDelete(row)">删除</el-button>
+        </template>
+      </el-table-column>
+    </el-table>
+
+    <!-- 分页 -->
+    <el-pagination style="margin-top: 16px; justify-content: flex-end"
+      v-model:current-page="pagination.page" v-model:page-size="pagination.size"
+      :total="pagination.total" :page-sizes="[10, 20, 50]"
+      layout="total, sizes, prev, pager, next" @change="fetchData" />
+
+    <!-- 详情对话框 -->
+    <el-dialog v-model="showDetail" :title="detailItem?.reportTitle" width="900px" destroy-on-close>
+      <el-descriptions :column="2" border>
+        <el-descriptions-item label="报告类型">
+          <el-tag :type="typeTag(detailItem?.reportType)">{{ typeLabel(detailItem?.reportType) }}</el-tag>
+        </el-descriptions-item>
+        <el-descriptions-item label="推送状态">
+          <el-tag :type="pushStatusTag(detailItem?.pushStatus)">{{ pushStatusLabel(detailItem?.pushStatus) }}</el-tag>
+        </el-descriptions-item>
+        <el-descriptions-item label="生成时间">{{ detailItem?.generatedAt }}</el-descriptions-item>
+        <el-descriptions-item label="报告周期">{{ formatPeriod(detailItem) }}</el-descriptions-item>
+      </el-descriptions>
+      <el-divider />
+      <div class="report-content" v-html="detailItem?.contentHtml"></div>
+    </el-dialog>
+
+    <!-- 推送记录对话框 -->
+    <el-dialog v-model="showPushLog" title="推送记录" width="700px">
+      <el-table :data="pushLogData" border size="small">
+        <el-table-column prop="channel" label="渠道" width="100" />
+        <el-table-column prop="target" label="目标" min-width="200" />
+        <el-table-column prop="status" label="状态" width="100">
+          <template #default="{ row }">
+            <el-tag :type="row.status === 'success' ? 'success' : row.status === 'fail' ? 'danger' : 'info'" size="small">
+              {{ row.status }}
+            </el-tag>
+          </template>
+        </el-table-column>
+        <el-table-column prop="time" label="时间" width="170" />
+        <el-table-column prop="error" label="错误信息" min-width="200" />
+      </el-table>
+      <template #footer>
+        <el-button @click="showPushLog = false">关闭</el-button>
+      </template>
+    </el-dialog>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, reactive, onMounted } from 'vue'
+import { ElMessage, ElMessageBox } from 'element-plus'
+import { Search, Plus, ArrowDown } from '@element-plus/icons-vue'
+import {
+  getGeneratedReports, getGeneratedReport, deleteGeneratedReport,
+  regenerateReport, manualPushReport, generateReport
+} from '@/api/reportApi'
+
+const loading = ref(false)
+const showDetail = ref(false)
+const showPushLog = ref(false)
+const tableData = ref<any[]>([])
+const detailItem = ref<any>(null)
+const pushLogData = ref<any[]>([])
+const timeRange = ref<string[]>([])
+
+const filterForm = reactive({ reportType: '', pushStatus: '', startTime: '', endTime: '' })
+const pagination = reactive({ page: 1, size: 10, total: 0 })
+
+onMounted(() => fetchData())
+
+async function fetchData() {
+  loading.value = true
+  try {
+    const res = await getGeneratedReports({
+      pageNum: pagination.page, pageSize: pagination.size, ...filterForm
+    })
+    tableData.value = res.data?.records || []
+    pagination.total = res.data?.total || 0
+  } finally { loading.value = false }
+}
+
+function handleSearch() { pagination.page = 1; fetchData() }
+function handleReset() {
+  filterForm.reportType = ''; filterForm.pushStatus = ''
+  filterForm.startTime = ''; filterForm.endTime = ''
+  timeRange.value = []
+  handleSearch()
+}
+
+function handleTimeChange(val: string[] | null) {
+  if (val && val.length === 2) {
+    filterForm.startTime = val[0]
+    filterForm.endTime = val[1]
+  } else {
+    filterForm.startTime = ''
+    filterForm.endTime = ''
+  }
+}
+
+async function handleGenerate(type: string) {
+  const label = typeLabel(type)
+  await ElMessageBox.confirm(`确定手动生成${label}？`, `生成${label}`)
+  try {
+    const res = await generateReport(type)
+    const count = Array.isArray(res.data) ? res.data.length : 0
+    ElMessage.success(`${label}生成完成，共 ${count} 份`)
+    fetchData()
+  } catch (e) { ElMessage.error('生成失败') }
+}
+
+async function viewDetail(row: any) {
+  try {
+    const res = await getGeneratedReport(row.id)
+    detailItem.value = res.data
+    showDetail.value = true
+  } catch (e) { ElMessage.error('获取详情失败') }
+}
+
+async function handleRegenerate(row: any) {
+  await ElMessageBox.confirm(`确定重新生成「${row.reportTitle}」？`, '确认重新生成')
+  try {
+    await regenerateReport(row.id)
+    ElMessage.success('重新生成成功')
+    fetchData()
+  } catch (e) { ElMessage.error('重新生成失败') }
+}
+
+async function handlePush(row: any) {
+  await ElMessageBox.confirm(`确定推送「${row.reportTitle}」？`, '确认推送')
+  try {
+    await manualPushReport(row.id)
+    ElMessage.success('推送完成')
+    fetchData()
+  } catch (e) { ElMessage.error('推送失败') }
+}
+
+function viewPushLog(row: any) {
+  try {
+    const logStr = row.pushLog || '[]'
+    pushLogData.value = JSON.parse(logStr)
+    showPushLog.value = true
+  } catch {
+    pushLogData.value = []
+    showPushLog.value = true
+  }
+}
+
+async function handleDelete(row: any) {
+  await ElMessageBox.confirm(`确定删除「${row.reportTitle}」？`, '确认删除', { type: 'warning' })
+  await deleteGeneratedReport(row.id)
+  ElMessage.success('删除成功')
+  fetchData()
+}
+
+function formatPeriod(row: any): string {
+  if (!row) return '-'
+  const start = row.periodStart || ''
+  const end = row.periodEnd || ''
+  if (!start && !end) return '-'
+  return `${start.substring(0, 10)} ~ ${end.substring(0, 10)}`
+}
+
+const typeMap: Record<string, string> = { daily: '日报', weekly: '周报', monthly: '月报' }
+const typeTagMap: Record<string, string> = { daily: 'success', weekly: 'warning', monthly: 'danger' }
+function typeLabel(t: string) { return typeMap[t] || t }
+function typeTag(t: string) { return (typeTagMap[t] || 'info') as any }
+
+const pushStatusMap: Record<string, string> = {
+  pending: '待推送', pushing: '推送中', success: '成功', partial_fail: '部分失败', fail: '失败'
+}
+const pushStatusTagMap: Record<string, string> = {
+  pending: 'info', pushing: 'warning', success: 'success', partial_fail: 'warning', fail: 'danger'
+}
+function pushStatusLabel(s: string) { return pushStatusMap[s] || s }
+function pushStatusTag(s: string) { return (pushStatusTagMap[s] || 'info') as any }
+</script>
+
+<style scoped>
+.report-content {
+  border: 1px solid #ddd;
+  padding: 16px;
+  border-radius: 6px;
+  max-height: 500px;
+  overflow-y: auto;
+  background: #fafafa;
+}
+</style>

frontend/src/views/bi/ReportTemplateView.vue

@@ -0,0 +1,304 @@
+<template>
+  <div class="report-template-mgmt">
+    <!-- 搜索区 -->
+    <el-card shadow="never">
+      <el-form :inline="true" :model="filterForm">
+        <el-form-item label="报告类型">
+          <el-select v-model="filterForm.reportType" placeholder="全部" clearable @change="handleSearch">
+            <el-option label="日报" value="daily" />
+            <el-option label="周报" value="weekly" />
+            <el-option label="月报" value="monthly" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="状态">
+          <el-select v-model="filterForm.status" placeholder="全部" clearable @change="handleSearch">
+            <el-option label="启用" value="active" />
+            <el-option label="停用" value="inactive" />
+          </el-select>
+        </el-form-item>
+        <el-form-item>
+          <el-button type="primary" @click="handleSearch"><el-icon><Search /></el-icon> 查询</el-button>
+          <el-button @click="handleReset">重置</el-button>
+        </el-form-item>
+      </el-form>
+    </el-card>
+
+    <!-- 操作栏 -->
+    <div style="margin-top: 16px">
+      <el-button type="primary" @click="openCreateDialog"><el-icon><Plus /></el-icon> 创建模板</el-button>
+    </div>
+
+    <!-- 列表 -->
+    <el-table :data="tableData" border style="margin-top: 12px" v-loading="loading">
+      <el-table-column prop="id" label="ID" width="70" />
+      <el-table-column prop="templateName" label="模板名称" min-width="200" show-overflow-tooltip />
+      <el-table-column prop="reportType" label="报告类型" width="100">
+        <template #default="{ row }">
+          <el-tag :type="typeTag(row.reportType)" size="small">{{ typeLabel(row.reportType) }}</el-tag>
+        </template>
+      </el-table-column>
+      <el-table-column prop="status" label="状态" width="90">
+        <template #default="{ row }">
+          <el-tag :type="row.status === 'active' ? 'success' : 'info'" size="small">
+            {{ row.status === 'active' ? '启用' : '停用' }}
+          </el-tag>
+        </template>
+      </el-table-column>
+      <el-table-column prop="pushChannels" label="推送方式" width="150">
+        <template #default="{ row }">
+          <span>{{ formatChannels(row.pushChannels) }}</span>
+        </template>
+      </el-table-column>
+      <el-table-column prop="createdAt" label="创建时间" width="170" />
+      <el-table-column label="操作" width="320" fixed="right">
+        <template #default="{ row }">
+          <el-button link type="primary" @click="openEditDialog(row)">编辑</el-button>
+          <el-button link type="info" @click="handlePreview(row)">预览</el-button>
+          <el-button link :type="row.status === 'active' ? 'warning' : 'success'"
+            @click="handleToggleStatus(row)">
+            {{ row.status === 'active' ? '停用' : '启用' }}
+          </el-button>
+          <el-button link type="success" @click="handleCopy(row)">复制</el-button>
+          <el-button link type="danger" @click="handleDelete(row)">删除</el-button>
+        </template>
+      </el-table-column>
+    </el-table>
+
+    <!-- 分页 -->
+    <el-pagination style="margin-top: 16px; justify-content: flex-end"
+      v-model:current-page="pagination.page" v-model:page-size="pagination.size"
+      :total="pagination.total" :page-sizes="[10, 20, 50]"
+      layout="total, sizes, prev, pager, next" @change="fetchData" />
+
+    <!-- 编辑对话框 -->
+    <el-dialog v-model="showEditor" :title="isEdit ? '编辑模板' : '创建模板'" width="800px" destroy-on-close>
+      <el-form :model="form" label-width="120px">
+        <el-form-item label="模板名称" required>
+          <el-input v-model="form.templateName" placeholder="如: 水务运营日报" />
+        </el-form-item>
+        <el-row :gutter="16">
+          <el-col :span="12">
+            <el-form-item label="报告类型" required>
+              <el-select v-model="form.reportType" style="width: 100%">
+                <el-option label="日报" value="daily" />
+                <el-option label="周报" value="weekly" />
+                <el-option label="月报" value="monthly" />
+              </el-select>
+            </el-form-item>
+          </el-col>
+          <el-col :span="12">
+            <el-form-item label="状态">
+              <el-select v-model="form.status" style="width: 100%">
+                <el-option label="启用" value="active" />
+                <el-option label="停用" value="inactive" />
+              </el-select>
+            </el-form-item>
+          </el-col>
+        </el-row>
+        <el-form-item label="模板内容">
+          <el-input v-model="form.templateContent" type="textarea" :rows="10"
+            placeholder="HTML模板，使用 {{variable}} 插入变量，如 {{waterVolume.totalSupply}}" />
+        </el-form-item>
+        <el-form-item label="数据源配置">
+          <el-input v-model="form.dataSourceConfig" type="textarea" :rows="2"
+            placeholder='JSON格式，如: {"modules":["waterVolume","waterQuality","revenue","energy"]}' />
+        </el-form-item>
+        <el-form-item label="推送渠道">
+          <el-checkbox-group v-model="pushChannelList">
+            <el-checkbox label="email">邮件</el-checkbox>
+            <el-checkbox label="wecom">企微</el-checkbox>
+          </el-checkbox-group>
+        </el-form-item>
+        <el-form-item label="推送目标">
+          <el-input v-model="form.pushTargets" type="textarea" :rows="2"
+            placeholder='JSON格式，如: {"emails":["admin@example.com"],"webhookUrls":["https://..."]}' />
+        </el-form-item>
+        <el-form-item label="备注">
+          <el-input v-model="form.remark" placeholder="备注说明" />
+        </el-form-item>
+      </el-form>
+      <template #footer>
+        <el-button @click="showEditor = false">取消</el-button>
+        <el-button type="primary" @click="handleSave" :loading="saving">保存</el-button>
+      </template>
+    </el-dialog>
+
+    <!-- 预览对话框 -->
+    <el-dialog v-model="showPreview" title="模板预览" width="900px" destroy-on-close>
+      <el-tabs v-model="previewTab">
+        <el-tab-pane label="变量列表" name="variables">
+          <el-descriptions :column="1" border>
+            <el-descriptions-item v-for="v in previewData?.variables" :key="v" :label="v">
+              {{ getSampleValue(v) }}
+            </el-descriptions-item>
+          </el-descriptions>
+        </el-tab-pane>
+        <el-tab-pane label="渲染预览" name="rendered">
+          <div class="preview-frame" v-html="previewData?.renderedPreview"></div>
+        </el-tab-pane>
+      </el-tabs>
+    </el-dialog>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, reactive, computed, onMounted } from 'vue'
+import { ElMessage, ElMessageBox } from 'element-plus'
+import { Search, Plus } from '@element-plus/icons-vue'
+import {
+  getReportTemplates, createReportTemplate, updateReportTemplate,
+  deleteReportTemplate, toggleTemplateStatus, copyReportTemplate, previewTemplate
+} from '@/api/reportApi'
+
+const loading = ref(false)
+const saving = ref(false)
+const showEditor = ref(false)
+const showPreview = ref(false)
+const isEdit = ref(false)
+const editId = ref<number | null>(null)
+const tableData = ref<any[]>([])
+const previewData = ref<any>(null)
+const previewTab = ref('variables')
+
+const filterForm = reactive({ reportType: '', status: '' })
+const pagination = reactive({ page: 1, size: 10, total: 0 })
+
+const form = reactive({
+  templateName: '', reportType: 'daily', templateContent: '',
+  dataSourceConfig: '', pushChannels: '', pushTargets: '',
+  status: 'active', remark: ''
+})
+
+const pushChannelList = ref<string[]>([])
+
+// Sync pushChannelList with form.pushChannels
+const syncChannels = () => {
+  try {
+    pushChannelList.value = JSON.parse(form.pushChannels || '[]')
+  } catch { pushChannelList.value = [] }
+}
+const syncPushChannels = () => {
+  form.pushChannels = JSON.stringify(pushChannelList.value)
+}
+
+onMounted(() => fetchData())
+
+async function fetchData() {
+  loading.value = true
+  try {
+    const res = await getReportTemplates({
+      pageNum: pagination.page, pageSize: pagination.size, ...filterForm
+    })
+    tableData.value = res.data?.records || []
+    pagination.total = res.data?.total || 0
+  } finally { loading.value = false }
+}
+
+function handleSearch() { pagination.page = 1; fetchData() }
+function handleReset() {
+  filterForm.reportType = ''; filterForm.status = ''; handleSearch()
+}
+
+function openCreateDialog() {
+  isEdit.value = false; editId.value = null
+  Object.assign(form, {
+    templateName: '', reportType: 'daily', templateContent: '',
+    dataSourceConfig: '{"modules":["waterVolume","waterQuality","revenue","energy"]}',
+    pushChannels: '["email"]', pushTargets: '{"emails":[],"webhookUrls":[]}',
+    status: 'active', remark: ''
+  })
+  pushChannelList.value = ['email']
+  showEditor.value = true
+}
+
+function openEditDialog(row: any) {
+  isEdit.value = true; editId.value = row.id
+  Object.assign(form, row)
+  syncChannels()
+  showEditor.value = true
+}
+
+async function handleSave() {
+  if (!form.templateName) { ElMessage.warning('请输入模板名称'); return }
+  syncPushChannels()
+  saving.value = true
+  try {
+    if (isEdit.value && editId.value) {
+      await updateReportTemplate(editId.value, form)
+    } else {
+      await createReportTemplate(form)
+    }
+    ElMessage.success(isEdit.value ? '更新成功' : '创建成功')
+    showEditor.value = false
+    fetchData()
+  } finally { saving.value = false }
+}
+
+async function handleToggleStatus(row: any) {
+  const newStatus = row.status === 'active' ? 'inactive' : 'active'
+  const action = newStatus === 'active' ? '启用' : '停用'
+  await ElMessageBox.confirm(`确定${action}「${row.templateName}」？`, `确认${action}`)
+  await toggleTemplateStatus(row.id, newStatus)
+  ElMessage.success(`${action}成功`)
+  fetchData()
+}
+
+async function handleCopy(row: any) {
+  await ElMessageBox.confirm(`确定复制「${row.templateName}」？`, '确认复制')
+  await copyReportTemplate(row.id)
+  ElMessage.success('复制成功')
+  fetchData()
+}
+
+async function handleDelete(row: any) {
+  await ElMessageBox.confirm(`确定删除「${row.templateName}」？`, '确认删除', { type: 'warning' })
+  await deleteReportTemplate(row.id)
+  ElMessage.success('删除成功')
+  fetchData()
+}
+
+async function handlePreview(row: any) {
+  try {
+    const res = await previewTemplate(row.id)
+    previewData.value = res.data
+    previewTab.value = 'variables'
+    showPreview.value = true
+  } catch (e) { ElMessage.error('预览失败') }
+}
+
+function getSampleValue(varName: string): string {
+  const data = previewData.value?.sampleData
+  if (!data) return '-'
+  const parts = varName.split('.')
+  let val: any = data
+  for (const p of parts) {
+    val = val?.[p]
+    if (val === undefined) return '-'
+  }
+  return String(val)
+}
+
+function formatChannels(channels: string): string {
+  try {
+    const arr = JSON.parse(channels || '[]')
+    const map: Record<string, string> = { email: '邮件', wecom: '企微' }
+    return arr.map((c: string) => map[c] || c).join(', ') || '-'
+  } catch { return '-' }
+}
+
+const typeMap: Record<string, string> = { daily: '日报', weekly: '周报', monthly: '月报' }
+const typeTagMap: Record<string, string> = { daily: 'success', weekly: 'warning', monthly: 'danger' }
+function typeLabel(t: string) { return typeMap[t] || t }
+function typeTag(t: string) { return (typeTagMap[t] || 'info') as any }
+</script>
+
+<style scoped>
+.preview-frame {
+  border: 1px solid #ddd;
+  padding: 16px;
+  border-radius: 6px;
+  max-height: 500px;
+  overflow-y: auto;
+  background: #fafafa;
+}
+</style>

wm-bi/pom.xml

@@ -5,6 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <parent><groupId>com.water</groupId><artifactId>wm-parent</artifactId><version>1.0.0-SNAPSHOT</version></parent>
     <artifactId>wm-bi</artifactId>
+    <name>wm-bi</name>
+    <description>BI报表与运营报告模块</description>
     <dependencies>
         <dependency><groupId>com.water</groupId><artifactId>wm-common</artifactId></dependency>
         <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>
@@ -12,5 +14,18 @@
         <dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-spring-boot3-starter</artifactId></dependency>
         <dependency><groupId>cn.dev33</groupId><artifactId>sa-token-spring-boot3-starter</artifactId></dependency>
         <dependency><groupId>org.postgresql</groupId><artifactId>postgresql</artifactId></dependency>
+        <dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId></dependency>
+        <dependency><groupId>com.github.xiaoymin</groupId><artifactId>knife4j-openapi3-jakarta-spring-boot-starter</artifactId></dependency>
+        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-mail</artifactId></dependency>
+        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>
+        <dependency><groupId>com.h2database</groupId><artifactId>h2</artifactId><scope>test</scope></dependency>
     </dependencies>
-</project>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>

wm-bi/src/main/java/com/water/bi/BiApplication.java

@@ -2,8 +2,10 @@ package com.water.bi;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableScheduling
 public class BiApplication {
     public static void main(String[] args) {
         SpringApplication.run(BiApplication.class, args);

wm-bi/src/main/java/com/water/bi/config/MyBatisPlusConfig.java

@@ -0,0 +1,33 @@
+package com.water.bi.config;
+
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
+import org.apache.ibatis.reflection.MetaObject;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.time.LocalDateTime;
+
+@Configuration
+public class MyBatisPlusConfig implements MetaObjectHandler {
+
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.POSTGRE_SQL));
+        return interceptor;
+    }
+
+    @Override
+    public void insertFill(MetaObject metaObject) {
+        this.strictInsertFill(metaObject, "createdAt", LocalDateTime::now, LocalDateTime.class);
+        this.strictUpdateFill(metaObject, "updatedAt", LocalDateTime::now, LocalDateTime.class);
+    }
+
+    @Override
+    public void updateFill(MetaObject metaObject) {
+        this.strictUpdateFill(metaObject, "updatedAt", LocalDateTime::now, LocalDateTime.class);
+    }
+}

wm-bi/src/main/java/com/water/bi/config/RestTemplateConfig.java

@@ -0,0 +1,23 @@
+package com.water.bi.config;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
+
+@Configuration
+public class RestTemplateConfig {
+
+    @Bean
+    public RestTemplate restTemplate() {
+        return new RestTemplate();
+    }
+
+    @Bean
+    public ObjectMapper objectMapper() {
+        ObjectMapper mapper = new ObjectMapper();
+        mapper.registerModule(new JavaTimeModule());
+        return mapper;
+    }
+}

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

@@ -0,0 +1,69 @@
+package com.water.bi.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.water.bi.entity.GeneratedReport;
+import com.water.bi.service.ReportGeneratorService;
+import com.water.common.core.result.R;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDateTime;
+
+/**
+ * 生成报告管理控制器
+ */
+@Tag(name = "报告管理")
+@RestController
+@RequestMapping("/api/bi/report")
+@RequiredArgsConstructor
+public class GeneratedReportController {
+
+    private final ReportGeneratorService generatorService;
+
+    @Operation(summary = "分页查询报告")
+    @GetMapping("/page")
+    public R<Page<GeneratedReport>> page(
+            @RequestParam(defaultValue = "1") int pageNum,
+            @RequestParam(defaultValue = "10") int pageSize,
+            @RequestParam(required = false) String reportType,
+            @RequestParam(required = false) String pushStatus,
+            @RequestParam(required = false) @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") LocalDateTime startTime,
+            @RequestParam(required = false) @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") LocalDateTime endTime) {
+        return R.ok(generatorService.page(pageNum, pageSize, reportType, pushStatus, startTime, endTime));
+    }
+
+    @Operation(summary = "获取报告详情")
+    @GetMapping("/{id}")
+    public R<GeneratedReport> getById(@PathVariable Long id) {
+        return R.ok(generatorService.getById(id));
+    }
+
+    @Operation(summary = "删除报告")
+    @DeleteMapping("/{id}")
+    public R<String> delete(@PathVariable Long id) {
+        generatorService.delete(id);
+        return R.ok("删除成功");
+    }
+
+    @Operation(summary = "重新生成报告")
+    @PostMapping("/{id}/regenerate")
+    public R<GeneratedReport> regenerate(@PathVariable Long id) {
+        return R.ok(generatorService.regenerate(id));
+    }
+
+    @Operation(summary = "手动推送报告")
+    @PostMapping("/{id}/push")
+    public R<String> manualPush(@PathVariable Long id) {
+        generatorService.manualPush(id);
+        return R.ok("推送完成");
+    }
+
+    @Operation(summary = "手动触发生成报告")
+    @PostMapping("/generate")
+    public R<?> generate(@RequestParam String reportType) {
+        return R.ok(generatorService.generateByType(reportType));
+    }
+}

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

@@ -0,0 +1,80 @@
+package com.water.bi.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.service.ReportTemplateService;
+import com.water.common.core.result.R;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+/**
+ * 报告模板管理控制器
+ */
+@Tag(name = "报告模板管理")
+@RestController
+@RequestMapping("/api/bi/report-template")
+@RequiredArgsConstructor
+public class ReportTemplateController {
+
+    private final ReportTemplateService templateService;
+
+    @Operation(summary = "分页查询模板")
+    @GetMapping("/page")
+    public R<Page<ReportTemplate>> page(
+            @RequestParam(defaultValue = "1") int pageNum,
+            @RequestParam(defaultValue = "10") int pageSize,
+            @RequestParam(required = false) String reportType,
+            @RequestParam(required = false) String status) {
+        return R.ok(templateService.page(pageNum, pageSize, reportType, status));
+    }
+
+    @Operation(summary = "获取模板详情")
+    @GetMapping("/{id}")
+    public R<ReportTemplate> getById(@PathVariable Long id) {
+        return R.ok(templateService.getById(id));
+    }
+
+    @Operation(summary = "创建模板")
+    @PostMapping
+    public R<ReportTemplate> create(@RequestBody ReportTemplate template) {
+        return R.ok(templateService.create(template));
+    }
+
+    @Operation(summary = "更新模板")
+    @PutMapping("/{id}")
+    public R<String> update(@PathVariable Long id, @RequestBody ReportTemplate template) {
+        template.setId(id);
+        templateService.update(template);
+        return R.ok("更新成功");
+    }
+
+    @Operation(summary = "删除模板")
+    @DeleteMapping("/{id}")
+    public R<String> delete(@PathVariable Long id) {
+        templateService.delete(id);
+        return R.ok("删除成功");
+    }
+
+    @Operation(summary = "启用/停用模板")
+    @PatchMapping("/{id}/status")
+    public R<String> toggleStatus(@PathVariable Long id, @RequestParam String status) {
+        templateService.toggleStatus(id, status);
+        return R.ok("状态变更成功");
+    }
+
+    @Operation(summary = "复制模板")
+    @PostMapping("/{id}/copy")
+    public R<ReportTemplate> copy(@PathVariable Long id) {
+        return R.ok(templateService.copy(id));
+    }
+
+    @Operation(summary = "预览模板变量")
+    @GetMapping("/{id}/preview")
+    public R<Map<String, Object>> preview(@PathVariable Long id) {
+        return R.ok(templateService.previewVariables(id));
+    }
+}

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

@@ -0,0 +1,50 @@
+package com.water.bi.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.water.common.core.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 生成报告实体
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("bi_generated_report")
+public class GeneratedReport extends BaseEntity {
+
+    /** 关联模板ID */
+    private Long templateId;
+
+    /** 报告标题 */
+    private String reportTitle;
+
+    /** 报告类型: daily/weekly/monthly */
+    private String reportType;
+
+    /** 报告内容(HTML) */
+    private String contentHtml;
+
+    /** 报告数据(JSON) */
+    private String dataJson;
+
+    /** 报告周期开始 */
+    private LocalDateTime periodStart;
+
+    /** 报告周期结束 */
+    private LocalDateTime periodEnd;
+
+    /** 生成时间 */
+    private LocalDateTime generatedAt;
+
+    /** 推送状态: pending/pushing/success/partial_fail/fail */
+    private String pushStatus;
+
+    /** 推送记录(JSON): [{"channel":"email","target":"xx","status":"success","time":"..."}] */
+    private String pushLog;
+
+    /** 备注 */
+    private String remark;
+}

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

@@ -0,0 +1,39 @@
+package com.water.bi.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.water.common.core.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 报告模板实体
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("bi_report_template")
+public class ReportTemplate extends BaseEntity {
+
+    /** 模板名称 */
+    private String templateName;
+
+    /** 报告类型: daily/weekly/monthly */
+    private String reportType;
+
+    /** 模板内容(HTML模板，支持{{variable}}变量) */
+    private String templateContent;
+
+    /** 数据源配置(JSON): 水量/水质/营收/能耗 */
+    private String dataSourceConfig;
+
+    /** 推送方式(JSON数组): ["email","wecom"] */
+    private String pushChannels;
+
+    /** 推送目标(JSON): {"emails":[],"webhookUrls":[]} */
+    private String pushTargets;
+
+    /** 状态: active/inactive */
+    private String status;
+
+    /** 备注 */
+    private String remark;
+}

wm-bi/src/main/java/com/water/bi/mapper/GeneratedReportMapper.java

@@ -0,0 +1,12 @@
+package com.water.bi.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.bi.entity.GeneratedReport;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 生成报告Mapper
+ */
+@Mapper
+public interface GeneratedReportMapper extends BaseMapper<GeneratedReport> {
+}

wm-bi/src/main/java/com/water/bi/mapper/ReportTemplateMapper.java

@@ -0,0 +1,12 @@
+package com.water.bi.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.bi.entity.ReportTemplate;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 报告模板Mapper
+ */
+@Mapper
+public interface ReportTemplateMapper extends BaseMapper<ReportTemplate> {
+}

wm-bi/src/main/java/com/water/bi/scheduler/ReportScheduler.java

@@ -0,0 +1,66 @@
+package com.water.bi.scheduler;
+
+import com.water.bi.entity.GeneratedReport;
+import com.water.bi.service.ReportGeneratorService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 报告定时调度器
+ * 日报：每天 08:00
+ * 周报：每周一 08:00
+ * 月报：每月1号 08:00
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class ReportScheduler {
+
+    private final ReportGeneratorService generatorService;
+
+    /**
+     * 日报 - 每天08:00生成
+     */
+    @Scheduled(cron = "0 0 8 * * ?")
+    public void generateDailyReport() {
+        log.info("========== 定时任务：生成日报 ==========");
+        try {
+            List<GeneratedReport> reports = generatorService.generateByType("daily");
+            log.info("日报生成完成，共生成 {} 份报告", reports.size());
+        } catch (Exception e) {
+            log.error("日报生成失败: {}", e.getMessage(), e);
+        }
+    }
+
+    /**
+     * 周报 - 每周一08:00生成
+     */
+    @Scheduled(cron = "0 0 8 ? * MON")
+    public void generateWeeklyReport() {
+        log.info("========== 定时任务：生成周报 ==========");
+        try {
+            List<GeneratedReport> reports = generatorService.generateByType("weekly");
+            log.info("周报生成完成，共生成 {} 份报告", reports.size());
+        } catch (Exception e) {
+            log.error("周报生成失败: {}", e.getMessage(), e);
+        }
+    }
+
+    /**
+     * 月报 - 每月1号08:00生成
+     */
+    @Scheduled(cron = "0 0 8 1 * ?")
+    public void generateMonthlyReport() {
+        log.info("========== 定时任务：生成月报 ==========");
+        try {
+            List<GeneratedReport> reports = generatorService.generateByType("monthly");
+            log.info("月报生成完成，共生成 {} 份报告", reports.size());
+        } catch (Exception e) {
+            log.error("月报生成失败: {}", e.getMessage(), e);
+        }
+    }
+}

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

@@ -0,0 +1,476 @@
+package com.water.bi.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.water.bi.entity.GeneratedReport;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.mapper.GeneratedReportMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.*;
+import org.springframework.mail.SimpleMailMessage;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+
+/**
+ * 报告生成服务
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class ReportGeneratorService {
+
+    private final GeneratedReportMapper reportMapper;
+    private final ReportTemplateService templateService;
+    private final JavaMailSender mailSender;
+    private final RestTemplate restTemplate;
+    private final ObjectMapper objectMapper;
+
+    /**
+     * 按报告类型触发定时生成
+     */
+    public List<GeneratedReport> generateByType(String reportType) {
+        List<ReportTemplate> templates = templateService.listActiveByType(reportType);
+        if (templates.isEmpty()) {
+            log.info("没有启用的 {} 类型模板，跳过生成", reportType);
+            return Collections.emptyList();
+        }
+
+        List<GeneratedReport> reports = new ArrayList<>();
+        for (ReportTemplate template : templates) {
+            try {
+                GeneratedReport report = generateFromTemplate(template);
+                reports.add(report);
+            } catch (Exception e) {
+                log.error("从模板 #{} 生成报告失败: {}", template.getId(), e.getMessage(), e);
+            }
+        }
+        return reports;
+    }
+
+    /**
+     * 从模板生成报告
+     */
+    public GeneratedReport generateFromTemplate(ReportTemplate template) {
+        log.info("开始从模板 #{} ({}) 生成报告", template.getId(), template.getTemplateName());
+
+        // 1. 数据采集聚合
+        Map<String, Object> reportData = collectData(template);
+
+        // 2. 计算报告周期
+        LocalDateTime[] period = calculatePeriod(template.getReportType());
+
+        // 3. 模板渲染生成HTML
+        String htmlContent = templateService.renderTemplate(template.getTemplateContent(), reportData);
+
+        // 4. 生成报告标题
+        String title = generateTitle(template);
+
+        // 5. 存储报告
+        GeneratedReport report = new GeneratedReport();
+        report.setTemplateId(template.getId());
+        report.setReportTitle(title);
+        report.setReportType(template.getReportType());
+        report.setContentHtml(htmlContent);
+        report.setPeriodStart(period[0]);
+        report.setPeriodEnd(period[1]);
+        report.setGeneratedAt(LocalDateTime.now());
+        report.setPushStatus("pending");
+
+        try {
+            report.setDataJson(objectMapper.writeValueAsString(reportData));
+        } catch (Exception e) {
+            log.error("序列化报告数据失败", e);
+            report.setDataJson("{}");
+        }
+
+        reportMapper.insert(report);
+        log.info("报告 #{} 生成成功: {}", report.getId(), title);
+
+        // 6. 推送调度
+        dispatchPush(report, template);
+
+        return report;
+    }
+
+    /**
+     * 重新生成报告
+     */
+    public GeneratedReport regenerate(Long reportId) {
+        GeneratedReport existing = reportMapper.selectById(reportId);
+        if (existing == null) {
+            throw new RuntimeException("报告不存在");
+        }
+        ReportTemplate template = templateService.getById(existing.getTemplateId());
+        if (template == null) {
+            throw new RuntimeException("关联模板不存在");
+        }
+        return generateFromTemplate(template);
+    }
+
+    /**
+     * 分页查询报告
+     */
+    public Page<GeneratedReport> page(int pageNum, int pageSize, String reportType,
+                                       String pushStatus, LocalDateTime startTime, LocalDateTime endTime) {
+        LambdaQueryWrapper<GeneratedReport> wrapper = new LambdaQueryWrapper<>();
+        if (reportType != null && !reportType.isEmpty()) {
+            wrapper.eq(GeneratedReport::getReportType, reportType);
+        }
+        if (pushStatus != null && !pushStatus.isEmpty()) {
+            wrapper.eq(GeneratedReport::getPushStatus, pushStatus);
+        }
+        if (startTime != null) {
+            wrapper.ge(GeneratedReport::getGeneratedAt, startTime);
+        }
+        if (endTime != null) {
+            wrapper.le(GeneratedReport::getGeneratedAt, endTime);
+        }
+        wrapper.orderByDesc(GeneratedReport::getGeneratedAt);
+        return reportMapper.selectPage(new Page<>(pageNum, pageSize), wrapper);
+    }
+
+    /**
+     * 获取报告详情
+     */
+    public GeneratedReport getById(Long id) {
+        return reportMapper.selectById(id);
+    }
+
+    /**
+     * 删除报告
+     */
+    public void delete(Long id) {
+        reportMapper.deleteById(id);
+    }
+
+    /**
+     * 手动推送报告
+     */
+    public void manualPush(Long reportId) {
+        GeneratedReport report = reportMapper.selectById(reportId);
+        if (report == null) {
+            throw new RuntimeException("报告不存在");
+        }
+        ReportTemplate template = templateService.getById(report.getTemplateId());
+        if (template == null) {
+            throw new RuntimeException("关联模板不存在");
+        }
+        dispatchPush(report, template);
+    }
+
+    // ==================== 内部方法 ====================
+
+    /**
+     * 数据采集聚合 - 模拟从各模块采集数据
+     */
+    private Map<String, Object> collectData(ReportTemplate template) {
+        Map<String, Object> data = new LinkedHashMap<>();
+        LocalDate today = LocalDate.now();
+
+        data.put("reportTitle", generateTitle(template));
+        data.put("reportDate", today.format(DateTimeFormatter.ISO_LOCAL_DATE));
+        data.put("reportPeriod", formatPeriod(template.getReportType()));
+
+        // 水量数据 - 模拟采集
+        Map<String, Object> waterVolume = new LinkedHashMap<>();
+        Random rand = new Random();
+        double totalSupply = 10000 + rand.nextDouble() * 5000;
+        double lossRate = 15 + rand.nextDouble() * 10;
+        double totalSales = totalSupply * (1 - lossRate / 100);
+        waterVolume.put("totalSupply", String.format("%.0f m³", totalSupply));
+        waterVolume.put("totalSales", String.format("%.0f m³", totalSales));
+        waterVolume.put("lossRate", String.format("%.1f%%", lossRate));
+        waterVolume.put("peakHour", "10:00-12:00");
+        waterVolume.put("avgPressure", String.format("%.2f MPa", 0.3 + rand.nextDouble() * 0.1));
+        data.put("waterVolume", waterVolume);
+
+        // 水质数据
+        Map<String, Object> waterQuality = new LinkedHashMap<>();
+        waterQuality.put("turbidityAvg", String.format("%.1f NTU", 0.5 + rand.nextDouble() * 0.8));
+        waterQuality.put("residualChlorine", String.format("%.2f mg/L", 0.3 + rand.nextDouble() * 0.4));
+        waterQuality.put("phValue", String.format("%.1f", 6.8 + rand.nextDouble() * 0.8));
+        waterQuality.put("qualifiedRate", String.format("%.1f%%", 98.5 + rand.nextDouble() * 1.5));
+        waterQuality.put("sampleCount", String.valueOf(20 + rand.nextInt(10)));
+        data.put("waterQuality", waterQuality);
+
+        // 营收数据
+        Map<String, Object> revenue = new LinkedHashMap<>();
+        double dailyRev = 70000 + rand.nextDouble() * 30000;
+        revenue.put("dailyRevenue", String.format("¥%.0f", dailyRev));
+        revenue.put("monthlyCumulative", String.format("¥%.0f", dailyRev * today.getDayOfMonth()));
+        revenue.put("collectionRate", String.format("%.1f%%", 94 + rand.nextDouble() * 5));
+        revenue.put("newUsers", String.valueOf(rand.nextInt(20) + 5));
+        revenue.put("totalUsers", String.valueOf(28000 + rand.nextInt(1000)));
+        data.put("revenue", revenue);
+
+        // 能耗数据
+        Map<String, Object> energy = new LinkedHashMap<>();
+        double totalPower = 2800 + rand.nextDouble() * 800;
+        energy.put("totalPower", String.format("%.0f kWh", totalPower));
+        energy.put("unitConsumption", String.format("%.3f kWh/m³", totalPower / totalSupply));
+        energy.put("pumpEfficiency", String.format("%.1f%%", 72 + rand.nextDouble() * 12));
+        energy.put("costPerM3", String.format("¥%.2f", totalPower * 0.65 / totalSupply));
+        energy.put("solarGeneration", String.format("%.0f kWh", 300 + rand.nextDouble() * 300));
+        data.put("energy", energy);
+
+        return data;
+    }
+
+    /**
+     * 计算报告周期
+     */
+    private LocalDateTime[] calculatePeriod(String reportType) {
+        LocalDate today = LocalDate.now();
+        return switch (reportType) {
+            case "daily" -> new LocalDateTime[]{
+                today.minusDays(1).atStartOfDay(),
+                today.minusDays(1).atTime(LocalTime.MAX)
+            };
+            case "weekly" -> new LocalDateTime[]{
+                today.minusWeeks(1).with(java.time.DayOfWeek.MONDAY).atStartOfDay(),
+                today.minusWeeks(1).with(java.time.DayOfWeek.SUNDAY).atTime(LocalTime.MAX)
+            };
+            case "monthly" -> new LocalDateTime[]{
+                today.minusMonths(1).withDayOfMonth(1).atStartOfDay(),
+                today.minusMonths(1).withDayOfMonth(today.minusMonths(1).lengthOfMonth()).atTime(LocalTime.MAX)
+            };
+            default -> new LocalDateTime[]{today.atStartOfDay(), today.atTime(LocalTime.MAX)};
+        };
+    }
+
+    /**
+     * 格式化报告周期显示
+     */
+    private String formatPeriod(String reportType) {
+        LocalDate today = LocalDate.now();
+        DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        return switch (reportType) {
+            case "daily" -> today.minusDays(1).format(fmt) + " 00:00 ~ 23:59";
+            case "weekly" -> {
+                LocalDate weekStart = today.minusWeeks(1).with(java.time.DayOfWeek.MONDAY);
+                LocalDate weekEnd = today.minusWeeks(1).with(java.time.DayOfWeek.SUNDAY);
+                yield weekStart.format(fmt) + " ~ " + weekEnd.format(fmt);
+            }
+            case "monthly" -> {
+                LocalDate monthStart = today.minusMonths(1).withDayOfMonth(1);
+                LocalDate monthEnd = today.minusMonths(1).withDayOfMonth(today.minusMonths(1).lengthOfMonth());
+                yield monthStart.format(fmt) + " ~ " + monthEnd.format(fmt);
+            }
+            default -> today.format(fmt);
+        };
+    }
+
+    /**
+     * 生成报告标题
+     */
+    private String generateTitle(ReportTemplate template) {
+        LocalDate today = LocalDate.now();
+        String typeLabel = switch (template.getReportType()) {
+            case "daily" -> "日报";
+            case "weekly" -> "周报";
+            case "monthly" -> "月报";
+            default -> "报告";
+        };
+        return template.getTemplateName() + " - " + typeLabel + " " + today.format(DateTimeFormatter.ISO_LOCAL_DATE);
+    }
+
+    /**
+     * 推送调度
+     */
+    private void dispatchPush(GeneratedReport report, ReportTemplate template) {
+        try {
+            report.setPushStatus("pushing");
+            reportMapper.updateById(report);
+
+            List<String> pushLog = new ArrayList<>();
+
+            // 解析推送渠道
+            List<String> channels = parseChannels(template.getPushChannels());
+            Map<String, Object> targets = parseTargets(template.getPushTargets());
+
+            for (String channel : channels) {
+                try {
+                    switch (channel) {
+                        case "email" -> pushEmail(report, targets, pushLog);
+                        case "wecom" -> pushWecom(report, targets, pushLog);
+                        default -> log.warn("未知推送渠道: {}", channel);
+                    }
+                } catch (Exception e) {
+                    log.error("推送渠道 {} 失败: {}", channel, e.getMessage());
+                    pushLog.add(String.format("{\"channel\":\"%s\",\"status\":\"fail\",\"error\":\"%s\",\"time\":\"%s\"}",
+                            channel, e.getMessage(), LocalDateTime.now()));
+                }
+            }
+
+            // 更新推送状态
+            report.setPushLog("[" + String.join(",", pushLog) + "]");
+            boolean allSuccess = pushLog.stream().allMatch(l -> l.contains("\"status\":\"success\""));
+            boolean anySuccess = pushLog.stream().anyMatch(l -> l.contains("\"status\":\"success\""));
+            if (pushLog.isEmpty()) {
+                report.setPushStatus("pending");
+            } else if (allSuccess) {
+                report.setPushStatus("success");
+            } else if (anySuccess) {
+                report.setPushStatus("partial_fail");
+            } else {
+                report.setPushStatus("fail");
+            }
+            reportMapper.updateById(report);
+
+        } catch (Exception e) {
+            log.error("推送调度失败: {}", e.getMessage(), e);
+            report.setPushStatus("fail");
+            report.setPushLog("[{\"error\":\"" + e.getMessage() + "\"}]");
+            reportMapper.updateById(report);
+        }
+    }
+
+    /**
+     * 邮件推送
+     */
+    private void pushEmail(GeneratedReport report, Map<String, Object> targets, List<String> pushLog) {
+        @SuppressWarnings("unchecked")
+        List<String> emails = (List<String>) targets.getOrDefault("emails", Collections.emptyList());
+        if (emails.isEmpty()) {
+            pushLog.add("{\"channel\":\"email\",\"status\":\"skip\",\"reason\":\"no_targets\"}");
+            return;
+        }
+
+        for (String email : emails) {
+            try {
+                SimpleMailMessage message = new SimpleMailMessage();
+                message.setFrom("water-system@xayunmei.com");
+                message.setTo(email);
+                message.setSubject(report.getReportTitle());
+                message.setText("报告内容请查看附件或系统页面。\n\n报告摘要：\n" + extractSummary(report));
+                mailSender.send(message);
+                pushLog.add(String.format("{\"channel\":\"email\",\"target\":\"%s\",\"status\":\"success\",\"time\":\"%s\"}",
+                        email, LocalDateTime.now()));
+                log.info("邮件推送成功: {}", email);
+            } catch (Exception e) {
+                pushLog.add(String.format("{\"channel\":\"email\",\"target\":\"%s\",\"status\":\"fail\",\"error\":\"%s\"}",
+                        email, e.getMessage()));
+                log.error("邮件推送失败 {}: {}", email, e.getMessage());
+            }
+        }
+    }
+
+    /**
+     * 企微webhook推送
+     */
+    private void pushWecom(GeneratedReport report, Map<String, Object> targets, List<String> pushLog) {
+        @SuppressWarnings("unchecked")
+        List<String> webhooks = (List<String>) targets.getOrDefault("webhookUrls", Collections.emptyList());
+        if (webhooks.isEmpty()) {
+            pushLog.add("{\"channel\":\"wecom\",\"status\":\"skip\",\"reason\":\"no_targets\"}");
+            return;
+        }
+
+        for (String webhookUrl : webhooks) {
+            try {
+                Map<String, Object> payload = new LinkedHashMap<>();
+                payload.put("msgtype", "markdown");
+                Map<String, String> markdown = new LinkedHashMap<>();
+                markdown.put("content", buildWecomMarkdown(report));
+                payload.put("markdown", markdown);
+
+                HttpHeaders headers = new HttpHeaders();
+                headers.setContentType(MediaType.APPLICATION_JSON);
+                HttpEntity<String> entity = new HttpEntity<>(objectMapper.writeValueAsString(payload), headers);
+                ResponseEntity<String> response = restTemplate.exchange(webhookUrl, HttpMethod.POST, entity, String.class);
+
+                if (response.getStatusCode().is2xxSuccessful()) {
+                    pushLog.add(String.format("{\"channel\":\"wecom\",\"target\":\"%s\",\"status\":\"success\",\"time\":\"%s\"}",
+                            webhookUrl, LocalDateTime.now()));
+                    log.info("企微推送成功: {}", webhookUrl);
+                } else {
+                    pushLog.add(String.format("{\"channel\":\"wecom\",\"target\":\"%s\",\"status\":\"fail\",\"httpStatus\":%d}",
+                            webhookUrl, response.getStatusCode().value()));
+                }
+            } catch (Exception e) {
+                pushLog.add(String.format("{\"channel\":\"wecom\",\"target\":\"%s\",\"status\":\"fail\",\"error\":\"%s\"}",
+                        webhookUrl, e.getMessage()));
+                log.error("企微推送失败 {}: {}", webhookUrl, e.getMessage());
+            }
+        }
+    }
+
+    /**
+     * 构建企微Markdown消息
+     */
+    private String buildWecomMarkdown(GeneratedReport report) {
+        StringBuilder sb = new StringBuilder();
+        sb.append("## ").append(report.getReportTitle()).append("\n\n");
+        sb.append("> 报告周期: ").append(report.getPeriodStart()).append(" ~ ").append(report.getPeriodEnd()).append("\n\n");
+        sb.append(extractSummary(report));
+        sb.append("\n\n[查看详情](/bi/report/").append(report.getId()).append(")");
+        return sb.toString();
+    }
+
+    /**
+     * 提取报告摘要
+     */
+    private String extractSummary(GeneratedReport report) {
+        try {
+            Map<String, Object> data = objectMapper.readValue(report.getDataJson(),
+                    new TypeReference<Map<String, Object>>() {});
+            StringBuilder sb = new StringBuilder();
+
+            appendMetric(sb, data, "waterVolume", "totalSupply", "供水量");
+            appendMetric(sb, data, "waterQuality", "qualifiedRate", "水质合格率");
+            appendMetric(sb, data, "revenue", "dailyRevenue", "营收");
+            appendMetric(sb, data, "energy", "unitConsumption", "单位能耗");
+
+            return sb.toString();
+        } catch (Exception e) {
+            return "报告数据解析失败";
+        }
+    }
+
+    @SuppressWarnings("unchecked")
+    private void appendMetric(StringBuilder sb, Map<String, Object> data, String category, String key, String label) {
+        Object cat = data.get(category);
+        if (cat instanceof Map) {
+            Object value = ((Map<String, Object>) cat).get(key);
+            if (value != null) {
+                sb.append("- ").append(label).append(": ").append(value).append("\n");
+            }
+        }
+    }
+
+    /**
+     * 解析推送渠道
+     */
+    private List<String> parseChannels(String pushChannels) {
+        if (pushChannels == null || pushChannels.isEmpty()) return Collections.emptyList();
+        try {
+            return objectMapper.readValue(pushChannels, new TypeReference<List<String>>() {});
+        } catch (Exception e) {
+            log.error("解析推送渠道失败: {}", e.getMessage());
+            return Collections.emptyList();
+        }
+    }
+
+    /**
+     * 解析推送目标
+     */
+    private Map<String, Object> parseTargets(String pushTargets) {
+        if (pushTargets == null || pushTargets.isEmpty()) return Collections.emptyMap();
+        try {
+            return objectMapper.readValue(pushTargets, new TypeReference<Map<String, Object>>() {});
+        } catch (Exception e) {
+            log.error("解析推送目标失败: {}", e.getMessage());
+            return Collections.emptyMap();
+        }
+    }
+}

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

@@ -0,0 +1,238 @@
+package com.water.bi.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.mapper.ReportTemplateMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+
+/**
+ * 报告模板服务
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class ReportTemplateService {
+
+    private final ReportTemplateMapper templateMapper;
+
+    /**
+     * 分页查询模板
+     */
+    public Page<ReportTemplate> page(int pageNum, int pageSize, String reportType, String status) {
+        LambdaQueryWrapper<ReportTemplate> wrapper = new LambdaQueryWrapper<>();
+        if (reportType != null && !reportType.isEmpty()) {
+            wrapper.eq(ReportTemplate::getReportType, reportType);
+        }
+        if (status != null && !status.isEmpty()) {
+            wrapper.eq(ReportTemplate::getStatus, status);
+        }
+        wrapper.orderByDesc(ReportTemplate::getCreatedAt);
+        return templateMapper.selectPage(new Page<>(pageNum, pageSize), wrapper);
+    }
+
+    /**
+     * 获取模板详情
+     */
+    public ReportTemplate getById(Long id) {
+        return templateMapper.selectById(id);
+    }
+
+    /**
+     * 创建模板
+     */
+    public ReportTemplate create(ReportTemplate template) {
+        if (template.getStatus() == null) {
+            template.setStatus("active");
+        }
+        templateMapper.insert(template);
+        return template;
+    }
+
+    /**
+     * 更新模板
+     */
+    public void update(ReportTemplate template) {
+        templateMapper.updateById(template);
+    }
+
+    /**
+     * 删除模板
+     */
+    public void delete(Long id) {
+        templateMapper.deleteById(id);
+    }
+
+    /**
+     * 启用/停用模板
+     */
+    public void toggleStatus(Long id, String status) {
+        ReportTemplate template = templateMapper.selectById(id);
+        if (template == null) {
+            throw new RuntimeException("模板不存在");
+        }
+        template.setStatus(status);
+        templateMapper.updateById(template);
+        log.info("模板 {} 状态变更为: {}", id, status);
+    }
+
+    /**
+     * 复制模板
+     */
+    public ReportTemplate copy(Long id) {
+        ReportTemplate source = templateMapper.selectById(id);
+        if (source == null) {
+            throw new RuntimeException("模板不存在");
+        }
+        ReportTemplate copy = new ReportTemplate();
+        copy.setTemplateName(source.getTemplateName() + " (副本)");
+        copy.setReportType(source.getReportType());
+        copy.setTemplateContent(source.getTemplateContent());
+        copy.setDataSourceConfig(source.getDataSourceConfig());
+        copy.setPushChannels(source.getPushChannels());
+        copy.setPushTargets(source.getPushTargets());
+        copy.setStatus("inactive");
+        copy.setRemark("从模板 #" + id + " 复制");
+        templateMapper.insert(copy);
+        return copy;
+    }
+
+    /**
+     * 预览模板变量 - 返回模板中的变量列表及示例值
+     */
+    public Map<String, Object> previewVariables(Long id) {
+        ReportTemplate template = templateMapper.selectById(id);
+        if (template == null) {
+            throw new RuntimeException("模板不存在");
+        }
+
+        // 解析模板中的 {{variable}} 变量
+        String content = template.getTemplateContent();
+        Set<String> variables = new LinkedHashSet<>();
+        if (content != null) {
+            int idx = 0;
+            while (idx < content.length()) {
+                int start = content.indexOf("{{", idx);
+                if (start < 0) break;
+                int end = content.indexOf("}}", start + 2);
+                if (end < 0) break;
+                String varName = content.substring(start + 2, end).trim();
+                if (!varName.isEmpty()) {
+                    variables.add(varName);
+                }
+                idx = end + 2;
+            }
+        }
+
+        // 生成示例数据
+        Map<String, Object> sampleData = generateSampleData();
+        Map<String, Object> result = new LinkedHashMap<>();
+        result.put("variables", variables);
+        result.put("sampleData", sampleData);
+        result.put("renderedPreview", renderTemplate(content, sampleData));
+        return result;
+    }
+
+    /**
+     * 获取所有启用的模板
+     */
+    public List<ReportTemplate> listActive() {
+        LambdaQueryWrapper<ReportTemplate> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ReportTemplate::getStatus, "active");
+        return templateMapper.selectList(wrapper);
+    }
+
+    /**
+     * 按类型获取启用模板
+     */
+    public List<ReportTemplate> listActiveByType(String reportType) {
+        LambdaQueryWrapper<ReportTemplate> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ReportTemplate::getStatus, "active");
+        wrapper.eq(ReportTemplate::getReportType, reportType);
+        return templateMapper.selectList(wrapper);
+    }
+
+    /**
+     * 生成示例数据（用于预览）
+     */
+    public Map<String, Object> generateSampleData() {
+        Map<String, Object> data = new LinkedHashMap<>();
+        data.put("reportTitle", "运营日报示例");
+        data.put("reportDate", "2026-06-14");
+        data.put("reportPeriod", "2026-06-14 00:00 ~ 23:59");
+
+        // 水量数据
+        Map<String, Object> waterVolume = new LinkedHashMap<>();
+        waterVolume.put("totalSupply", "12580 m³");
+        waterVolume.put("totalSales", "10250 m³");
+        waterVolume.put("lossRate", "18.5%");
+        waterVolume.put("peakHour", "10:00-12:00");
+        waterVolume.put("avgPressure", "0.35 MPa");
+        data.put("waterVolume", waterVolume);
+
+        // 水质数据
+        Map<String, Object> waterQuality = new LinkedHashMap<>();
+        waterQuality.put("turbidityAvg", "0.8 NTU");
+        waterQuality.put("residualChlorine", "0.5 mg/L");
+        waterQuality.put("phValue", "7.2");
+        waterQuality.put("qualifiedRate", "99.8%");
+        waterQuality.put("sampleCount", "24");
+        data.put("waterQuality", waterQuality);
+
+        // 营收数据
+        Map<String, Object> revenue = new LinkedHashMap<>();
+        revenue.put("dailyRevenue", "¥85,600");
+        revenue.put("monthlyCumulative", "¥1,125,800");
+        revenue.put("collectionRate", "96.5%");
+        revenue.put("newUsers", "15");
+        revenue.put("totalUsers", "28,560");
+        data.put("revenue", revenue);
+
+        // 能耗数据
+        Map<String, Object> energy = new LinkedHashMap<>();
+        energy.put("totalPower", "3,250 kWh");
+        energy.put("unitConsumption", "0.258 kWh/m³");
+        energy.put("pumpEfficiency", "78.5%");
+        energy.put("costPerM3", "¥0.18");
+        energy.put("solarGeneration", "450 kWh");
+        data.put("energy", energy);
+
+        return data;
+    }
+
+    /**
+     * 渲染模板 - 将变量替换为实际数据
+     */
+    public String renderTemplate(String templateContent, Map<String, Object> data) {
+        if (templateContent == null) return "";
+        String rendered = templateContent;
+        for (Map.Entry<String, Object> entry : flattenMap("", data).entrySet()) {
+            String placeholder = "{{" + entry.getKey() + "}}";
+            String value = entry.getValue() != null ? entry.getValue().toString() : "";
+            rendered = rendered.replace(placeholder, value);
+        }
+        return rendered;
+    }
+
+    /**
+     * 将嵌套Map扁平化为点分隔的key
+     */
+    @SuppressWarnings("unchecked")
+    private Map<String, Object> flattenMap(String prefix, Map<String, Object> map) {
+        Map<String, Object> result = new LinkedHashMap<>();
+        for (Map.Entry<String, Object> entry : map.entrySet()) {
+            String key = prefix.isEmpty() ? entry.getKey() : prefix + "." + entry.getKey();
+            Object value = entry.getValue();
+            if (value instanceof Map) {
+                result.putAll(flattenMap(key, (Map<String, Object>) value));
+            } else {
+                result.put(key, value);
+            }
+        }
+        return result;
+    }
+}

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

@@ -12,6 +12,17 @@ spring:
     nacos:
       discovery:
         server-addr: ${NACOS_HOST:127.0.0.1}:8848
+  mail:
+    host: ${MAIL_HOST:smtp.exmail.qq.com}
+    port: ${MAIL_PORT:465}
+    username: ${MAIL_USER:water-system@xayunmei.com}
+    password: ${MAIL_PASS:}
+    properties:
+      mail:
+        smtp:
+          auth: true
+          ssl:
+            enable: true
 
 mybatis-plus:
   mapper-locations: classpath*:/mapper/**/*.xml

wm-bi/src/main/resources/db/V_bi_report.sql

@@ -0,0 +1,228 @@
+-- =============================================
+-- BI 运营报告模块 DDL
+-- =============================================
+
+-- 报告模板表
+CREATE TABLE IF NOT EXISTS bi_report_template (
+    id              BIGSERIAL PRIMARY KEY,
+    template_name   VARCHAR(200) NOT NULL COMMENT '模板名称',
+    report_type     VARCHAR(20) NOT NULL COMMENT '报告类型: daily/weekly/monthly',
+    template_content TEXT COMMENT '模板内容(HTML，支持{{variable}}变量)',
+    data_source_config TEXT COMMENT '数据源配置(JSON)',
+    push_channels   VARCHAR(500) COMMENT '推送方式(JSON数组): ["email","wecom"]',
+    push_targets    TEXT COMMENT '推送目标(JSON)',
+    status          VARCHAR(20) DEFAULT 'active' COMMENT '状态: active/inactive',
+    remark          VARCHAR(500) COMMENT '备注',
+    deleted         INTEGER DEFAULT 0,
+    created_at      TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at      TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+COMMENT ON TABLE bi_report_template IS 'BI报告模板表';
+
+-- 生成报告表
+CREATE TABLE IF NOT EXISTS bi_generated_report (
+    id              BIGSERIAL PRIMARY KEY,
+    template_id     BIGINT COMMENT '关联模板ID',
+    report_title    VARCHAR(500) NOT NULL COMMENT '报告标题',
+    report_type     VARCHAR(20) NOT NULL COMMENT '报告类型: daily/weekly/monthly',
+    content_html    TEXT COMMENT '报告内容(HTML)',
+    data_json       TEXT COMMENT '报告数据(JSON)',
+    period_start    TIMESTAMP COMMENT '报告周期开始',
+    period_end      TIMESTAMP COMMENT '报告周期结束',
+    generated_at    TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '生成时间',
+    push_status     VARCHAR(20) DEFAULT 'pending' COMMENT '推送状态: pending/pushing/success/partial_fail/fail',
+    push_log        TEXT COMMENT '推送记录(JSON)',
+    remark          VARCHAR(500) COMMENT '备注',
+    deleted         INTEGER DEFAULT 0,
+    created_at      TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at      TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+COMMENT ON TABLE bi_generated_report IS 'BI生成报告表';
+
+-- 索引
+CREATE INDEX IF NOT EXISTS idx_report_template_type ON bi_report_template(report_type);
+CREATE INDEX IF NOT EXISTS idx_report_template_status ON bi_report_template(status);
+CREATE INDEX IF NOT EXISTS idx_generated_report_type ON bi_generated_report(report_type);
+CREATE INDEX IF NOT EXISTS idx_generated_report_push_status ON bi_generated_report(push_status);
+CREATE INDEX IF NOT EXISTS idx_generated_report_generated_at ON bi_generated_report(generated_at);
+CREATE INDEX IF NOT EXISTS idx_generated_report_template_id ON bi_generated_report(template_id);
+
+-- 插入默认模板
+INSERT INTO bi_report_template (template_name, report_type, template_content, data_source_config, push_channels, push_targets, status, remark)
+VALUES (
+    '水务运营日报',
+    'daily',
+    '<html><head><meta charset="UTF-8"><title>{{reportTitle}}</title>
+<style>
+body{font-family:Arial,sans-serif;margin:20px;background:#f5f5f5}
+.container{max-width:800px;margin:0 auto;background:#fff;padding:30px;border-radius:8px;box-shadow:0 2px 8px rgba(0,0,0,0.1)}
+h1{color:#1890ff;border-bottom:2px solid #1890ff;padding-bottom:10px}
+h2{color:#333;margin-top:24px}
+.metric{display:inline-block;width:22%;margin:10px 1%;padding:15px;background:#f0f8ff;border-radius:6px;text-align:center}
+.metric .value{font-size:24px;font-weight:bold;color:#1890ff}
+.metric .label{font-size:12px;color:#666;margin-top:4px}
+table{width:100%;border-collapse:collapse;margin:16px 0}
+th,td{padding:10px;border:1px solid #ddd;text-align:left}
+th{background:#1890ff;color:#fff}
+.footer{margin-top:30px;padding-top:16px;border-top:1px solid #ddd;color:#999;font-size:12px}
+</style></head><body>
+<div class="container">
+<h1>💧 {{reportTitle}}</h1>
+<p>报告周期: {{reportPeriod}}</p>
+
+<h2>📊 水量数据</h2>
+<div class="metric"><div class="value">{{waterVolume.totalSupply}}</div><div class="label">总供水量</div></div>
+<div class="metric"><div class="value">{{waterVolume.totalSales}}</div><div class="label">总售水量</div></div>
+<div class="metric"><div class="value">{{waterVolume.lossRate}}</div><div class="label">产销差率</div></div>
+<div class="metric"><div class="value">{{waterVolume.avgPressure}}</div><div class="label">平均压力</div></div>
+
+<h2>🧪 水质数据</h2>
+<div class="metric"><div class="value">{{waterQuality.qualifiedRate}}</div><div class="label">合格率</div></div>
+<div class="metric"><div class="value">{{waterQuality.turbidityAvg}}</div><div class="label">平均浊度</div></div>
+<div class="metric"><div class="value">{{waterQuality.residualChlorine}}</div><div class="label">余氯</div></div>
+<div class="metric"><div class="value">{{waterQuality.phValue}}</div><div class="label">pH值</div></div>
+
+<h2>💰 营收数据</h2>
+<div class="metric"><div class="value">{{revenue.dailyRevenue}}</div><div class="label">日营收</div></div>
+<div class="metric"><div class="value">{{revenue.monthlyCumulative}}</div><div class="label">月累计</div></div>
+<div class="metric"><div class="value">{{revenue.collectionRate}}</div><div class="label">回收率</div></div>
+<div class="metric"><div class="value">{{revenue.totalUsers}}</div><div class="label">用户总数</div></div>
+
+<h2>⚡ 能耗数据</h2>
+<div class="metric"><div class="value">{{energy.totalPower}}</div><div class="label">总用电量</div></div>
+<div class="metric"><div class="value">{{energy.unitConsumption}}</div><div class="label">单位能耗</div></div>
+<div class="metric"><div class="value">{{energy.pumpEfficiency}}</div><div class="label">泵站效率</div></div>
+<div class="metric"><div class="value">{{energy.solarGeneration}}</div><div class="label">光伏发电</div></div>
+
+<div class="footer">
+<p>本报告由智慧水务管理系统自动生成 | {{reportDate}}</p>
+</div>
+</div></body></html>',
+    '{"modules":["waterVolume","waterQuality","revenue","energy"]}',
+    '["email"]',
+    '{"emails":["admin@xayunmei.com"]}',
+    'active',
+    '默认水务运营日报模板'
+);
+
+INSERT INTO bi_report_template (template_name, report_type, template_content, data_source_config, push_channels, push_targets, status, remark)
+VALUES (
+    '水务运营周报',
+    'weekly',
+    '<html><head><meta charset="UTF-8"><title>{{reportTitle}}</title>
+<style>
+body{font-family:Arial,sans-serif;margin:20px;background:#f5f5f5}
+.container{max-width:800px;margin:0 auto;background:#fff;padding:30px;border-radius:8px;box-shadow:0 2px 8px rgba(0,0,0,0.1)}
+h1{color:#52c41a;border-bottom:2px solid #52c41a;padding-bottom:10px}
+h2{color:#333;margin-top:24px}
+.summary{background:#f6ffed;padding:16px;border-radius:6px;margin:16px 0;border-left:4px solid #52c41a}
+table{width:100%;border-collapse:collapse;margin:16px 0}
+th,td{padding:10px;border:1px solid #ddd;text-align:center}
+th{background:#52c41a;color:#fff}
+.footer{margin-top:30px;padding-top:16px;border-top:1px solid #ddd;color:#999;font-size:12px}
+</style></head><body>
+<div class="container">
+<h1>📈 {{reportTitle}}</h1>
+<p>报告周期: {{reportPeriod}}</p>
+
+<div class="summary">
+<strong>本周概要:</strong> 供水 {{waterVolume.totalSupply}} | 水质合格率 {{waterQuality.qualifiedRate}} | 营收 {{revenue.dailyRevenue}} | 能耗 {{energy.unitConsumption}}
+</div>
+
+<h2>水量分析</h2>
+<table><tr><th>指标</th><th>数值</th></tr>
+<tr><td>总供水量</td><td>{{waterVolume.totalSupply}}</td></tr>
+<tr><td>总售水量</td><td>{{waterVolume.totalSales}}</td></tr>
+<tr><td>产销差率</td><td>{{waterVolume.lossRate}}</td></tr>
+<tr><td>高峰时段</td><td>{{waterVolume.peakHour}}</td></tr></table>
+
+<h2>水质分析</h2>
+<table><tr><th>指标</th><th>数值</th></tr>
+<tr><td>平均浊度</td><td>{{waterQuality.turbidityAvg}}</td></tr>
+<tr><td>余氯</td><td>{{waterQuality.residualChlorine}}</td></tr>
+<tr><td>pH值</td><td>{{waterQuality.phValue}}</td></tr>
+<tr><td>合格率</td><td>{{waterQuality.qualifiedRate}}</td></tr></table>
+
+<h2>营收分析</h2>
+<table><tr><th>指标</th><th>数值</th></tr>
+<tr><td>日营收</td><td>{{revenue.dailyRevenue}}</td></tr>
+<tr><td>月累计</td><td>{{revenue.monthlyCumulative}}</td></tr>
+<tr><td>回收率</td><td>{{revenue.collectionRate}}</td></tr>
+<tr><td>新增用户</td><td>{{revenue.newUsers}}</td></tr></table>
+
+<h2>能耗分析</h2>
+<table><tr><th>指标</th><th>数值</th></tr>
+<tr><td>总用电量</td><td>{{energy.totalPower}}</td></tr>
+<tr><td>单位能耗</td><td>{{energy.unitConsumption}}</td></tr>
+<tr><td>泵站效率</td><td>{{energy.pumpEfficiency}}</td></tr>
+<tr><td>光伏发电</td><td>{{energy.solarGeneration}}</td></tr></table>
+
+<div class="footer"><p>本报告由智慧水务管理系统自动生成 | {{reportDate}}</p></div>
+</div></body></html>',
+    '{"modules":["waterVolume","waterQuality","revenue","energy"]}',
+    '["email","wecom"]',
+    '{"emails":["admin@xayunmei.com"],"webhookUrls":[]}',
+    'active',
+    '默认水务运营周报模板'
+);
+
+INSERT INTO bi_report_template (template_name, report_type, template_content, data_source_config, push_channels, push_targets, status, remark)
+VALUES (
+    '水务运营月报',
+    'monthly',
+    '<html><head><meta charset="UTF-8"><title>{{reportTitle}}</title>
+<style>
+body{font-family:Arial,sans-serif;margin:20px;background:#f5f5f5}
+.container{max-width:900px;margin:0 auto;background:#fff;padding:30px;border-radius:8px;box-shadow:0 2px 8px rgba(0,0,0,0.1)}
+h1{color:#722ed1;border-bottom:2px solid #722ed1;padding-bottom:10px}
+h2{color:#333;margin-top:24px}
+.kpi-row{display:flex;gap:16px;margin:16px 0}
+.kpi-card{flex:1;padding:20px;border-radius:8px;text-align:center;color:#fff}
+.kpi-card.blue{background:linear-gradient(135deg,#1890ff,#096dd9)}
+.kpi-card.green{background:linear-gradient(135deg,#52c41a,#389e0d)}
+.kpi-card.orange{background:linear-gradient(135deg,#fa8c16,#d46b08)}
+.kpi-card.purple{background:linear-gradient(135deg,#722ed1,#531dab)}
+.kpi-card .value{font-size:28px;font-weight:bold}
+.kpi-card .label{font-size:13px;opacity:0.9;margin-top:4px}
+table{width:100%;border-collapse:collapse;margin:16px 0}
+th,td{padding:10px;border:1px solid #ddd;text-align:center}
+th{background:#722ed1;color:#fff}
+.footer{margin-top:30px;padding-top:16px;border-top:1px solid #ddd;color:#999;font-size:12px}
+</style></head><body>
+<div class="container">
+<h1>📊 {{reportTitle}}</h1>
+<p>报告周期: {{reportPeriod}}</p>
+
+<div class="kpi-row">
+<div class="kpi-card blue"><div class="value">{{waterVolume.totalSupply}}</div><div class="label">月总供水量</div></div>
+<div class="kpi-card green"><div class="value">{{waterQuality.qualifiedRate}}</div><div class="label">水质合格率</div></div>
+<div class="kpi-card orange"><div class="value">{{revenue.monthlyCumulative}}</div><div class="label">月营收</div></div>
+<div class="kpi-card purple"><div class="value">{{energy.unitConsumption}}</div><div class="label">单位能耗</div></div>
+</div>
+
+<h2>水量月度统计</h2>
+<table><tr><th>总供水量</th><th>总售水量</th><th>产销差率</th><th>平均压力</th></tr>
+<tr><td>{{waterVolume.totalSupply}}</td><td>{{waterVolume.totalSales}}</td><td>{{waterVolume.lossRate}}</td><td>{{waterVolume.avgPressure}}</td></tr></table>
+
+<h2>水质月度统计</h2>
+<table><tr><th>平均浊度</th><th>余氯</th><th>pH值</th><th>合格率</th><th>采样次数</th></tr>
+<tr><td>{{waterQuality.turbidityAvg}}</td><td>{{waterQuality.residualChlorine}}</td><td>{{waterQuality.phValue}}</td><td>{{waterQuality.qualifiedRate}}</td><td>{{waterQuality.sampleCount}}</td></tr></table>
+
+<h2>营收月度统计</h2>
+<table><tr><th>日营收</th><th>月累计</th><th>回收率</th><th>新增用户</th><th>用户总数</th></tr>
+<tr><td>{{revenue.dailyRevenue}}</td><td>{{revenue.monthlyCumulative}}</td><td>{{revenue.collectionRate}}</td><td>{{revenue.newUsers}}</td><td>{{revenue.totalUsers}}</td></tr></table>
+
+<h2>能耗月度统计</h2>
+<table><tr><th>总用电量</th><th>单位能耗</th><th>泵站效率</th><th>吨水成本</th><th>光伏发电</th></tr>
+<tr><td>{{energy.totalPower}}</td><td>{{energy.unitConsumption}}</td><td>{{energy.pumpEfficiency}}</td><td>{{energy.costPerM3}}</td><td>{{energy.solarGeneration}}</td></tr></table>
+
+<div class="footer"><p>本报告由智慧水务管理系统自动生成 | {{reportDate}}</p></div>
+</div></body></html>',
+    '{"modules":["waterVolume","waterQuality","revenue","energy"]}',
+    '["email","wecom"]',
+    '{"emails":["admin@xayunmei.com"],"webhookUrls":[]}',
+    'active',
+    '默认水务运营月报模板'
+);

wm-bi/src/test/java/com/water/bi/service/ReportGeneratorServiceTest.java

@@ -0,0 +1,161 @@
+package com.water.bi.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import com.water.bi.entity.GeneratedReport;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.mapper.GeneratedReportMapper;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Collections;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.*;
+import static org.mockito.Mockito.*;
+
+/**
+ * 报告生成服务测试
+ */
+@ExtendWith(MockitoExtension.class)
+class ReportGeneratorServiceTest {
+
+    @Mock
+    private GeneratedReportMapper reportMapper;
+
+    @Mock
+    private JavaMailSender mailSender;
+
+    @Mock
+    private RestTemplate restTemplate;
+
+    private ReportTemplateService templateService;
+    private ReportGeneratorService generatorService;
+
+    @BeforeEach
+    void setUp() {
+        ReportTemplateMapper templateMapper = mock(ReportTemplateMapper.class);
+        templateService = new ReportTemplateService(templateMapper);
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.registerModule(new JavaTimeModule());
+        generatorService = new ReportGeneratorService(reportMapper, templateService, mailSender, restTemplate, objectMapper);
+    }
+
+    @Test
+    @DisplayName("按类型生成报告 - 无模板返回空列表")
+    void testGenerateByTypeNoTemplates() {
+        // templateService.listActiveByType returns empty
+        ReportGeneratorService spyService = spy(generatorService);
+        ReportTemplateService mockTemplateService = mock(ReportTemplateService.class);
+
+        // We need to re-construct with the mock
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.registerModule(new JavaTimeModule());
+        ReportGeneratorService testService = new ReportGeneratorService(
+                reportMapper, mockTemplateService, mailSender, restTemplate, objectMapper);
+
+        when(mockTemplateService.listActiveByType("daily")).thenReturn(Collections.emptyList());
+
+        List<GeneratedReport> result = testService.generateByType("daily");
+        assertTrue(result.isEmpty());
+    }
+
+    @Test
+    @DisplayName("从模板生成报告 - 完整流程")
+    void testGenerateFromTemplate() {
+        ReportTemplate template = new ReportTemplate();
+        template.setId(1L);
+        template.setTemplateName("测试日报");
+        template.setReportType("daily");
+        template.setTemplateContent("<h1>{{reportTitle}}</h1><p>{{waterVolume.totalSupply}}</p>");
+        template.setPushChannels("[]");  // no push
+        template.setPushTargets("{}");
+
+        ReportTemplateService mockTemplateService = mock(ReportTemplateService.class);
+        when(mockTemplateService.listActiveByType(anyString())).thenReturn(List.of(template));
+        when(mockTemplateService.renderTemplate(anyString(), anyMap())).thenReturn("<h1>标题</h1><p>10000 m³</p>");
+
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.registerModule(new JavaTimeModule());
+        ReportGeneratorService testService = new ReportGeneratorService(
+                reportMapper, mockTemplateService, mailSender, restTemplate, objectMapper);
+
+        when(reportMapper.insert(any(GeneratedReport.class))).thenReturn(1);
+        when(reportMapper.updateById(any(GeneratedReport.class))).thenReturn(1);
+
+        GeneratedReport report = testService.generateFromTemplate(template);
+
+        assertNotNull(report);
+        assertEquals(1L, report.getTemplateId());
+        assertTrue(report.getReportTitle().contains("测试日报"));
+        assertEquals("daily", report.getReportType());
+        assertNotNull(report.getContentHtml());
+        assertNotNull(report.getDataJson());
+        assertNotNull(report.getGeneratedAt());
+        verify(reportMapper).insert(any(GeneratedReport.class));
+    }
+
+    @Test
+    @DisplayName("重新生成报告 - 报告不存在抛异常")
+    void testRegenerateNotFound() {
+        when(reportMapper.selectById(999L)).thenReturn(null);
+
+        assertThrows(RuntimeException.class, () -> {
+            generatorService.regenerate(999L);
+        });
+    }
+
+    @Test
+    @DisplayName("删除报告")
+    void testDeleteReport() {
+        when(reportMapper.deleteById(1L)).thenReturn(1);
+        generatorService.delete(1L);
+        verify(reportMapper).deleteById(1L);
+    }
+
+    @Test
+    @DisplayName("手动推送 - 报告不存在抛异常")
+    void testManualPushNotFound() {
+        when(reportMapper.selectById(999L)).thenReturn(null);
+
+        assertThrows(RuntimeException.class, () -> {
+            generatorService.manualPush(999L);
+        });
+    }
+
+    @Test
+    @DisplayName("分页查询报告")
+    void testPage() {
+        var page = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<GeneratedReport>(1, 10);
+        page.setRecords(List.of(new GeneratedReport()));
+        page.setTotal(1);
+
+        when(reportMapper.selectPage(any(), any(LambdaQueryWrapper.class))).thenReturn(page);
+
+        var result = generatorService.page(1, 10, "daily", null, null, null);
+        assertNotNull(result);
+        assertEquals(1, result.getRecords().size());
+    }
+
+    @Test
+    @DisplayName("获取报告详情")
+    void testGetById() {
+        GeneratedReport report = new GeneratedReport();
+        report.setId(1L);
+        report.setReportTitle("测试报告");
+
+        when(reportMapper.selectById(1L)).thenReturn(report);
+
+        GeneratedReport result = generatorService.getById(1L);
+        assertNotNull(result);
+        assertEquals("测试报告", result.getReportTitle());
+    }
+}

wm-bi/src/test/java/com/water/bi/service/ReportTemplateServiceTest.java

@@ -0,0 +1,228 @@
+package com.water.bi.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.water.bi.entity.ReportTemplate;
+import com.water.bi.mapper.ReportTemplateMapper;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.*;
+import static org.mockito.Mockito.*;
+
+/**
+ * 报告模板服务测试
+ */
+@ExtendWith(MockitoExtension.class)
+class ReportTemplateServiceTest {
+
+    @Mock
+    private ReportTemplateMapper templateMapper;
+
+    private ReportTemplateService templateService;
+
+    @BeforeEach
+    void setUp() {
+        templateService = new ReportTemplateService(templateMapper);
+    }
+
+    @Test
+    @DisplayName("创建模板 - 默认状态为active")
+    void testCreateTemplate() {
+        ReportTemplate template = new ReportTemplate();
+        template.setTemplateName("测试日报模板");
+        template.setReportType("daily");
+        template.setTemplateContent("<h1>{{reportTitle}}</h1>");
+
+        when(templateMapper.insert(any(ReportTemplate.class))).thenReturn(1);
+
+        ReportTemplate created = templateService.create(template);
+        assertNotNull(created);
+        assertEquals("active", created.getStatus());
+        verify(templateMapper).insert(any(ReportTemplate.class));
+    }
+
+    @Test
+    @DisplayName("创建模板 - 指定状态")
+    void testCreateTemplateWithStatus() {
+        ReportTemplate template = new ReportTemplate();
+        template.setTemplateName("测试模板");
+        template.setReportType("weekly");
+        template.setStatus("inactive");
+
+        when(templateMapper.insert(any(ReportTemplate.class))).thenReturn(1);
+
+        ReportTemplate created = templateService.create(template);
+        assertEquals("inactive", created.getStatus());
+    }
+
+    @Test
+    @DisplayName("启用/停用模板")
+    void testToggleStatus() {
+        ReportTemplate template = new ReportTemplate();
+        template.setId(1L);
+        template.setTemplateName("测试模板");
+        template.setStatus("active");
+
+        when(templateMapper.selectById(1L)).thenReturn(template);
+        when(templateMapper.updateById(any(ReportTemplate.class))).thenReturn(1);
+
+        templateService.toggleStatus(1L, "inactive");
+
+        verify(templateMapper).updateById(argThat(t -> "inactive".equals(t.getStatus())));
+    }
+
+    @Test
+    @DisplayName("启用/停用模板 - 模板不存在抛异常")
+    void testToggleStatusNotFound() {
+        when(templateMapper.selectById(999L)).thenReturn(null);
+
+        assertThrows(RuntimeException.class, () -> {
+            templateService.toggleStatus(999L, "active");
+        });
+    }
+
+    @Test
+    @DisplayName("复制模板")
+    void testCopyTemplate() {
+        ReportTemplate source = new ReportTemplate();
+        source.setId(1L);
+        source.setTemplateName("原始模板");
+        source.setReportType("daily");
+        source.setTemplateContent("<h1>{{reportTitle}}</h1>");
+        source.setDataSourceConfig("{\"modules\":[\"waterVolume\"]}");
+        source.setPushChannels("[\"email\"]");
+        source.setPushTargets("{\"emails\":[\"test@example.com\"]}");
+        source.setStatus("active");
+
+        when(templateMapper.selectById(1L)).thenReturn(source);
+        when(templateMapper.insert(any(ReportTemplate.class))).thenReturn(1);
+
+        ReportTemplate copy = templateService.copy(1L);
+
+        assertNotNull(copy);
+        assertEquals("原始模板 (副本)", copy.getTemplateName());
+        assertEquals("daily", copy.getReportType());
+        assertEquals("inactive", copy.getStatus());
+        assertEquals("<h1>{{reportTitle}}</h1>", copy.getTemplateContent());
+        verify(templateMapper).insert(any(ReportTemplate.class));
+    }
+
+    @Test
+    @DisplayName("复制模板 - 源不存在抛异常")
+    void testCopyTemplateNotFound() {
+        when(templateMapper.selectById(999L)).thenReturn(null);
+
+        assertThrows(RuntimeException.class, () -> {
+            templateService.copy(999L);
+        });
+    }
+
+    @Test
+    @DisplayName("预览模板变量 - 解析变量列表")
+    void testPreviewVariables() {
+        ReportTemplate template = new ReportTemplate();
+        template.setId(1L);
+        template.setTemplateName("测试模板");
+        template.setTemplateContent(
+                "<h1>{{reportTitle}}</h1>" +
+                "<p>{{waterVolume.totalSupply}}</p>" +
+                "<p>{{waterQuality.qualifiedRate}}</p>" +
+                "<p>{{reportTitle}}</p>"  // duplicate should be deduplicated
+        );
+
+        when(templateMapper.selectById(1L)).thenReturn(template);
+
+        Map<String, Object> result = templateService.previewVariables(1L);
+
+        assertNotNull(result);
+        assertTrue(result.containsKey("variables"));
+        assertTrue(result.containsKey("sampleData"));
+        assertTrue(result.containsKey("renderedPreview"));
+
+        @SuppressWarnings("unchecked")
+        java.util.Set<String> variables = (java.util.Set<String>) result.get("variables");
+        assertEquals(3, variables.size()); // reportTitle, waterVolume.totalSupply, waterQuality.qualifiedRate
+        assertTrue(variables.contains("reportTitle"));
+        assertTrue(variables.contains("waterVolume.totalSupply"));
+        assertTrue(variables.contains("waterQuality.qualifiedRate"));
+
+        // Preview should have variables replaced
+        String preview = (String) result.get("renderedPreview");
+        assertFalse(preview.contains("{{reportTitle}}"));
+    }
+
+    @Test
+    @DisplayName("渲染模板 - 变量替换")
+    void testRenderTemplate() {
+        String template = "<h1>{{title}}</h1><p>{{data.value}}</p>";
+        Map<String, Object> data = Map.of(
+                "title", "测试报告",
+                "data", Map.of("value", "100")
+        );
+
+        String result = templateService.renderTemplate(template, data);
+        assertEquals("<h1>测试报告</h1><p>100</p>", result);
+    }
+
+    @Test
+    @DisplayName("渲染模板 - null内容返回空串")
+    void testRenderTemplateNull() {
+        String result = templateService.renderTemplate(null, Map.of());
+        assertEquals("", result);
+    }
+
+    @Test
+    @DisplayName("生成示例数据 - 包含所有4类数据")
+    void testGenerateSampleData() {
+        Map<String, Object> data = templateService.generateSampleData();
+
+        assertNotNull(data);
+        assertTrue(data.containsKey("waterVolume"));
+        assertTrue(data.containsKey("waterQuality"));
+        assertTrue(data.containsKey("revenue"));
+        assertTrue(data.containsKey("energy"));
+        assertTrue(data.containsKey("reportTitle"));
+        assertTrue(data.containsKey("reportDate"));
+    }
+
+    @Test
+    @DisplayName("获取所有启用模板")
+    void testListActive() {
+        ReportTemplate t1 = new ReportTemplate();
+        t1.setStatus("active");
+        when(templateMapper.selectList(any(LambdaQueryWrapper.class))).thenReturn(List.of(t1));
+
+        List<ReportTemplate> result = templateService.listActive();
+        assertEquals(1, result.size());
+    }
+
+    @Test
+    @DisplayName("按类型获取启用模板")
+    void testListActiveByType() {
+        ReportTemplate t1 = new ReportTemplate();
+        t1.setReportType("daily");
+        t1.setStatus("active");
+        when(templateMapper.selectList(any(LambdaQueryWrapper.class))).thenReturn(List.of(t1));
+
+        List<ReportTemplate> result = templateService.listActiveByType("daily");
+        assertEquals(1, result.size());
+        assertEquals("daily", result.get(0).getReportType());
+    }
+
+    @Test
+    @DisplayName("删除模板")
+    void testDeleteTemplate() {
+        when(templateMapper.deleteById(1L)).thenReturn(1);
+        templateService.delete(1L);
+        verify(templateMapper).deleteById(1L);
+    }
+}