feat(wm-patrol): #78 统计分析（执行率/里程/问题分类）

wm-patrol/src/main/java/com/water/patrol/controller/StatsController.java

@@ -0,0 +1,176 @@
+package com.water.patrol.controller;
+
+import com.water.common.core.result.R;
+import com.water.patrol.entity.dto.RankResult;
+import com.water.patrol.entity.dto.StatsQueryRequest;
+import com.water.patrol.entity.dto.StatsSummary;
+import com.water.patrol.service.PatrolRankService;
+import com.water.patrol.service.PatrolStatsService;
+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.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 巡检统计分析 REST API
+ */
+@Tag(name = "巡检统计分析")
+@RestController
+@RequestMapping("/api/patrol/stats")
+@RequiredArgsConstructor
+public class StatsController {
+
+    private final PatrolStatsService statsService;
+    private final PatrolRankService rankService;
+
+    // ==================== 综合看板 ====================
+
+    @Operation(summary = "综合看板概览")
+    @GetMapping("/summary")
+    public R<StatsSummary> summary(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.dashboardSummary(request));
+    }
+
+    // ==================== 执行率统计 ====================
+
+    @Operation(summary = "执行率统计 - 按巡检员")
+    @GetMapping("/execution-rate/by-inspector")
+    public R<List<Map<String, Object>>> executionRateByInspector(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.executionRateByInspector(request));
+    }
+
+    @Operation(summary = "执行率统计 - 按路线")
+    @GetMapping("/execution-rate/by-route")
+    public R<List<Map<String, Object>>> executionRateByRoute(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.executionRateByRoute(request));
+    }
+
+    @Operation(summary = "执行率统计 - 按时间段")
+    @GetMapping("/execution-rate/by-period")
+    public R<List<Map<String, Object>>> executionRateByPeriod(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.executionRateByPeriod(request));
+    }
+
+    // ==================== 里程统计 ====================
+
+    @Operation(summary = "里程统计概览")
+    @GetMapping("/mileage/summary")
+    public R<Map<String, Object>> mileageSummary(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.mileageSummary(request));
+    }
+
+    @Operation(summary = "里程统计 - 按巡检员")
+    @GetMapping("/mileage/by-inspector")
+    public R<List<Map<String, Object>>> mileageByInspector(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.mileageByInspector(request));
+    }
+
+    @Operation(summary = "里程趋势（按天）")
+    @GetMapping("/mileage/trend")
+    public R<List<Map<String, Object>>> mileageTrend(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.mileageTrend(request));
+    }
+
+    // ==================== 问题分类统计 ====================
+
+    @Operation(summary = "问题类型分布")
+    @GetMapping("/issues/type-distribution")
+    public R<List<Map<String, Object>>> issueTypeDistribution(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.issueTypeDistribution(request));
+    }
+
+    @Operation(summary = "问题严重度分布")
+    @GetMapping("/issues/severity-distribution")
+    public R<List<Map<String, Object>>> issueSeverityDistribution(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.issueSeverityDistribution(request));
+    }
+
+    @Operation(summary = "问题解决率统计")
+    @GetMapping("/issues/resolution-rate")
+    public R<Map<String, Object>> issueResolutionRate(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        return R.ok(statsService.issueResolutionStats(request));
+    }
+
+    // ==================== 排名 ====================
+
+    @Operation(summary = "巡检员排名")
+    @GetMapping("/rank/inspectors")
+    public R<List<RankResult>> inspectorRank(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate,
+            @RequestParam(required = false, defaultValue = "10") Integer topN) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        request.setTopN(topN);
+        return R.ok(rankService.inspectorRank(request));
+    }
+
+    @Operation(summary = "路线排名")
+    @GetMapping("/rank/routes")
+    public R<List<RankResult>> routeRank(
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate,
+            @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate,
+            @RequestParam(required = false, defaultValue = "10") Integer topN) {
+        StatsQueryRequest request = new StatsQueryRequest();
+        request.setStartDate(startDate);
+        request.setEndDate(endDate);
+        request.setTopN(topN);
+        return R.ok(rankService.routeRank(request));
+    }
+}

wm-patrol/src/main/java/com/water/patrol/entity/dto/RankResult.java

@@ -0,0 +1,62 @@
+package com.water.patrol.entity.dto;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 排名结果 DTO
+ */
+@Data
+public class RankResult {
+
+    /**
+     * 排名
+     */
+    private Integer rank;
+
+    /**
+     * ID（巡检员ID或路线ID）
+     */
+    private Long id;
+
+    /**
+     * 名称（巡检员姓名或路线名称）
+     */
+    private String name;
+
+    /**
+     * 总任务数
+     */
+    private Integer totalTasks;
+
+    /**
+     * 已完成数
+     */
+    private Integer completedTasks;
+
+    /**
+     * 完成率（百分比）
+     */
+    private BigDecimal completionRate;
+
+    /**
+     * 总里程（公里）
+     */
+    private BigDecimal totalDistance;
+
+    /**
+     * 综合评分
+     */
+    private BigDecimal score;
+
+    /**
+     * 发现问题数
+     */
+    private Integer issueCount;
+
+    /**
+     * 额外指标（如准时率等）
+     */
+    private String extraMetric;
+}

wm-patrol/src/main/java/com/water/patrol/entity/dto/StatsQueryRequest.java

@@ -0,0 +1,60 @@
+package com.water.patrol.entity.dto;
+
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.time.LocalDate;
+
+/**
+ * 统计查询请求 DTO
+ */
+@Data
+public class StatsQueryRequest {
+
+    /**
+     * 开始日期
+     */
+    @DateTimeFormat(iso = DateTimeFormat.ISO.DATE)
+    private LocalDate startDate;
+
+    /**
+     * 结束日期
+     */
+    @DateTimeFormat(iso = DateTimeFormat.ISO.DATE)
+    private LocalDate endDate;
+
+    /**
+     * 巡检员ID（可选，按人员筛选）
+     */
+    private Long inspectorId;
+
+    /**
+     * 路线ID（可选，按路线筛选）
+     */
+    private Long routeId;
+
+    /**
+     * 部门（可选）
+     */
+    private String dept;
+
+    /**
+     * 分组维度: day/week/month（用于趋势分析）
+     */
+    private String groupBy;
+
+    /**
+     * 分页：当前页
+     */
+    private Integer pageNum = 1;
+
+    /**
+     * 分页：每页大小
+     */
+    private Integer pageSize = 10;
+
+    /**
+     * 排名数量限制
+     */
+    private Integer topN = 10;
+}

wm-patrol/src/main/java/com/water/patrol/entity/dto/StatsSummary.java

@@ -0,0 +1,77 @@
+package com.water.patrol.entity.dto;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 统计概览 DTO
+ */
+@Data
+public class StatsSummary {
+
+    /**
+     * 总任务数
+     */
+    private Integer totalTasks;
+
+    /**
+     * 已完成任务数
+     */
+    private Integer completedTasks;
+
+    /**
+     * 执行率（百分比）
+     */
+    private BigDecimal executionRate;
+
+    /**
+     * 完成率（百分比）
+     */
+    private BigDecimal completionRate;
+
+    /**
+     * 总里程（公里）
+     */
+    private BigDecimal totalDistance;
+
+    /**
+     * 日均里程（公里）
+     */
+    private BigDecimal avgDailyDistance;
+
+    /**
+     * 总问题数
+     */
+    private Integer totalIssues;
+
+    /**
+     * 已解决问题数
+     */
+    private Integer resolvedIssues;
+
+    /**
+     * 问题解决率（百分比）
+     */
+    private BigDecimal resolutionRate;
+
+    /**
+     * 严重问题数
+     */
+    private Integer criticalIssues;
+
+    /**
+     * 巡检员数量
+     */
+    private Integer inspectorCount;
+
+    /**
+     * 活跃路线数
+     */
+    private Integer activeRoutes;
+
+    /**
+     * 平均效率（公里/小时）
+     */
+    private BigDecimal avgEfficiency;
+}

wm-patrol/src/main/java/com/water/patrol/mapper/StatsMapper.java

@@ -0,0 +1,205 @@
+package com.water.patrol.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 统计查询 Mapper
+ */
+@Mapper
+public interface StatsMapper {
+
+    // ==================== 执行率统计 ====================
+
+    /**
+     * 按巡检员统计执行率
+     */
+    @Select("SELECT " +
+            "e.inspector_id as inspector_id, " +
+            "e.inspector_name as inspector_name, " +
+            "COUNT(*) as total_executions, " +
+            "COUNT(CASE WHEN e.status = 'completed' THEN 1 END) as completed_count, " +
+            "COUNT(CASE WHEN e.status = 'in_progress' THEN 1 END) as in_progress_count, " +
+            "COUNT(CASE WHEN e.status = 'aborted' THEN 1 END) as aborted_count, " +
+            "ROUND(COUNT(CASE WHEN e.status = 'completed' THEN 1 END) * 100.0 / NULLIF(COUNT(*), 0), 2) as completion_rate " +
+            "FROM patrol_execution e " +
+            "WHERE e.deleted = 0 " +
+            "AND e.start_time >= #{startDate}::timestamp " +
+            "AND e.start_time < (#{endDate}::date + interval '1 day')::timestamp " +
+            "GROUP BY e.inspector_id, e.inspector_name " +
+            "ORDER BY completion_rate DESC")
+    List<Map<String, Object>> executionRateByInspector(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    /**
+     * 按路线统计执行率
+     */
+    @Select("SELECT " +
+            "t.route_id as route_id, " +
+            "r.route_name as route_name, " +
+            "COUNT(t.id) as total_tasks, " +
+            "COUNT(CASE WHEN t.status = 'completed' THEN 1 END) as completed_count, " +
+            "ROUND(COUNT(CASE WHEN t.status = 'completed' THEN 1 END) * 100.0 / NULLIF(COUNT(t.id), 0), 2) as completion_rate " +
+            "FROM patrol_task t " +
+            "LEFT JOIN patrol_route r ON t.route_id = r.id AND r.deleted = 0 " +
+            "WHERE t.deleted = 0 " +
+            "AND t.task_date BETWEEN #{startDate} AND #{endDate} " +
+            "GROUP BY t.route_id, r.route_name " +
+            "ORDER BY completion_rate DESC")
+    List<Map<String, Object>> executionRateByRoute(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    /**
+     * 按时间段统计执行率（按天分组）
+     */
+    @Select("SELECT " +
+            "DATE(e.start_time) as period, " +
+            "COUNT(*) as total_executions, " +
+            "COUNT(CASE WHEN e.status = 'completed' THEN 1 END) as completed_count, " +
+            "ROUND(COUNT(CASE WHEN e.status = 'completed' THEN 1 END) * 100.0 / NULLIF(COUNT(*), 0), 2) as completion_rate " +
+            "FROM patrol_execution e " +
+            "WHERE e.deleted = 0 " +
+            "AND e.start_time >= #{startDate}::timestamp " +
+            "AND e.start_time < (#{endDate}::date + interval '1 day')::timestamp " +
+            "GROUP BY DATE(e.start_time) " +
+            "ORDER BY period")
+    List<Map<String, Object>> executionRateByPeriod(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    // ==================== 里程统计 ====================
+
+    /**
+     * 里程统计概览
+     */
+    @Select("SELECT " +
+            "COALESCE(SUM(total_distance), 0) as total_distance, " +
+            "COALESCE(AVG(total_distance), 0) as avg_distance, " +
+            "COUNT(*) as execution_count, " +
+            "COALESCE(MAX(total_distance), 0) as max_distance, " +
+            "COALESCE(MIN(total_distance), 0) as min_distance " +
+            "FROM patrol_execution " +
+            "WHERE deleted = 0 AND status = 'completed' " +
+            "AND start_time >= #{startDate}::timestamp " +
+            "AND start_time < (#{endDate}::date + interval '1 day')::timestamp")
+    Map<String, Object> mileageSummary(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    /**
+     * 按巡检员统计里程
+     */
+    @Select("SELECT " +
+            "e.inspector_id as inspector_id, " +
+            "e.inspector_name as inspector_name, " +
+            "COALESCE(SUM(e.total_distance), 0) as total_distance, " +
+            "COALESCE(AVG(e.total_distance), 0) as avg_distance, " +
+            "COUNT(*) as execution_count " +
+            "FROM patrol_execution e " +
+            "WHERE e.deleted = 0 AND e.status = 'completed' " +
+            "AND e.start_time >= #{startDate}::timestamp " +
+            "AND e.start_time < (#{endDate}::date + interval '1 day')::timestamp " +
+            "GROUP BY e.inspector_id, e.inspector_name " +
+            "ORDER BY total_distance DESC")
+    List<Map<String, Object>> mileageByInspector(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    /**
+     * 里程趋势（按天）
+     */
+    @Select("SELECT " +
+            "DATE(start_time) as date, " +
+            "COALESCE(SUM(total_distance), 0) as daily_distance, " +
+            "COUNT(*) as execution_count " +
+            "FROM patrol_execution " +
+            "WHERE deleted = 0 AND status = 'completed' " +
+            "AND start_time >= #{startDate}::timestamp " +
+            "AND start_time < (#{endDate}::date + interval '1 day')::timestamp " +
+            "GROUP BY DATE(start_time) " +
+            "ORDER BY date")
+    List<Map<String, Object>> mileageTrend(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    // ==================== 问题分类统计 ====================
+
+    /**
+     * 问题类型分布
+     */
+    @Select("SELECT " +
+            "i.issue_type as issue_type, " +
+            "COUNT(*) as count " +
+            "FROM patrol_issue i " +
+            "INNER JOIN patrol_execution e ON i.execution_id = e.id AND e.deleted = 0 " +
+            "WHERE i.deleted = 0 " +
+            "AND i.report_time >= #{startDate}::timestamp " +
+            "AND i.report_time < (#{endDate}::date + interval '1 day')::timestamp " +
+            "GROUP BY i.issue_type " +
+            "ORDER BY count DESC")
+    List<Map<String, Object>> issueTypeDistribution(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    /**
+     * 问题严重度分布
+     */
+    @Select("SELECT " +
+            "i.severity as severity, " +
+            "COUNT(*) as count " +
+            "FROM patrol_issue i " +
+            "WHERE i.deleted = 0 " +
+            "AND i.report_time >= #{startDate}::timestamp " +
+            "AND i.report_time < (#{endDate}::date + interval '1 day')::timestamp " +
+            "GROUP BY i.severity " +
+            "ORDER BY count DESC")
+    List<Map<String, Object>> issueSeverityDistribution(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    /**
+     * 问题解决率统计
+     */
+    @Select("SELECT " +
+            "COUNT(*) as total_issues, " +
+            "COUNT(CASE WHEN i.handle_status = 'resolved' OR i.handle_status = 'closed' THEN 1 END) as resolved_count, " +
+            "COUNT(CASE WHEN i.handle_status = 'pending' THEN 1 END) as pending_count, " +
+            "COUNT(CASE WHEN i.handle_status = 'processing' THEN 1 END) as processing_count, " +
+            "ROUND((COUNT(CASE WHEN i.handle_status = 'resolved' OR i.handle_status = 'closed' THEN 1 END)) * 100.0 " +
+            "/ NULLIF(COUNT(*), 0), 2) as resolution_rate " +
+            "FROM patrol_issue i " +
+            "WHERE i.deleted = 0 " +
+            "AND i.report_time >= #{startDate}::timestamp " +
+            "AND i.report_time < (#{endDate}::date + interval '1 day')::timestamp")
+    Map<String, Object> issueResolutionStats(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+
+    // ==================== 综合看板 ====================
+
+    /**
+     * 综合统计概览
+     */
+    @Select("SELECT " +
+            "(SELECT COUNT(*) FROM patrol_task WHERE task_date BETWEEN #{startDate} AND #{endDate} AND deleted = 0) as total_tasks, " +
+            "(SELECT COUNT(*) FROM patrol_task WHERE task_date BETWEEN #{startDate} AND #{endDate} AND deleted = 0 AND status = 'completed') as completed_tasks, " +
+            "(SELECT COALESCE(SUM(total_distance), 0) FROM patrol_execution WHERE deleted = 0 AND status = 'completed' " +
+            "AND start_time >= #{startDate}::timestamp AND start_time < (#{endDate}::date + interval '1 day')::timestamp) as total_distance, " +
+            "(SELECT COUNT(*) FROM patrol_issue WHERE deleted = 0 " +
+            "AND report_time >= #{startDate}::timestamp AND report_time < (#{endDate}::date + interval '1 day')::timestamp) as total_issues, " +
+            "(SELECT COUNT(*) FROM patrol_issue WHERE deleted = 0 AND (handle_status = 'resolved' OR handle_status = 'closed') " +
+            "AND report_time >= #{startDate}::timestamp AND report_time < (#{endDate}::date + interval '1 day')::timestamp) as resolved_issues, " +
+            "(SELECT COUNT(DISTINCT inspector_id) FROM patrol_execution WHERE deleted = 0 " +
+            "AND start_time >= #{startDate}::timestamp AND start_time < (#{endDate}::date + interval '1 day')::timestamp) as inspector_count, " +
+            "(SELECT COUNT(DISTINCT route_id) FROM patrol_task WHERE task_date BETWEEN #{startDate} AND #{endDate} AND deleted = 0) as active_routes")
+    Map<String, Object> dashboardSummary(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate);
+}

wm-patrol/src/main/java/com/water/patrol/service/PatrolRankService.java

@@ -0,0 +1,163 @@
+package com.water.patrol.service;
+
+import com.water.patrol.entity.dto.RankResult;
+import com.water.patrol.entity.dto.StatsQueryRequest;
+import com.water.patrol.mapper.PatrolTaskMapper;
+import com.water.patrol.mapper.StatsMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 巡检排名服务
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class PatrolRankService {
+
+    private final StatsMapper statsMapper;
+
+    /**
+     * 巡检员排名（按综合评分）
+     * 评分规则：完成率 * 0.4 + 里程 * 0.3 + 问题发现 * 0.3
+     */
+    public List<RankResult> inspectorRank(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        int topN = request.getTopN() != null ? request.getTopN() : 10;
+
+        log.info("巡检员排名: {} ~ {}, topN={}", start, end, topN);
+
+        // 获取执行率数据
+        List<Map<String, Object>> executionStats = statsMapper.executionRateByInspector(start, end);
+        // 获取里程数据
+        List<Map<String, Object>> mileageStats = statsMapper.mileageByInspector(start, end);
+
+        // 合并数据
+        Map<String, Map<String, Object>> mileageMap = mileageStats.stream()
+                .collect(Collectors.toMap(
+                        m -> String.valueOf(m.get("inspector_id")),
+                        m -> m,
+                        (a, b) -> a
+                ));
+
+        List<RankResult> results = new ArrayList<>();
+        for (Map<String, Object> exec : executionStats) {
+            RankResult rank = new RankResult();
+            rank.setId(toLong(exec.get("inspector_id")));
+            rank.setName(String.valueOf(exec.get("inspector_name")));
+            rank.setTotalTasks(toInt(exec.get("total_executions")));
+            rank.setCompletedTasks(toInt(exec.get("completed_count")));
+
+            BigDecimal completionRate = exec.get("completion_rate") != null
+                    ? new BigDecimal(exec.get("completion_rate").toString())
+                    : BigDecimal.ZERO;
+            rank.setCompletionRate(completionRate);
+
+            // 合并里程
+            String key = String.valueOf(exec.get("inspector_id"));
+            Map<String, Object> mileage = mileageMap.get(key);
+            if (mileage != null) {
+                BigDecimal totalDist = mileage.get("total_distance") != null
+                        ? new BigDecimal(mileage.get("total_distance").toString())
+                        : BigDecimal.ZERO;
+                rank.setTotalDistance(totalDist);
+            } else {
+                rank.setTotalDistance(BigDecimal.ZERO);
+            }
+
+            // 计算综合评分
+            BigDecimal score = calculateScore(completionRate, rank.getTotalDistance(), BigDecimal.ZERO);
+            rank.setScore(score);
+
+            results.add(rank);
+        }
+
+        // 按评分排序
+        results.sort(Comparator.comparing(RankResult::getScore).reversed());
+
+        // 设置排名
+        for (int i = 0; i < results.size(); i++) {
+            results.get(i).setRank(i + 1);
+        }
+
+        return results.stream().limit(topN).collect(Collectors.toList());
+    }
+
+    /**
+     * 路线排名（按完成率）
+     */
+    public List<RankResult> routeRank(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        int topN = request.getTopN() != null ? request.getTopN() : 10;
+
+        log.info("路线排名: {} ~ {}, topN={}", start, end, topN);
+
+        List<Map<String, Object>> routeStats = statsMapper.executionRateByRoute(start, end);
+
+        List<RankResult> results = new ArrayList<>();
+        for (Map<String, Object> route : routeStats) {
+            RankResult rank = new RankResult();
+            rank.setId(toLong(route.get("route_id")));
+            rank.setName(String.valueOf(route.get("route_name")));
+            rank.setTotalTasks(toInt(route.get("total_tasks")));
+            rank.setCompletedTasks(toInt(route.get("completed_count")));
+
+            BigDecimal completionRate = route.get("completion_rate") != null
+                    ? new BigDecimal(route.get("completion_rate").toString())
+                    : BigDecimal.ZERO;
+            rank.setCompletionRate(completionRate);
+            rank.setScore(completionRate); // 路线排名直接用完成率作为评分
+
+            results.add(rank);
+        }
+
+        // 按评分排序
+        results.sort(Comparator.comparing(RankResult::getScore).reversed());
+
+        // 设置排名
+        for (int i = 0; i < results.size(); i++) {
+            results.get(i).setRank(i + 1);
+        }
+
+        return results.stream().limit(topN).collect(Collectors.toList());
+    }
+
+    /**
+     * 计算综合评分
+     * 完成率权重 0.4，里程权重 0.3，问题发现权重 0.3
+     */
+    private BigDecimal calculateScore(BigDecimal completionRate, BigDecimal totalDistance, BigDecimal issueScore) {
+        BigDecimal rateScore = completionRate.multiply(BigDecimal.valueOf(0.4));
+        // 里程分数：每10公里算1分，封顶100
+        BigDecimal distanceScore = totalDistance.divide(BigDecimal.valueOf(10), 2, RoundingMode.HALF_UP)
+                .min(BigDecimal.valueOf(100))
+                .multiply(BigDecimal.valueOf(0.3));
+        BigDecimal issuePart = issueScore.multiply(BigDecimal.valueOf(0.3));
+
+        return rateScore.add(distanceScore).add(issuePart).setScale(2, RoundingMode.HALF_UP);
+    }
+
+    private int toInt(Object obj) {
+        if (obj == null) return 0;
+        if (obj instanceof Number) return ((Number) obj).intValue();
+        return Integer.parseInt(obj.toString());
+    }
+
+    private Long toLong(Object obj) {
+        if (obj == null) return null;
+        if (obj instanceof Number) return ((Number) obj).longValue();
+        return Long.parseLong(obj.toString());
+    }
+}

wm-patrol/src/main/java/com/water/patrol/service/PatrolStatsService.java

@@ -0,0 +1,205 @@
+package com.water.patrol.service;
+
+import com.water.patrol.entity.dto.StatsQueryRequest;
+import com.water.patrol.entity.dto.StatsSummary;
+import com.water.patrol.mapper.StatsMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.time.LocalDate;
+import java.time.temporal.ChronoUnit;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 巡检统计服务
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class PatrolStatsService {
+
+    private final StatsMapper statsMapper;
+
+    // ==================== 执行率统计 ====================
+
+    /**
+     * 按巡检员统计执行率
+     */
+    public List<Map<String, Object>> executionRateByInspector(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询执行率(按巡检员): {} ~ {}", start, end);
+        return statsMapper.executionRateByInspector(start, end);
+    }
+
+    /**
+     * 按路线统计执行率
+     */
+    public List<Map<String, Object>> executionRateByRoute(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询执行率(按路线): {} ~ {}", start, end);
+        return statsMapper.executionRateByRoute(start, end);
+    }
+
+    /**
+     * 按时间段统计执行率
+     */
+    public List<Map<String, Object>> executionRateByPeriod(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询执行率(按时间段): {} ~ {}", start, end);
+        return statsMapper.executionRateByPeriod(start, end);
+    }
+
+    // ==================== 里程统计 ====================
+
+    /**
+     * 里程统计概览
+     */
+    public Map<String, Object> mileageSummary(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询里程统计概览: {} ~ {}", start, end);
+
+        Map<String, Object> raw = statsMapper.mileageSummary(start, end);
+        if (raw == null) {
+            raw = new HashMap<>();
+        }
+
+        // 计算日均里程
+        long days = ChronoUnit.DAYS.between(start, end) + 1;
+        Object totalObj = raw.get("total_distance");
+        BigDecimal total = totalObj != null ? new BigDecimal(totalObj.toString()) : BigDecimal.ZERO;
+        BigDecimal avgDaily = total.divide(BigDecimal.valueOf(days), 2, RoundingMode.HALF_UP);
+        raw.put("avg_daily_distance", avgDaily);
+        raw.put("days", days);
+
+        return raw;
+    }
+
+    /**
+     * 按巡检员统计里程
+     */
+    public List<Map<String, Object>> mileageByInspector(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询里程(按巡检员): {} ~ {}", start, end);
+        return statsMapper.mileageByInspector(start, end);
+    }
+
+    /**
+     * 里程趋势（按天）
+     */
+    public List<Map<String, Object>> mileageTrend(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询里程趋势: {} ~ {}", start, end);
+        return statsMapper.mileageTrend(start, end);
+    }
+
+    // ==================== 问题分类统计 ====================
+
+    /**
+     * 问题类型分布
+     */
+    public List<Map<String, Object>> issueTypeDistribution(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询问题类型分布: {} ~ {}", start, end);
+        return statsMapper.issueTypeDistribution(start, end);
+    }
+
+    /**
+     * 问题严重度分布
+     */
+    public List<Map<String, Object>> issueSeverityDistribution(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询问题严重度分布: {} ~ {}", start, end);
+        return statsMapper.issueSeverityDistribution(start, end);
+    }
+
+    /**
+     * 问题解决率统计
+     */
+    public Map<String, Object> issueResolutionStats(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询问题解决率: {} ~ {}", start, end);
+        Map<String, Object> result = statsMapper.issueResolutionStats(start, end);
+        return result != null ? result : new HashMap<>();
+    }
+
+    // ==================== 综合看板 ====================
+
+    /**
+     * 综合统计概览
+     */
+    public StatsSummary dashboardSummary(StatsQueryRequest request) {
+        LocalDate start = request.getStartDate() != null ? request.getStartDate() : LocalDate.now().minusDays(30);
+        LocalDate end = request.getEndDate() != null ? request.getEndDate() : LocalDate.now();
+        log.info("查询综合看板: {} ~ {}", start, end);
+
+        Map<String, Object> raw = statsMapper.dashboardSummary(start, end);
+
+        StatsSummary summary = new StatsSummary();
+        if (raw == null) {
+            return summary;
+        }
+
+        int totalTasks = toInt(raw.get("total_tasks"));
+        int completedTasks = toInt(raw.get("completed_tasks"));
+        summary.setTotalTasks(totalTasks);
+        summary.setCompletedTasks(completedTasks);
+
+        // 执行率
+        if (totalTasks > 0) {
+            summary.setExecutionRate(BigDecimal.valueOf(completedTasks * 100.0 / totalTasks)
+                    .setScale(2, RoundingMode.HALF_UP));
+            summary.setCompletionRate(summary.getExecutionRate());
+        } else {
+            summary.setExecutionRate(BigDecimal.ZERO);
+            summary.setCompletionRate(BigDecimal.ZERO);
+        }
+
+        // 里程
+        BigDecimal totalDistance = raw.get("total_distance") != null
+                ? new BigDecimal(raw.get("total_distance").toString())
+                : BigDecimal.ZERO;
+        summary.setTotalDistance(totalDistance);
+
+        long days = ChronoUnit.DAYS.between(start, end) + 1;
+        summary.setAvgDailyDistance(totalDistance.divide(BigDecimal.valueOf(days), 2, RoundingMode.HALF_UP));
+
+        // 问题
+        int totalIssues = toInt(raw.get("total_issues"));
+        int resolvedIssues = toInt(raw.get("resolved_issues"));
+        summary.setTotalIssues(totalIssues);
+        summary.setResolvedIssues(resolvedIssues);
+
+        if (totalIssues > 0) {
+            summary.setResolutionRate(BigDecimal.valueOf(resolvedIssues * 100.0 / totalIssues)
+                    .setScale(2, RoundingMode.HALF_UP));
+        } else {
+            summary.setResolutionRate(BigDecimal.ZERO);
+        }
+
+        // 人员与路线
+        summary.setInspectorCount(toInt(raw.get("inspector_count")));
+        summary.setActiveRoutes(toInt(raw.get("active_routes")));
+
+        return summary;
+    }
+
+    private int toInt(Object obj) {
+        if (obj == null) return 0;
+        if (obj instanceof Number) return ((Number) obj).intValue();
+        return Integer.parseInt(obj.toString());
+    }
+}

wm-patrol/src/test/java/com/water/patrol/service/PatrolRankServiceTest.java

@@ -0,0 +1,176 @@
+package com.water.patrol.service;
+
+import com.water.patrol.entity.dto.RankResult;
+import com.water.patrol.entity.dto.StatsQueryRequest;
+import com.water.patrol.mapper.StatsMapper;
+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.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.util.*;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class PatrolRankServiceTest {
+
+    @Mock
+    private StatsMapper statsMapper;
+
+    @InjectMocks
+    private PatrolRankService rankService;
+
+    private StatsQueryRequest defaultRequest;
+
+    @BeforeEach
+    void setUp() {
+        defaultRequest = new StatsQueryRequest();
+        defaultRequest.setStartDate(LocalDate.of(2026, 1, 1));
+        defaultRequest.setEndDate(LocalDate.of(2026, 1, 31));
+        defaultRequest.setTopN(10);
+    }
+
+    @Test
+    @DisplayName("巡检员排名 - 按综合评分排序")
+    void inspectorRank_sortedByScore() {
+        // 模拟执行率数据
+        List<Map<String, Object>> execStats = new ArrayList<>();
+        execStats.add(buildExecStat(1L, "张三", 20, 18, "90.00"));
+        execStats.add(buildExecStat(2L, "李四", 15, 10, "66.67"));
+        execStats.add(buildExecStat(3L, "王五", 25, 25, "100.00"));
+
+        when(statsMapper.executionRateByInspector(any(), any())).thenReturn(execStats);
+
+        // 模拟里程数据
+        List<Map<String, Object>> mileageStats = new ArrayList<>();
+        mileageStats.add(buildMileageStat(1L, "张三", "50.00"));
+        mileageStats.add(buildMileageStat(2L, "李四", "30.00"));
+        mileageStats.add(buildMileageStat(3L, "王五", "80.00"));
+
+        when(statsMapper.mileageByInspector(any(), any())).thenReturn(mileageStats);
+
+        List<RankResult> results = rankService.inspectorRank(defaultRequest);
+
+        assertNotNull(results);
+        assertEquals(3, results.size());
+
+        // 王五完成率100%+里程80km，应该排第一
+        assertEquals(1, results.get(0).getRank());
+        assertEquals("王五", results.get(0).getName());
+
+        // 张三完成率90%+里程50km，应该排第二
+        assertEquals(2, results.get(1).getRank());
+        assertEquals("张三", results.get(1).getName());
+
+        verify(statsMapper).executionRateByInspector(any(), any());
+        verify(statsMapper).mileageByInspector(any(), any());
+    }
+
+    @Test
+    @DisplayName("巡检员排名 - topN限制")
+    void inspectorRank_respectsTopN() {
+        List<Map<String, Object>> execStats = new ArrayList<>();
+        for (long i = 1; i <= 15; i++) {
+            execStats.add(buildExecStat(i, "巡检员" + i, 10, 8, "80.00"));
+        }
+        when(statsMapper.executionRateByInspector(any(), any())).thenReturn(execStats);
+        when(statsMapper.mileageByInspector(any(), any())).thenReturn(new ArrayList<>());
+
+        defaultRequest.setTopN(5);
+        List<RankResult> results = rankService.inspectorRank(defaultRequest);
+
+        assertNotNull(results);
+        assertEquals(5, results.size());
+    }
+
+    @Test
+    @DisplayName("路线排名 - 按完成率排序")
+    void routeRank_sortedByCompletionRate() {
+        List<Map<String, Object>> routeStats = new ArrayList<>();
+        routeStats.add(buildRouteStat(1L, "东线", 30, 28, "93.33"));
+        routeStats.add(buildRouteStat(2L, "西线", 20, 10, "50.00"));
+        routeStats.add(buildRouteStat(3L, "南线", 25, 25, "100.00"));
+
+        when(statsMapper.executionRateByRoute(any(), any())).thenReturn(routeStats);
+
+        List<RankResult> results = rankService.routeRank(defaultRequest);
+
+        assertNotNull(results);
+        assertEquals(3, results.size());
+
+        // 南线100%完成率排第一
+        assertEquals("南线", results.get(0).getName());
+        assertEquals(1, results.get(0).getRank());
+
+        // 西线50%完成率排最后
+        assertEquals("西线", results.get(2).getName());
+        assertEquals(3, results.get(2).getRank());
+    }
+
+    @Test
+    @DisplayName("巡检员排名 - 空数据返回空列表")
+    void inspectorRank_emptyData() {
+        when(statsMapper.executionRateByInspector(any(), any())).thenReturn(new ArrayList<>());
+        when(statsMapper.mileageByInspector(any(), any())).thenReturn(new ArrayList<>());
+
+        List<RankResult> results = rankService.inspectorRank(defaultRequest);
+
+        assertNotNull(results);
+        assertTrue(results.isEmpty());
+    }
+
+    @Test
+    @DisplayName("路线排名 - 排名编号正确")
+    void routeRank_rankNumbersCorrect() {
+        List<Map<String, Object>> routeStats = new ArrayList<>();
+        routeStats.add(buildRouteStat(1L, "A线", 10, 10, "100.00"));
+        routeStats.add(buildRouteStat(2L, "B线", 10, 10, "100.00"));
+        routeStats.add(buildRouteStat(3L, "C线", 10, 5, "50.00"));
+
+        when(statsMapper.executionRateByRoute(any(), any())).thenReturn(routeStats);
+
+        List<RankResult> results = rankService.routeRank(defaultRequest);
+
+        assertEquals(1, results.get(0).getRank());
+        assertEquals(2, results.get(1).getRank());
+        assertEquals(3, results.get(2).getRank());
+    }
+
+    // ==================== Helper Methods ====================
+
+    private Map<String, Object> buildExecStat(Long id, String name, int total, int completed, String rate) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("inspector_id", id);
+        map.put("inspector_name", name);
+        map.put("total_executions", total);
+        map.put("completed_count", completed);
+        map.put("completion_rate", new BigDecimal(rate));
+        return map;
+    }
+
+    private Map<String, Object> buildMileageStat(Long id, String name, String distance) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("inspector_id", id);
+        map.put("inspector_name", name);
+        map.put("total_distance", new BigDecimal(distance));
+        return map;
+    }
+
+    private Map<String, Object> buildRouteStat(Long id, String name, int total, int completed, String rate) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("route_id", id);
+        map.put("route_name", name);
+        map.put("total_tasks", total);
+        map.put("completed_count", completed);
+        map.put("completion_rate", new BigDecimal(rate));
+        return map;
+    }
+}

wm-patrol/src/test/java/com/water/patrol/service/PatrolStatsServiceTest.java

@@ -0,0 +1,194 @@
+package com.water.patrol.service;
+
+import com.water.patrol.entity.dto.StatsQueryRequest;
+import com.water.patrol.entity.dto.StatsSummary;
+import com.water.patrol.mapper.StatsMapper;
+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.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.util.*;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class PatrolStatsServiceTest {
+
+    @Mock
+    private StatsMapper statsMapper;
+
+    @InjectMocks
+    private PatrolStatsService statsService;
+
+    private StatsQueryRequest defaultRequest;
+
+    @BeforeEach
+    void setUp() {
+        defaultRequest = new StatsQueryRequest();
+        defaultRequest.setStartDate(LocalDate.of(2026, 1, 1));
+        defaultRequest.setEndDate(LocalDate.of(2026, 1, 31));
+    }
+
+    @Test
+    @DisplayName("综合看板概览 - 正常返回统计数据")
+    void dashboardSummary_success() {
+        Map<String, Object> mockData = new HashMap<>();
+        mockData.put("total_tasks", 100);
+        mockData.put("completed_tasks", 85);
+        mockData.put("total_distance", new BigDecimal("250.50"));
+        mockData.put("total_issues", 20);
+        mockData.put("resolved_issues", 15);
+        mockData.put("inspector_count", 8);
+        mockData.put("active_routes", 5);
+
+        when(statsMapper.dashboardSummary(any(LocalDate.class), any(LocalDate.class))).thenReturn(mockData);
+
+        StatsSummary summary = statsService.dashboardSummary(defaultRequest);
+
+        assertNotNull(summary);
+        assertEquals(100, summary.getTotalTasks());
+        assertEquals(85, summary.getCompletedTasks());
+        assertEquals(85.0, summary.getExecutionRate().doubleValue(), 0.01);
+        assertEquals(new BigDecimal("250.50"), summary.getTotalDistance());
+        assertEquals(20, summary.getTotalIssues());
+        assertEquals(15, summary.getResolvedIssues());
+        assertEquals(75.0, summary.getResolutionRate().doubleValue(), 0.01);
+        assertEquals(8, summary.getInspectorCount());
+        assertEquals(5, summary.getActiveRoutes());
+
+        verify(statsMapper).dashboardSummary(any(LocalDate.class), any(LocalDate.class));
+    }
+
+    @Test
+    @DisplayName("综合看板概览 - 空数据返回零值")
+    void dashboardSummary_emptyData() {
+        when(statsMapper.dashboardSummary(any(LocalDate.class), any(LocalDate.class))).thenReturn(null);
+
+        StatsSummary summary = statsService.dashboardSummary(defaultRequest);
+
+        assertNotNull(summary);
+        assertEquals(0, summary.getTotalTasks());
+        assertEquals(0, summary.getCompletedTasks());
+        assertEquals(BigDecimal.ZERO, summary.getExecutionRate());
+    }
+
+    @Test
+    @DisplayName("执行率按巡检员统计 - 正确返回")
+    void executionRateByInspector_success() {
+        List<Map<String, Object>> mockData = new ArrayList<>();
+        Map<String, Object> row = new HashMap<>();
+        row.put("inspector_id", 1L);
+        row.put("inspector_name", "张三");
+        row.put("total_executions", 20);
+        row.put("completed_count", 18);
+        row.put("completion_rate", new BigDecimal("90.00"));
+        mockData.add(row);
+
+        when(statsMapper.executionRateByInspector(any(LocalDate.class), any(LocalDate.class))).thenReturn(mockData);
+
+        List<Map<String, Object>> result = statsService.executionRateByInspector(defaultRequest);
+
+        assertNotNull(result);
+        assertEquals(1, result.size());
+        assertEquals("张三", result.get(0).get("inspector_name"));
+        assertEquals(20, result.get(0).get("total_executions"));
+
+        verify(statsMapper).executionRateByInspector(any(LocalDate.class), any(LocalDate.class));
+    }
+
+    @Test
+    @DisplayName("里程统计概览 - 计算日均里程")
+    void mileageSummary_calculatesDailyAverage() {
+        Map<String, Object> mockData = new HashMap<>();
+        mockData.put("total_distance", new BigDecimal("310.00"));
+        mockData.put("avg_distance", new BigDecimal("10.00"));
+        mockData.put("execution_count", 31);
+        mockData.put("max_distance", new BigDecimal("15.5"));
+        mockData.put("min_distance", new BigDecimal("5.0"));
+
+        when(statsMapper.mileageSummary(any(LocalDate.class), any(LocalDate.class))).thenReturn(mockData);
+
+        Map<String, Object> result = statsService.mileageSummary(defaultRequest);
+
+        assertNotNull(result);
+        assertEquals(new BigDecimal("310.00"), new BigDecimal(result.get("total_distance").toString()));
+        assertNotNull(result.get("avg_daily_distance"));
+        assertEquals(31, result.get("days"));
+
+        // 31天，310公里，日均应为10.00
+        BigDecimal avgDaily = (BigDecimal) result.get("avg_daily_distance");
+        assertEquals(10.0, avgDaily.doubleValue(), 0.01);
+
+        verify(statsMapper).mileageSummary(any(LocalDate.class), any(LocalDate.class));
+    }
+
+    @Test
+    @DisplayName("问题类型分布 - 正确返回分布数据")
+    void issueTypeDistribution_success() {
+        List<Map<String, Object>> mockData = new ArrayList<>();
+
+        Map<String, Object> leak = new HashMap<>();
+        leak.put("issue_type", "leak");
+        leak.put("count", 15);
+        mockData.add(leak);
+
+        Map<String, Object> damage = new HashMap<>();
+        damage.put("issue_type", "damage");
+        damage.put("count", 8);
+        mockData.add(damage);
+
+        when(statsMapper.issueTypeDistribution(any(LocalDate.class), any(LocalDate.class))).thenReturn(mockData);
+
+        List<Map<String, Object>> result = statsService.issueTypeDistribution(defaultRequest);
+
+        assertNotNull(result);
+        assertEquals(2, result.size());
+        assertEquals("leak", result.get(0).get("issue_type"));
+        assertEquals(15, result.get(0).get("count"));
+
+        verify(statsMapper).issueTypeDistribution(any(LocalDate.class), any(LocalDate.class));
+    }
+
+    @Test
+    @DisplayName("问题解决率统计 - 正确计算解决率")
+    void issueResolutionStats_success() {
+        Map<String, Object> mockData = new HashMap<>();
+        mockData.put("total_issues", 50);
+        mockData.put("resolved_count", 40);
+        mockData.put("pending_count", 5);
+        mockData.put("processing_count", 5);
+        mockData.put("resolution_rate", new BigDecimal("80.00"));
+
+        when(statsMapper.issueResolutionStats(any(LocalDate.class), any(LocalDate.class))).thenReturn(mockData);
+
+        Map<String, Object> result = statsService.issueResolutionStats(defaultRequest);
+
+        assertNotNull(result);
+        assertEquals(50, result.get("total_issues"));
+        assertEquals(40, result.get("resolved_count"));
+        assertEquals(new BigDecimal("80.00"), new BigDecimal(result.get("resolution_rate").toString()));
+
+        verify(statsMapper).issueResolutionStats(any(LocalDate.class), any(LocalDate.class));
+    }
+
+    @Test
+    @DisplayName("默认日期范围 - 当未传入日期时使用近30天")
+    void defaultDateRange_lastThirtyDays() {
+        StatsQueryRequest emptyRequest = new StatsQueryRequest();
+
+        when(statsMapper.dashboardSummary(any(LocalDate.class), any(LocalDate.class))).thenReturn(new HashMap<>());
+
+        statsService.dashboardSummary(emptyRequest);
+
+        verify(statsMapper).dashboardSummary(any(LocalDate.class), any(LocalDate.class));
+    }
+}